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 "content/child/fileapi/file_system_dispatcher.h" | 5 #include "content/child/fileapi/file_system_dispatcher.h" |
6 | 6 |
7 #include "base/callback.h" | 7 #include "base/callback.h" |
8 #include "base/file_util.h" | 8 #include "base/file_util.h" |
9 #include "base/message_loop/message_loop_proxy.h" | 9 #include "base/message_loop/message_loop_proxy.h" |
10 #include "base/process/process.h" | 10 #include "base/process/process.h" |
(...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
70 const StatusCallback& error_callback) { | 70 const StatusCallback& error_callback) { |
71 CallbackDispatcher* dispatcher = new CallbackDispatcher; | 71 CallbackDispatcher* dispatcher = new CallbackDispatcher; |
72 dispatcher->write_callback_ = callback; | 72 dispatcher->write_callback_ = callback; |
73 dispatcher->error_callback_ = error_callback; | 73 dispatcher->error_callback_ = error_callback; |
74 return dispatcher; | 74 return dispatcher; |
75 } | 75 } |
76 | 76 |
77 ~CallbackDispatcher() {} | 77 ~CallbackDispatcher() {} |
78 | 78 |
79 void DidSucceed() { | 79 void DidSucceed() { |
80 status_callback_.Run(base::PLATFORM_FILE_OK); | 80 status_callback_.Run(base::File::FILE_OK); |
81 } | 81 } |
82 | 82 |
83 void DidFail(base::PlatformFileError error_code) { | 83 void DidFail(base::File::Error error_code) { |
84 error_callback_.Run(error_code); | 84 error_callback_.Run(error_code); |
85 } | 85 } |
86 | 86 |
87 void DidReadMetadata( | 87 void DidReadMetadata( |
88 const base::PlatformFileInfo& file_info) { | 88 const base::File::Info& file_info) { |
89 metadata_callback_.Run(file_info); | 89 metadata_callback_.Run(file_info); |
90 } | 90 } |
91 | 91 |
92 void DidCreateSnapshotFile( | 92 void DidCreateSnapshotFile( |
93 const base::PlatformFileInfo& file_info, | 93 const base::File::Info& file_info, |
94 const base::FilePath& platform_path, | 94 const base::FilePath& platform_path, |
95 int request_id) { | 95 int request_id) { |
96 snapshot_callback_.Run(file_info, platform_path, request_id); | 96 snapshot_callback_.Run(file_info, platform_path, request_id); |
97 } | 97 } |
98 | 98 |
99 void DidReadDirectory( | 99 void DidReadDirectory( |
100 const std::vector<fileapi::DirectoryEntry>& entries, | 100 const std::vector<fileapi::DirectoryEntry>& entries, |
101 bool has_more) { | 101 bool has_more) { |
102 directory_callback_.Run(entries, has_more); | 102 directory_callback_.Run(entries, has_more); |
103 } | 103 } |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
143 FileSystemDispatcher::FileSystemDispatcher() { | 143 FileSystemDispatcher::FileSystemDispatcher() { |
144 } | 144 } |
145 | 145 |
146 FileSystemDispatcher::~FileSystemDispatcher() { | 146 FileSystemDispatcher::~FileSystemDispatcher() { |
147 // Make sure we fire all the remaining callbacks. | 147 // Make sure we fire all the remaining callbacks. |
148 for (IDMap<CallbackDispatcher, IDMapOwnPointer>::iterator | 148 for (IDMap<CallbackDispatcher, IDMapOwnPointer>::iterator |
149 iter(&dispatchers_); !iter.IsAtEnd(); iter.Advance()) { | 149 iter(&dispatchers_); !iter.IsAtEnd(); iter.Advance()) { |
150 int request_id = iter.GetCurrentKey(); | 150 int request_id = iter.GetCurrentKey(); |
151 CallbackDispatcher* dispatcher = iter.GetCurrentValue(); | 151 CallbackDispatcher* dispatcher = iter.GetCurrentValue(); |
152 DCHECK(dispatcher); | 152 DCHECK(dispatcher); |
153 dispatcher->DidFail(base::PLATFORM_FILE_ERROR_ABORT); | 153 dispatcher->DidFail(base::File::FILE_ERROR_ABORT); |
154 dispatchers_.Remove(request_id); | 154 dispatchers_.Remove(request_id); |
155 } | 155 } |
156 } | 156 } |
157 | 157 |
158 bool FileSystemDispatcher::OnMessageReceived(const IPC::Message& msg) { | 158 bool FileSystemDispatcher::OnMessageReceived(const IPC::Message& msg) { |
159 bool handled = true; | 159 bool handled = true; |
160 IPC_BEGIN_MESSAGE_MAP(FileSystemDispatcher, msg) | 160 IPC_BEGIN_MESSAGE_MAP(FileSystemDispatcher, msg) |
161 IPC_MESSAGE_HANDLER(FileSystemMsg_DidOpenFileSystem, OnDidOpenFileSystem) | 161 IPC_MESSAGE_HANDLER(FileSystemMsg_DidOpenFileSystem, OnDidOpenFileSystem) |
162 IPC_MESSAGE_HANDLER(FileSystemMsg_DidResolveURL, OnDidResolveURL) | 162 IPC_MESSAGE_HANDLER(FileSystemMsg_DidResolveURL, OnDidResolveURL) |
163 IPC_MESSAGE_HANDLER(FileSystemMsg_DidSucceed, OnDidSucceed) | 163 IPC_MESSAGE_HANDLER(FileSystemMsg_DidSucceed, OnDidSucceed) |
(...skipping 196 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
360 } | 360 } |
361 | 361 |
362 void FileSystemDispatcher::OnDidSucceed(int request_id) { | 362 void FileSystemDispatcher::OnDidSucceed(int request_id) { |
363 CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id); | 363 CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id); |
364 DCHECK(dispatcher); | 364 DCHECK(dispatcher); |
365 dispatcher->DidSucceed(); | 365 dispatcher->DidSucceed(); |
366 dispatchers_.Remove(request_id); | 366 dispatchers_.Remove(request_id); |
367 } | 367 } |
368 | 368 |
369 void FileSystemDispatcher::OnDidReadMetadata( | 369 void FileSystemDispatcher::OnDidReadMetadata( |
370 int request_id, const base::PlatformFileInfo& file_info) { | 370 int request_id, const base::File::Info& file_info) { |
371 CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id); | 371 CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id); |
372 DCHECK(dispatcher); | 372 DCHECK(dispatcher); |
373 dispatcher->DidReadMetadata(file_info); | 373 dispatcher->DidReadMetadata(file_info); |
374 dispatchers_.Remove(request_id); | 374 dispatchers_.Remove(request_id); |
375 } | 375 } |
376 | 376 |
377 void FileSystemDispatcher::OnDidCreateSnapshotFile( | 377 void FileSystemDispatcher::OnDidCreateSnapshotFile( |
378 int request_id, const base::PlatformFileInfo& file_info, | 378 int request_id, const base::File::Info& file_info, |
379 const base::FilePath& platform_path) { | 379 const base::FilePath& platform_path) { |
380 CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id); | 380 CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id); |
381 DCHECK(dispatcher); | 381 DCHECK(dispatcher); |
382 dispatcher->DidCreateSnapshotFile(file_info, platform_path, request_id); | 382 dispatcher->DidCreateSnapshotFile(file_info, platform_path, request_id); |
383 dispatchers_.Remove(request_id); | 383 dispatchers_.Remove(request_id); |
384 } | 384 } |
385 | 385 |
386 void FileSystemDispatcher::OnDidReadDirectory( | 386 void FileSystemDispatcher::OnDidReadDirectory( |
387 int request_id, | 387 int request_id, |
388 const std::vector<fileapi::DirectoryEntry>& entries, | 388 const std::vector<fileapi::DirectoryEntry>& entries, |
389 bool has_more) { | 389 bool has_more) { |
390 CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id); | 390 CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id); |
391 DCHECK(dispatcher); | 391 DCHECK(dispatcher); |
392 dispatcher->DidReadDirectory(entries, has_more); | 392 dispatcher->DidReadDirectory(entries, has_more); |
393 dispatchers_.Remove(request_id); | 393 dispatchers_.Remove(request_id); |
394 } | 394 } |
395 | 395 |
396 void FileSystemDispatcher::OnDidFail( | 396 void FileSystemDispatcher::OnDidFail( |
397 int request_id, base::PlatformFileError error_code) { | 397 int request_id, base::File::Error error_code) { |
398 CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id); | 398 CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id); |
399 DCHECK(dispatcher); | 399 DCHECK(dispatcher); |
400 dispatcher->DidFail(error_code); | 400 dispatcher->DidFail(error_code); |
401 dispatchers_.Remove(request_id); | 401 dispatchers_.Remove(request_id); |
402 } | 402 } |
403 | 403 |
404 void FileSystemDispatcher::OnDidWrite( | 404 void FileSystemDispatcher::OnDidWrite( |
405 int request_id, int64 bytes, bool complete) { | 405 int request_id, int64 bytes, bool complete) { |
406 CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id); | 406 CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id); |
407 DCHECK(dispatcher); | 407 DCHECK(dispatcher); |
408 dispatcher->DidWrite(bytes, complete); | 408 dispatcher->DidWrite(bytes, complete); |
409 if (complete) | 409 if (complete) |
410 dispatchers_.Remove(request_id); | 410 dispatchers_.Remove(request_id); |
411 } | 411 } |
412 | 412 |
413 void FileSystemDispatcher::OnDidOpenFile( | 413 void FileSystemDispatcher::OnDidOpenFile( |
414 int request_id, | 414 int request_id, |
415 IPC::PlatformFileForTransit file, | 415 IPC::PlatformFileForTransit file, |
416 int file_open_id, | 416 int file_open_id, |
417 quota::QuotaLimitType quota_policy) { | 417 quota::QuotaLimitType quota_policy) { |
418 CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id); | 418 CallbackDispatcher* dispatcher = dispatchers_.Lookup(request_id); |
419 DCHECK(dispatcher); | 419 DCHECK(dispatcher); |
420 dispatcher->DidOpenFile(IPC::PlatformFileForTransitToPlatformFile(file), | 420 dispatcher->DidOpenFile(IPC::PlatformFileForTransitToPlatformFile(file), |
421 file_open_id, | 421 file_open_id, |
422 quota_policy); | 422 quota_policy); |
423 dispatchers_.Remove(request_id); | 423 dispatchers_.Remove(request_id); |
424 } | 424 } |
425 | 425 |
426 } // namespace content | 426 } // namespace content |
OLD | NEW |