Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(14)

Side by Side Diff: content/child/resource_dispatcher.cc

Issue 23696002: Propagate the encoded data length through OnDownloadData delegate method (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 7 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « content/child/resource_dispatcher.h ('k') | content/child/resource_dispatcher_unittest.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 // See http://dev.chromium.org/developers/design-documents/multi-process-resourc e-loading 5 // See http://dev.chromium.org/developers/design-documents/multi-process-resourc e-loading
6 6
7 #include "content/child/resource_dispatcher.h" 7 #include "content/child/resource_dispatcher.h"
8 8
9 #include "base/basictypes.h" 9 #include "base/basictypes.h"
10 #include "base/bind.h" 10 #include "base/bind.h"
(...skipping 433 matching lines...) Expand 10 before | Expand all | Expand 10 after
444 base::TimeTicks::Now() - time_start); 444 base::TimeTicks::Now() - time_start);
445 } 445 }
446 446
447 // Acknowledge the reception of this data. 447 // Acknowledge the reception of this data.
448 message_sender()->Send( 448 message_sender()->Send(
449 new ResourceHostMsg_DataReceived_ACK(message.routing_id(), request_id)); 449 new ResourceHostMsg_DataReceived_ACK(message.routing_id(), request_id));
450 } 450 }
451 451
452 void ResourceDispatcher::OnDownloadedData(const IPC::Message& message, 452 void ResourceDispatcher::OnDownloadedData(const IPC::Message& message,
453 int request_id, 453 int request_id,
454 int data_len) { 454 int data_len,
455 int encoded_data_length) {
455 // Acknowledge the reception of this message. 456 // Acknowledge the reception of this message.
456 message_sender()->Send( 457 message_sender()->Send(
457 new ResourceHostMsg_DataDownloaded_ACK(message.routing_id(), request_id)); 458 new ResourceHostMsg_DataDownloaded_ACK(message.routing_id(), request_id));
458 459
459 PendingRequestInfo* request_info = GetPendingRequestInfo(request_id); 460 PendingRequestInfo* request_info = GetPendingRequestInfo(request_id);
460 if (!request_info) 461 if (!request_info)
461 return; 462 return;
462 463
463 request_info->peer->OnDownloadedData(data_len); 464 request_info->peer->OnDownloadedData(data_len, encoded_data_length);
464 } 465 }
465 466
466 void ResourceDispatcher::OnReceivedRedirect( 467 void ResourceDispatcher::OnReceivedRedirect(
467 const IPC::Message& message, 468 const IPC::Message& message,
468 int request_id, 469 int request_id,
469 const GURL& new_url, 470 const GURL& new_url,
470 const ResourceResponseHead& response_head) { 471 const ResourceResponseHead& response_head) {
471 PendingRequestInfo* request_info = GetPendingRequestInfo(request_id); 472 PendingRequestInfo* request_info = GetPendingRequestInfo(request_id);
472 if (!request_info) 473 if (!request_info)
473 return; 474 return;
(...skipping 319 matching lines...) Expand 10 before | Expand all | Expand 10 after
793 void ResourceDispatcher::ReleaseResourcesInMessageQueue(MessageQueue* queue) { 794 void ResourceDispatcher::ReleaseResourcesInMessageQueue(MessageQueue* queue) {
794 while (!queue->empty()) { 795 while (!queue->empty()) {
795 IPC::Message* message = queue->front(); 796 IPC::Message* message = queue->front();
796 ReleaseResourcesInDataMessage(*message); 797 ReleaseResourcesInDataMessage(*message);
797 queue->pop_front(); 798 queue->pop_front();
798 delete message; 799 delete message;
799 } 800 }
800 } 801 }
801 802
802 } // namespace content 803 } // namespace content
OLDNEW
« no previous file with comments | « content/child/resource_dispatcher.h ('k') | content/child/resource_dispatcher_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698