blob: cae7e64cbc487b07b357151d038fba06db8a7255 [file] [log] [blame]
// 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 "base/callback_forward.h"
#include "base/memory/scoped_ptr.h"
#include "base/memory/weak_ptr.h"
#include "content/common/content_export.h"
#include "content/public/browser/browser_message_filter.h"
#include "content/public/common/resource_type.h"
struct ResourceHostMsg_Request;
namespace fileapi {
class FileSystemContext;
} // namespace fileapi
namespace net {
class URLRequestContext;
} // namespace net
namespace content {
class ChromeAppCacheService;
class ChromeBlobStorageContext;
class ResourceContext;
class ServiceWorkerContextWrapper;
// This class filters out incoming IPC messages for network requests and
// processes them on the IPC thread. As a result, network requests are not
// delayed by costly UI processing that may be occuring on the main thread of
// the browser. It also means that any hangs in starting a network request
// will not interfere with browser UI.
class CONTENT_EXPORT ResourceMessageFilter : public BrowserMessageFilter {
typedef base::Callback<void(const ResourceHostMsg_Request&,
net::URLRequestContext**)> GetContextsCallback;
// |appcache_service|, |blob_storage_context|, |file_system_context| may be
// NULL in unittests or for requests from the (NPAPI) plugin process.
int child_id,
int process_type,
ChromeAppCacheService* appcache_service,
ChromeBlobStorageContext* blob_storage_context,
fileapi::FileSystemContext* file_system_context,
ServiceWorkerContextWrapper* service_worker_context,
const GetContextsCallback& get_contexts_callback);
// BrowserMessageFilter implementation.
virtual void OnChannelClosing() OVERRIDE;
virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE;
void GetContexts(const ResourceHostMsg_Request& request,
ResourceContext** resource_context,
net::URLRequestContext** request_context);
// Returns the net::URLRequestContext for the given request.
net::URLRequestContext* GetURLRequestContext(ResourceType request_type);
ChromeAppCacheService* appcache_service() const {
return appcache_service_.get();
ChromeBlobStorageContext* blob_storage_context() const {
return blob_storage_context_.get();
fileapi::FileSystemContext* file_system_context() const {
return file_system_context_.get();
ServiceWorkerContextWrapper* service_worker_context() const {
return service_worker_context_.get();
int child_id() const { return child_id_; }
int process_type() const { return process_type_; }
base::WeakPtr<ResourceMessageFilter> GetWeakPtr();
// Protected destructor so that we can be overriden in tests.
virtual ~ResourceMessageFilter();
// The ID of the child process.
int child_id_;
int process_type_;
scoped_refptr<ChromeAppCacheService> appcache_service_;
scoped_refptr<ChromeBlobStorageContext> blob_storage_context_;
scoped_refptr<fileapi::FileSystemContext> file_system_context_;
scoped_refptr<ServiceWorkerContextWrapper> service_worker_context_;
GetContextsCallback get_contexts_callback_;
// This must come last to make sure weak pointers are invalidated first.
base::WeakPtrFactory<ResourceMessageFilter> weak_ptr_factory_;
} // namespace content