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 "chrome/browser/chromeos/drive/file_system/drive_operations.h" | 5 #include "chrome/browser/chromeos/drive/file_system/drive_operations.h" |
6 | 6 |
7 #include "base/callback.h" | 7 #include "base/callback.h" |
8 #include "chrome/browser/chromeos/drive/file_system/copy_operation.h" | 8 #include "chrome/browser/chromeos/drive/file_system/copy_operation.h" |
9 #include "chrome/browser/chromeos/drive/file_system/create_directory_operation.h
" | 9 #include "chrome/browser/chromeos/drive/file_system/create_directory_operation.h
" |
10 #include "chrome/browser/chromeos/drive/file_system/move_operation.h" | 10 #include "chrome/browser/chromeos/drive/file_system/move_operation.h" |
11 #include "chrome/browser/chromeos/drive/file_system/remove_operation.h" | 11 #include "chrome/browser/chromeos/drive/file_system/remove_operation.h" |
12 #include "chrome/browser/chromeos/drive/file_system/update_operation.h" | 12 #include "chrome/browser/chromeos/drive/file_system/update_operation.h" |
13 #include "content/public/browser/browser_thread.h" | 13 #include "content/public/browser/browser_thread.h" |
14 | 14 |
15 using content::BrowserThread; | 15 using content::BrowserThread; |
16 | 16 |
17 namespace drive { | 17 namespace drive { |
18 namespace file_system { | 18 namespace file_system { |
19 | 19 |
20 DriveOperations::DriveOperations() { | 20 DriveOperations::DriveOperations() { |
21 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 21 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
22 } | 22 } |
23 | 23 |
24 DriveOperations::~DriveOperations() { | 24 DriveOperations::~DriveOperations() { |
25 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 25 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
26 } | 26 } |
27 | 27 |
28 void DriveOperations::Init( | 28 void DriveOperations::Init( |
29 DriveScheduler* drive_scheduler, | 29 JobScheduler* job_scheduler, |
30 DriveFileSystemInterface* drive_file_system, | 30 DriveFileSystemInterface* drive_file_system, |
31 DriveCache* cache, | 31 DriveCache* cache, |
32 DriveResourceMetadata* metadata, | 32 DriveResourceMetadata* metadata, |
33 scoped_refptr<base::SequencedTaskRunner> blocking_task_runner, | 33 scoped_refptr<base::SequencedTaskRunner> blocking_task_runner, |
34 OperationObserver* observer) { | 34 OperationObserver* observer) { |
35 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 35 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
36 | 36 |
37 copy_operation_.reset(new file_system::CopyOperation(drive_scheduler, | 37 copy_operation_.reset(new file_system::CopyOperation(job_scheduler, |
38 drive_file_system, | 38 drive_file_system, |
39 metadata, | 39 metadata, |
40 blocking_task_runner, | 40 blocking_task_runner, |
41 observer)); | 41 observer)); |
42 create_directory_operation_.reset( | 42 create_directory_operation_.reset( |
43 new CreateDirectoryOperation(drive_scheduler, | 43 new CreateDirectoryOperation(job_scheduler, |
44 metadata, | 44 metadata, |
45 observer)); | 45 observer)); |
46 move_operation_.reset(new file_system::MoveOperation(drive_scheduler, | 46 move_operation_.reset(new file_system::MoveOperation(job_scheduler, |
47 metadata, | 47 metadata, |
48 observer)); | 48 observer)); |
49 remove_operation_.reset(new file_system::RemoveOperation(drive_scheduler, | 49 remove_operation_.reset(new file_system::RemoveOperation(job_scheduler, |
50 cache, | 50 cache, |
51 metadata, | 51 metadata, |
52 observer)); | 52 observer)); |
53 update_operation_.reset(new file_system::UpdateOperation(cache, | 53 update_operation_.reset(new file_system::UpdateOperation(cache, |
54 metadata, | 54 metadata, |
55 drive_scheduler, | 55 job_scheduler, |
56 blocking_task_runner, | 56 blocking_task_runner, |
57 observer)); | 57 observer)); |
58 } | 58 } |
59 | 59 |
60 void DriveOperations::InitForTesting(CopyOperation* copy_operation, | 60 void DriveOperations::InitForTesting(CopyOperation* copy_operation, |
61 MoveOperation* move_operation, | 61 MoveOperation* move_operation, |
62 RemoveOperation* remove_operation, | 62 RemoveOperation* remove_operation, |
63 UpdateOperation* update_operation) { | 63 UpdateOperation* update_operation) { |
64 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 64 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
65 | 65 |
(...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
149 DriveClientContext context, | 149 DriveClientContext context, |
150 const FileOperationCallback& callback) { | 150 const FileOperationCallback& callback) { |
151 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 151 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
152 DCHECK(!callback.is_null()); | 152 DCHECK(!callback.is_null()); |
153 | 153 |
154 update_operation_->UpdateFileByResourceId(resource_id, context, callback); | 154 update_operation_->UpdateFileByResourceId(resource_id, context, callback); |
155 } | 155 } |
156 | 156 |
157 } // namespace file_system | 157 } // namespace file_system |
158 } // namespace drive | 158 } // namespace drive |
OLD | NEW |