| Index: content/child/blob_storage/blob_message_filter.h
|
| diff --git a/content/child/blob_storage/blob_message_filter.h b/content/child/blob_storage/blob_message_filter.h
|
| index 26266658a22e301cc61aa3f27ec15198ed1a4d96..a539a05d85658a3eced39050ebc96808eec545ca 100644
|
| --- a/content/child/blob_storage/blob_message_filter.h
|
| +++ b/content/child/blob_storage/blob_message_filter.h
|
| @@ -11,11 +11,16 @@
|
| #include <vector>
|
|
|
| #include "base/macros.h"
|
| +#include "base/memory/ref_counted.h"
|
| #include "base/memory/shared_memory.h"
|
| #include "ipc/ipc_platform_file.h"
|
| #include "ipc/message_filter.h"
|
| #include "storage/common/blob_storage/blob_storage_constants.h"
|
|
|
| +namespace base {
|
| +class TaskRunner;
|
| +}
|
| +
|
| namespace IPC {
|
| class Sender;
|
| class Message;
|
| @@ -23,6 +28,7 @@ class Message;
|
|
|
| namespace storage {
|
| struct BlobItemBytesRequest;
|
| +struct BlobItemBytesResponse;
|
| }
|
|
|
| namespace content {
|
| @@ -32,8 +38,10 @@ namespace content {
|
| // operated on by the IO thread.
|
| class BlobMessageFilter : public IPC::MessageFilter {
|
| public:
|
| - BlobMessageFilter();
|
| + BlobMessageFilter(scoped_refptr<base::TaskRunner> io_runner,
|
| + scoped_refptr<base::TaskRunner> file_runner);
|
|
|
| + void OnChannelClosing() override;
|
| void OnFilterAdded(IPC::Sender* sender) override;
|
| bool OnMessageReceived(const IPC::Message& message) override;
|
| bool GetSupportedMessageClasses(
|
| @@ -51,10 +59,18 @@ class BlobMessageFilter : public IPC::MessageFilter {
|
|
|
| void OnCancelBuildingBlob(const std::string& uuid,
|
| storage::IPCBlobCreationCancelCode code);
|
| + void SendResponses(
|
| + const std::string& uuid,
|
| + const std::vector<storage::BlobItemBytesResponse>& responses);
|
| +
|
| + void SendCancel(const std::string& uuid,
|
| + storage::IPCBlobCreationCancelCode code);
|
|
|
| void OnDoneBuildingBlob(const std::string& uuid);
|
|
|
| IPC::Sender* sender_;
|
| + scoped_refptr<base::TaskRunner> io_runner_;
|
| + scoped_refptr<base::TaskRunner> file_runner_;
|
|
|
| DISALLOW_COPY_AND_ASSIGN(BlobMessageFilter);
|
| };
|
|
|