Implementation of shared worker code path for WebView file system permission.

content/browser/worker_host/worker_process_host.cc

 // Copyright (c) 2012 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/browser/worker_host/worker_process_host.h"
 
 #include <set>
 #include <string>
 #include <vector>
 
@@ skipping 123 matching lines @@
                                                          worker_process_id);
 }
 
 }  // namespace
 
 WorkerProcessHost::WorkerProcessHost(
     ResourceContext* resource_context,
     const WorkerStoragePartition& partition)
     : resource_context_(resource_context),
       partition_(partition),
-      process_launched_(false) {
+      process_launched_(false),
+      weak_factory_(this) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
   DCHECK(resource_context_);
   process_.reset(
       new BrowserChildProcessHostImpl(PROCESS_TYPE_WORKER, this));
 }
 
 WorkerProcessHost::~WorkerProcessHost() {
   // If we crashed, tell the RenderViewHosts.
   for (Instances::iterator i = instances_.begin(); i != instances_.end(); ++i) {
     if (!i->load_failed()) {
@@ skipping 224 matching lines @@
                         OnWorkerContextClosed)
     IPC_MESSAGE_HANDLER(WorkerHostMsg_WorkerContextDestroyed,
                         OnWorkerContextDestroyed)
     IPC_MESSAGE_HANDLER(WorkerHostMsg_WorkerScriptLoaded,
                         OnWorkerScriptLoaded)
     IPC_MESSAGE_HANDLER(WorkerHostMsg_WorkerScriptLoadFailed,
                         OnWorkerScriptLoadFailed)
     IPC_MESSAGE_HANDLER(WorkerHostMsg_WorkerConnected,
                         OnWorkerConnected)
     IPC_MESSAGE_HANDLER(WorkerProcessHostMsg_AllowDatabase, OnAllowDatabase)
-    IPC_MESSAGE_HANDLER(WorkerProcessHostMsg_RequestFileSystemAccessSync,
-                        OnRequestFileSystemAccessSync)
+    IPC_MESSAGE_HANDLER_DELAY_REPLY(
+        WorkerProcessHostMsg_RequestFileSystemAccessSync,
+        OnRequestFileSystemAccess)
     IPC_MESSAGE_HANDLER(WorkerProcessHostMsg_AllowIndexedDB, OnAllowIndexedDB)
     IPC_MESSAGE_HANDLER(WorkerProcessHostMsg_ForceKillWorker,
                         OnForceKillWorkerProcess)
     IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP()
 
   return handled;
 }
 
 // Sent to notify the browser process when a worker context invokes close(), so
@@ skipping 65 matching lines @@
                                         const GURL& url,
                                         const base::string16& name,
                                         const base::string16& display_name,
                                         unsigned long estimated_size,
                                         bool* result) {
   *result = GetContentClient()->browser()->AllowWorkerDatabase(
       url, name, display_name, estimated_size, resource_context_,
       GetRenderFrameIDsForWorker(worker_route_id));
 }
 
-void WorkerProcessHost::OnRequestFileSystemAccessSync(int worker_route_id,
-                                                      const GURL& url,
-                                                      bool* result) {
-  *result = GetContentClient()->browser()->AllowWorkerFileSystem(
-      url, resource_context_, GetRenderFrameIDsForWorker(worker_route_id));
+void WorkerProcessHost::OnRequestFileSystemAccess(int worker_route_id,
+                                                  const GURL& url,
+                                                  IPC::Message* reply_msg) {
+  GetContentClient()->browser()->RequestWorkerFileSystemAccess(
+      url,
+      resource_context_,
+      GetRenderFrameIDsForWorker(worker_route_id),
+      base::Bind(&WorkerProcessHost::OnRequestFileSystemAccessResponse,
+                 weak_factory_.GetWeakPtr(),
+                 base::Passed(scoped_ptr<IPC::Message>(reply_msg))));
+}
+
+void WorkerProcessHost::OnRequestFileSystemAccessResponse(
+    scoped_ptr<IPC::Message> reply_msg,
+    bool allowed) {
+  WorkerProcessHostMsg_RequestFileSystemAccessSync::WriteReplyParams(
+      reply_msg.get(),
+      allowed);
+  Send(reply_msg.release());
 }
 
 void WorkerProcessHost::OnAllowIndexedDB(int worker_route_id,
                                          const GURL& url,
                                          const base::string16& name,
                                          bool* result) {
   *result = GetContentClient()->browser()->AllowWorkerIndexedDB(
       url, name, resource_context_,
       GetRenderFrameIDsForWorker(worker_route_id));
 }
@@ skipping 330 matching lines @@
   return false;
 }
 
 WorkerProcessHost::WorkerInstance::FilterInfo
 WorkerProcessHost::WorkerInstance::GetFilter() const {
   DCHECK(NumFilters() == 1);
   return *filters_.begin();
 }
 
 }  // namespace content