Index: content/child/resource_dispatcher.cc |
diff --git a/content/child/resource_dispatcher.cc b/content/child/resource_dispatcher.cc |
index be24da4af1e6da853f4d869a0f0f5e0ad2336c3c..dac5def79e5f7f0f4bf0e417cf58df14738e9688 100644 |
--- a/content/child/resource_dispatcher.cc |
+++ b/content/child/resource_dispatcher.cc |
@@ -22,12 +22,14 @@ |
#include "content/common/inter_process_time_ticks_converter.h" |
#include "content/common/resource_messages.h" |
#include "content/common/service_worker/service_worker_types.h" |
+#include "content/public/child/request_delegate_peer.h" |
#include "content/public/child/resource_dispatcher_delegate.h" |
#include "content/public/common/resource_response.h" |
#include "net/base/net_errors.h" |
#include "net/base/net_util.h" |
#include "net/base/request_priority.h" |
#include "net/http/http_response_headers.h" |
+#include "webkit/child/resource_loader_bridge.h" |
#include "webkit/common/resource_type.h" |
using webkit_glue::ResourceLoaderBridge; |
@@ -76,14 +78,14 @@ class IPCResourceLoaderBridge : public ResourceLoaderBridge { |
// ResourceLoaderBridge |
virtual void SetRequestBody(ResourceRequestBody* request_body) OVERRIDE; |
- virtual bool Start(Peer* peer) OVERRIDE; |
+ virtual bool Start(RequestDelegatePeer* peer) OVERRIDE; |
virtual void Cancel() OVERRIDE; |
virtual void SetDefersLoading(bool value) OVERRIDE; |
virtual void DidChangePriority(net::RequestPriority new_priority) OVERRIDE; |
virtual void SyncLoad(SyncLoadResponse* response) OVERRIDE; |
private: |
- ResourceLoaderBridge::Peer* peer_; |
+ RequestDelegatePeer* peer_; |
// The resource dispatcher for this loader. The bridge doesn't own it, but |
// it's guaranteed to outlive the bridge. |
@@ -184,7 +186,7 @@ void IPCResourceLoaderBridge::SetRequestBody( |
} |
// Writes a footer on the message and sends it |
-bool IPCResourceLoaderBridge::Start(Peer* peer) { |
+bool IPCResourceLoaderBridge::Start(RequestDelegatePeer* peer) { |
if (request_id_ != -1) { |
NOTREACHED() << "Starting a request twice"; |
return false; |
@@ -355,7 +357,7 @@ void ResourceDispatcher::OnReceivedResponse( |
request_info->response_start = ConsumeIOTimestamp(); |
if (delegate_) { |
- ResourceLoaderBridge::Peer* new_peer = |
+ RequestDelegatePeer* new_peer = |
delegate_->OnReceivedResponse( |
request_info->peer, response_head.mime_type, request_info->url); |
if (new_peer) |
@@ -539,10 +541,10 @@ void ResourceDispatcher::OnRequestComplete( |
request_info->buffer.reset(); |
request_info->buffer_size = 0; |
- ResourceLoaderBridge::Peer* peer = request_info->peer; |
+ RequestDelegatePeer* peer = request_info->peer; |
if (delegate_) { |
- ResourceLoaderBridge::Peer* new_peer = |
+ RequestDelegatePeer* new_peer = |
delegate_->OnRequestComplete( |
request_info->peer, request_info->resource_type, |
request_complete_data.error_code); |
@@ -563,12 +565,11 @@ void ResourceDispatcher::OnRequestComplete( |
request_complete_data.encoded_data_length); |
} |
-int ResourceDispatcher::AddPendingRequest( |
- ResourceLoaderBridge::Peer* callback, |
- ResourceType::Type resource_type, |
- int origin_pid, |
- const GURL& frame_origin, |
- const GURL& request_url) { |
+int ResourceDispatcher::AddPendingRequest(RequestDelegatePeer* callback, |
+ ResourceType::Type resource_type, |
+ int origin_pid, |
+ const GURL& frame_origin, |
+ const GURL& request_url) { |
// Compute a unique request_id for this renderer process. |
int id = MakeRequestID(); |
pending_requests_[id] = PendingRequestInfo( |
@@ -638,7 +639,7 @@ ResourceDispatcher::PendingRequestInfo::PendingRequestInfo() |
} |
ResourceDispatcher::PendingRequestInfo::PendingRequestInfo( |
- webkit_glue::ResourceLoaderBridge::Peer* peer, |
+ RequestDelegatePeer* peer, |
ResourceType::Type resource_type, |
int origin_pid, |
const GURL& frame_origin, |
@@ -651,8 +652,7 @@ ResourceDispatcher::PendingRequestInfo::PendingRequestInfo( |
frame_origin(frame_origin), |
response_url(request_url), |
request_start(base::TimeTicks::Now()), |
- blocked_response(false) { |
-} |
+ blocked_response(false) {} |
ResourceDispatcher::PendingRequestInfo::~PendingRequestInfo() {} |