Refactor channel dispatchers on the host side.

remoting/protocol/host_event_dispatcher.cc

Index: remoting/protocol/host_event_dispatcher.cc
diff --git a/remoting/protocol/host_event_dispatcher.cc b/remoting/protocol/host_event_dispatcher.cc
new file mode 100644
index 0000000000000000000000000000000000000000..9234e8e652f2741f06ea8c583428e0d48e9bb7ed
--- /dev/null
+++ b/remoting/protocol/host_event_dispatcher.cc
@@ -0,0 +1,51 @@
+// 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.
+
+#include "remoting/protocol/host_event_dispatcher.h"
+
+#include "remoting/proto/event.pb.h"
+#include "remoting/proto/internal.pb.h"
+#include "remoting/protocol/input_stub.h"
+#include "remoting/protocol/session.h"
+
+namespace remoting {
+namespace protocol {
+
+HostEventDispatcher::HostEventDispatcher()
+    : input_stub_(NULL) {
+}
+
+HostEventDispatcher::~HostEventDispatcher() {
+}
+
+void HostEventDispatcher::Init(Session* session) {
+  DCHECK(session);
+  reader_.Init(session->event_channel(), base::Bind(
+      &HostEventDispatcher::OnMessageReceived, base::Unretained(this)));
+}
+
+void HostEventDispatcher::OnMessageReceived(
+    EventMessage* message, const base::Closure& done_task) {
+  DCHECK(input_stub_);
+
+  base::ScopedClosureRunner done_runner(done_task);
+
+  sequence_number_callback_.Run(message->sequence_number());
+
+  if (message->has_key_event()) {
+    const KeyEvent& event = message->key_event();
+    if (event.has_keycode() && event.has_pressed()) {
+      input_stub_->InjectKeyEvent(event);
+    } else {
+      LOG(WARNING) << "Received invalid key event.";
+    }
+  } else if (message->has_mouse_event()) {
+    input_stub_->InjectMouseEvent(message->mouse_event());
+  } else {
+    LOG(WARNING) << "Unknown event message received.";
+  }
+}
+
+}  // namespace protocol
+}  // namespace remoting