Blob support for IDB [Chromium]

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 212 matching lines @@
       get_contexts_callback);
   process_->GetHost()->AddFilter(resource_message_filter);
 
   worker_message_filter_ = new WorkerMessageFilter(
       render_process_id, resource_context_, partition_,
       base::Bind(&WorkerServiceImpl::next_worker_route_id,
                  base::Unretained(WorkerServiceImpl::GetInstance())));
   process_->GetHost()->AddFilter(worker_message_filter_.get());
   process_->GetHost()->AddFilter(new AppCacheDispatcherHost(
       partition_.appcache_service(), process_->GetData().id));
-  process_->GetHost()->AddFilter(new FileAPIMessageFilter(
-      process_->GetData().id,
-      url_request_context,
-      partition_.filesystem_context(),
-      blob_storage_context,
-      stream_context));
   process_->GetHost()->AddFilter(new FileUtilitiesMessageFilter(
       process_->GetData().id));
   process_->GetHost()->AddFilter(new MimeRegistryMessageFilter());
   process_->GetHost()->AddFilter(
       new DatabaseMessageFilter(partition_.database_tracker()));
   process_->GetHost()->AddFilter(new QuotaDispatcherHost(
       process_->GetData().id,
       partition_.quota_manager(),
       GetContentClient()->browser()->CreateQuotaPermissionContext()));
 
   SocketStreamDispatcherHost::GetRequestContextCallback
       request_context_callback(
           base::Bind(&WorkerProcessHost::GetRequestContext,
           base::Unretained(this)));
 
   SocketStreamDispatcherHost* socket_stream_dispatcher_host =
       new SocketStreamDispatcherHost(
           render_process_id,
           request_context_callback,
           resource_context_);
   socket_stream_dispatcher_host_ = socket_stream_dispatcher_host;
   process_->GetHost()->AddFilter(socket_stream_dispatcher_host);
   process_->GetHost()->AddFilter(
       new WorkerDevToolsMessageFilter(process_->GetData().id));
-  process_->GetHost()->AddFilter(new IndexedDBDispatcherHost(
-      process_->GetData().id, partition_.indexed_db_context()));
+  {
+    FileAPIMessageFilter* file_api_message_filter = new FileAPIMessageFilter(
+        process_->GetData().id,
+        url_request_context,
+        partition_.filesystem_context(),
+        blob_storage_context,
+        stream_context);
+    process_->GetHost()->AddFilter(file_api_message_filter);
+    process_->GetHost()->AddFilter(new IndexedDBDispatcherHost(
+        process_->GetData().id, url_request_context,
+        partition_.indexed_db_context(),
+        file_api_message_filter));
+  }
 }
 
 void WorkerProcessHost::CreateWorker(const WorkerInstance& instance) {
   ChildProcessSecurityPolicyImpl::GetInstance()->GrantRequestURL(
       process_->GetData().id, instance.url());
 
   instances_.push_back(instance);
 
   WorkerProcessMsg_CreateWorker_Params params;
   params.url = instance.url();
@@ skipping 436 matching lines @@
   return false;
 }
 
 WorkerProcessHost::WorkerInstance::FilterInfo
 WorkerProcessHost::WorkerInstance::GetFilter() const {
   DCHECK(NumFilters() == 1);
   return *filters_.begin();
 }
 
 }  // namespace content