| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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/sync_file_system/drive_backend_v1/api_util.h" | 5 #include "chrome/browser/sync_file_system/drive_backend_v1/api_util.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <functional> | 8 #include <functional> |
| 9 #include <sstream> | 9 #include <sstream> |
| 10 #include <string> | 10 #include <string> |
| (...skipping 462 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 473 drive_service_->GetResourceListInDirectory(directory_resource_id, callback); | 473 drive_service_->GetResourceListInDirectory(directory_resource_id, callback); |
| 474 } | 474 } |
| 475 | 475 |
| 476 void APIUtil::ListChanges(int64 start_changestamp, | 476 void APIUtil::ListChanges(int64 start_changestamp, |
| 477 const ResourceListCallback& callback) { | 477 const ResourceListCallback& callback) { |
| 478 DCHECK(CalledOnValidThread()); | 478 DCHECK(CalledOnValidThread()); |
| 479 DVLOG(2) << "Listing changes since: " << start_changestamp; | 479 DVLOG(2) << "Listing changes since: " << start_changestamp; |
| 480 | 480 |
| 481 drive_service_->GetChangeList( | 481 drive_service_->GetChangeList( |
| 482 start_changestamp, | 482 start_changestamp, |
| 483 base::Bind(&APIUtil::DidGetResourceList, AsWeakPtr(), callback)); | 483 base::Bind(&APIUtil::DidGetChangeList, AsWeakPtr(), callback)); |
| 484 } | 484 } |
| 485 | 485 |
| 486 void APIUtil::ContinueListing(const GURL& next_link, | 486 void APIUtil::ContinueListing(const GURL& next_link, |
| 487 const ResourceListCallback& callback) { | 487 const ResourceListCallback& callback) { |
| 488 DCHECK(CalledOnValidThread()); | 488 DCHECK(CalledOnValidThread()); |
| 489 DVLOG(2) << "Continue listing on feed: " << next_link.spec(); | 489 DVLOG(2) << "Continue listing on feed: " << next_link.spec(); |
| 490 | 490 |
| 491 drive_service_->GetRemainingFileList( | 491 drive_service_->GetRemainingFileList( |
| 492 next_link, | 492 next_link, |
| 493 base::Bind(&APIUtil::DidGetResourceList, AsWeakPtr(), callback)); | 493 base::Bind(&APIUtil::DidGetResourceList, AsWeakPtr(), callback)); |
| (...skipping 174 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 668 FOR_EACH_OBSERVER(APIUtilObserver, observers_, OnNetworkConnected()); | 668 FOR_EACH_OBSERVER(APIUtilObserver, observers_, OnNetworkConnected()); |
| 669 return; | 669 return; |
| 670 } | 670 } |
| 671 // We're now disconnected, reset the drive_uploader_ to force stop | 671 // We're now disconnected, reset the drive_uploader_ to force stop |
| 672 // uploading, otherwise the uploader may get stuck. | 672 // uploading, otherwise the uploader may get stuck. |
| 673 // TODO(kinuko): Check the uploader behavior if it's the expected behavior | 673 // TODO(kinuko): Check the uploader behavior if it's the expected behavior |
| 674 // (http://crbug.com/223818) | 674 // (http://crbug.com/223818) |
| 675 CancelAllUploads(google_apis::GDATA_NO_CONNECTION); | 675 CancelAllUploads(google_apis::GDATA_NO_CONNECTION); |
| 676 } | 676 } |
| 677 | 677 |
| 678 void APIUtil::DidGetChangeList( |
| 679 const ResourceListCallback& callback, |
| 680 google_apis::GDataErrorCode error, |
| 681 scoped_ptr<google_apis::ChangeList> change_list) { |
| 682 DCHECK(CalledOnValidThread()); |
| 683 |
| 684 if (error != google_apis::HTTP_SUCCESS) { |
| 685 DVLOG(2) << "Error on listing changes: " << error; |
| 686 callback.Run(error, scoped_ptr<google_apis::ResourceList>()); |
| 687 return; |
| 688 } |
| 689 |
| 690 DVLOG(2) << "Got change list"; |
| 691 DCHECK(change_list); |
| 692 callback.Run(error, |
| 693 drive::util::ConvertChangeListToResourceList(*change_list)); |
| 694 } |
| 695 |
| 678 void APIUtil::DidGetResourceList( | 696 void APIUtil::DidGetResourceList( |
| 679 const ResourceListCallback& callback, | 697 const ResourceListCallback& callback, |
| 680 google_apis::GDataErrorCode error, | 698 google_apis::GDataErrorCode error, |
| 681 scoped_ptr<google_apis::ResourceList> resource_list) { | 699 scoped_ptr<google_apis::ResourceList> resource_list) { |
| 682 DCHECK(CalledOnValidThread()); | 700 DCHECK(CalledOnValidThread()); |
| 683 | 701 |
| 684 if (error != google_apis::HTTP_SUCCESS) { | 702 if (error != google_apis::HTTP_SUCCESS) { |
| 685 DVLOG(2) << "Error on listing resource: " << error; | 703 DVLOG(2) << "Error on listing resource: " << error; |
| 686 callback.Run(error, scoped_ptr<google_apis::ResourceList>()); | 704 callback.Run(error, scoped_ptr<google_apis::ResourceList>()); |
| 687 return; | 705 return; |
| (...skipping 435 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1123 } | 1141 } |
| 1124 | 1142 |
| 1125 std::string APIUtil::GetRootResourceId() const { | 1143 std::string APIUtil::GetRootResourceId() const { |
| 1126 if (IsDriveAPIDisabled()) | 1144 if (IsDriveAPIDisabled()) |
| 1127 return drive_service_->GetRootResourceId(); | 1145 return drive_service_->GetRootResourceId(); |
| 1128 return root_resource_id_; | 1146 return root_resource_id_; |
| 1129 } | 1147 } |
| 1130 | 1148 |
| 1131 } // namespace drive_backend | 1149 } // namespace drive_backend |
| 1132 } // namespace sync_file_system | 1150 } // namespace sync_file_system |
| OLD | NEW |