OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 "webkit/fileapi/quota_file_util.h" | 5 #include "webkit/fileapi/quota_file_util.h" |
6 | 6 |
7 #include "base/file_util.h" | 7 #include "base/file_util.h" |
8 #include "base/logging.h" | 8 #include "base/logging.h" |
9 #include "webkit/fileapi/file_system_context.h" | 9 #include "webkit/fileapi/file_system_context.h" |
10 #include "webkit/fileapi/file_system_operation_context.h" | 10 #include "webkit/fileapi/file_system_operation_context.h" |
11 #include "webkit/fileapi/file_system_path_manager.h" | 11 #include "webkit/fileapi/file_system_path_manager.h" |
12 #include "webkit/fileapi/file_system_quota_util.h" | 12 #include "webkit/fileapi/file_system_quota_util.h" |
| 13 #include "webkit/fileapi/native_file_util.h" |
13 #include "webkit/quota/quota_manager.h" | 14 #include "webkit/quota/quota_manager.h" |
14 | 15 |
15 using quota::QuotaManagerProxy; | 16 using quota::QuotaManagerProxy; |
16 | 17 |
17 namespace fileapi { | 18 namespace fileapi { |
18 | 19 |
19 const int64 QuotaFileUtil::kNoLimit = kint64max; | 20 const int64 QuotaFileUtil::kNoLimit = kint64max; |
20 | 21 |
21 // See the comment in the header file as for these constants. | 22 // See the comment in the header file as for these constants. |
22 const int64 QuotaFileUtil::kFilePathCostPerChar = 2; | 23 const int64 QuotaFileUtil::kFilePathCostPerChar = 2; |
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
63 FileSystemOperationContext* operation_context_; | 64 FileSystemOperationContext* operation_context_; |
64 FileSystemQuotaUtil* quota_util_; | 65 FileSystemQuotaUtil* quota_util_; |
65 QuotaManagerProxy* quota_manager_proxy_; | 66 QuotaManagerProxy* quota_manager_proxy_; |
66 const GURL& origin_url_; | 67 const GURL& origin_url_; |
67 FileSystemType type_; | 68 FileSystemType type_; |
68 DISALLOW_COPY_AND_ASSIGN(ScopedOriginUpdateHelper); | 69 DISALLOW_COPY_AND_ASSIGN(ScopedOriginUpdateHelper); |
69 }; | 70 }; |
70 | 71 |
71 } // namespace (anonymous) | 72 } // namespace (anonymous) |
72 | 73 |
73 QuotaFileUtil::QuotaFileUtil(FileSystemFileUtil* underlying_file_util) | 74 QuotaFileUtil::QuotaFileUtil(FileApiFileUtil* underlying_file_util) |
74 : underlying_file_util_(underlying_file_util) { | 75 : FileApiFileUtil(underlying_file_util) { |
75 } | 76 } |
76 | 77 |
77 QuotaFileUtil::~QuotaFileUtil() { | 78 QuotaFileUtil::~QuotaFileUtil() { |
78 } | 79 } |
79 | 80 |
80 // static | 81 // static |
81 QuotaFileUtil* QuotaFileUtil::CreateDefault() { | 82 QuotaFileUtil* QuotaFileUtil::CreateDefault() { |
82 return new QuotaFileUtil(new FileSystemFileUtil()); | 83 return new QuotaFileUtil(new NativeFileUtil()); |
83 } | 84 } |
84 | 85 |
85 int64 QuotaFileUtil::ComputeFilePathCost(const FilePath& file_path) const { | 86 int64 QuotaFileUtil::ComputeFilePathCost(const FilePath& file_path) const { |
86 return kFilePathCostPerFile + | 87 return kFilePathCostPerFile + |
87 file_path.BaseName().value().length() * kFilePathCostPerChar; | 88 file_path.BaseName().value().length() * kFilePathCostPerChar; |
88 } | 89 } |
89 | 90 |
90 PlatformFileError QuotaFileUtil::CreateOrOpen( | 91 PlatformFileError QuotaFileUtil::CreateOrOpen( |
91 FileSystemOperationContext* fs_context, | 92 FileSystemOperationContext* fs_context, |
92 const FilePath& file_path, int file_flags, | 93 const FilePath& file_path, int file_flags, |
(...skipping 10 matching lines...) Expand all Loading... |
103 if (growth > 0) { | 104 if (growth > 0) { |
104 helper.reset(new ScopedOriginUpdateHelper( | 105 helper.reset(new ScopedOriginUpdateHelper( |
105 fs_context, | 106 fs_context, |
106 fs_context->src_origin_url(), | 107 fs_context->src_origin_url(), |
107 fs_context->src_type())); | 108 fs_context->src_type())); |
108 | 109 |
109 if (allowed_bytes_growth != kNoLimit && growth > allowed_bytes_growth) | 110 if (allowed_bytes_growth != kNoLimit && growth > allowed_bytes_growth) |
110 return base::PLATFORM_FILE_ERROR_NO_SPACE; | 111 return base::PLATFORM_FILE_ERROR_NO_SPACE; |
111 } | 112 } |
112 | 113 |
113 base::PlatformFileError error = underlying_file_util_->CreateOrOpen( | 114 base::PlatformFileError error = underlying_file_util()->CreateOrOpen( |
114 fs_context, file_path, file_flags, file_handle, created); | 115 fs_context, file_path, file_flags, file_handle, created); |
115 | 116 |
116 if (growth > 0) { | 117 if (growth > 0) { |
117 if (error == base::PLATFORM_FILE_OK) | 118 if (error == base::PLATFORM_FILE_OK) |
118 helper->NotifyUpdate(growth); | 119 helper->NotifyUpdate(growth); |
119 } | 120 } |
120 | 121 |
121 return error; | 122 return error; |
122 } | 123 } |
123 | 124 |
(...skipping 13 matching lines...) Expand all Loading... |
137 if (growth > 0) { | 138 if (growth > 0) { |
138 helper.reset(new ScopedOriginUpdateHelper( | 139 helper.reset(new ScopedOriginUpdateHelper( |
139 fs_context, | 140 fs_context, |
140 fs_context->src_origin_url(), | 141 fs_context->src_origin_url(), |
141 fs_context->src_type())); | 142 fs_context->src_type())); |
142 | 143 |
143 if (allowed_bytes_growth != kNoLimit && growth > allowed_bytes_growth) | 144 if (allowed_bytes_growth != kNoLimit && growth > allowed_bytes_growth) |
144 return base::PLATFORM_FILE_ERROR_NO_SPACE; | 145 return base::PLATFORM_FILE_ERROR_NO_SPACE; |
145 } | 146 } |
146 | 147 |
147 base::PlatformFileError error = underlying_file_util_->EnsureFileExists( | 148 base::PlatformFileError error = underlying_file_util()->EnsureFileExists( |
148 fs_context, file_path, created); | 149 fs_context, file_path, created); |
149 | 150 |
150 if (growth > 0 &&error == base::PLATFORM_FILE_OK) | 151 if (growth > 0 &&error == base::PLATFORM_FILE_OK) |
151 helper->NotifyUpdate(growth); | 152 helper->NotifyUpdate(growth); |
152 | 153 |
153 return error; | 154 return error; |
154 } | 155 } |
155 | 156 |
156 PlatformFileError QuotaFileUtil::CreateDirectory( | 157 PlatformFileError QuotaFileUtil::CreateDirectory( |
157 FileSystemOperationContext* fs_context, | 158 FileSystemOperationContext* fs_context, |
158 const FilePath& file_path, | 159 const FilePath& file_path, |
159 bool exclusive, | 160 bool exclusive, |
160 bool recursive) { | 161 bool recursive) { |
161 DCHECK(fs_context); | 162 DCHECK(fs_context); |
162 scoped_ptr<ScopedOriginUpdateHelper> helper; | 163 scoped_ptr<ScopedOriginUpdateHelper> helper; |
163 | 164 |
164 int64 allowed_bytes_growth = fs_context->allowed_bytes_growth(); | 165 int64 allowed_bytes_growth = fs_context->allowed_bytes_growth(); |
165 int64 growth = 0; | 166 int64 growth = 0; |
166 | 167 |
167 if (!exclusive || !file_util::PathExists(file_path)) { | 168 if (!exclusive || !file_util::PathExists(file_path)) { |
168 if (recursive) { | 169 if (recursive) { |
169 FilePath last_path; | 170 FilePath last_path; |
170 for (FilePath path = fs_context->src_virtual_path(); | 171 for (FilePath path = fs_context->src_virtual_path(); |
171 path.value() != last_path.value() && | 172 path.value() != last_path.value() && |
172 !fs_context->src_file_system_file_util()->PathExists( | 173 !fs_context->src_file_util()->PathExists( |
173 fs_context, fs_context->src_virtual_path()); | 174 fs_context, fs_context->src_virtual_path()); |
174 path = path.DirName()) { | 175 path = path.DirName()) { |
175 growth += ComputeFilePathCost(fs_context->src_virtual_path()); | 176 growth += ComputeFilePathCost(fs_context->src_virtual_path()); |
176 last_path = path; | 177 last_path = path; |
177 } | 178 } |
178 } else { | 179 } else { |
179 growth += ComputeFilePathCost(fs_context->src_virtual_path()); | 180 growth += ComputeFilePathCost(fs_context->src_virtual_path()); |
180 } | 181 } |
181 } | 182 } |
182 | 183 |
183 if (growth > 0) { | 184 if (growth > 0) { |
184 helper.reset(new ScopedOriginUpdateHelper( | 185 helper.reset(new ScopedOriginUpdateHelper( |
185 fs_context, | 186 fs_context, |
186 fs_context->src_origin_url(), | 187 fs_context->src_origin_url(), |
187 fs_context->src_type())); | 188 fs_context->src_type())); |
188 | 189 |
189 if (allowed_bytes_growth != kNoLimit && growth > allowed_bytes_growth) | 190 if (allowed_bytes_growth != kNoLimit && growth > allowed_bytes_growth) |
190 return base::PLATFORM_FILE_ERROR_NO_SPACE; | 191 return base::PLATFORM_FILE_ERROR_NO_SPACE; |
191 } | 192 } |
192 | 193 |
193 base::PlatformFileError error = base::PLATFORM_FILE_OK; | 194 base::PlatformFileError error = base::PLATFORM_FILE_OK; |
194 error = underlying_file_util_->CreateDirectory( | 195 error = underlying_file_util()->CreateDirectory( |
195 fs_context, file_path, exclusive, recursive); | 196 fs_context, file_path, exclusive, recursive); |
196 | 197 |
197 if (growth > 0 && error == base::PLATFORM_FILE_OK) | 198 if (growth > 0 && error == base::PLATFORM_FILE_OK) |
198 helper->NotifyUpdate(growth); | 199 helper->NotifyUpdate(growth); |
199 | 200 |
200 return error; | 201 return error; |
201 } | 202 } |
202 | 203 |
203 base::PlatformFileError QuotaFileUtil::CopyOrMoveFile( | 204 base::PlatformFileError QuotaFileUtil::CopyOrMoveFile( |
204 FileSystemOperationContext* fs_context, | 205 FileSystemOperationContext* fs_context, |
(...skipping 26 matching lines...) Expand all Loading... |
231 ComputeFilePathCost(fs_context->src_virtual_path()); | 232 ComputeFilePathCost(fs_context->src_virtual_path()); |
232 int64 dest_file_path_cost = | 233 int64 dest_file_path_cost = |
233 ComputeFilePathCost(fs_context->dest_virtual_path()); | 234 ComputeFilePathCost(fs_context->dest_virtual_path()); |
234 if (!file_util::GetFileInfo(dest_file_path, &dest_file_info)) | 235 if (!file_util::GetFileInfo(dest_file_path, &dest_file_info)) |
235 dest_file_info.size = 0; | 236 dest_file_info.size = 0; |
236 growth = -dest_file_info.size - src_file_path_cost + dest_file_path_cost; | 237 growth = -dest_file_info.size - src_file_path_cost + dest_file_path_cost; |
237 if (allowed_bytes_growth != kNoLimit && growth > allowed_bytes_growth) | 238 if (allowed_bytes_growth != kNoLimit && growth > allowed_bytes_growth) |
238 return base::PLATFORM_FILE_ERROR_NO_SPACE; | 239 return base::PLATFORM_FILE_ERROR_NO_SPACE; |
239 } | 240 } |
240 | 241 |
241 base::PlatformFileError error = underlying_file_util_->CopyOrMoveFile( | 242 base::PlatformFileError error = underlying_file_util()->CopyOrMoveFile( |
242 fs_context, src_file_path, dest_file_path, copy); | 243 fs_context, src_file_path, dest_file_path, copy); |
243 | 244 |
244 if (error == base::PLATFORM_FILE_OK) { | 245 if (error == base::PLATFORM_FILE_OK) { |
245 // TODO(kinuko): For cross-filesystem move case, call this with -growth | 246 // TODO(kinuko): For cross-filesystem move case, call this with -growth |
246 // for source and growth for dest. | 247 // for source and growth for dest. |
247 helper.NotifyUpdate(growth); | 248 helper.NotifyUpdate(growth); |
248 } | 249 } |
249 | 250 |
250 return error; | 251 return error; |
251 } | 252 } |
252 | 253 |
253 base::PlatformFileError QuotaFileUtil::DeleteFile( | 254 base::PlatformFileError QuotaFileUtil::DeleteFile( |
254 FileSystemOperationContext* fs_context, | 255 FileSystemOperationContext* fs_context, |
255 const FilePath& file_path) { | 256 const FilePath& file_path) { |
256 DCHECK(fs_context); | 257 DCHECK(fs_context); |
257 ScopedOriginUpdateHelper helper( | 258 ScopedOriginUpdateHelper helper( |
258 fs_context, | 259 fs_context, |
259 fs_context->src_origin_url(), | 260 fs_context->src_origin_url(), |
260 fs_context->src_type()); | 261 fs_context->src_type()); |
261 | 262 |
262 int64 growth = 0; | 263 int64 growth = 0; |
263 base::PlatformFileInfo file_info; | 264 base::PlatformFileInfo file_info; |
264 if (file_util::GetFileInfo(file_path, &file_info)) { | 265 if (file_util::GetFileInfo(file_path, &file_info)) { |
265 growth -= file_info.size + | 266 growth -= file_info.size + |
266 ComputeFilePathCost(fs_context->src_virtual_path()); | 267 ComputeFilePathCost(fs_context->src_virtual_path()); |
267 } | 268 } |
268 | 269 |
269 base::PlatformFileError error = underlying_file_util_->DeleteFile( | 270 base::PlatformFileError error = underlying_file_util()->DeleteFile( |
270 fs_context, file_path); | 271 fs_context, file_path); |
271 | 272 |
272 if (error == base::PLATFORM_FILE_OK) | 273 if (error == base::PLATFORM_FILE_OK) |
273 helper.NotifyUpdate(growth); | 274 helper.NotifyUpdate(growth); |
274 | 275 |
275 return error; | 276 return error; |
276 } | 277 } |
277 | 278 |
278 base::PlatformFileError QuotaFileUtil::DeleteSingleDirectory( | 279 base::PlatformFileError QuotaFileUtil::DeleteSingleDirectory( |
279 FileSystemOperationContext* fs_context, | 280 FileSystemOperationContext* fs_context, |
280 const FilePath& file_path) { | 281 const FilePath& file_path) { |
281 DCHECK(fs_context); | 282 DCHECK(fs_context); |
282 ScopedOriginUpdateHelper helper( | 283 ScopedOriginUpdateHelper helper( |
283 fs_context, | 284 fs_context, |
284 fs_context->src_origin_url(), | 285 fs_context->src_origin_url(), |
285 fs_context->src_type()); | 286 fs_context->src_type()); |
286 | 287 |
287 int64 growth = 0; | 288 int64 growth = 0; |
288 if (file_util::DirectoryExists(file_path)) | 289 if (file_util::DirectoryExists(file_path)) |
289 growth -= ComputeFilePathCost(fs_context->src_virtual_path()); | 290 growth -= ComputeFilePathCost(fs_context->src_virtual_path()); |
290 | 291 |
291 base::PlatformFileError error = underlying_file_util_->DeleteSingleDirectory( | 292 base::PlatformFileError error = underlying_file_util()->DeleteSingleDirectory( |
292 fs_context, file_path); | 293 fs_context, file_path); |
293 | 294 |
294 if (error == base::PLATFORM_FILE_OK) | 295 if (error == base::PLATFORM_FILE_OK) |
295 helper.NotifyUpdate(growth); | 296 helper.NotifyUpdate(growth); |
296 | 297 |
297 return error; | 298 return error; |
298 } | 299 } |
299 | 300 |
300 base::PlatformFileError QuotaFileUtil::Truncate( | 301 base::PlatformFileError QuotaFileUtil::Truncate( |
301 FileSystemOperationContext* fs_context, | 302 FileSystemOperationContext* fs_context, |
302 const FilePath& path, | 303 const FilePath& path, |
303 int64 length) { | 304 int64 length) { |
304 int64 allowed_bytes_growth = fs_context->allowed_bytes_growth(); | 305 int64 allowed_bytes_growth = fs_context->allowed_bytes_growth(); |
305 ScopedOriginUpdateHelper helper( | 306 ScopedOriginUpdateHelper helper( |
306 fs_context, | 307 fs_context, |
307 fs_context->src_origin_url(), | 308 fs_context->src_origin_url(), |
308 fs_context->src_type()); | 309 fs_context->src_type()); |
309 | 310 |
310 int64 growth = 0; | 311 int64 growth = 0; |
311 base::PlatformFileInfo file_info; | 312 base::PlatformFileInfo file_info; |
312 if (!file_util::GetFileInfo(path, &file_info)) | 313 if (!file_util::GetFileInfo(path, &file_info)) |
313 return base::PLATFORM_FILE_ERROR_FAILED; | 314 return base::PLATFORM_FILE_ERROR_FAILED; |
314 | 315 |
315 growth = length - file_info.size; | 316 growth = length - file_info.size; |
316 if (allowed_bytes_growth != kNoLimit && growth > allowed_bytes_growth) | 317 if (allowed_bytes_growth != kNoLimit && growth > allowed_bytes_growth) |
317 return base::PLATFORM_FILE_ERROR_NO_SPACE; | 318 return base::PLATFORM_FILE_ERROR_NO_SPACE; |
318 | 319 |
319 base::PlatformFileError error = underlying_file_util_->Truncate( | 320 base::PlatformFileError error = underlying_file_util()->Truncate( |
320 fs_context, path, length); | 321 fs_context, path, length); |
321 | 322 |
322 if (error == base::PLATFORM_FILE_OK) | 323 if (error == base::PLATFORM_FILE_OK) |
323 helper.NotifyUpdate(growth); | 324 helper.NotifyUpdate(growth); |
324 | 325 |
325 return error; | 326 return error; |
326 } | 327 } |
327 | 328 |
328 // Checks if copying in the same filesystem can be performed. | 329 // Checks if copying in the same filesystem can be performed. |
329 // This method is not called for moving within a single filesystem. | 330 // This method is not called for moving within a single filesystem. |
(...skipping 17 matching lines...) Expand all Loading... |
347 } | 348 } |
348 *growth = src_file_info.size - dest_file_info.size + dest_file_path_cost; | 349 *growth = src_file_info.size - dest_file_info.size + dest_file_path_cost; |
349 if (allowed_bytes_growth != QuotaFileUtil::kNoLimit && | 350 if (allowed_bytes_growth != QuotaFileUtil::kNoLimit && |
350 *growth > allowed_bytes_growth) | 351 *growth > allowed_bytes_growth) |
351 return false; | 352 return false; |
352 | 353 |
353 return true; | 354 return true; |
354 } | 355 } |
355 | 356 |
356 } // namespace fileapi | 357 } // namespace fileapi |
OLD | NEW |