Propagate connection state from networking layer to UI.

remoting/protocol/connection_to_host.h

 // 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.
 
 #ifndef REMOTING_PROTOCOL_CONNECTION_TO_HOST_H_
 #define REMOTING_PROTOCOL_CONNECTION_TO_HOST_H_
 
+#include <set>
 #include <string>
 
 #include "base/callback_forward.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/threading/non_thread_safe.h"
 #include "remoting/jingle_glue/signal_strategy.h"
 #include "remoting/proto/internal.pb.h"
 #include "remoting/protocol/clipboard_filter.h"
 #include "remoting/protocol/errors.h"
@@ skipping 39 matching lines @@
     FAILED,
     CLOSED,
   };
 
   class HostEventCallback {
    public:
     virtual ~HostEventCallback() {}
 
     // Called when state of the connection changes.
     virtual void OnConnectionState(State state, ErrorCode error) = 0;
+
+    // Called when ready state of the connection changes. When |ready|
+    // is set to false some data sent by the peers may be
+    // delayed. This is used to indicate in the UI when connection is
+    // temporarily broken.
+    virtual void OnConnectionReady(bool ready) = 0;
   };
 
   ConnectionToHost(bool allow_nat_traversal);
   virtual ~ConnectionToHost();
 
   virtual void Connect(scoped_refptr<XmppProxy> xmpp_proxy,
                        const std::string& local_jid,
                        const std::string& host_jid,
                        const std::string& host_public_key,
                        scoped_ptr<TransportFactory> transport_factory,
@@ skipping 20 matching lines @@
   // SessionManager::Listener interface.
   virtual void OnSessionManagerReady() OVERRIDE;
   virtual void OnIncomingSession(
       Session* session,
       SessionManager::IncomingSessionResponse* response) OVERRIDE;
 
   // Session::EventHandler interface.
   virtual void OnSessionStateChange(Session::State state) OVERRIDE;
   virtual void OnSessionRouteChange(const std::string& channel_name,
                                     const TransportRoute& route) OVERRIDE;
+  virtual void OnSessionChannelReady(const std::string& channel_name,
+                                     bool ready) OVERRIDE;
 
   // Return the current state of ConnectionToHost.
   State state() const;
 
  private:
   // Callbacks for channel initialization
   void OnChannelInitialized(bool successful);
 
   void NotifyIfChannelsReady();
 
@@ skipping 26 matching lines @@
   scoped_ptr<AudioReader> audio_reader_;
   scoped_ptr<ClientControlDispatcher> control_dispatcher_;
   scoped_ptr<ClientEventDispatcher> event_dispatcher_;
   ClipboardFilter clipboard_forwarder_;
   InputFilter event_forwarder_;
 
   // Internal state of the connection.
   State state_;
   ErrorCode error_;
 
+  // List of channels that are not currently ready.
+  std::set<std::string> not_ready_channels_;
+
  private:
   DISALLOW_COPY_AND_ASSIGN(ConnectionToHost);
 };
 
 }  // namespace protocol
 }  // namespace remoting
 
 #endif  // REMOTING_PROTOCOL_CONNECTION_TO_HOST_H_