| 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() {}
|
|
|
|
|