Implemented QuicHttpStream::GetTotalSentBytes.

net/quic/quic_http_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_http_stream.h"
 
 #include "base/callback_helpers.h"
 #ifdef TEMP_INSTRUMENTATION_468529
 #include "base/debug/alias.h"
 #endif
@@ skipping 23 matching lines @@
       session_error_(OK),
       was_handshake_confirmed_(session->IsCryptoHandshakeConfirmed()),
       stream_(nullptr),
       request_info_(nullptr),
       request_body_stream_(nullptr),
       priority_(MINIMUM_PRIORITY),
       response_info_(nullptr),
       response_status_(OK),
       response_headers_received_(false),
       closed_stream_received_bytes_(0),
+      closed_stream_sent_bytes_(0),
       user_buffer_len_(0),
       weak_factory_(this) {
   DCHECK(session_);
   session_->AddObserver(this);
 }
 
 QuicHttpStream::~QuicHttpStream() {
 #ifdef TEMP_INSTRUMENTATION_468529
   liveness_ = DEAD;
   stack_trace_ = base::debug::StackTrace();
@@ skipping 192 matching lines @@
 void QuicHttpStream::SetConnectionReused() {
   // QUIC doesn't need an indicator here.
 }
 
 bool QuicHttpStream::CanReuseConnection() const {
   // QUIC streams aren't considered reusable.
   return false;
 }
 
 int64 QuicHttpStream::GetTotalReceivedBytes() const {
+  // TODO(sclittle): Currently, this only includes response body bytes. Change
+  // this to include headers and QUIC overhead as well.
   if (stream_) {
     return stream_->stream_bytes_read();
   }
 
   return closed_stream_received_bytes_;
 }
 
 int64_t QuicHttpStream::GetTotalSentBytes() const {
-  // TODO(sclittle): Implement this for real. http://crbug.com/518897.
-  return 0;
+  // TODO(sclittle): Currently, this only includes request body bytes. Change
+  // this to include headers and QUIC overhead as well.
+  if (stream_) {
+    return stream_->stream_bytes_written();
+  }
+
+  return closed_stream_sent_bytes_;
 }
 
 bool QuicHttpStream::GetLoadTimingInfo(LoadTimingInfo* load_timing_info) const {
   // TODO(mmenke):  Figure out what to do here.
   return true;
 }
 
 void QuicHttpStream::GetSSLInfo(SSLInfo* ssl_info) {
   DCHECK(stream_);
   session_->GetSSLInfo(ssl_info);
@@ skipping 264 matching lines @@
 }
 
 SpdyMajorVersion QuicHttpStream::GetSpdyVersion() {
   return SpdyUtils::GetSpdyVersionForQuicVersion(stream_->version());
 }
 
 void QuicHttpStream::ResetStream() {
   if (!stream_)
     return;
   closed_stream_received_bytes_ = stream_->stream_bytes_read();
+  closed_stream_sent_bytes_ = stream_->stream_bytes_written();
   stream_ = nullptr;
 
   // If |request_body_stream_| is non-NULL, Reset it, to abort any in progress
   // read.
   if (request_body_stream_)
     request_body_stream_->Reset();
 }
 
 void QuicHttpStream::CrashIfInvalid() const {
 #ifdef TEMP_INSTRUMENTATION_468529
   Liveness liveness = liveness_;
 
   if (liveness == ALIVE)
     return;
 
   // Copy relevant variables onto the stack to guarantee they will be available
   // in minidumps, and then crash.
   base::debug::StackTrace stack_trace = stack_trace_;
 
   base::debug::Alias(&liveness);
   base::debug::Alias(&stack_trace);
 
   CHECK_EQ(ALIVE, liveness);
 #endif
 }
 
 }  // namespace net