| 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 "content/child/fileapi/webfilesystem_impl.h" | 5 #include "content/child/fileapi/webfilesystem_impl.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/id_map.h" | 8 #include "base/id_map.h" |
| 9 #include "base/lazy_instance.h" | 9 #include "base/lazy_instance.h" |
| 10 #include "base/logging.h" | 10 #include "base/logging.h" |
| (...skipping 234 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 245 return; | 245 return; |
| 246 | 246 |
| 247 WebFileSystemCallbacks* callbacks = | 247 WebFileSystemCallbacks* callbacks = |
| 248 CallbacksMap::Get()->GetAndUnregisterCallbacks(callbacks_id); | 248 CallbacksMap::Get()->GetAndUnregisterCallbacks(callbacks_id); |
| 249 DCHECK(callbacks); | 249 DCHECK(callbacks); |
| 250 | 250 |
| 251 if (file_info.is_directory || file_info.size < 0) { | 251 if (file_info.is_directory || file_info.size < 0) { |
| 252 callbacks->didFail(WebKit::WebFileErrorInvalidState); | 252 callbacks->didFail(WebKit::WebFileErrorInvalidState); |
| 253 return; | 253 return; |
| 254 } | 254 } |
| 255 WebFileWriterImpl::Type type = callbacks->shouldBlockUntilCompletion() ? | |
| 256 WebFileWriterImpl::TYPE_SYNC : WebFileWriterImpl::TYPE_ASYNC; | |
| 257 callbacks->didCreateFileWriter( | 255 callbacks->didCreateFileWriter( |
| 258 new WebFileWriterImpl(path, client, type, main_thread_loop), | 256 new WebFileWriterImpl(path, client, main_thread_loop), file_info.size); |
| 259 file_info.size); | |
| 260 } | 257 } |
| 261 | 258 |
| 262 void CreateFileWriterCallbackAdapter( | 259 void CreateFileWriterCallbackAdapter( |
| 263 int thread_id, int callbacks_id, | 260 int thread_id, int callbacks_id, |
| 264 WaitableCallbackResults* waitable_results, | 261 WaitableCallbackResults* waitable_results, |
| 265 base::MessageLoopProxy* main_thread_loop, | 262 base::MessageLoopProxy* main_thread_loop, |
| 266 const GURL& path, | 263 const GURL& path, |
| 267 WebKit::WebFileWriterClient* client, | 264 WebKit::WebFileWriterClient* client, |
| 268 const base::PlatformFileInfo& file_info) { | 265 const base::PlatformFileInfo& file_info) { |
| 269 DispatchResultsClosure( | 266 DispatchResultsClosure( |
| (...skipping 214 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 484 CurrentWorkerId(), callbacks_id, | 481 CurrentWorkerId(), callbacks_id, |
| 485 base::Unretained(waitable_results)), | 482 base::Unretained(waitable_results)), |
| 486 base::Bind(&StatusCallbackAdapter, | 483 base::Bind(&StatusCallbackAdapter, |
| 487 CurrentWorkerId(), callbacks_id, | 484 CurrentWorkerId(), callbacks_id, |
| 488 base::Unretained(waitable_results))), | 485 base::Unretained(waitable_results))), |
| 489 make_scoped_ptr(waitable_results)); | 486 make_scoped_ptr(waitable_results)); |
| 490 } | 487 } |
| 491 | 488 |
| 492 WebKit::WebFileWriter* WebFileSystemImpl::createFileWriter( | 489 WebKit::WebFileWriter* WebFileSystemImpl::createFileWriter( |
| 493 const WebURL& path, WebKit::WebFileWriterClient* client) { | 490 const WebURL& path, WebKit::WebFileWriterClient* client) { |
| 494 return new WebFileWriterImpl(GURL(path), client, | 491 return new WebFileWriterImpl(GURL(path), client, main_thread_loop_.get()); |
| 495 WebFileWriterImpl::TYPE_ASYNC, | |
| 496 main_thread_loop_.get()); | |
| 497 } | 492 } |
| 498 | 493 |
| 499 void WebFileSystemImpl::createFileWriter( | 494 void WebFileSystemImpl::createFileWriter( |
| 500 const WebURL& path, | 495 const WebURL& path, |
| 501 WebKit::WebFileWriterClient* client, | 496 WebKit::WebFileWriterClient* client, |
| 502 WebKit::WebFileSystemCallbacks* callbacks) { | 497 WebKit::WebFileSystemCallbacks* callbacks) { |
| 503 int callbacks_id = CallbacksMap::GetOrCreate()->RegisterCallbacks(callbacks); | 498 int callbacks_id = CallbacksMap::GetOrCreate()->RegisterCallbacks(callbacks); |
| 504 WaitableCallbackResults* waitable_results = | 499 WaitableCallbackResults* waitable_results = |
| 505 WaitableCallbackResults::MaybeCreate(callbacks); | 500 WaitableCallbackResults::MaybeCreate(callbacks); |
| 506 CallDispatcherOnMainThread( | 501 CallDispatcherOnMainThread( |
| (...skipping 24 matching lines...) Expand all Loading... |
| 531 CurrentWorkerId(), callbacks_id, | 526 CurrentWorkerId(), callbacks_id, |
| 532 base::Unretained(waitable_results), | 527 base::Unretained(waitable_results), |
| 533 main_thread_loop_), | 528 main_thread_loop_), |
| 534 base::Bind(&StatusCallbackAdapter, | 529 base::Bind(&StatusCallbackAdapter, |
| 535 CurrentWorkerId(), callbacks_id, | 530 CurrentWorkerId(), callbacks_id, |
| 536 base::Unretained(waitable_results))), | 531 base::Unretained(waitable_results))), |
| 537 make_scoped_ptr(waitable_results)); | 532 make_scoped_ptr(waitable_results)); |
| 538 } | 533 } |
| 539 | 534 |
| 540 } // namespace content | 535 } // namespace content |
| OLD | NEW |