Index: content/browser/loader/async_resource_handler.h |
diff --git a/content/browser/loader/async_resource_handler.h b/content/browser/loader/async_resource_handler.h |
index 0991021336043dc8b4d990a24352ca6408aaa22d..38b178def3c4e95bc0fd7ff0c202f90ed692c604 100644 |
--- a/content/browser/loader/async_resource_handler.h |
+++ b/content/browser/loader/async_resource_handler.h |
@@ -14,6 +14,8 @@ |
#include "base/timer/timer.h" |
#include "content/browser/loader/resource_handler.h" |
#include "content/browser/loader/resource_message_delegate.h" |
+#include "mojo/message_pump/handle_watcher.h" |
+#include "mojo/public/cpp/system/data_pipe.h" |
#include "net/base/io_buffer.h" |
#include "url/gurl.h" |
@@ -34,7 +36,8 @@ class AsyncResourceHandler : public ResourceHandler, |
public ResourceMessageDelegate { |
public: |
AsyncResourceHandler(net::URLRequest* request, |
- ResourceDispatcherHostImpl* rdh); |
+ ResourceDispatcherHostImpl* rdh, |
+ bool using_mojo_data_handle); |
~AsyncResourceHandler() override; |
bool OnMessageReceived(const IPC::Message& message) override; |
@@ -71,6 +74,7 @@ class AsyncResourceHandler : public ResourceHandler, |
bool CheckForSufficientResource(); |
int CalculateEncodedDataLengthToReport(); |
void RecordHistogram(); |
+ void OnWritable(MojoResult result); |
scoped_refptr<ResourceBuffer> buffer_; |
ResourceDispatcherHostImpl* rdh_; |
@@ -86,6 +90,7 @@ class AsyncResourceHandler : public ResourceHandler, |
bool has_checked_for_sufficient_resources_; |
bool sent_received_response_msg_; |
bool sent_data_buffer_msg_; |
+ bool using_mojo_data_handle_; |
std::unique_ptr<InliningHelper> inlining_helper_; |
base::TimeTicks response_started_ticks_; |
@@ -97,6 +102,9 @@ class AsyncResourceHandler : public ResourceHandler, |
int64_t reported_transfer_size_; |
+ mojo::ScopedDataPipeProducerHandle writer_; |
+ mojo::common::HandleWatcher handle_watcher_; |
+ |
DISALLOW_COPY_AND_ASSIGN(AsyncResourceHandler); |
}; |