summaryrefslogtreecommitdiffstats
path: root/remoting/protocol/host_event_dispatcher.cc
diff options
context:
space:
mode:
authorsergeyu@chromium.org <sergeyu@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2011-11-18 01:31:43 +0000
committersergeyu@chromium.org <sergeyu@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2011-11-18 01:31:43 +0000
commita07ef3d0c6638ded56f324d265b90c414e3c4bd2 (patch)
tree69a137c25f28eff2811537dc8133f9f00e7bf860 /remoting/protocol/host_event_dispatcher.cc
parent0b6fba80bd0159af9b1f0fa38e87c6c1cff768fd (diff)
downloadchromium_src-a07ef3d0c6638ded56f324d265b90c414e3c4bd2.zip
chromium_src-a07ef3d0c6638ded56f324d265b90c414e3c4bd2.tar.gz
chromium_src-a07ef3d0c6638ded56f324d265b90c414e3c4bd2.tar.bz2
Refactor channel dispatchers on the host side.
The new HostControlDispatcher manages reading and writing to and from control channel on the host side. Similarly HostEventDispatcher is responsible for reading and, in future, writing to and from the event channel. Review URL: http://codereview.chromium.org/8468022 git-svn-id: svn://svn.chromium.org/chrome/trunk/src@110625 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'remoting/protocol/host_event_dispatcher.cc')
-rw-r--r--remoting/protocol/host_event_dispatcher.cc51
1 files changed, 51 insertions, 0 deletions
diff --git a/remoting/protocol/host_event_dispatcher.cc b/remoting/protocol/host_event_dispatcher.cc
new file mode 100644
index 0000000..9234e8e
--- /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