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 "components/drive/job_scheduler.h" | 5 #include "components/drive/job_scheduler.h" |
6 | 6 |
7 #include <stddef.h> | 7 #include <stddef.h> |
8 #include <algorithm> | 8 #include <algorithm> |
9 #include <utility> | 9 #include <utility> |
10 | 10 |
(...skipping 299 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
310 base::Bind(&JobScheduler::OnGetFileListJobDone, | 310 base::Bind(&JobScheduler::OnGetFileListJobDone, |
311 weak_ptr_factory_.GetWeakPtr(), | 311 weak_ptr_factory_.GetWeakPtr(), |
312 new_job->job_info.job_id, | 312 new_job->job_info.job_id, |
313 callback)); | 313 callback)); |
314 new_job->abort_callback = CreateErrorRunCallback(callback); | 314 new_job->abort_callback = CreateErrorRunCallback(callback); |
315 StartJob(new_job); | 315 StartJob(new_job); |
316 } | 316 } |
317 | 317 |
318 void JobScheduler::GetFileListInDirectory( | 318 void JobScheduler::GetFileListInDirectory( |
319 const std::string& directory_resource_id, | 319 const std::string& directory_resource_id, |
| 320 const std::string& team_drive_id, |
320 const google_apis::FileListCallback& callback) { | 321 const google_apis::FileListCallback& callback) { |
321 DCHECK(thread_checker_.CalledOnValidThread()); | 322 DCHECK(thread_checker_.CalledOnValidThread()); |
322 DCHECK(!callback.is_null()); | 323 DCHECK(!callback.is_null()); |
323 | 324 |
324 JobEntry* new_job = CreateNewJob( | 325 JobEntry* new_job = CreateNewJob( |
325 TYPE_GET_RESOURCE_LIST_IN_DIRECTORY); | 326 TYPE_GET_RESOURCE_LIST_IN_DIRECTORY); |
326 new_job->task = base::Bind( | 327 new_job->task = base::Bind(&DriveServiceInterface::GetFileListInDirectory, |
327 &DriveServiceInterface::GetFileListInDirectory, | 328 base::Unretained(drive_service_), |
328 base::Unretained(drive_service_), | 329 directory_resource_id, team_drive_id, |
329 directory_resource_id, | 330 base::Bind(&JobScheduler::OnGetFileListJobDone, |
330 base::Bind(&JobScheduler::OnGetFileListJobDone, | 331 weak_ptr_factory_.GetWeakPtr(), |
331 weak_ptr_factory_.GetWeakPtr(), | 332 new_job->job_info.job_id, callback)); |
332 new_job->job_info.job_id, | |
333 callback)); | |
334 new_job->abort_callback = CreateErrorRunCallback(callback); | 333 new_job->abort_callback = CreateErrorRunCallback(callback); |
335 StartJob(new_job); | 334 StartJob(new_job); |
336 } | 335 } |
337 | 336 |
338 void JobScheduler::Search(const std::string& search_query, | 337 void JobScheduler::Search(const std::string& search_query, |
339 const google_apis::FileListCallback& callback) { | 338 const google_apis::FileListCallback& callback) { |
340 DCHECK(thread_checker_.CalledOnValidThread()); | 339 DCHECK(thread_checker_.CalledOnValidThread()); |
341 DCHECK(!callback.is_null()); | 340 DCHECK(!callback.is_null()); |
342 | 341 |
343 JobEntry* new_job = CreateNewJob(TYPE_SEARCH); | 342 JobEntry* new_job = CreateNewJob(TYPE_SEARCH); |
(...skipping 893 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1237 case FILE_QUEUE: | 1236 case FILE_QUEUE: |
1238 return "FILE_QUEUE"; | 1237 return "FILE_QUEUE"; |
1239 case NUM_QUEUES: | 1238 case NUM_QUEUES: |
1240 break; // This value is just a sentinel. Should never be used. | 1239 break; // This value is just a sentinel. Should never be used. |
1241 } | 1240 } |
1242 NOTREACHED(); | 1241 NOTREACHED(); |
1243 return ""; | 1242 return ""; |
1244 } | 1243 } |
1245 | 1244 |
1246 } // namespace drive | 1245 } // namespace drive |
OLD | NEW |