Include HTTP header bytes in GetTotalSent/ReceivedBytes for QUIC.

net/quic/quic_reliable_client_stream.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/quic/quic_reliable_client_stream.h"
 
 #include "base/callback_helpers.h"
 #include "base/location.h"
 #include "base/thread_task_runner_handle.h"
 #include "net/base/io_buffer.h"
@@ skipping 15 matching lines @@
 
 QuicReliableClientStream::~QuicReliableClientStream() {
   if (delegate_)
     delegate_->OnClose(connection_error());
 }
 
 void QuicReliableClientStream::OnStreamHeadersComplete(bool fin,
                                                        size_t frame_len) {
   QuicDataStream::OnStreamHeadersComplete(fin, frame_len);
   // The delegate will read the headers via a posted task.
-  NotifyDelegateOfHeadersCompleteLater();
+  NotifyDelegateOfHeadersCompleteLater(frame_len);
 }
 
 void QuicReliableClientStream::OnDataAvailable() {
   // TODO(rch): buffer data if we don't have a delegate.
   if (!delegate_) {
     DLOG(ERROR) << "Missing delegate";
     Reset(QUIC_STREAM_CANCELLED);
     return;
   }
 
@@ skipping 79 matching lines @@
 bool QuicReliableClientStream::CanWrite(const CompletionCallback& callback) {
   bool can_write =  session()->connection()->CanWrite(HAS_RETRANSMITTABLE_DATA);
   if (!can_write) {
     session()->MarkConnectionLevelWriteBlocked(id(), EffectivePriority());
     DCHECK(callback_.is_null());
     callback_ = callback;
   }
   return can_write;
 }
 
-void QuicReliableClientStream::NotifyDelegateOfHeadersCompleteLater() {
+void QuicReliableClientStream::NotifyDelegateOfHeadersCompleteLater(
+    size_t frame_len) {
   DCHECK(delegate_);
   base::ThreadTaskRunnerHandle::Get()->PostTask(
       FROM_HERE,
       base::Bind(&QuicReliableClientStream::NotifyDelegateOfHeadersComplete,
-                 weak_factory_.GetWeakPtr()));
+                 weak_factory_.GetWeakPtr(), frame_len));
 }
 
-void QuicReliableClientStream::NotifyDelegateOfHeadersComplete() {
+void QuicReliableClientStream::NotifyDelegateOfHeadersComplete(
+    size_t frame_len) {
   if (!delegate_)
     return;
 
   size_t headers_len = decompressed_headers().length();
   SpdyHeaderBlock headers;
   SpdyFramer framer(SpdyUtils::GetSpdyVersionForQuicVersion(version()));
   size_t len = framer.ParseHeaderBlockInBuffer(decompressed_headers().data(),
                                                headers_len, &headers);
   MarkHeadersConsumed(headers_len);
   headers_delivered_ = true;
   if (len == 0 || len != headers_len) {
     DLOG(WARNING) << "Invalid headers";
     Reset(QUIC_BAD_APPLICATION_PAYLOAD);
     return;
   }
 
-  delegate_->OnHeadersAvailable(headers);
+  delegate_->OnHeadersAvailable(headers, frame_len);
 }
 
 void QuicReliableClientStream::NotifyDelegateOfDataAvailableLater() {
   DCHECK(delegate_);
   base::ThreadTaskRunnerHandle::Get()->PostTask(
       FROM_HERE,
       base::Bind(&QuicReliableClientStream::NotifyDelegateOfDataAvailable,
                  weak_factory_.GetWeakPtr()));
 }
 
 void QuicReliableClientStream::NotifyDelegateOfDataAvailable() {
   if (delegate_)
     delegate_->OnDataAvailable();
 }
 
 }  // namespace net