OLD | NEW |
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/drive_service_on_worker.
h" | 5 #include "chrome/browser/sync_file_system/drive_backend/drive_service_on_worker.
h" |
6 | 6 |
7 #include <string> | 7 #include <string> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/logging.h" | 10 #include "base/logging.h" |
(...skipping 26 matching lines...) Expand all Loading... |
37 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); | 37 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); |
38 | 38 |
39 ui_task_runner_->PostTask( | 39 ui_task_runner_->PostTask( |
40 FROM_HERE, | 40 FROM_HERE, |
41 base::Bind(&DriveServiceWrapper::AddNewDirectory, | 41 base::Bind(&DriveServiceWrapper::AddNewDirectory, |
42 wrapper_, | 42 wrapper_, |
43 parent_resource_id, | 43 parent_resource_id, |
44 directory_title, | 44 directory_title, |
45 options, | 45 options, |
46 RelayCallbackToTaskRunner( | 46 RelayCallbackToTaskRunner( |
47 worker_task_runner_, | 47 worker_task_runner_.get(), FROM_HERE, callback))); |
48 FROM_HERE, | |
49 callback))); | |
50 | 48 |
51 return google_apis::CancelCallback(); | 49 return google_apis::CancelCallback(); |
52 } | 50 } |
53 | 51 |
54 google_apis::CancelCallback DriveServiceOnWorker::DeleteResource( | 52 google_apis::CancelCallback DriveServiceOnWorker::DeleteResource( |
55 const std::string& resource_id, | 53 const std::string& resource_id, |
56 const std::string& etag, | 54 const std::string& etag, |
57 const google_apis::EntryActionCallback& callback) { | 55 const google_apis::EntryActionCallback& callback) { |
58 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); | 56 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); |
59 | 57 |
60 ui_task_runner_->PostTask( | 58 ui_task_runner_->PostTask( |
61 FROM_HERE, | 59 FROM_HERE, |
62 base::Bind(&DriveServiceWrapper::DeleteResource, | 60 base::Bind(&DriveServiceWrapper::DeleteResource, |
63 wrapper_, | 61 wrapper_, |
64 resource_id, | 62 resource_id, |
65 etag, | 63 etag, |
66 RelayCallbackToTaskRunner( | 64 RelayCallbackToTaskRunner( |
67 worker_task_runner_, | 65 worker_task_runner_.get(), FROM_HERE, callback))); |
68 FROM_HERE, | |
69 callback))); | |
70 | 66 |
71 return google_apis::CancelCallback(); | 67 return google_apis::CancelCallback(); |
72 } | 68 } |
73 | 69 |
74 google_apis::CancelCallback DriveServiceOnWorker::DownloadFile( | 70 google_apis::CancelCallback DriveServiceOnWorker::DownloadFile( |
75 const base::FilePath& local_cache_path, | 71 const base::FilePath& local_cache_path, |
76 const std::string& resource_id, | 72 const std::string& resource_id, |
77 const google_apis::DownloadActionCallback& download_action_callback, | 73 const google_apis::DownloadActionCallback& download_action_callback, |
78 const google_apis::GetContentCallback& get_content_callback, | 74 const google_apis::GetContentCallback& get_content_callback, |
79 const google_apis::ProgressCallback& progress_callback) { | 75 const google_apis::ProgressCallback& progress_callback) { |
80 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); | 76 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); |
81 | 77 |
82 ui_task_runner_->PostTask( | 78 ui_task_runner_->PostTask( |
83 FROM_HERE, | 79 FROM_HERE, |
84 base::Bind(&DriveServiceWrapper::DownloadFile, | 80 base::Bind( |
85 wrapper_, | 81 &DriveServiceWrapper::DownloadFile, |
86 local_cache_path, | 82 wrapper_, |
87 resource_id, | 83 local_cache_path, |
88 RelayCallbackToTaskRunner( | 84 resource_id, |
89 worker_task_runner_, | 85 RelayCallbackToTaskRunner( |
90 FROM_HERE, | 86 worker_task_runner_.get(), FROM_HERE, download_action_callback), |
91 download_action_callback), | 87 RelayCallbackToTaskRunner( |
92 RelayCallbackToTaskRunner( | 88 worker_task_runner_.get(), FROM_HERE, get_content_callback), |
93 worker_task_runner_, | 89 RelayCallbackToTaskRunner( |
94 FROM_HERE, | 90 worker_task_runner_.get(), FROM_HERE, progress_callback))); |
95 get_content_callback), | |
96 RelayCallbackToTaskRunner( | |
97 worker_task_runner_, | |
98 FROM_HERE, | |
99 progress_callback))); | |
100 | 91 |
101 return google_apis::CancelCallback(); | 92 return google_apis::CancelCallback(); |
102 } | 93 } |
103 | 94 |
104 google_apis::CancelCallback DriveServiceOnWorker::GetAboutResource( | 95 google_apis::CancelCallback DriveServiceOnWorker::GetAboutResource( |
105 const google_apis::AboutResourceCallback& callback) { | 96 const google_apis::AboutResourceCallback& callback) { |
106 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); | 97 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); |
107 | 98 |
108 ui_task_runner_->PostTask( | 99 ui_task_runner_->PostTask( |
109 FROM_HERE, | 100 FROM_HERE, |
110 base::Bind(&DriveServiceWrapper::GetAboutResource, | 101 base::Bind(&DriveServiceWrapper::GetAboutResource, |
111 wrapper_, | 102 wrapper_, |
112 RelayCallbackToTaskRunner( | 103 RelayCallbackToTaskRunner( |
113 worker_task_runner_, | 104 worker_task_runner_.get(), FROM_HERE, callback))); |
114 FROM_HERE, | |
115 callback))); | |
116 | 105 |
117 return google_apis::CancelCallback(); | 106 return google_apis::CancelCallback(); |
118 } | 107 } |
119 | 108 |
120 google_apis::CancelCallback DriveServiceOnWorker::GetChangeList( | 109 google_apis::CancelCallback DriveServiceOnWorker::GetChangeList( |
121 int64 start_changestamp, | 110 int64 start_changestamp, |
122 const google_apis::ChangeListCallback& callback) { | 111 const google_apis::ChangeListCallback& callback) { |
123 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); | 112 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); |
124 | 113 |
125 ui_task_runner_->PostTask( | 114 ui_task_runner_->PostTask( |
126 FROM_HERE, | 115 FROM_HERE, |
127 base::Bind(&DriveServiceWrapper::GetChangeList, | 116 base::Bind(&DriveServiceWrapper::GetChangeList, |
128 wrapper_, | 117 wrapper_, |
129 start_changestamp, | 118 start_changestamp, |
130 RelayCallbackToTaskRunner( | 119 RelayCallbackToTaskRunner( |
131 worker_task_runner_, | 120 worker_task_runner_.get(), FROM_HERE, callback))); |
132 FROM_HERE, | |
133 callback))); | |
134 | 121 |
135 return google_apis::CancelCallback(); | 122 return google_apis::CancelCallback(); |
136 } | 123 } |
137 | 124 |
138 google_apis::CancelCallback DriveServiceOnWorker::GetRemainingChangeList( | 125 google_apis::CancelCallback DriveServiceOnWorker::GetRemainingChangeList( |
139 const GURL& next_link, | 126 const GURL& next_link, |
140 const google_apis::ChangeListCallback& callback) { | 127 const google_apis::ChangeListCallback& callback) { |
141 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); | 128 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); |
142 | 129 |
143 ui_task_runner_->PostTask( | 130 ui_task_runner_->PostTask( |
144 FROM_HERE, | 131 FROM_HERE, |
145 base::Bind(&DriveServiceWrapper::GetRemainingChangeList, | 132 base::Bind(&DriveServiceWrapper::GetRemainingChangeList, |
146 wrapper_, | 133 wrapper_, |
147 next_link, | 134 next_link, |
148 RelayCallbackToTaskRunner( | 135 RelayCallbackToTaskRunner( |
149 worker_task_runner_, | 136 worker_task_runner_.get(), FROM_HERE, callback))); |
150 FROM_HERE, | |
151 callback))); | |
152 | 137 |
153 return google_apis::CancelCallback(); | 138 return google_apis::CancelCallback(); |
154 } | 139 } |
155 | 140 |
156 std::string DriveServiceOnWorker::GetRootResourceId() const { | 141 std::string DriveServiceOnWorker::GetRootResourceId() const { |
157 NOTREACHED(); | 142 NOTREACHED(); |
158 // This method is expected to be called only on unit tests. | 143 // This method is expected to be called only on unit tests. |
159 return "root"; | 144 return "root"; |
160 } | 145 } |
161 | 146 |
162 google_apis::CancelCallback DriveServiceOnWorker::GetRemainingFileList( | 147 google_apis::CancelCallback DriveServiceOnWorker::GetRemainingFileList( |
163 const GURL& next_link, | 148 const GURL& next_link, |
164 const google_apis::FileListCallback& callback) { | 149 const google_apis::FileListCallback& callback) { |
165 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); | 150 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); |
166 | 151 |
167 ui_task_runner_->PostTask( | 152 ui_task_runner_->PostTask( |
168 FROM_HERE, | 153 FROM_HERE, |
169 base::Bind(&DriveServiceWrapper::GetRemainingFileList, | 154 base::Bind(&DriveServiceWrapper::GetRemainingFileList, |
170 wrapper_, | 155 wrapper_, |
171 next_link, | 156 next_link, |
172 RelayCallbackToTaskRunner( | 157 RelayCallbackToTaskRunner( |
173 worker_task_runner_, | 158 worker_task_runner_.get(), FROM_HERE, callback))); |
174 FROM_HERE, | |
175 callback))); | |
176 | 159 |
177 return google_apis::CancelCallback(); | 160 return google_apis::CancelCallback(); |
178 } | 161 } |
179 | 162 |
180 | 163 |
181 google_apis::CancelCallback DriveServiceOnWorker::GetFileResource( | 164 google_apis::CancelCallback DriveServiceOnWorker::GetFileResource( |
182 const std::string& resource_id, | 165 const std::string& resource_id, |
183 const google_apis::FileResourceCallback& callback) { | 166 const google_apis::FileResourceCallback& callback) { |
184 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); | 167 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); |
185 | 168 |
186 ui_task_runner_->PostTask( | 169 ui_task_runner_->PostTask( |
187 FROM_HERE, | 170 FROM_HERE, |
188 base::Bind(&DriveServiceWrapper::GetFileResource, | 171 base::Bind(&DriveServiceWrapper::GetFileResource, |
189 wrapper_, | 172 wrapper_, |
190 resource_id, | 173 resource_id, |
191 RelayCallbackToTaskRunner( | 174 RelayCallbackToTaskRunner( |
192 worker_task_runner_, | 175 worker_task_runner_.get(), FROM_HERE, callback))); |
193 FROM_HERE, | |
194 callback))); | |
195 | 176 |
196 return google_apis::CancelCallback(); | 177 return google_apis::CancelCallback(); |
197 } | 178 } |
198 | 179 |
199 google_apis::CancelCallback DriveServiceOnWorker::GetFileListInDirectory( | 180 google_apis::CancelCallback DriveServiceOnWorker::GetFileListInDirectory( |
200 const std::string& directory_resource_id, | 181 const std::string& directory_resource_id, |
201 const google_apis::FileListCallback& callback) { | 182 const google_apis::FileListCallback& callback) { |
202 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); | 183 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); |
203 | 184 |
204 ui_task_runner_->PostTask( | 185 ui_task_runner_->PostTask( |
205 FROM_HERE, | 186 FROM_HERE, |
206 base::Bind(&DriveServiceWrapper::GetFileListInDirectory, | 187 base::Bind(&DriveServiceWrapper::GetFileListInDirectory, |
207 wrapper_, | 188 wrapper_, |
208 directory_resource_id, | 189 directory_resource_id, |
209 RelayCallbackToTaskRunner( | 190 RelayCallbackToTaskRunner( |
210 worker_task_runner_, | 191 worker_task_runner_.get(), FROM_HERE, callback))); |
211 FROM_HERE, | |
212 callback))); | |
213 | 192 |
214 return google_apis::CancelCallback(); | 193 return google_apis::CancelCallback(); |
215 } | 194 } |
216 | 195 |
217 google_apis::CancelCallback DriveServiceOnWorker::RemoveResourceFromDirectory( | 196 google_apis::CancelCallback DriveServiceOnWorker::RemoveResourceFromDirectory( |
218 const std::string& parent_resource_id, | 197 const std::string& parent_resource_id, |
219 const std::string& resource_id, | 198 const std::string& resource_id, |
220 const google_apis::EntryActionCallback& callback) { | 199 const google_apis::EntryActionCallback& callback) { |
221 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); | 200 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); |
222 | 201 |
223 ui_task_runner_->PostTask( | 202 ui_task_runner_->PostTask( |
224 FROM_HERE, | 203 FROM_HERE, |
225 base::Bind(&DriveServiceWrapper::RemoveResourceFromDirectory, | 204 base::Bind(&DriveServiceWrapper::RemoveResourceFromDirectory, |
226 wrapper_, | 205 wrapper_, |
227 parent_resource_id, | 206 parent_resource_id, |
228 resource_id, | 207 resource_id, |
229 RelayCallbackToTaskRunner( | 208 RelayCallbackToTaskRunner( |
230 worker_task_runner_, | 209 worker_task_runner_.get(), FROM_HERE, callback))); |
231 FROM_HERE, | |
232 callback))); | |
233 | 210 |
234 return google_apis::CancelCallback(); | 211 return google_apis::CancelCallback(); |
235 } | 212 } |
236 | 213 |
237 google_apis::CancelCallback DriveServiceOnWorker::SearchByTitle( | 214 google_apis::CancelCallback DriveServiceOnWorker::SearchByTitle( |
238 const std::string& title, | 215 const std::string& title, |
239 const std::string& directory_resource_id, | 216 const std::string& directory_resource_id, |
240 const google_apis::FileListCallback& callback) { | 217 const google_apis::FileListCallback& callback) { |
241 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); | 218 DCHECK(sequence_checker_.CalledOnValidSequencedThread()); |
242 | 219 |
243 ui_task_runner_->PostTask( | 220 ui_task_runner_->PostTask( |
244 FROM_HERE, | 221 FROM_HERE, |
245 base::Bind(&DriveServiceWrapper::SearchByTitle, | 222 base::Bind(&DriveServiceWrapper::SearchByTitle, |
246 wrapper_, | 223 wrapper_, |
247 title, | 224 title, |
248 directory_resource_id, | 225 directory_resource_id, |
249 RelayCallbackToTaskRunner( | 226 RelayCallbackToTaskRunner( |
250 worker_task_runner_, | 227 worker_task_runner_.get(), FROM_HERE, callback))); |
251 FROM_HERE, | |
252 callback))); | |
253 | 228 |
254 return google_apis::CancelCallback(); | 229 return google_apis::CancelCallback(); |
255 } | 230 } |
256 | 231 |
257 bool DriveServiceOnWorker::HasRefreshToken() const { | 232 bool DriveServiceOnWorker::HasRefreshToken() const { |
258 NOTREACHED(); | 233 NOTREACHED(); |
259 return false; | 234 return false; |
260 } | 235 } |
261 | 236 |
262 void DriveServiceOnWorker::Initialize(const std::string& account_id) { | 237 void DriveServiceOnWorker::Initialize(const std::string& account_id) { |
(...skipping 156 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
419 const std::string& resource_id, | 394 const std::string& resource_id, |
420 const std::string& email, | 395 const std::string& email, |
421 google_apis::drive::PermissionRole role, | 396 google_apis::drive::PermissionRole role, |
422 const google_apis::EntryActionCallback& callback) { | 397 const google_apis::EntryActionCallback& callback) { |
423 NOTREACHED(); | 398 NOTREACHED(); |
424 return google_apis::CancelCallback(); | 399 return google_apis::CancelCallback(); |
425 } | 400 } |
426 | 401 |
427 } // namespace drive_backend | 402 } // namespace drive_backend |
428 } // namespace sync_file_system | 403 } // namespace sync_file_system |
OLD | NEW |