Added a debug info UI for Blimp

blimp/net/blimp_connection.cc

 // Copyright 2015 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 <blimp/net/blimp_connection_statistics.h>
 #include "blimp/net/blimp_connection.h"
 
 #include "base/callback_helpers.h"
 #include "base/logging.h"
 #include "base/macros.h"
 #include "base/memory/weak_ptr.h"
 #include "base/message_loop/message_loop.h"
 #include "blimp/common/logging.h"
 #include "blimp/common/proto/blimp_message.pb.h"
 #include "blimp/net/blimp_message_processor.h"
@@ skipping 14 matching lines @@
   ~BlimpMessageSender() override;
 
   void set_error_observer(ConnectionErrorObserver* observer) {
     error_observer_ = observer;
   }
 
   // BlimpMessageProcessor implementation.
   void ProcessMessage(std::unique_ptr<BlimpMessage> message,
                       const net::CompletionCallback& callback) override;
 
+  void SetBlimpConnectionStatistics(BlimpConnectionStatistics* statistics) {
+    DCHECK(writer_);
+    writer_->set_blimp_connection_statistics(statistics);
+  }
+
  private:
   void OnWritePacketComplete(int result);
 
   PacketWriter* writer_;
   ConnectionErrorObserver* error_observer_ = nullptr;
   scoped_refptr<net::IOBuffer> buffer_;
   net::CompletionCallback pending_process_msg_callback_;
   base::WeakPtrFactory<BlimpMessageSender> weak_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(BlimpMessageSender);
@@ skipping 80 matching lines @@
 void BlimpConnection::RemoveConnectionErrorObserver(
     ConnectionErrorObserver* observer) {
   error_observers_.RemoveObserver(observer);
 }
 
 void BlimpConnection::SetIncomingMessageProcessor(
     BlimpMessageProcessor* processor) {
   message_pump_->SetMessageProcessor(processor);
 }
 
+void BlimpConnection::SetBlimpConnectionStatistics(
+    BlimpConnectionStatistics* statistics) {
+  if (message_pump_) {

[Kevin M, 2016/05/20 01:02:03]

message_pump_ will always be set, ditto for the sender.

[shaktisahu, 2016/05/22 22:36:56]

Done.

+    message_pump_->SetBlimpConnectionStatistics(statistics);
+  }
+  BlimpMessageSender* sender =
+      static_cast<BlimpMessageSender*>(outgoing_msg_processor_.get());

[Kevin M, 2016/05/20 01:02:03]

Change the type of outgoing_msg_processor_ to a BlimpMessageSender instead of
using static_cast<>.

[shaktisahu, 2016/05/22 22:36:56]

In that case I have to forward declare BlimpMessageSender in header file and
remove the namespace wrapping from the .cc file. I don't think it is necessary
to expose this class.

+  if (sender) {
+    sender->SetBlimpConnectionStatistics(statistics);
+  }
+}
+
 BlimpMessageProcessor* BlimpConnection::GetOutgoingMessageProcessor() {
   return outgoing_msg_processor_.get();
 }
 
 void BlimpConnection::OnConnectionError(int error) {
   VLOG(1) << "OnConnectionError, error=" << error;
 
   // Propagate the error to all observers.
   FOR_EACH_OBSERVER(ConnectionErrorObserver, error_observers_,
                     OnConnectionError(error));
 }
 
 }  // namespace blimp