Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(75)

Side by Side Diff: chrome/browser/sync_file_system/drive_backend/fake_sync_worker.cc

Issue 2189113002: Rename CalledOnValidSequencedThread() to CalledOnValidSequence(). (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 4 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 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/fake_sync_worker.h" 5 #include "chrome/browser/sync_file_system/drive_backend/fake_sync_worker.h"
6 6
7 #include <utility> 7 #include <utility>
8 8
9 #include "base/values.h" 9 #include "base/values.h"
10 #include "chrome/browser/sync_file_system/drive_backend/drive_backend_constants. h" 10 #include "chrome/browser/sync_file_system/drive_backend/drive_backend_constants. h"
11 #include "chrome/browser/sync_file_system/drive_backend/sync_engine_context.h" 11 #include "chrome/browser/sync_file_system/drive_backend/sync_engine_context.h"
12 #include "chrome/browser/sync_file_system/sync_status_code.h" 12 #include "chrome/browser/sync_file_system/sync_status_code.h"
13 13
14 namespace sync_file_system { 14 namespace sync_file_system {
15 namespace drive_backend { 15 namespace drive_backend {
16 16
17 FakeSyncWorker::FakeSyncWorker() 17 FakeSyncWorker::FakeSyncWorker()
18 : sync_enabled_(true) { 18 : sync_enabled_(true) {
19 sequence_checker_.DetachFromSequence(); 19 sequence_checker_.DetachFromSequence();
20 } 20 }
21 21
22 FakeSyncWorker::~FakeSyncWorker() { 22 FakeSyncWorker::~FakeSyncWorker() {
23 observers_.Clear(); 23 observers_.Clear();
24 } 24 }
25 25
26 void FakeSyncWorker::Initialize( 26 void FakeSyncWorker::Initialize(
27 std::unique_ptr<SyncEngineContext> sync_engine_context) { 27 std::unique_ptr<SyncEngineContext> sync_engine_context) {
28 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 28 DCHECK(sequence_checker_.CalledOnValidSequence());
29 29
30 sync_engine_context_ = std::move(sync_engine_context); 30 sync_engine_context_ = std::move(sync_engine_context);
31 status_map_.clear(); 31 status_map_.clear();
32 // TODO(peria): Set |status_map_| as a fake metadata database. 32 // TODO(peria): Set |status_map_| as a fake metadata database.
33 } 33 }
34 34
35 void FakeSyncWorker::RegisterOrigin(const GURL& origin, 35 void FakeSyncWorker::RegisterOrigin(const GURL& origin,
36 const SyncStatusCallback& callback) { 36 const SyncStatusCallback& callback) {
37 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 37 DCHECK(sequence_checker_.CalledOnValidSequence());
38 // TODO(peria): Check how it should act on installing installed app? 38 // TODO(peria): Check how it should act on installing installed app?
39 status_map_[origin] = REGISTERED; 39 status_map_[origin] = REGISTERED;
40 callback.Run(SYNC_STATUS_OK); 40 callback.Run(SYNC_STATUS_OK);
41 } 41 }
42 42
43 void FakeSyncWorker::EnableOrigin(const GURL& origin, 43 void FakeSyncWorker::EnableOrigin(const GURL& origin,
44 const SyncStatusCallback& callback) { 44 const SyncStatusCallback& callback) {
45 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 45 DCHECK(sequence_checker_.CalledOnValidSequence());
46 // TODO(peria): Check how it should act on enabling non-installed app? 46 // TODO(peria): Check how it should act on enabling non-installed app?
47 status_map_[origin] = ENABLED; 47 status_map_[origin] = ENABLED;
48 callback.Run(SYNC_STATUS_OK); 48 callback.Run(SYNC_STATUS_OK);
49 } 49 }
50 50
51 void FakeSyncWorker::DisableOrigin(const GURL& origin, 51 void FakeSyncWorker::DisableOrigin(const GURL& origin,
52 const SyncStatusCallback& callback) { 52 const SyncStatusCallback& callback) {
53 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 53 DCHECK(sequence_checker_.CalledOnValidSequence());
54 // TODO(peria): Check how it should act on disabling non-installed app? 54 // TODO(peria): Check how it should act on disabling non-installed app?
55 status_map_[origin] = DISABLED; 55 status_map_[origin] = DISABLED;
56 callback.Run(SYNC_STATUS_OK); 56 callback.Run(SYNC_STATUS_OK);
57 } 57 }
58 58
59 void FakeSyncWorker::UninstallOrigin(const GURL& origin, 59 void FakeSyncWorker::UninstallOrigin(const GURL& origin,
60 RemoteFileSyncService::UninstallFlag flag, 60 RemoteFileSyncService::UninstallFlag flag,
61 const SyncStatusCallback& callback) { 61 const SyncStatusCallback& callback) {
62 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 62 DCHECK(sequence_checker_.CalledOnValidSequence());
63 // TODO(peria): Check how it should act on uninstalling non-installed app? 63 // TODO(peria): Check how it should act on uninstalling non-installed app?
64 status_map_[origin] = UNINSTALLED; 64 status_map_[origin] = UNINSTALLED;
65 callback.Run(SYNC_STATUS_OK); 65 callback.Run(SYNC_STATUS_OK);
66 } 66 }
67 67
68 void FakeSyncWorker::ProcessRemoteChange( 68 void FakeSyncWorker::ProcessRemoteChange(
69 const SyncFileCallback& callback) { 69 const SyncFileCallback& callback) {
70 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 70 DCHECK(sequence_checker_.CalledOnValidSequence());
71 callback.Run(SYNC_STATUS_OK, storage::FileSystemURL()); 71 callback.Run(SYNC_STATUS_OK, storage::FileSystemURL());
72 } 72 }
73 73
74 void FakeSyncWorker::SetRemoteChangeProcessor( 74 void FakeSyncWorker::SetRemoteChangeProcessor(
75 RemoteChangeProcessorOnWorker* remote_change_processor_on_worker) { 75 RemoteChangeProcessorOnWorker* remote_change_processor_on_worker) {
76 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 76 DCHECK(sequence_checker_.CalledOnValidSequence());
77 } 77 }
78 78
79 RemoteServiceState FakeSyncWorker::GetCurrentState() const { 79 RemoteServiceState FakeSyncWorker::GetCurrentState() const {
80 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 80 DCHECK(sequence_checker_.CalledOnValidSequence());
81 return REMOTE_SERVICE_OK; 81 return REMOTE_SERVICE_OK;
82 } 82 }
83 83
84 void FakeSyncWorker::GetOriginStatusMap( 84 void FakeSyncWorker::GetOriginStatusMap(
85 const RemoteFileSyncService::StatusMapCallback& callback) { 85 const RemoteFileSyncService::StatusMapCallback& callback) {
86 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 86 DCHECK(sequence_checker_.CalledOnValidSequence());
87 87
88 std::unique_ptr<RemoteFileSyncService::OriginStatusMap> status_map( 88 std::unique_ptr<RemoteFileSyncService::OriginStatusMap> status_map(
89 new RemoteFileSyncService::OriginStatusMap); 89 new RemoteFileSyncService::OriginStatusMap);
90 for (StatusMap::const_iterator itr = status_map_.begin(); 90 for (StatusMap::const_iterator itr = status_map_.begin();
91 itr != status_map_.end(); ++itr) { 91 itr != status_map_.end(); ++itr) {
92 switch (itr->second) { 92 switch (itr->second) {
93 case REGISTERED: 93 case REGISTERED:
94 (*status_map)[itr->first] = "Registered"; 94 (*status_map)[itr->first] = "Registered";
95 break; 95 break;
96 case ENABLED: 96 case ENABLED:
97 (*status_map)[itr->first] = "Enabled"; 97 (*status_map)[itr->first] = "Enabled";
98 break; 98 break;
99 case DISABLED: 99 case DISABLED:
100 (*status_map)[itr->first] = "Disabled"; 100 (*status_map)[itr->first] = "Disabled";
101 break; 101 break;
102 case UNINSTALLED: 102 case UNINSTALLED:
103 (*status_map)[itr->first] = "Uninstalled"; 103 (*status_map)[itr->first] = "Uninstalled";
104 break; 104 break;
105 default: 105 default:
106 (*status_map)[itr->first] = "Unknown"; 106 (*status_map)[itr->first] = "Unknown";
107 break; 107 break;
108 } 108 }
109 } 109 }
110 callback.Run(std::move(status_map)); 110 callback.Run(std::move(status_map));
111 } 111 }
112 112
113 std::unique_ptr<base::ListValue> FakeSyncWorker::DumpFiles(const GURL& origin) { 113 std::unique_ptr<base::ListValue> FakeSyncWorker::DumpFiles(const GURL& origin) {
114 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 114 DCHECK(sequence_checker_.CalledOnValidSequence());
115 return nullptr; 115 return nullptr;
116 } 116 }
117 117
118 std::unique_ptr<base::ListValue> FakeSyncWorker::DumpDatabase() { 118 std::unique_ptr<base::ListValue> FakeSyncWorker::DumpDatabase() {
119 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 119 DCHECK(sequence_checker_.CalledOnValidSequence());
120 return nullptr; 120 return nullptr;
121 } 121 }
122 122
123 void FakeSyncWorker::SetSyncEnabled(bool enabled) { 123 void FakeSyncWorker::SetSyncEnabled(bool enabled) {
124 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 124 DCHECK(sequence_checker_.CalledOnValidSequence());
125 sync_enabled_ = enabled; 125 sync_enabled_ = enabled;
126 126
127 if (enabled) 127 if (enabled)
128 UpdateServiceState(REMOTE_SERVICE_OK, "Set FakeSyncWorker enabled."); 128 UpdateServiceState(REMOTE_SERVICE_OK, "Set FakeSyncWorker enabled.");
129 else 129 else
130 UpdateServiceState(REMOTE_SERVICE_DISABLED, "Disabled FakeSyncWorker."); 130 UpdateServiceState(REMOTE_SERVICE_DISABLED, "Disabled FakeSyncWorker.");
131 } 131 }
132 132
133 void FakeSyncWorker::PromoteDemotedChanges(const base::Closure& callback) { 133 void FakeSyncWorker::PromoteDemotedChanges(const base::Closure& callback) {
134 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 134 DCHECK(sequence_checker_.CalledOnValidSequence());
135 FOR_EACH_OBSERVER( 135 FOR_EACH_OBSERVER(
136 Observer, 136 Observer,
137 observers_, 137 observers_,
138 OnPendingFileListUpdated(10)); 138 OnPendingFileListUpdated(10));
139 callback.Run(); 139 callback.Run();
140 } 140 }
141 141
142 void FakeSyncWorker::ApplyLocalChange(const FileChange& local_change, 142 void FakeSyncWorker::ApplyLocalChange(const FileChange& local_change,
143 const base::FilePath& local_path, 143 const base::FilePath& local_path,
144 const SyncFileMetadata& local_metadata, 144 const SyncFileMetadata& local_metadata,
145 const storage::FileSystemURL& url, 145 const storage::FileSystemURL& url,
146 const SyncStatusCallback& callback) { 146 const SyncStatusCallback& callback) {
147 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 147 DCHECK(sequence_checker_.CalledOnValidSequence());
148 callback.Run(SYNC_STATUS_OK); 148 callback.Run(SYNC_STATUS_OK);
149 } 149 }
150 150
151 void FakeSyncWorker::ActivateService(RemoteServiceState service_state, 151 void FakeSyncWorker::ActivateService(RemoteServiceState service_state,
152 const std::string& description) { 152 const std::string& description) {
153 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 153 DCHECK(sequence_checker_.CalledOnValidSequence());
154 UpdateServiceState(service_state, description); 154 UpdateServiceState(service_state, description);
155 } 155 }
156 156
157 void FakeSyncWorker::DeactivateService(const std::string& description) { 157 void FakeSyncWorker::DeactivateService(const std::string& description) {
158 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 158 DCHECK(sequence_checker_.CalledOnValidSequence());
159 UpdateServiceState(REMOTE_SERVICE_TEMPORARY_UNAVAILABLE, description); 159 UpdateServiceState(REMOTE_SERVICE_TEMPORARY_UNAVAILABLE, description);
160 } 160 }
161 161
162 void FakeSyncWorker::DetachFromSequence() { 162 void FakeSyncWorker::DetachFromSequence() {
163 sequence_checker_.DetachFromSequence(); 163 sequence_checker_.DetachFromSequence();
164 } 164 }
165 165
166 void FakeSyncWorker::AddObserver(Observer* observer) { 166 void FakeSyncWorker::AddObserver(Observer* observer) {
167 // This method is called on UI thread. 167 // This method is called on UI thread.
168 observers_.AddObserver(observer); 168 observers_.AddObserver(observer);
169 } 169 }
170 170
171 void FakeSyncWorker::UpdateServiceState(RemoteServiceState state, 171 void FakeSyncWorker::UpdateServiceState(RemoteServiceState state,
172 const std::string& description) { 172 const std::string& description) {
173 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); 173 DCHECK(sequence_checker_.CalledOnValidSequence());
174 174
175 FOR_EACH_OBSERVER( 175 FOR_EACH_OBSERVER(
176 Observer, observers_, 176 Observer, observers_,
177 UpdateServiceState(state, description)); 177 UpdateServiceState(state, description));
178 } 178 }
179 179
180 } // namespace drive_backend 180 } // namespace drive_backend
181 } // namespace sync_file_system 181 } // namespace sync_file_system
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698