Index: content/child/resource_dispatcher.cc |
=================================================================== |
--- content/child/resource_dispatcher.cc (revision 221543) |
+++ content/child/resource_dispatcher.cc (working copy) |
@@ -200,7 +200,7 @@ |
} |
if (!is_synchronous_request_) |
- dispatcher_->CancelPendingRequest(routing_id_, request_id_); |
+ dispatcher_->CancelPendingRequest(request_id_); |
// We can't remove the request ID from the resource dispatcher because more |
// data might be pending. Sending the cancel message may cause more data |
@@ -324,8 +324,8 @@ |
return &(it->second); |
} |
-void ResourceDispatcher::OnUploadProgress( |
- const IPC::Message& message, int request_id, int64 position, int64 size) { |
+void ResourceDispatcher::OnUploadProgress(int request_id, int64 position, |
+ int64 size) { |
PendingRequestInfo* request_info = GetPendingRequestInfo(request_id); |
if (!request_info) |
return; |
@@ -333,8 +333,7 @@ |
request_info->peer->OnUploadProgress(position, size); |
// Acknowledge receipt |
- message_sender()->Send( |
- new ResourceHostMsg_UploadProgress_ACK(message.routing_id(), request_id)); |
+ message_sender()->Send(new ResourceHostMsg_UploadProgress_ACK(request_id)); |
} |
void ResourceDispatcher::OnReceivedResponse( |
@@ -373,8 +372,7 @@ |
request_info->peer->OnReceivedCachedMetadata(&data.front(), data.size()); |
} |
-void ResourceDispatcher::OnSetDataBuffer(const IPC::Message& message, |
- int request_id, |
+void ResourceDispatcher::OnSetDataBuffer(int request_id, |
base::SharedMemoryHandle shm_handle, |
int shm_size, |
base::ProcessId renderer_pid) { |
@@ -404,8 +402,7 @@ |
request_info->buffer_size = shm_size; |
} |
-void ResourceDispatcher::OnReceivedData(const IPC::Message& message, |
- int request_id, |
+void ResourceDispatcher::OnReceivedData(int request_id, |
int data_offset, |
int data_length, |
int encoded_data_length) { |
@@ -449,17 +446,15 @@ |
} |
// Acknowledge the reception of this data. |
- message_sender()->Send( |
- new ResourceHostMsg_DataReceived_ACK(message.routing_id(), request_id)); |
+ message_sender()->Send(new ResourceHostMsg_DataReceived_ACK(request_id)); |
} |
-void ResourceDispatcher::OnDownloadedData(const IPC::Message& message, |
- int request_id, |
+void ResourceDispatcher::OnDownloadedData(int request_id, |
int data_len, |
int encoded_data_length) { |
// Acknowledge the reception of this message. |
message_sender()->Send( |
- new ResourceHostMsg_DataDownloaded_ACK(message.routing_id(), request_id)); |
+ new ResourceHostMsg_DataDownloaded_ACK(request_id)); |
PendingRequestInfo* request_info = GetPendingRequestInfo(request_id); |
if (!request_info) |
@@ -469,7 +464,6 @@ |
} |
void ResourceDispatcher::OnReceivedRedirect( |
- const IPC::Message& message, |
int request_id, |
const GURL& new_url, |
const ResourceResponseHead& response_head) { |
@@ -478,7 +472,6 @@ |
return; |
request_info->response_start = ConsumeIOTimestamp(); |
- int32 routing_id = message.routing_id(); |
bool has_new_first_party_for_cookies = false; |
GURL new_first_party_for_cookies; |
ResourceResponseInfo renderer_response_info; |
@@ -495,14 +488,14 @@ |
// SiteIsolationPolicy later when OnReceivedResponse is called. |
request_info->response_url = new_url; |
request_info->pending_redirect_message.reset( |
- new ResourceHostMsg_FollowRedirect(routing_id, request_id, |
+ new ResourceHostMsg_FollowRedirect(request_id, |
has_new_first_party_for_cookies, |
new_first_party_for_cookies)); |
if (!request_info->is_deferred) { |
FollowPendingRedirect(request_id, *request_info); |
} |
} else { |
- CancelPendingRequest(routing_id, request_id); |
+ CancelPendingRequest(request_id); |
} |
} |
@@ -574,8 +567,7 @@ |
return true; |
} |
-void ResourceDispatcher::CancelPendingRequest(int routing_id, |
- int request_id) { |
+void ResourceDispatcher::CancelPendingRequest(int request_id) { |
PendingRequestList::iterator it = pending_requests_.find(request_id); |
if (it == pending_requests_.end()) { |
DVLOG(1) << "unknown request"; |
@@ -587,8 +579,7 @@ |
ReleaseResourcesInMessageQueue(&request_info.deferred_message_queue); |
pending_requests_.erase(it); |
- message_sender()->Send( |
- new ResourceHostMsg_CancelRequest(routing_id, request_id)); |
+ message_sender()->Send(new ResourceHostMsg_CancelRequest(request_id)); |
} |
void ResourceDispatcher::SetDefersLoading(int request_id, bool value) { |
@@ -617,7 +608,7 @@ |
int routing_id, int request_id, net::RequestPriority new_priority) { |
DCHECK(ContainsKey(pending_requests_, request_id)); |
message_sender()->Send(new ResourceHostMsg_DidChangePriority( |
- routing_id, request_id, new_priority)); |
+ request_id, new_priority)); |
} |
ResourceDispatcher::PendingRequestInfo::PendingRequestInfo() |