Close all writers before JingleSession is destroyed.

remoting/protocol/connection_to_host.h

 // Copyright (c) 2011 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 <string>
 
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/task.h"
 #include "remoting/jingle_glue/signal_strategy.h"
 #include "remoting/proto/internal.pb.h"
 #include "remoting/protocol/connection_to_host.h"
-#include "remoting/protocol/host_stub.h"
-#include "remoting/protocol/input_stub.h"
 #include "remoting/protocol/message_reader.h"
 #include "remoting/protocol/session.h"
 #include "remoting/protocol/session_manager.h"
 
 class MessageLoop;
 
 namespace talk_base {
 class NetworkManager;
 class PacketSocketFactory;
 }  // namespace talk_base
 
 namespace remoting {
 
 class JingleThread;
 class PortAllocatorSessionFactory;
 class XmppProxy;
 class VideoPacket;
 
 namespace protocol {
 
 class ClientMessageDispatcher;
+class ClientControlSender;
 class ClientStub;
+class HostControlSender;
+class HostStub;
+class InputSender;
+class InputStub;
 class SessionConfig;
 class VideoReader;
 class VideoStub;
 
 class ConnectionToHost : public SignalStrategy::StatusObserver {
  public:
   enum State {
     STATE_EMPTY,
     STATE_CONNECTED,
     STATE_AUTHENTICATED,
@@ skipping 62 matching lines @@
   State state() const;
 
  private:
   // Called on the jingle thread after we've successfully to XMPP server. Starts
   // P2P connection to the host.
   void InitSession();
 
   // Callback for |video_reader_|.
   void OnVideoPacket(VideoPacket* packet);
 
+  // Stops writing in the channels.
+  void CloseChannels();
+
   // Used by Disconnect() to disconnect chromoting connection, stop chromoting
   // server, and then disconnect XMPP connection.
   void OnDisconnected(const base::Closure& shutdown_task);
   void OnServerClosed(const base::Closure& shutdown_task);
 
   // Internal state of the connection.
   State state_;
 
   MessageLoop* message_loop_;
 
@@ skipping 13 matching lines @@
   std::string host_jid_;
   std::string host_public_key_;
   std::string access_code_;
 
   scoped_ptr<ClientMessageDispatcher> dispatcher_;
 
   ////////////////////////////////////////////////////////////////////////////
   // User input event channel interface
 
   // Stub for sending input event messages to the host.
-  scoped_ptr<InputStub> input_stub_;
+  scoped_ptr<InputSender> input_sender_;
 
   ////////////////////////////////////////////////////////////////////////////
   // Protocol control channel interface
 
   // Stub for sending control messages to the host.
-  scoped_ptr<HostStub> host_stub_;
+  scoped_ptr<HostControlSender> host_control_sender_;
 
   // Stub for receiving control messages from the host.
   ClientStub* client_stub_;
 
   ////////////////////////////////////////////////////////////////////////////
   // Video channel interface
 
   // Stub for receiving video packets from the host.
   VideoStub* video_stub_;
 
  private:
   DISALLOW_COPY_AND_ASSIGN(ConnectionToHost);
 };
 
 }  // namespace protocol
 }  // namespace remoting
 
 DISABLE_RUNNABLE_METHOD_REFCOUNT(remoting::protocol::ConnectionToHost);
 
 #endif  // REMOTING_PROTOCOL_CONNECTION_TO_HOST_H_