| 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/google_apis/gdata_wapi_operations.h" | 5 #include "chrome/browser/google_apis/gdata_wapi_operations.h" |
| 6 | 6 |
| 7 #include "base/stringprintf.h" | 7 #include "base/stringprintf.h" |
| 8 #include "base/strings/string_number_conversions.h" | 8 #include "base/strings/string_number_conversions.h" |
| 9 #include "base/task_runner_util.h" | 9 #include "base/task_runner_util.h" |
| 10 #include "base/threading/sequenced_worker_pool.h" | 10 #include "base/threading/sequenced_worker_pool.h" |
| (...skipping 143 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 154 error = GDATA_OTHER_ERROR; | 154 error = GDATA_OTHER_ERROR; |
| 155 | 155 |
| 156 callback.Run(error, open_link); | 156 callback.Run(error, open_link); |
| 157 } | 157 } |
| 158 | 158 |
| 159 } // namespace | 159 } // namespace |
| 160 | 160 |
| 161 //============================ GetResourceListOperation ======================== | 161 //============================ GetResourceListOperation ======================== |
| 162 | 162 |
| 163 GetResourceListOperation::GetResourceListOperation( | 163 GetResourceListOperation::GetResourceListOperation( |
| 164 OperationRunner* runner, | 164 RequestSender* runner, |
| 165 net::URLRequestContextGetter* url_request_context_getter, | 165 net::URLRequestContextGetter* url_request_context_getter, |
| 166 const GDataWapiUrlGenerator& url_generator, | 166 const GDataWapiUrlGenerator& url_generator, |
| 167 const GURL& override_url, | 167 const GURL& override_url, |
| 168 int64 start_changestamp, | 168 int64 start_changestamp, |
| 169 const std::string& search_string, | 169 const std::string& search_string, |
| 170 const std::string& directory_resource_id, | 170 const std::string& directory_resource_id, |
| 171 const GetResourceListCallback& callback) | 171 const GetResourceListCallback& callback) |
| 172 : GetDataRequest(runner, url_request_context_getter, | 172 : GetDataRequest(runner, url_request_context_getter, |
| 173 base::Bind(&ParseResourceListAndRun, callback)), | 173 base::Bind(&ParseResourceListAndRun, callback)), |
| 174 url_generator_(url_generator), | 174 url_generator_(url_generator), |
| 175 override_url_(override_url), | 175 override_url_(override_url), |
| 176 start_changestamp_(start_changestamp), | 176 start_changestamp_(start_changestamp), |
| 177 search_string_(search_string), | 177 search_string_(search_string), |
| 178 directory_resource_id_(directory_resource_id) { | 178 directory_resource_id_(directory_resource_id) { |
| 179 DCHECK(!callback.is_null()); | 179 DCHECK(!callback.is_null()); |
| 180 } | 180 } |
| 181 | 181 |
| 182 GetResourceListOperation::~GetResourceListOperation() {} | 182 GetResourceListOperation::~GetResourceListOperation() {} |
| 183 | 183 |
| 184 GURL GetResourceListOperation::GetURL() const { | 184 GURL GetResourceListOperation::GetURL() const { |
| 185 return url_generator_.GenerateResourceListUrl(override_url_, | 185 return url_generator_.GenerateResourceListUrl(override_url_, |
| 186 start_changestamp_, | 186 start_changestamp_, |
| 187 search_string_, | 187 search_string_, |
| 188 directory_resource_id_); | 188 directory_resource_id_); |
| 189 } | 189 } |
| 190 | 190 |
| 191 //============================ SearchByTitleOperation ========================== | 191 //============================ SearchByTitleOperation ========================== |
| 192 | 192 |
| 193 SearchByTitleOperation::SearchByTitleOperation( | 193 SearchByTitleOperation::SearchByTitleOperation( |
| 194 OperationRunner* runner, | 194 RequestSender* runner, |
| 195 net::URLRequestContextGetter* url_request_context_getter, | 195 net::URLRequestContextGetter* url_request_context_getter, |
| 196 const GDataWapiUrlGenerator& url_generator, | 196 const GDataWapiUrlGenerator& url_generator, |
| 197 const std::string& title, | 197 const std::string& title, |
| 198 const std::string& directory_resource_id, | 198 const std::string& directory_resource_id, |
| 199 const GetResourceListCallback& callback) | 199 const GetResourceListCallback& callback) |
| 200 : GetDataRequest(runner, url_request_context_getter, | 200 : GetDataRequest(runner, url_request_context_getter, |
| 201 base::Bind(&ParseResourceListAndRun, callback)), | 201 base::Bind(&ParseResourceListAndRun, callback)), |
| 202 url_generator_(url_generator), | 202 url_generator_(url_generator), |
| 203 title_(title), | 203 title_(title), |
| 204 directory_resource_id_(directory_resource_id) { | 204 directory_resource_id_(directory_resource_id) { |
| 205 DCHECK(!callback.is_null()); | 205 DCHECK(!callback.is_null()); |
| 206 } | 206 } |
| 207 | 207 |
| 208 SearchByTitleOperation::~SearchByTitleOperation() {} | 208 SearchByTitleOperation::~SearchByTitleOperation() {} |
| 209 | 209 |
| 210 GURL SearchByTitleOperation::GetURL() const { | 210 GURL SearchByTitleOperation::GetURL() const { |
| 211 return url_generator_.GenerateSearchByTitleUrl( | 211 return url_generator_.GenerateSearchByTitleUrl( |
| 212 title_, directory_resource_id_); | 212 title_, directory_resource_id_); |
| 213 } | 213 } |
| 214 | 214 |
| 215 //============================ GetResourceEntryOperation ======================= | 215 //============================ GetResourceEntryOperation ======================= |
| 216 | 216 |
| 217 GetResourceEntryOperation::GetResourceEntryOperation( | 217 GetResourceEntryOperation::GetResourceEntryOperation( |
| 218 OperationRunner* runner, | 218 RequestSender* runner, |
| 219 net::URLRequestContextGetter* url_request_context_getter, | 219 net::URLRequestContextGetter* url_request_context_getter, |
| 220 const GDataWapiUrlGenerator& url_generator, | 220 const GDataWapiUrlGenerator& url_generator, |
| 221 const std::string& resource_id, | 221 const std::string& resource_id, |
| 222 const GetDataCallback& callback) | 222 const GetDataCallback& callback) |
| 223 : GetDataRequest(runner, url_request_context_getter, callback), | 223 : GetDataRequest(runner, url_request_context_getter, callback), |
| 224 url_generator_(url_generator), | 224 url_generator_(url_generator), |
| 225 resource_id_(resource_id) { | 225 resource_id_(resource_id) { |
| 226 DCHECK(!callback.is_null()); | 226 DCHECK(!callback.is_null()); |
| 227 } | 227 } |
| 228 | 228 |
| 229 GetResourceEntryOperation::~GetResourceEntryOperation() {} | 229 GetResourceEntryOperation::~GetResourceEntryOperation() {} |
| 230 | 230 |
| 231 GURL GetResourceEntryOperation::GetURL() const { | 231 GURL GetResourceEntryOperation::GetURL() const { |
| 232 return url_generator_.GenerateEditUrl(resource_id_); | 232 return url_generator_.GenerateEditUrl(resource_id_); |
| 233 } | 233 } |
| 234 | 234 |
| 235 //========================= GetAccountMetadataOperation ======================== | 235 //========================= GetAccountMetadataOperation ======================== |
| 236 | 236 |
| 237 GetAccountMetadataOperation::GetAccountMetadataOperation( | 237 GetAccountMetadataOperation::GetAccountMetadataOperation( |
| 238 OperationRunner* runner, | 238 RequestSender* runner, |
| 239 net::URLRequestContextGetter* url_request_context_getter, | 239 net::URLRequestContextGetter* url_request_context_getter, |
| 240 const GDataWapiUrlGenerator& url_generator, | 240 const GDataWapiUrlGenerator& url_generator, |
| 241 const GetAccountMetadataCallback& callback, | 241 const GetAccountMetadataCallback& callback, |
| 242 bool include_installed_apps) | 242 bool include_installed_apps) |
| 243 : GetDataRequest(runner, url_request_context_getter, | 243 : GetDataRequest(runner, url_request_context_getter, |
| 244 base::Bind(&ParseAccounetMetadataAndRun, callback)), | 244 base::Bind(&ParseAccounetMetadataAndRun, callback)), |
| 245 url_generator_(url_generator), | 245 url_generator_(url_generator), |
| 246 include_installed_apps_(include_installed_apps) { | 246 include_installed_apps_(include_installed_apps) { |
| 247 DCHECK(!callback.is_null()); | 247 DCHECK(!callback.is_null()); |
| 248 } | 248 } |
| 249 | 249 |
| 250 GetAccountMetadataOperation::~GetAccountMetadataOperation() {} | 250 GetAccountMetadataOperation::~GetAccountMetadataOperation() {} |
| 251 | 251 |
| 252 GURL GetAccountMetadataOperation::GetURL() const { | 252 GURL GetAccountMetadataOperation::GetURL() const { |
| 253 return url_generator_.GenerateAccountMetadataUrl(include_installed_apps_); | 253 return url_generator_.GenerateAccountMetadataUrl(include_installed_apps_); |
| 254 } | 254 } |
| 255 | 255 |
| 256 //=========================== DeleteResourceOperation ========================== | 256 //=========================== DeleteResourceOperation ========================== |
| 257 | 257 |
| 258 DeleteResourceOperation::DeleteResourceOperation( | 258 DeleteResourceOperation::DeleteResourceOperation( |
| 259 OperationRunner* runner, | 259 RequestSender* runner, |
| 260 net::URLRequestContextGetter* url_request_context_getter, | 260 net::URLRequestContextGetter* url_request_context_getter, |
| 261 const GDataWapiUrlGenerator& url_generator, | 261 const GDataWapiUrlGenerator& url_generator, |
| 262 const EntryActionCallback& callback, | 262 const EntryActionCallback& callback, |
| 263 const std::string& resource_id, | 263 const std::string& resource_id, |
| 264 const std::string& etag) | 264 const std::string& etag) |
| 265 : EntryActionRequest(runner, url_request_context_getter, callback), | 265 : EntryActionRequest(runner, url_request_context_getter, callback), |
| 266 url_generator_(url_generator), | 266 url_generator_(url_generator), |
| 267 resource_id_(resource_id), | 267 resource_id_(resource_id), |
| 268 etag_(etag) { | 268 etag_(etag) { |
| 269 DCHECK(!callback.is_null()); | 269 DCHECK(!callback.is_null()); |
| (...skipping 12 matching lines...) Expand all Loading... |
| 282 std::vector<std::string> | 282 std::vector<std::string> |
| 283 DeleteResourceOperation::GetExtraRequestHeaders() const { | 283 DeleteResourceOperation::GetExtraRequestHeaders() const { |
| 284 std::vector<std::string> headers; | 284 std::vector<std::string> headers; |
| 285 headers.push_back(util::GenerateIfMatchHeader(etag_)); | 285 headers.push_back(util::GenerateIfMatchHeader(etag_)); |
| 286 return headers; | 286 return headers; |
| 287 } | 287 } |
| 288 | 288 |
| 289 //========================== CreateDirectoryOperation ========================== | 289 //========================== CreateDirectoryOperation ========================== |
| 290 | 290 |
| 291 CreateDirectoryOperation::CreateDirectoryOperation( | 291 CreateDirectoryOperation::CreateDirectoryOperation( |
| 292 OperationRunner* runner, | 292 RequestSender* runner, |
| 293 net::URLRequestContextGetter* url_request_context_getter, | 293 net::URLRequestContextGetter* url_request_context_getter, |
| 294 const GDataWapiUrlGenerator& url_generator, | 294 const GDataWapiUrlGenerator& url_generator, |
| 295 const GetDataCallback& callback, | 295 const GetDataCallback& callback, |
| 296 const std::string& parent_resource_id, | 296 const std::string& parent_resource_id, |
| 297 const std::string& directory_name) | 297 const std::string& directory_name) |
| 298 : GetDataRequest(runner, url_request_context_getter, callback), | 298 : GetDataRequest(runner, url_request_context_getter, callback), |
| 299 url_generator_(url_generator), | 299 url_generator_(url_generator), |
| 300 parent_resource_id_(parent_resource_id), | 300 parent_resource_id_(parent_resource_id), |
| 301 directory_name_(directory_name) { | 301 directory_name_(directory_name) { |
| 302 DCHECK(!callback.is_null()); | 302 DCHECK(!callback.is_null()); |
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 334 xml_writer.StopWriting(); | 334 xml_writer.StopWriting(); |
| 335 upload_content->assign(xml_writer.GetWrittenString()); | 335 upload_content->assign(xml_writer.GetWrittenString()); |
| 336 DVLOG(1) << "CreateDirectory data: " << *upload_content_type << ", [" | 336 DVLOG(1) << "CreateDirectory data: " << *upload_content_type << ", [" |
| 337 << *upload_content << "]"; | 337 << *upload_content << "]"; |
| 338 return true; | 338 return true; |
| 339 } | 339 } |
| 340 | 340 |
| 341 //============================ CopyHostedDocumentOperation ===================== | 341 //============================ CopyHostedDocumentOperation ===================== |
| 342 | 342 |
| 343 CopyHostedDocumentOperation::CopyHostedDocumentOperation( | 343 CopyHostedDocumentOperation::CopyHostedDocumentOperation( |
| 344 OperationRunner* runner, | 344 RequestSender* runner, |
| 345 net::URLRequestContextGetter* url_request_context_getter, | 345 net::URLRequestContextGetter* url_request_context_getter, |
| 346 const GDataWapiUrlGenerator& url_generator, | 346 const GDataWapiUrlGenerator& url_generator, |
| 347 const GetDataCallback& callback, | 347 const GetDataCallback& callback, |
| 348 const std::string& resource_id, | 348 const std::string& resource_id, |
| 349 const std::string& new_name) | 349 const std::string& new_name) |
| 350 : GetDataRequest(runner, url_request_context_getter, callback), | 350 : GetDataRequest(runner, url_request_context_getter, callback), |
| 351 url_generator_(url_generator), | 351 url_generator_(url_generator), |
| 352 resource_id_(resource_id), | 352 resource_id_(resource_id), |
| 353 new_name_(new_name) { | 353 new_name_(new_name) { |
| 354 DCHECK(!callback.is_null()); | 354 DCHECK(!callback.is_null()); |
| (...skipping 25 matching lines...) Expand all Loading... |
| 380 xml_writer.StopWriting(); | 380 xml_writer.StopWriting(); |
| 381 upload_content->assign(xml_writer.GetWrittenString()); | 381 upload_content->assign(xml_writer.GetWrittenString()); |
| 382 DVLOG(1) << "CopyHostedDocumentOperation data: " << *upload_content_type | 382 DVLOG(1) << "CopyHostedDocumentOperation data: " << *upload_content_type |
| 383 << ", [" << *upload_content << "]"; | 383 << ", [" << *upload_content << "]"; |
| 384 return true; | 384 return true; |
| 385 } | 385 } |
| 386 | 386 |
| 387 //=========================== RenameResourceOperation ========================== | 387 //=========================== RenameResourceOperation ========================== |
| 388 | 388 |
| 389 RenameResourceOperation::RenameResourceOperation( | 389 RenameResourceOperation::RenameResourceOperation( |
| 390 OperationRunner* runner, | 390 RequestSender* runner, |
| 391 net::URLRequestContextGetter* url_request_context_getter, | 391 net::URLRequestContextGetter* url_request_context_getter, |
| 392 const GDataWapiUrlGenerator& url_generator, | 392 const GDataWapiUrlGenerator& url_generator, |
| 393 const EntryActionCallback& callback, | 393 const EntryActionCallback& callback, |
| 394 const std::string& resource_id, | 394 const std::string& resource_id, |
| 395 const std::string& new_name) | 395 const std::string& new_name) |
| 396 : EntryActionRequest(runner, url_request_context_getter, callback), | 396 : EntryActionRequest(runner, url_request_context_getter, callback), |
| 397 url_generator_(url_generator), | 397 url_generator_(url_generator), |
| 398 resource_id_(resource_id), | 398 resource_id_(resource_id), |
| 399 new_name_(new_name) { | 399 new_name_(new_name) { |
| 400 DCHECK(!callback.is_null()); | 400 DCHECK(!callback.is_null()); |
| (...skipping 30 matching lines...) Expand all Loading... |
| 431 xml_writer.StopWriting(); | 431 xml_writer.StopWriting(); |
| 432 upload_content->assign(xml_writer.GetWrittenString()); | 432 upload_content->assign(xml_writer.GetWrittenString()); |
| 433 DVLOG(1) << "RenameResourceOperation data: " << *upload_content_type << ", [" | 433 DVLOG(1) << "RenameResourceOperation data: " << *upload_content_type << ", [" |
| 434 << *upload_content << "]"; | 434 << *upload_content << "]"; |
| 435 return true; | 435 return true; |
| 436 } | 436 } |
| 437 | 437 |
| 438 //=========================== AuthorizeAppOperation ========================== | 438 //=========================== AuthorizeAppOperation ========================== |
| 439 | 439 |
| 440 AuthorizeAppOperation::AuthorizeAppOperation( | 440 AuthorizeAppOperation::AuthorizeAppOperation( |
| 441 OperationRunner* runner, | 441 RequestSender* runner, |
| 442 net::URLRequestContextGetter* url_request_context_getter, | 442 net::URLRequestContextGetter* url_request_context_getter, |
| 443 const GDataWapiUrlGenerator& url_generator, | 443 const GDataWapiUrlGenerator& url_generator, |
| 444 const AuthorizeAppCallback& callback, | 444 const AuthorizeAppCallback& callback, |
| 445 const std::string& resource_id, | 445 const std::string& resource_id, |
| 446 const std::string& app_id) | 446 const std::string& app_id) |
| 447 : GetDataRequest(runner, url_request_context_getter, | 447 : GetDataRequest(runner, url_request_context_getter, |
| 448 base::Bind(&ParseOpenLinkAndRun, app_id, callback)), | 448 base::Bind(&ParseOpenLinkAndRun, app_id, callback)), |
| 449 url_generator_(url_generator), | 449 url_generator_(url_generator), |
| 450 resource_id_(resource_id), | 450 resource_id_(resource_id), |
| 451 app_id_(app_id) { | 451 app_id_(app_id) { |
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 483 return true; | 483 return true; |
| 484 } | 484 } |
| 485 | 485 |
| 486 GURL AuthorizeAppOperation::GetURL() const { | 486 GURL AuthorizeAppOperation::GetURL() const { |
| 487 return url_generator_.GenerateEditUrl(resource_id_); | 487 return url_generator_.GenerateEditUrl(resource_id_); |
| 488 } | 488 } |
| 489 | 489 |
| 490 //======================= AddResourceToDirectoryOperation ====================== | 490 //======================= AddResourceToDirectoryOperation ====================== |
| 491 | 491 |
| 492 AddResourceToDirectoryOperation::AddResourceToDirectoryOperation( | 492 AddResourceToDirectoryOperation::AddResourceToDirectoryOperation( |
| 493 OperationRunner* runner, | 493 RequestSender* runner, |
| 494 net::URLRequestContextGetter* url_request_context_getter, | 494 net::URLRequestContextGetter* url_request_context_getter, |
| 495 const GDataWapiUrlGenerator& url_generator, | 495 const GDataWapiUrlGenerator& url_generator, |
| 496 const EntryActionCallback& callback, | 496 const EntryActionCallback& callback, |
| 497 const std::string& parent_resource_id, | 497 const std::string& parent_resource_id, |
| 498 const std::string& resource_id) | 498 const std::string& resource_id) |
| 499 : EntryActionRequest(runner, url_request_context_getter, callback), | 499 : EntryActionRequest(runner, url_request_context_getter, callback), |
| 500 url_generator_(url_generator), | 500 url_generator_(url_generator), |
| 501 parent_resource_id_(parent_resource_id), | 501 parent_resource_id_(parent_resource_id), |
| 502 resource_id_(resource_id) { | 502 resource_id_(resource_id) { |
| 503 DCHECK(!callback.is_null()); | 503 DCHECK(!callback.is_null()); |
| (...skipping 25 matching lines...) Expand all Loading... |
| 529 xml_writer.StopWriting(); | 529 xml_writer.StopWriting(); |
| 530 upload_content->assign(xml_writer.GetWrittenString()); | 530 upload_content->assign(xml_writer.GetWrittenString()); |
| 531 DVLOG(1) << "AddResourceToDirectoryOperation data: " << *upload_content_type | 531 DVLOG(1) << "AddResourceToDirectoryOperation data: " << *upload_content_type |
| 532 << ", [" << *upload_content << "]"; | 532 << ", [" << *upload_content << "]"; |
| 533 return true; | 533 return true; |
| 534 } | 534 } |
| 535 | 535 |
| 536 //==================== RemoveResourceFromDirectoryOperation ==================== | 536 //==================== RemoveResourceFromDirectoryOperation ==================== |
| 537 | 537 |
| 538 RemoveResourceFromDirectoryOperation::RemoveResourceFromDirectoryOperation( | 538 RemoveResourceFromDirectoryOperation::RemoveResourceFromDirectoryOperation( |
| 539 OperationRunner* runner, | 539 RequestSender* runner, |
| 540 net::URLRequestContextGetter* url_request_context_getter, | 540 net::URLRequestContextGetter* url_request_context_getter, |
| 541 const GDataWapiUrlGenerator& url_generator, | 541 const GDataWapiUrlGenerator& url_generator, |
| 542 const EntryActionCallback& callback, | 542 const EntryActionCallback& callback, |
| 543 const std::string& parent_resource_id, | 543 const std::string& parent_resource_id, |
| 544 const std::string& document_resource_id) | 544 const std::string& document_resource_id) |
| 545 : EntryActionRequest(runner, url_request_context_getter, callback), | 545 : EntryActionRequest(runner, url_request_context_getter, callback), |
| 546 url_generator_(url_generator), | 546 url_generator_(url_generator), |
| 547 resource_id_(document_resource_id), | 547 resource_id_(document_resource_id), |
| 548 parent_resource_id_(parent_resource_id) { | 548 parent_resource_id_(parent_resource_id) { |
| 549 DCHECK(!callback.is_null()); | 549 DCHECK(!callback.is_null()); |
| (...skipping 15 matching lines...) Expand all Loading... |
| 565 std::vector<std::string> | 565 std::vector<std::string> |
| 566 RemoveResourceFromDirectoryOperation::GetExtraRequestHeaders() const { | 566 RemoveResourceFromDirectoryOperation::GetExtraRequestHeaders() const { |
| 567 std::vector<std::string> headers; | 567 std::vector<std::string> headers; |
| 568 headers.push_back(util::kIfMatchAllHeader); | 568 headers.push_back(util::kIfMatchAllHeader); |
| 569 return headers; | 569 return headers; |
| 570 } | 570 } |
| 571 | 571 |
| 572 //======================= InitiateUploadNewFileOperation ======================= | 572 //======================= InitiateUploadNewFileOperation ======================= |
| 573 | 573 |
| 574 InitiateUploadNewFileOperation::InitiateUploadNewFileOperation( | 574 InitiateUploadNewFileOperation::InitiateUploadNewFileOperation( |
| 575 OperationRunner* runner, | 575 RequestSender* runner, |
| 576 net::URLRequestContextGetter* url_request_context_getter, | 576 net::URLRequestContextGetter* url_request_context_getter, |
| 577 const GDataWapiUrlGenerator& url_generator, | 577 const GDataWapiUrlGenerator& url_generator, |
| 578 const InitiateUploadCallback& callback, | 578 const InitiateUploadCallback& callback, |
| 579 const base::FilePath& drive_file_path, | 579 const base::FilePath& drive_file_path, |
| 580 const std::string& content_type, | 580 const std::string& content_type, |
| 581 int64 content_length, | 581 int64 content_length, |
| 582 const std::string& parent_resource_id, | 582 const std::string& parent_resource_id, |
| 583 const std::string& title) | 583 const std::string& title) |
| 584 : InitiateUploadRequestBase(runner, | 584 : InitiateUploadRequestBase(runner, |
| 585 url_request_context_getter, | 585 url_request_context_getter, |
| (...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 618 xml_writer.StopWriting(); | 618 xml_writer.StopWriting(); |
| 619 upload_content->assign(xml_writer.GetWrittenString()); | 619 upload_content->assign(xml_writer.GetWrittenString()); |
| 620 DVLOG(1) << "InitiateUploadNewFile: " << *upload_content_type << ", [" | 620 DVLOG(1) << "InitiateUploadNewFile: " << *upload_content_type << ", [" |
| 621 << *upload_content << "]"; | 621 << *upload_content << "]"; |
| 622 return true; | 622 return true; |
| 623 } | 623 } |
| 624 | 624 |
| 625 //===================== InitiateUploadExistingFileOperation ==================== | 625 //===================== InitiateUploadExistingFileOperation ==================== |
| 626 | 626 |
| 627 InitiateUploadExistingFileOperation::InitiateUploadExistingFileOperation( | 627 InitiateUploadExistingFileOperation::InitiateUploadExistingFileOperation( |
| 628 OperationRunner* runner, | 628 RequestSender* runner, |
| 629 net::URLRequestContextGetter* url_request_context_getter, | 629 net::URLRequestContextGetter* url_request_context_getter, |
| 630 const GDataWapiUrlGenerator& url_generator, | 630 const GDataWapiUrlGenerator& url_generator, |
| 631 const InitiateUploadCallback& callback, | 631 const InitiateUploadCallback& callback, |
| 632 const base::FilePath& drive_file_path, | 632 const base::FilePath& drive_file_path, |
| 633 const std::string& content_type, | 633 const std::string& content_type, |
| 634 int64 content_length, | 634 int64 content_length, |
| 635 const std::string& resource_id, | 635 const std::string& resource_id, |
| 636 const std::string& etag) | 636 const std::string& etag) |
| 637 : InitiateUploadRequestBase(runner, | 637 : InitiateUploadRequestBase(runner, |
| 638 url_request_context_getter, | 638 url_request_context_getter, |
| (...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 672 InitiateUploadExistingFileOperation::GetExtraRequestHeaders() const { | 672 InitiateUploadExistingFileOperation::GetExtraRequestHeaders() const { |
| 673 std::vector<std::string> headers( | 673 std::vector<std::string> headers( |
| 674 InitiateUploadRequestBase::GetExtraRequestHeaders()); | 674 InitiateUploadRequestBase::GetExtraRequestHeaders()); |
| 675 headers.push_back(util::GenerateIfMatchHeader(etag_)); | 675 headers.push_back(util::GenerateIfMatchHeader(etag_)); |
| 676 return headers; | 676 return headers; |
| 677 } | 677 } |
| 678 | 678 |
| 679 //============================ ResumeUploadOperation =========================== | 679 //============================ ResumeUploadOperation =========================== |
| 680 | 680 |
| 681 ResumeUploadOperation::ResumeUploadOperation( | 681 ResumeUploadOperation::ResumeUploadOperation( |
| 682 OperationRunner* runner, | 682 RequestSender* runner, |
| 683 net::URLRequestContextGetter* url_request_context_getter, | 683 net::URLRequestContextGetter* url_request_context_getter, |
| 684 const UploadRangeCallback& callback, | 684 const UploadRangeCallback& callback, |
| 685 const ProgressCallback& progress_callback, | 685 const ProgressCallback& progress_callback, |
| 686 const base::FilePath& drive_file_path, | 686 const base::FilePath& drive_file_path, |
| 687 const GURL& upload_location, | 687 const GURL& upload_location, |
| 688 int64 start_position, | 688 int64 start_position, |
| 689 int64 end_position, | 689 int64 end_position, |
| 690 int64 content_length, | 690 int64 content_length, |
| 691 const std::string& content_type, | 691 const std::string& content_type, |
| 692 const base::FilePath& local_file_path) | 692 const base::FilePath& local_file_path) |
| (...skipping 20 matching lines...) Expand all Loading... |
| 713 | 713 |
| 714 void ResumeUploadOperation::OnURLFetchUploadProgress( | 714 void ResumeUploadOperation::OnURLFetchUploadProgress( |
| 715 const URLFetcher* source, int64 current, int64 total) { | 715 const URLFetcher* source, int64 current, int64 total) { |
| 716 if (!progress_callback_.is_null()) | 716 if (!progress_callback_.is_null()) |
| 717 progress_callback_.Run(current, total); | 717 progress_callback_.Run(current, total); |
| 718 } | 718 } |
| 719 | 719 |
| 720 //========================== GetUploadStatusOperation ========================== | 720 //========================== GetUploadStatusOperation ========================== |
| 721 | 721 |
| 722 GetUploadStatusOperation::GetUploadStatusOperation( | 722 GetUploadStatusOperation::GetUploadStatusOperation( |
| 723 OperationRunner* runner, | 723 RequestSender* runner, |
| 724 net::URLRequestContextGetter* url_request_context_getter, | 724 net::URLRequestContextGetter* url_request_context_getter, |
| 725 const UploadRangeCallback& callback, | 725 const UploadRangeCallback& callback, |
| 726 const base::FilePath& drive_file_path, | 726 const base::FilePath& drive_file_path, |
| 727 const GURL& upload_url, | 727 const GURL& upload_url, |
| 728 int64 content_length) | 728 int64 content_length) |
| 729 : GetUploadStatusRequestBase(runner, | 729 : GetUploadStatusRequestBase(runner, |
| 730 url_request_context_getter, | 730 url_request_context_getter, |
| 731 drive_file_path, | 731 drive_file_path, |
| 732 upload_url, | 732 upload_url, |
| 733 content_length), | 733 content_length), |
| 734 callback_(callback) { | 734 callback_(callback) { |
| 735 DCHECK(!callback.is_null()); | 735 DCHECK(!callback.is_null()); |
| 736 } | 736 } |
| 737 | 737 |
| 738 GetUploadStatusOperation::~GetUploadStatusOperation() {} | 738 GetUploadStatusOperation::~GetUploadStatusOperation() {} |
| 739 | 739 |
| 740 void GetUploadStatusOperation::OnRangeRequestComplete( | 740 void GetUploadStatusOperation::OnRangeRequestComplete( |
| 741 const UploadRangeResponse& response, scoped_ptr<base::Value> value) { | 741 const UploadRangeResponse& response, scoped_ptr<base::Value> value) { |
| 742 callback_.Run(response, ParseResourceEntry(value.Pass())); | 742 callback_.Run(response, ParseResourceEntry(value.Pass())); |
| 743 } | 743 } |
| 744 | 744 |
| 745 } // namespace google_apis | 745 } // namespace google_apis |
| OLD | NEW |