Support synchronous mode in WebFileWriterImpl

content/child/fileapi/webfilesystem_impl.cc

 // Copyright 2013 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "content/child/fileapi/webfilesystem_impl.h"
 
 #include "base/bind.h"
 #include "base/id_map.h"
 #include "base/lazy_instance.h"
 #include "base/logging.h"
@@ skipping 234 matching lines @@
     return;
 
   WebFileSystemCallbacks* callbacks =
       CallbacksMap::Get()->GetAndUnregisterCallbacks(callbacks_id);
   DCHECK(callbacks);
 
   if (file_info.is_directory || file_info.size < 0) {
     callbacks->didFail(WebKit::WebFileErrorInvalidState);
     return;
   }
+  WebFileWriterImpl::Type type = callbacks->shouldBlockUntilCompletion() ?
+      WebFileWriterImpl::TYPE_SYNC : WebFileWriterImpl::TYPE_ASYNC;
   callbacks->didCreateFileWriter(
-      new WebFileWriterImpl(path, client, main_thread_loop), file_info.size);
+      new WebFileWriterImpl(path, client, type, main_thread_loop),
+      file_info.size);
 }
 
 void CreateFileWriterCallbackAdapter(
     int thread_id, int callbacks_id,
     WaitableCallbackResults* waitable_results,
     base::MessageLoopProxy* main_thread_loop,
     const GURL& path,
     WebKit::WebFileWriterClient* client,
     const base::PlatformFileInfo& file_info) {
   DispatchResultsClosure(
@@ skipping 214 matching lines @@
                            CurrentWorkerId(), callbacks_id,
                            base::Unretained(waitable_results)),
                 base::Bind(&StatusCallbackAdapter,
                            CurrentWorkerId(), callbacks_id,
 base::Unretained(waitable_results))),
       make_scoped_ptr(waitable_results));
 }
 
 WebKit::WebFileWriter* WebFileSystemImpl::createFileWriter(
     const WebURL& path, WebKit::WebFileWriterClient* client) {
-  return new WebFileWriterImpl(GURL(path), client, main_thread_loop_.get());
+  return new WebFileWriterImpl(GURL(path), client,
+                               WebFileWriterImpl::TYPE_ASYNC,
+                               main_thread_loop_.get());
 }
 
 void WebFileSystemImpl::createFileWriter(
     const WebURL& path,
     WebKit::WebFileWriterClient* client,
     WebKit::WebFileSystemCallbacks* callbacks) {
   int callbacks_id = CallbacksMap::GetOrCreate()->RegisterCallbacks(callbacks);
   WaitableCallbackResults* waitable_results =
       WaitableCallbackResults::MaybeCreate(callbacks);
   CallDispatcherOnMainThread(
@@ skipping 24 matching lines @@
                            CurrentWorkerId(), callbacks_id,
                            base::Unretained(waitable_results),
                            main_thread_loop_),
                 base::Bind(&StatusCallbackAdapter,
                            CurrentWorkerId(), callbacks_id,
                            base::Unretained(waitable_results))),
       make_scoped_ptr(waitable_results));
 }
 
 }  // namespace content