| 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 |