Measure bandwidth for chromoting video channel

remoting/client/chromoting_client.cc

 // Copyright (c) 2010 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 "remoting/client/chromoting_client.h"
 
 #include "base/message_loop.h"
 #include "remoting/base/tracer.h"
 #include "remoting/client/chromoting_view.h"
 #include "remoting/client/client_context.h"
@@ skipping 74 matching lines @@
 
   view_->TearDown();
 }
 
 void ChromotingClient::ClientDone() {
   if (client_done_ != NULL) {
     message_loop()->PostTask(FROM_HERE, client_done_);
   }
 }
 
+ChromotingStats* ChromotingClient::GetStats() {
+  return &stats_;
+}
+
 void ChromotingClient::Repaint() {
   if (message_loop() != MessageLoop::current()) {
     message_loop()->PostTask(
         FROM_HERE,
         NewRunnableMethod(this, &ChromotingClient::Repaint));
     return;
   }
 
   view_->Paint();
 }
@@ skipping 13 matching lines @@
 void ChromotingClient::ProcessVideoPacket(const VideoPacket* packet,
                                           Task* done) {
   if (message_loop() != MessageLoop::current()) {
     message_loop()->PostTask(
         FROM_HERE,
         NewRunnableMethod(this, &ChromotingClient::ProcessVideoPacket,
                           packet, done));
     return;
   }
 
+  // Record size of the packet for statistics.
+  stats_.video_bandwidth()->Record(packet->data().size());
+
   received_packets_.push_back(QueuedVideoPacket(packet, done));
   if (!packet_being_processed_)
     DispatchPacket();
 }
 
 int ChromotingClient::GetPendingPackets() {
   return received_packets_.size();
 }
 
 void ChromotingClient::DispatchPacket() {
@@ skipping 121 matching lines @@
   if (msg->success()) {
     connection_->OnClientAuthenticated();
   }
 
   view_->UpdateLoginStatus(msg->success(), msg->error_info());
   done->Run();
   delete done;
 }
 
 }  // namespace remoting