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 "base/lazy_instance.h" | 5 #include "base/lazy_instance.h" |
6 #include "chrome/browser/browser_process.h" | 6 #include "chrome/browser/browser_process.h" |
7 #include "chrome/browser/chrome_notification_types.h" | 7 #include "chrome/browser/chrome_notification_types.h" |
8 #include "chrome/browser/extensions/api/image_writer_private/destroy_partitions_
operation.h" | 8 #include "chrome/browser/extensions/api/image_writer_private/destroy_partitions_
operation.h" |
9 #include "chrome/browser/extensions/api/image_writer_private/error_messages.h" | 9 #include "chrome/browser/extensions/api/image_writer_private/error_messages.h" |
10 #include "chrome/browser/extensions/api/image_writer_private/operation.h" | 10 #include "chrome/browser/extensions/api/image_writer_private/operation.h" |
(...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
52 BrowserThread::PostTask(BrowserThread::FILE, | 52 BrowserThread::PostTask(BrowserThread::FILE, |
53 FROM_HERE, | 53 FROM_HERE, |
54 base::Bind(&Operation::Abort, | 54 base::Bind(&Operation::Abort, |
55 iter->second)); | 55 iter->second)); |
56 } | 56 } |
57 } | 57 } |
58 | 58 |
59 void OperationManager::StartWriteFromUrl( | 59 void OperationManager::StartWriteFromUrl( |
60 const ExtensionId& extension_id, | 60 const ExtensionId& extension_id, |
61 GURL url, | 61 GURL url, |
62 content::RenderViewHost* rvh, | |
63 const std::string& hash, | 62 const std::string& hash, |
64 bool saveImageAsDownload, | 63 bool saveImageAsDownload, |
65 const std::string& storage_unit_id, | 64 const std::string& device_path, |
66 const Operation::StartWriteCallback& callback) { | 65 const Operation::StartWriteCallback& callback) { |
67 OperationMap::iterator existing_operation = operations_.find(extension_id); | 66 OperationMap::iterator existing_operation = operations_.find(extension_id); |
68 | 67 |
69 if (existing_operation != operations_.end()) { | 68 if (existing_operation != operations_.end()) { |
70 return callback.Run(false, error::kOperationAlreadyInProgress); | 69 return callback.Run(false, error::kOperationAlreadyInProgress); |
71 } | 70 } |
72 | 71 |
73 scoped_refptr<Operation> operation( | 72 scoped_refptr<Operation> operation( |
74 new WriteFromUrlOperation(weak_factory_.GetWeakPtr(), | 73 new WriteFromUrlOperation(weak_factory_.GetWeakPtr(), |
75 extension_id, | 74 extension_id, |
76 rvh, | 75 profile_->GetRequestContext(), |
77 url, | 76 url, |
78 hash, | 77 hash, |
79 saveImageAsDownload, | 78 saveImageAsDownload, |
80 storage_unit_id)); | 79 device_path)); |
81 operations_[extension_id] = operation; | 80 operations_[extension_id] = operation; |
82 BrowserThread::PostTask(BrowserThread::FILE, | 81 BrowserThread::PostTask(BrowserThread::FILE, |
83 FROM_HERE, | 82 FROM_HERE, |
84 base::Bind(&Operation::Start, operation)); | 83 base::Bind(&Operation::Start, operation)); |
85 callback.Run(true, ""); | 84 callback.Run(true, ""); |
86 } | 85 } |
87 | 86 |
88 void OperationManager::StartWriteFromFile( | 87 void OperationManager::StartWriteFromFile( |
89 const ExtensionId& extension_id, | 88 const ExtensionId& extension_id, |
90 const base::FilePath& path, | 89 const base::FilePath& path, |
91 const std::string& storage_unit_id, | 90 const std::string& device_path, |
92 const Operation::StartWriteCallback& callback) { | 91 const Operation::StartWriteCallback& callback) { |
93 OperationMap::iterator existing_operation = operations_.find(extension_id); | 92 OperationMap::iterator existing_operation = operations_.find(extension_id); |
94 | 93 |
95 if (existing_operation != operations_.end()) { | 94 if (existing_operation != operations_.end()) { |
96 return callback.Run(false, error::kOperationAlreadyInProgress); | 95 return callback.Run(false, error::kOperationAlreadyInProgress); |
97 } | 96 } |
98 | 97 |
99 scoped_refptr<Operation> operation( | 98 scoped_refptr<Operation> operation( |
100 new WriteFromFileOperation(weak_factory_.GetWeakPtr(), | 99 new WriteFromFileOperation(weak_factory_.GetWeakPtr(), |
101 extension_id, | 100 extension_id, |
102 path, | 101 path, |
103 storage_unit_id)); | 102 device_path)); |
104 operations_[extension_id] = operation; | 103 operations_[extension_id] = operation; |
105 BrowserThread::PostTask(BrowserThread::FILE, | 104 BrowserThread::PostTask(BrowserThread::FILE, |
106 FROM_HERE, | 105 FROM_HERE, |
107 base::Bind(&Operation::Start, operation)); | 106 base::Bind(&Operation::Start, operation)); |
108 callback.Run(true, ""); | 107 callback.Run(true, ""); |
109 } | 108 } |
110 | 109 |
111 void OperationManager::CancelWrite( | 110 void OperationManager::CancelWrite( |
112 const ExtensionId& extension_id, | 111 const ExtensionId& extension_id, |
113 const Operation::CancelWriteCallback& callback) { | 112 const Operation::CancelWriteCallback& callback) { |
114 Operation* existing_operation = GetOperation(extension_id); | 113 Operation* existing_operation = GetOperation(extension_id); |
115 | 114 |
116 if (existing_operation == NULL) { | 115 if (existing_operation == NULL) { |
117 callback.Run(false, error::kNoOperationInProgress); | 116 callback.Run(false, error::kNoOperationInProgress); |
118 } else { | 117 } else { |
119 BrowserThread::PostTask(BrowserThread::FILE, | 118 BrowserThread::PostTask(BrowserThread::FILE, |
120 FROM_HERE, | 119 FROM_HERE, |
121 base::Bind(&Operation::Cancel, existing_operation)); | 120 base::Bind(&Operation::Cancel, existing_operation)); |
122 DeleteOperation(extension_id); | 121 DeleteOperation(extension_id); |
123 callback.Run(true, ""); | 122 callback.Run(true, ""); |
124 } | 123 } |
125 } | 124 } |
126 | 125 |
127 void OperationManager::DestroyPartitions( | 126 void OperationManager::DestroyPartitions( |
128 const ExtensionId& extension_id, | 127 const ExtensionId& extension_id, |
129 const std::string& storage_unit_id, | 128 const std::string& device_path, |
130 const Operation::StartWriteCallback& callback) { | 129 const Operation::StartWriteCallback& callback) { |
131 OperationMap::iterator existing_operation = operations_.find(extension_id); | 130 OperationMap::iterator existing_operation = operations_.find(extension_id); |
132 | 131 |
133 if (existing_operation != operations_.end()) { | 132 if (existing_operation != operations_.end()) { |
134 return callback.Run(false, error::kOperationAlreadyInProgress); | 133 return callback.Run(false, error::kOperationAlreadyInProgress); |
135 } | 134 } |
136 | 135 |
137 scoped_refptr<Operation> operation( | 136 scoped_refptr<Operation> operation( |
138 new DestroyPartitionsOperation(weak_factory_.GetWeakPtr(), | 137 new DestroyPartitionsOperation(weak_factory_.GetWeakPtr(), |
139 extension_id, | 138 extension_id, |
140 storage_unit_id)); | 139 device_path)); |
141 operations_[extension_id] = operation; | 140 operations_[extension_id] = operation; |
142 BrowserThread::PostTask(BrowserThread::FILE, | 141 BrowserThread::PostTask(BrowserThread::FILE, |
143 FROM_HERE, | 142 FROM_HERE, |
144 base::Bind(&Operation::Start, operation)); | 143 base::Bind(&Operation::Start, operation)); |
145 callback.Run(true, ""); | 144 callback.Run(true, ""); |
146 } | 145 } |
147 | 146 |
148 void OperationManager::OnProgress(const ExtensionId& extension_id, | 147 void OperationManager::OnProgress(const ExtensionId& extension_id, |
149 image_writer_api::Stage stage, | 148 image_writer_api::Stage stage, |
150 int progress) { | 149 int progress) { |
(...skipping 106 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
257 g_factory = LAZY_INSTANCE_INITIALIZER; | 256 g_factory = LAZY_INSTANCE_INITIALIZER; |
258 | 257 |
259 ProfileKeyedAPIFactory<OperationManager>* | 258 ProfileKeyedAPIFactory<OperationManager>* |
260 OperationManager::GetFactoryInstance() { | 259 OperationManager::GetFactoryInstance() { |
261 return g_factory.Pointer(); | 260 return g_factory.Pointer(); |
262 } | 261 } |
263 | 262 |
264 | 263 |
265 } // namespace image_writer | 264 } // namespace image_writer |
266 } // namespace extensions | 265 } // namespace extensions |
OLD | NEW |