Notify NetworkDelegate when bytes have been received over the network.

net/url_request/url_request_http_job.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "net/url_request/url_request_http_job.h"
 
 #include "base/base_switches.h"
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/command_line.h"
@@ skipping 179 matching lines @@
       bytes_observed_in_packets_(0),
       request_time_snapshot_(),
       final_packet_time_(),
       filter_context_(new HttpFilterContext(this)),
       on_headers_received_callback_(
           base::Bind(&URLRequestHttpJob::OnHeadersReceivedCallback,
                      base::Unretained(this))),
       awaiting_callback_(false),
       http_user_agent_settings_(http_user_agent_settings),
       backoff_manager_(request->context()->backoff_manager()),
+      total_received_bytes_from_previous_transactions_(0),
       weak_factory_(this) {
   URLRequestThrottlerManager* manager = request->context()->throttler_manager();
   if (manager)
     throttling_entry_ = manager->RegisterRequestUrl(request->url());
 
   ResetTimer();
 }
 
 URLRequestHttpJob::~URLRequestHttpJob() {
   CHECK(!awaiting_callback_);
@@ skipping 204 matching lines @@
 
 void URLRequestHttpJob::NotifyDone(const URLRequestStatus& status) {
   DoneWithRequest(FINISHED);
   URLRequestJob::NotifyDone(status);
 }
 
 void URLRequestHttpJob::DestroyTransaction() {
   DCHECK(transaction_.get());
 
   DoneWithRequest(ABORTED);
+
+  total_received_bytes_from_previous_transactions_ +=
+      transaction_->GetTotalReceivedBytes();
   transaction_.reset();
   response_info_ = NULL;
   receive_headers_end_ = base::TimeTicks();
 }
 
 void URLRequestHttpJob::StartTransaction() {
   // TODO(mmenke): Remove ScopedTracker below once crbug.com/456327 is fixed.
   tracked_objects::ScopedTracker tracking_profile(
       FROM_HERE_WITH_EXPLICIT_FUNCTION(
           "456327 URLRequestHttpJob::StartTransaction"));
@@ skipping 918 matching lines @@
 
 bool URLRequestHttpJob::GetFullRequestHeaders(
     HttpRequestHeaders* headers) const {
   if (!transaction_)
     return false;
 
   return transaction_->GetFullRequestHeaders(headers);
 }
 
 int64 URLRequestHttpJob::GetTotalReceivedBytes() const {
-  if (!transaction_)
-    return 0;
-
-  return transaction_->GetTotalReceivedBytes();
+  int64_t total_received_bytes =
+      total_received_bytes_from_previous_transactions_;
+  if (transaction_)
+    total_received_bytes += transaction_->GetTotalReceivedBytes();
+  return total_received_bytes;
 }
 
 void URLRequestHttpJob::DoneReading() {
   if (transaction_) {
     transaction_->DoneReading();
   }
   DoneWithRequest(FINISHED);
 }
 
 void URLRequestHttpJob::DoneReadingRedirectResponse() {
@@ skipping 176 matching lines @@
   return override_response_headers_.get() ?
              override_response_headers_.get() :
              transaction_->GetResponseInfo()->headers.get();
 }
 
 void URLRequestHttpJob::NotifyURLRequestDestroyed() {
   awaiting_callback_ = false;
 }
 
 }  // namespace net