| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "chrome/browser/drive/drive_api_service.h" | 5 #include "chrome/browser/drive/drive_api_service.h" |
| 6 | 6 |
| 7 #include <string> | 7 #include <string> |
| 8 #include <vector> | 8 #include <vector> |
| 9 | 9 |
| 10 #include "base/bind.h" | 10 #include "base/bind.h" |
| (...skipping 168 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 179 const base::FilePath& local_file_path, | 179 const base::FilePath& local_file_path, |
| 180 const UploadNewFileOptions& options, | 180 const UploadNewFileOptions& options, |
| 181 const google_apis::FileResourceCallback& callback, | 181 const google_apis::FileResourceCallback& callback, |
| 182 const google_apis::ProgressCallback& progress_callback) { | 182 const google_apis::ProgressCallback& progress_callback) { |
| 183 DCHECK(CalledOnValidThread()); | 183 DCHECK(CalledOnValidThread()); |
| 184 DCHECK(!callback.is_null()); | 184 DCHECK(!callback.is_null()); |
| 185 | 185 |
| 186 DCHECK(batch_request_); | 186 DCHECK(batch_request_); |
| 187 | 187 |
| 188 batch_request_->AddRequest( | 188 batch_request_->AddRequest( |
| 189 new google_apis::drive::MultipartUploadNewFileRequest( | 189 new google_apis::drive::MultipartUploadNewFileDelegate( |
| 190 batch_request_->sender(), title, parent_resource_id, content_type, | 190 batch_request_->sender(), title, parent_resource_id, content_type, |
| 191 content_length, options.modified_date, options.last_viewed_by_me_date, | 191 content_length, options.modified_date, options.last_viewed_by_me_date, |
| 192 local_file_path, options.properties, batch_request_->url_generator(), | 192 local_file_path, options.properties, batch_request_->url_generator(), |
| 193 callback, progress_callback)); | 193 callback, progress_callback)); |
| 194 return cancel_callback_; | 194 return cancel_callback_; |
| 195 } | 195 } |
| 196 | 196 |
| 197 google_apis::CancelCallback | 197 google_apis::CancelCallback |
| 198 BatchRequestConfigurator::MultipartUploadExistingFile( | 198 BatchRequestConfigurator::MultipartUploadExistingFile( |
| 199 const std::string& content_type, | 199 const std::string& content_type, |
| 200 int64 content_length, | 200 int64 content_length, |
| 201 const std::string& resource_id, | 201 const std::string& resource_id, |
| 202 const base::FilePath& local_file_path, | 202 const base::FilePath& local_file_path, |
| 203 const UploadExistingFileOptions& options, | 203 const UploadExistingFileOptions& options, |
| 204 const google_apis::FileResourceCallback& callback, | 204 const google_apis::FileResourceCallback& callback, |
| 205 const google_apis::ProgressCallback& progress_callback) { | 205 const google_apis::ProgressCallback& progress_callback) { |
| 206 DCHECK(CalledOnValidThread()); | 206 DCHECK(CalledOnValidThread()); |
| 207 DCHECK(!callback.is_null()); | 207 DCHECK(!callback.is_null()); |
| 208 DCHECK(batch_request_); | 208 DCHECK(batch_request_); |
| 209 | 209 |
| 210 batch_request_->AddRequest( | 210 batch_request_->AddRequest( |
| 211 new google_apis::drive::MultipartUploadExistingFileRequest( | 211 new google_apis::drive::MultipartUploadExistingFileDelegate( |
| 212 batch_request_->sender(), options.title, resource_id, | 212 batch_request_->sender(), options.title, resource_id, |
| 213 options.parent_resource_id, content_type, content_length, | 213 options.parent_resource_id, content_type, content_length, |
| 214 options.modified_date, options.last_viewed_by_me_date, | 214 options.modified_date, options.last_viewed_by_me_date, |
| 215 local_file_path, options.etag, options.properties, | 215 local_file_path, options.etag, options.properties, |
| 216 batch_request_->url_generator(), callback, progress_callback)); | 216 batch_request_->url_generator(), callback, progress_callback)); |
| 217 return cancel_callback_; | 217 return cancel_callback_; |
| 218 } | 218 } |
| 219 | 219 |
| 220 void BatchRequestConfigurator::Commit() { | 220 void BatchRequestConfigurator::Commit() { |
| 221 DCHECK(CalledOnValidThread()); | 221 DCHECK(CalledOnValidThread()); |
| (...skipping 483 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 705 const std::string& parent_resource_id, | 705 const std::string& parent_resource_id, |
| 706 const std::string& title, | 706 const std::string& title, |
| 707 const base::FilePath& local_file_path, | 707 const base::FilePath& local_file_path, |
| 708 const drive::UploadNewFileOptions& options, | 708 const drive::UploadNewFileOptions& options, |
| 709 const FileResourceCallback& callback, | 709 const FileResourceCallback& callback, |
| 710 const google_apis::ProgressCallback& progress_callback) { | 710 const google_apis::ProgressCallback& progress_callback) { |
| 711 DCHECK(thread_checker_.CalledOnValidThread()); | 711 DCHECK(thread_checker_.CalledOnValidThread()); |
| 712 DCHECK(!callback.is_null()); | 712 DCHECK(!callback.is_null()); |
| 713 | 713 |
| 714 return sender_->StartRequestWithRetry( | 714 return sender_->StartRequestWithRetry( |
| 715 new google_apis::drive::MultipartUploadNewFileRequest( | 715 new google_apis::drive::SingleBatchableDelegateRequest( |
| 716 sender_.get(), title, parent_resource_id, content_type, | 716 sender_.get(), |
| 717 content_length, options.modified_date, options.last_viewed_by_me_date, | 717 new google_apis::drive::MultipartUploadNewFileDelegate( |
| 718 local_file_path, options.properties, url_generator_, callback, | 718 sender_.get(), title, parent_resource_id, content_type, |
| 719 progress_callback)); | 719 content_length, options.modified_date, |
| 720 options.last_viewed_by_me_date, local_file_path, |
| 721 options.properties, url_generator_, callback, |
| 722 progress_callback))); |
| 720 } | 723 } |
| 721 | 724 |
| 722 CancelCallback DriveAPIService::MultipartUploadExistingFile( | 725 CancelCallback DriveAPIService::MultipartUploadExistingFile( |
| 723 const std::string& content_type, | 726 const std::string& content_type, |
| 724 int64 content_length, | 727 int64 content_length, |
| 725 const std::string& resource_id, | 728 const std::string& resource_id, |
| 726 const base::FilePath& local_file_path, | 729 const base::FilePath& local_file_path, |
| 727 const drive::UploadExistingFileOptions& options, | 730 const drive::UploadExistingFileOptions& options, |
| 728 const FileResourceCallback& callback, | 731 const FileResourceCallback& callback, |
| 729 const google_apis::ProgressCallback& progress_callback) { | 732 const google_apis::ProgressCallback& progress_callback) { |
| 730 DCHECK(thread_checker_.CalledOnValidThread()); | 733 DCHECK(thread_checker_.CalledOnValidThread()); |
| 731 DCHECK(!callback.is_null()); | 734 DCHECK(!callback.is_null()); |
| 732 | 735 |
| 733 return sender_->StartRequestWithRetry( | 736 return sender_->StartRequestWithRetry( |
| 734 new google_apis::drive::MultipartUploadExistingFileRequest( | 737 new google_apis::drive::SingleBatchableDelegateRequest( |
| 735 sender_.get(), options.title, resource_id, options.parent_resource_id, | 738 sender_.get(), |
| 736 content_type, content_length, options.modified_date, | 739 new google_apis::drive::MultipartUploadExistingFileDelegate( |
| 737 options.last_viewed_by_me_date, local_file_path, options.etag, | 740 sender_.get(), options.title, resource_id, |
| 738 options.properties, url_generator_, callback, progress_callback)); | 741 options.parent_resource_id, content_type, content_length, |
| 742 options.modified_date, options.last_viewed_by_me_date, |
| 743 local_file_path, options.etag, options.properties, url_generator_, |
| 744 callback, progress_callback))); |
| 739 } | 745 } |
| 740 | 746 |
| 741 CancelCallback DriveAPIService::AuthorizeApp( | 747 CancelCallback DriveAPIService::AuthorizeApp( |
| 742 const std::string& resource_id, | 748 const std::string& resource_id, |
| 743 const std::string& app_id, | 749 const std::string& app_id, |
| 744 const AuthorizeAppCallback& callback) { | 750 const AuthorizeAppCallback& callback) { |
| 745 DCHECK(thread_checker_.CalledOnValidThread()); | 751 DCHECK(thread_checker_.CalledOnValidThread()); |
| 746 DCHECK(!callback.is_null()); | 752 DCHECK(!callback.is_null()); |
| 747 | 753 |
| 748 // Files.Authorize is only available for whitelisted clients like official | 754 // Files.Authorize is only available for whitelisted clients like official |
| (...skipping 109 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 858 // RequestSender before the request is committed because the request has a | 864 // RequestSender before the request is committed because the request has a |
| 859 // reference to RequestSender and we should ensure to delete the request when | 865 // reference to RequestSender and we should ensure to delete the request when |
| 860 // the sender is deleted. Resolve the circulating dependency and fix it. | 866 // the sender is deleted. Resolve the circulating dependency and fix it. |
| 861 const google_apis::CancelCallback callback = | 867 const google_apis::CancelCallback callback = |
| 862 sender_->StartRequestWithRetry(request.release()); | 868 sender_->StartRequestWithRetry(request.release()); |
| 863 return make_scoped_ptr<BatchRequestConfiguratorInterface>( | 869 return make_scoped_ptr<BatchRequestConfiguratorInterface>( |
| 864 new BatchRequestConfigurator(weak_ref, callback)); | 870 new BatchRequestConfigurator(weak_ref, callback)); |
| 865 } | 871 } |
| 866 | 872 |
| 867 } // namespace drive | 873 } // namespace drive |
| OLD | NEW |