diff options
author | sergeyu@chromium.org <sergeyu@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2011-11-18 01:31:43 +0000 |
---|---|---|
committer | sergeyu@chromium.org <sergeyu@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2011-11-18 01:31:43 +0000 |
commit | a07ef3d0c6638ded56f324d265b90c414e3c4bd2 (patch) | |
tree | 69a137c25f28eff2811537dc8133f9f00e7bf860 /remoting/protocol/host_event_dispatcher.cc | |
parent | 0b6fba80bd0159af9b1f0fa38e87c6c1cff768fd (diff) | |
download | chromium_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.cc | 51 |
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 |