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/chromeos/file_system_provider/provided_file_system.h" | 5 #include "chrome/browser/chromeos/file_system_provider/provided_file_system.h" |
6 | 6 |
7 #include <vector> | 7 #include <vector> |
8 | 8 |
9 #include "base/files/file.h" | 9 #include "base/files/file.h" |
| 10 #include "base/macros.h" |
10 #include "base/trace_event/trace_event.h" | 11 #include "base/trace_event/trace_event.h" |
11 #include "chrome/browser/chromeos/file_system_provider/notification_manager.h" | 12 #include "chrome/browser/chromeos/file_system_provider/notification_manager.h" |
12 #include "chrome/browser/chromeos/file_system_provider/operations/abort.h" | 13 #include "chrome/browser/chromeos/file_system_provider/operations/abort.h" |
13 #include "chrome/browser/chromeos/file_system_provider/operations/add_watcher.h" | 14 #include "chrome/browser/chromeos/file_system_provider/operations/add_watcher.h" |
14 #include "chrome/browser/chromeos/file_system_provider/operations/close_file.h" | 15 #include "chrome/browser/chromeos/file_system_provider/operations/close_file.h" |
15 #include "chrome/browser/chromeos/file_system_provider/operations/configure.h" | 16 #include "chrome/browser/chromeos/file_system_provider/operations/configure.h" |
16 #include "chrome/browser/chromeos/file_system_provider/operations/copy_entry.h" | 17 #include "chrome/browser/chromeos/file_system_provider/operations/copy_entry.h" |
17 #include "chrome/browser/chromeos/file_system_provider/operations/create_directo
ry.h" | 18 #include "chrome/browser/chromeos/file_system_provider/operations/create_directo
ry.h" |
18 #include "chrome/browser/chromeos/file_system_provider/operations/create_file.h" | 19 #include "chrome/browser/chromeos/file_system_provider/operations/create_file.h" |
19 #include "chrome/browser/chromeos/file_system_provider/operations/delete_entry.h
" | 20 #include "chrome/browser/chromeos/file_system_provider/operations/delete_entry.h
" |
(...skipping 226 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
246 return AbortCallback(); | 247 return AbortCallback(); |
247 } | 248 } |
248 | 249 |
249 return base::Bind( | 250 return base::Bind( |
250 &ProvidedFileSystem::Abort, weak_ptr_factory_.GetWeakPtr(), request_id); | 251 &ProvidedFileSystem::Abort, weak_ptr_factory_.GetWeakPtr(), request_id); |
251 } | 252 } |
252 | 253 |
253 AbortCallback ProvidedFileSystem::ReadFile( | 254 AbortCallback ProvidedFileSystem::ReadFile( |
254 int file_handle, | 255 int file_handle, |
255 net::IOBuffer* buffer, | 256 net::IOBuffer* buffer, |
256 int64 offset, | 257 int64_t offset, |
257 int length, | 258 int length, |
258 const ReadChunkReceivedCallback& callback) { | 259 const ReadChunkReceivedCallback& callback) { |
259 TRACE_EVENT1( | 260 TRACE_EVENT1( |
260 "file_system_provider", "ProvidedFileSystem::ReadFile", "length", length); | 261 "file_system_provider", "ProvidedFileSystem::ReadFile", "length", length); |
261 const int request_id = request_manager_->CreateRequest( | 262 const int request_id = request_manager_->CreateRequest( |
262 READ_FILE, | 263 READ_FILE, |
263 make_scoped_ptr<RequestManager::HandlerInterface>( | 264 make_scoped_ptr<RequestManager::HandlerInterface>( |
264 new operations::ReadFile(event_router_, | 265 new operations::ReadFile(event_router_, |
265 file_system_info_, | 266 file_system_info_, |
266 file_handle, | 267 file_handle, |
(...skipping 120 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
387 return AbortCallback(); | 388 return AbortCallback(); |
388 } | 389 } |
389 | 390 |
390 return base::Bind( | 391 return base::Bind( |
391 &ProvidedFileSystem::Abort, weak_ptr_factory_.GetWeakPtr(), request_id); | 392 &ProvidedFileSystem::Abort, weak_ptr_factory_.GetWeakPtr(), request_id); |
392 } | 393 } |
393 | 394 |
394 AbortCallback ProvidedFileSystem::WriteFile( | 395 AbortCallback ProvidedFileSystem::WriteFile( |
395 int file_handle, | 396 int file_handle, |
396 net::IOBuffer* buffer, | 397 net::IOBuffer* buffer, |
397 int64 offset, | 398 int64_t offset, |
398 int length, | 399 int length, |
399 const storage::AsyncFileUtil::StatusCallback& callback) { | 400 const storage::AsyncFileUtil::StatusCallback& callback) { |
400 TRACE_EVENT1("file_system_provider", | 401 TRACE_EVENT1("file_system_provider", |
401 "ProvidedFileSystem::WriteFile", | 402 "ProvidedFileSystem::WriteFile", |
402 "length", | 403 "length", |
403 length); | 404 length); |
404 const int request_id = request_manager_->CreateRequest( | 405 const int request_id = request_manager_->CreateRequest( |
405 WRITE_FILE, | 406 WRITE_FILE, |
406 make_scoped_ptr<RequestManager::HandlerInterface>( | 407 make_scoped_ptr<RequestManager::HandlerInterface>( |
407 new operations::WriteFile(event_router_, | 408 new operations::WriteFile(event_router_, |
(...skipping 28 matching lines...) Expand all Loading... |
436 callback.Run(base::File::FILE_ERROR_SECURITY); | 437 callback.Run(base::File::FILE_ERROR_SECURITY); |
437 return AbortCallback(); | 438 return AbortCallback(); |
438 } | 439 } |
439 | 440 |
440 return base::Bind( | 441 return base::Bind( |
441 &ProvidedFileSystem::Abort, weak_ptr_factory_.GetWeakPtr(), request_id); | 442 &ProvidedFileSystem::Abort, weak_ptr_factory_.GetWeakPtr(), request_id); |
442 } | 443 } |
443 | 444 |
444 AbortCallback ProvidedFileSystem::Truncate( | 445 AbortCallback ProvidedFileSystem::Truncate( |
445 const base::FilePath& file_path, | 446 const base::FilePath& file_path, |
446 int64 length, | 447 int64_t length, |
447 const storage::AsyncFileUtil::StatusCallback& callback) { | 448 const storage::AsyncFileUtil::StatusCallback& callback) { |
448 const int request_id = request_manager_->CreateRequest( | 449 const int request_id = request_manager_->CreateRequest( |
449 TRUNCATE, | 450 TRUNCATE, |
450 scoped_ptr<RequestManager::HandlerInterface>(new operations::Truncate( | 451 scoped_ptr<RequestManager::HandlerInterface>(new operations::Truncate( |
451 event_router_, file_system_info_, file_path, length, callback))); | 452 event_router_, file_system_info_, file_path, length, callback))); |
452 if (!request_id) { | 453 if (!request_id) { |
453 callback.Run(base::File::FILE_ERROR_SECURITY); | 454 callback.Run(base::File::FILE_ERROR_SECURITY); |
454 return AbortCallback(); | 455 return AbortCallback(); |
455 } | 456 } |
456 | 457 |
(...skipping 377 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
834 const storage::AsyncFileUtil::StatusCallback& callback, | 835 const storage::AsyncFileUtil::StatusCallback& callback, |
835 base::File::Error result) { | 836 base::File::Error result) { |
836 // Closing files is final. Even if an error happened, we remove it from the | 837 // Closing files is final. Even if an error happened, we remove it from the |
837 // list of opened files. | 838 // list of opened files. |
838 opened_files_.erase(file_handle); | 839 opened_files_.erase(file_handle); |
839 callback.Run(result); | 840 callback.Run(result); |
840 } | 841 } |
841 | 842 |
842 } // namespace file_system_provider | 843 } // namespace file_system_provider |
843 } // namespace chromeos | 844 } // namespace chromeos |
OLD | NEW |