Refactor client channel dispatchers.

remoting/protocol/client_control_dispatcher.h

Index: remoting/protocol/client_control_dispatcher.h
diff --git a/remoting/protocol/client_control_dispatcher.h b/remoting/protocol/client_control_dispatcher.h
new file mode 100644
index 0000000000000000000000000000000000000000..005cc0d0ff6b4a7dec8bbfa99bbef0902e59ebfd
--- /dev/null
+++ b/remoting/protocol/client_control_dispatcher.h
@@ -0,0 +1,57 @@
+// 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_CLIENT_CONTROL_DISPATCHER_H_
+#define REMOTING_PROTOCOL_CLIENT_CONTROL_DISPATCHER_H_
+
+#include "base/basictypes.h"
+#include "base/memory/ref_counted.h"
+#include "remoting/protocol/host_stub.h"
+#include "remoting/protocol/message_reader.h"
+
+namespace base {
+class MessageLoopProxy;
+}  // namespace base
+
+namespace remoting {
+namespace protocol {
+
+class ClientStub;
+class ControlMessage;
+class BufferedSocketWriter;
+class Session;
+
+// ClientControlDispatcher dispatches incoming messages on the control
+// channel to ClientStub, and also implements HostStub for outgoing
+// messages.
+class ClientControlDispatcher : public HostStub {
+ public:
+  ClientControlDispatcher();
+  virtual ~ClientControlDispatcher();
+
+  // Initialize the control channel and the dispatcher for the
+  // |session|. Doesn't take ownership of |session|.

[Wez, 2011/11/17 22:30:22]

nit: Doesn't take... -> Caller retains ...

[Sergey Ulanov, 2011/11/17 22:48:08]

Removed this method in the next CL.

+  void Init(protocol::Session* session);
+
+  // Sets ClientStub that will be called for each incoming control
+  // message. Doesn't take ownershipt of |client_stub|. It must outlive
+  // this dispatcher.

[Wez, 2011/11/17 22:30:22]

typo & nit: Caller retains...

[Sergey Ulanov, 2011/11/17 22:48:08]

Fixed typo. Caller doesn't own |client_stub|.

+  void set_client_stub(ClientStub* client_stub) { client_stub_ = client_stub; }
+
+ private:
+  void OnMessageReceived(ControlMessage* message,
+                         const base::Closure& done_task);
+
+  ClientStub* client_stub_;
+
+  ProtobufMessageReader<ControlMessage> reader_;
+  scoped_refptr<BufferedSocketWriter> writer_;
+
+  DISALLOW_COPY_AND_ASSIGN(ClientControlDispatcher);
+};
+
+}  // namespace protocol
+}  // namespace remoting
+
+#endif  // REMOTING_PROTOCOL_CLIENT_CONTROL_DISPATCHER_H_