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); |
}; |