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/local_to_remote_syncer.h
" | 5 #include "chrome/browser/sync_file_system/drive_backend/local_to_remote_syncer.h
" |
6 | 6 |
7 #include <string> | 7 #include <string> |
8 #include <vector> | 8 #include <vector> |
9 | 9 |
10 #include "base/callback.h" | 10 #include "base/callback.h" |
(...skipping 11 matching lines...) Expand all Loading... |
22 #include "chrome/browser/sync_file_system/drive_backend/drive_backend_util.h" | 22 #include "chrome/browser/sync_file_system/drive_backend/drive_backend_util.h" |
23 #include "chrome/browser/sync_file_system/drive_backend/folder_creator.h" | 23 #include "chrome/browser/sync_file_system/drive_backend/folder_creator.h" |
24 #include "chrome/browser/sync_file_system/drive_backend/metadata_database.h" | 24 #include "chrome/browser/sync_file_system/drive_backend/metadata_database.h" |
25 #include "chrome/browser/sync_file_system/drive_backend/metadata_database.pb.h" | 25 #include "chrome/browser/sync_file_system/drive_backend/metadata_database.pb.h" |
26 #include "chrome/browser/sync_file_system/drive_backend/sync_engine_context.h" | 26 #include "chrome/browser/sync_file_system/drive_backend/sync_engine_context.h" |
27 #include "chrome/browser/sync_file_system/drive_backend/sync_task_manager.h" | 27 #include "chrome/browser/sync_file_system/drive_backend/sync_task_manager.h" |
28 #include "chrome/browser/sync_file_system/drive_backend/sync_task_token.h" | 28 #include "chrome/browser/sync_file_system/drive_backend/sync_task_token.h" |
29 #include "chrome/browser/sync_file_system/logger.h" | 29 #include "chrome/browser/sync_file_system/logger.h" |
30 #include "google_apis/drive/drive_api_parser.h" | 30 #include "google_apis/drive/drive_api_parser.h" |
31 #include "net/base/mime_util.h" | 31 #include "net/base/mime_util.h" |
32 #include "webkit/common/fileapi/file_system_util.h" | 32 #include "storage/common/fileapi/file_system_util.h" |
33 | 33 |
34 namespace sync_file_system { | 34 namespace sync_file_system { |
35 namespace drive_backend { | 35 namespace drive_backend { |
36 | 36 |
37 namespace { | 37 namespace { |
38 | 38 |
39 scoped_ptr<FileTracker> FindTrackerByID(MetadataDatabase* metadata_database, | 39 scoped_ptr<FileTracker> FindTrackerByID(MetadataDatabase* metadata_database, |
40 int64 tracker_id) { | 40 int64 tracker_id) { |
41 scoped_ptr<FileTracker> tracker(new FileTracker); | 41 scoped_ptr<FileTracker> tracker(new FileTracker); |
42 if (metadata_database->FindTrackerByTrackerID(tracker_id, tracker.get())) | 42 if (metadata_database->FindTrackerByTrackerID(tracker_id, tracker.get())) |
(...skipping 25 matching lines...) Expand all Loading... |
68 return kMimeTypeOctetStream; | 68 return kMimeTypeOctetStream; |
69 return mime_type; | 69 return mime_type; |
70 } | 70 } |
71 | 71 |
72 } // namespace | 72 } // namespace |
73 | 73 |
74 LocalToRemoteSyncer::LocalToRemoteSyncer(SyncEngineContext* sync_context, | 74 LocalToRemoteSyncer::LocalToRemoteSyncer(SyncEngineContext* sync_context, |
75 const SyncFileMetadata& local_metadata, | 75 const SyncFileMetadata& local_metadata, |
76 const FileChange& local_change, | 76 const FileChange& local_change, |
77 const base::FilePath& local_path, | 77 const base::FilePath& local_path, |
78 const fileapi::FileSystemURL& url) | 78 const storage::FileSystemURL& url) |
79 : sync_context_(sync_context), | 79 : sync_context_(sync_context), |
80 local_change_(local_change), | 80 local_change_(local_change), |
81 local_is_missing_(IsLocalFileMissing(local_metadata, local_change)), | 81 local_is_missing_(IsLocalFileMissing(local_metadata, local_change)), |
82 local_path_(local_path), | 82 local_path_(local_path), |
83 url_(url), | 83 url_(url), |
84 sync_action_(SYNC_ACTION_NONE), | 84 sync_action_(SYNC_ACTION_NONE), |
85 remote_file_change_id_(0), | 85 remote_file_change_id_(0), |
86 retry_on_success_(false), | 86 retry_on_success_(false), |
87 needs_remote_change_listing_(false), | 87 needs_remote_change_listing_(false), |
88 weak_ptr_factory_(this) { | 88 weak_ptr_factory_(this) { |
(...skipping 60 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
149 NOTREACHED(); | 149 NOTREACHED(); |
150 token->RecordLog(base::StringPrintf( | 150 token->RecordLog(base::StringPrintf( |
151 "Detected invalid ancestor: %s", | 151 "Detected invalid ancestor: %s", |
152 active_ancestor_path.value().c_str())); | 152 active_ancestor_path.value().c_str())); |
153 SyncTaskManager::NotifyTaskDone(token.Pass(), SYNC_STATUS_FAILED); | 153 SyncTaskManager::NotifyTaskDone(token.Pass(), SYNC_STATUS_FAILED); |
154 return; | 154 return; |
155 } | 155 } |
156 } | 156 } |
157 | 157 |
158 std::vector<base::FilePath::StringType> missing_components; | 158 std::vector<base::FilePath::StringType> missing_components; |
159 fileapi::VirtualPath::GetComponents(missing_entries, &missing_components); | 159 storage::VirtualPath::GetComponents(missing_entries, &missing_components); |
160 | 160 |
161 if (!missing_components.empty()) { | 161 if (!missing_components.empty()) { |
162 if (local_is_missing_) { | 162 if (local_is_missing_) { |
163 token->RecordLog("Both local and remote are marked missing"); | 163 token->RecordLog("Both local and remote are marked missing"); |
164 // !IsDelete() but SYNC_FILE_TYPE_UNKNOWN could happen when a file is | 164 // !IsDelete() but SYNC_FILE_TYPE_UNKNOWN could happen when a file is |
165 // deleted by recursive deletion (which is not recorded by tracker) | 165 // deleted by recursive deletion (which is not recorded by tracker) |
166 // but there're remaining changes for the same file in the tracker. | 166 // but there're remaining changes for the same file in the tracker. |
167 | 167 |
168 // Local file is deleted and remote file is missing, already deleted or | 168 // Local file is deleted and remote file is missing, already deleted or |
169 // not yet synced. There is nothing to do for the file. | 169 // not yet synced. There is nothing to do for the file. |
(...skipping 187 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
357 if (!metadata_database()->FindFileByFileID( | 357 if (!metadata_database()->FindFileByFileID( |
358 remote_file_tracker_->file_id(), &remote_file_metadata)) { | 358 remote_file_tracker_->file_id(), &remote_file_metadata)) { |
359 NOTREACHED(); | 359 NOTREACHED(); |
360 MoveToBackground(base::Bind(&LocalToRemoteSyncer::CreateRemoteFolder, | 360 MoveToBackground(base::Bind(&LocalToRemoteSyncer::CreateRemoteFolder, |
361 weak_ptr_factory_.GetWeakPtr()), | 361 weak_ptr_factory_.GetWeakPtr()), |
362 token.Pass()); | 362 token.Pass()); |
363 return; | 363 return; |
364 } | 364 } |
365 | 365 |
366 const FileDetails& remote_details = remote_file_metadata.details(); | 366 const FileDetails& remote_details = remote_file_metadata.details(); |
367 base::FilePath title = fileapi::VirtualPath::BaseName(target_path_); | 367 base::FilePath title = storage::VirtualPath::BaseName(target_path_); |
368 if (!remote_details.missing() && | 368 if (!remote_details.missing() && |
369 remote_details.file_kind() == FILE_KIND_FOLDER && | 369 remote_details.file_kind() == FILE_KIND_FOLDER && |
370 remote_details.title() == title.AsUTF8Unsafe() && | 370 remote_details.title() == title.AsUTF8Unsafe() && |
371 HasFileAsParent(remote_details, | 371 HasFileAsParent(remote_details, |
372 remote_parent_folder_tracker_->file_id())) { | 372 remote_parent_folder_tracker_->file_id())) { |
373 | 373 |
374 MoveToBackground( | 374 MoveToBackground( |
375 base::Bind(&LocalToRemoteSyncer::UpdateTrackerForReusedFolder, | 375 base::Bind(&LocalToRemoteSyncer::UpdateTrackerForReusedFolder, |
376 weak_ptr_factory_.GetWeakPtr(), | 376 weak_ptr_factory_.GetWeakPtr(), |
377 remote_details), | 377 remote_details), |
(...skipping 190 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
568 | 568 |
569 FileMetadata file; | 569 FileMetadata file; |
570 if (!metadata_database()->FindFileByFileID( | 570 if (!metadata_database()->FindFileByFileID( |
571 remote_file_tracker_->file_id(), &file)) { | 571 remote_file_tracker_->file_id(), &file)) { |
572 NOTREACHED(); | 572 NOTREACHED(); |
573 SyncCompleted(token.Pass(), SYNC_STATUS_FAILED); | 573 SyncCompleted(token.Pass(), SYNC_STATUS_FAILED); |
574 return; | 574 return; |
575 } | 575 } |
576 | 576 |
577 const FileDetails& details = file.details(); | 577 const FileDetails& details = file.details(); |
578 base::FilePath title = fileapi::VirtualPath::BaseName(target_path_); | 578 base::FilePath title = storage::VirtualPath::BaseName(target_path_); |
579 if (!details.missing() && | 579 if (!details.missing() && |
580 details.file_kind() == FILE_KIND_FILE && | 580 details.file_kind() == FILE_KIND_FILE && |
581 details.title() == title.AsUTF8Unsafe() && | 581 details.title() == title.AsUTF8Unsafe() && |
582 HasFileAsParent(details, | 582 HasFileAsParent(details, |
583 remote_parent_folder_tracker_->file_id())) { | 583 remote_parent_folder_tracker_->file_id())) { |
584 metadata_database()->UpdateTracker( | 584 metadata_database()->UpdateTracker( |
585 remote_file_tracker_->tracker_id(), | 585 remote_file_tracker_->tracker_id(), |
586 file.details(), | 586 file.details(), |
587 base::Bind(&LocalToRemoteSyncer::SyncCompleted, | 587 base::Bind(&LocalToRemoteSyncer::SyncCompleted, |
588 weak_ptr_factory_.GetWeakPtr(), | 588 weak_ptr_factory_.GetWeakPtr(), |
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
639 *entry, | 639 *entry, |
640 base::Bind(&LocalToRemoteSyncer::SyncCompleted, | 640 base::Bind(&LocalToRemoteSyncer::SyncCompleted, |
641 weak_ptr_factory_.GetWeakPtr(), | 641 weak_ptr_factory_.GetWeakPtr(), |
642 base::Passed(&token))); | 642 base::Passed(&token))); |
643 } | 643 } |
644 | 644 |
645 void LocalToRemoteSyncer::UploadNewFile(scoped_ptr<SyncTaskToken> token) { | 645 void LocalToRemoteSyncer::UploadNewFile(scoped_ptr<SyncTaskToken> token) { |
646 DCHECK(remote_parent_folder_tracker_); | 646 DCHECK(remote_parent_folder_tracker_); |
647 | 647 |
648 sync_action_ = SYNC_ACTION_ADDED; | 648 sync_action_ = SYNC_ACTION_ADDED; |
649 base::FilePath title = fileapi::VirtualPath::BaseName(target_path_); | 649 base::FilePath title = storage::VirtualPath::BaseName(target_path_); |
650 drive_uploader()->UploadNewFile( | 650 drive_uploader()->UploadNewFile( |
651 remote_parent_folder_tracker_->file_id(), | 651 remote_parent_folder_tracker_->file_id(), |
652 local_path_, | 652 local_path_, |
653 title.AsUTF8Unsafe(), | 653 title.AsUTF8Unsafe(), |
654 GetMimeTypeFromTitle(title), | 654 GetMimeTypeFromTitle(title), |
655 drive::DriveUploader::UploadNewFileOptions(), | 655 drive::DriveUploader::UploadNewFileOptions(), |
656 base::Bind(&LocalToRemoteSyncer::DidUploadNewFile, | 656 base::Bind(&LocalToRemoteSyncer::DidUploadNewFile, |
657 weak_ptr_factory_.GetWeakPtr(), | 657 weak_ptr_factory_.GetWeakPtr(), |
658 base::Passed(&token)), | 658 base::Passed(&token)), |
659 google_apis::ProgressCallback()); | 659 google_apis::ProgressCallback()); |
(...skipping 23 matching lines...) Expand all Loading... |
683 remote_parent_folder_tracker_->tracker_id(), *entry, | 683 remote_parent_folder_tracker_->tracker_id(), *entry, |
684 base::Bind(&LocalToRemoteSyncer::SyncCompleted, | 684 base::Bind(&LocalToRemoteSyncer::SyncCompleted, |
685 weak_ptr_factory_.GetWeakPtr(), | 685 weak_ptr_factory_.GetWeakPtr(), |
686 base::Passed(&token))); | 686 base::Passed(&token))); |
687 } | 687 } |
688 | 688 |
689 void LocalToRemoteSyncer::CreateRemoteFolder( | 689 void LocalToRemoteSyncer::CreateRemoteFolder( |
690 scoped_ptr<SyncTaskToken> token) { | 690 scoped_ptr<SyncTaskToken> token) { |
691 DCHECK(remote_parent_folder_tracker_); | 691 DCHECK(remote_parent_folder_tracker_); |
692 | 692 |
693 base::FilePath title = fileapi::VirtualPath::BaseName(target_path_); | 693 base::FilePath title = storage::VirtualPath::BaseName(target_path_); |
694 sync_action_ = SYNC_ACTION_ADDED; | 694 sync_action_ = SYNC_ACTION_ADDED; |
695 | 695 |
696 DCHECK(!folder_creator_); | 696 DCHECK(!folder_creator_); |
697 folder_creator_.reset(new FolderCreator( | 697 folder_creator_.reset(new FolderCreator( |
698 drive_service(), metadata_database(), | 698 drive_service(), metadata_database(), |
699 remote_parent_folder_tracker_->file_id(), | 699 remote_parent_folder_tracker_->file_id(), |
700 title.AsUTF8Unsafe())); | 700 title.AsUTF8Unsafe())); |
701 folder_creator_->Run(base::Bind( | 701 folder_creator_->Run(base::Bind( |
702 &LocalToRemoteSyncer::DidCreateRemoteFolder, | 702 &LocalToRemoteSyncer::DidCreateRemoteFolder, |
703 weak_ptr_factory_.GetWeakPtr(), | 703 weak_ptr_factory_.GetWeakPtr(), |
(...skipping 68 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
772 set_used_network(true); | 772 set_used_network(true); |
773 return sync_context_->GetDriveUploader(); | 773 return sync_context_->GetDriveUploader(); |
774 } | 774 } |
775 | 775 |
776 MetadataDatabase* LocalToRemoteSyncer::metadata_database() { | 776 MetadataDatabase* LocalToRemoteSyncer::metadata_database() { |
777 return sync_context_->GetMetadataDatabase(); | 777 return sync_context_->GetMetadataDatabase(); |
778 } | 778 } |
779 | 779 |
780 } // namespace drive_backend | 780 } // namespace drive_backend |
781 } // namespace sync_file_system | 781 } // namespace sync_file_system |
OLD | NEW |