remoting/protocol/host_event_dispatcher.cc

   1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "remoting/protocol/host_event_dispatcher.h"
   6
   7 #include "base/callback_helpers.h"
   8 #include "net/socket/stream_socket.h"
   9 #include "remoting/base/constants.h"
  10 #include "remoting/proto/event.pb.h"
  11 #include "remoting/proto/internal.pb.h"
  12 #include "remoting/protocol/input_stub.h"
  13
  14 namespace remoting {
  15 namespace protocol {
  16
  17 HostEventDispatcher::HostEventDispatcher()
  18     : ChannelDispatcherBase(kEventChannelName),
  19       input_stub_(NULL) {
  20 }
  21
  22 HostEventDispatcher::~HostEventDispatcher() {
  23 }
  24
  25 void HostEventDispatcher::OnInitialized() {
  26   reader_.Init(channel(), base::Bind(
  27       &HostEventDispatcher::OnMessageReceived, base::Unretained(this)));
  28 }
  29
  30 void HostEventDispatcher::OnMessageReceived(
  31     scoped_ptr<EventMessage> message, const base::Closure& done_task) {
  32   DCHECK(input_stub_);
  33
  34   base::ScopedClosureRunner done_runner(done_task);
  35
  36   if (message->has_sequence_number() && !sequence_number_callback_.is_null())
  37     sequence_number_callback_.Run(message->sequence_number());
  38
  39   if (message->has_key_event()) {
  40     const KeyEvent& event = message->key_event();
  41     if (event.has_usb_keycode() && event.has_pressed()) {
  42       input_stub_->InjectKeyEvent(event);
  43     } else {
  44       LOG(WARNING) << "Received invalid key event.";
  45     }
  46   } else if (message->has_mouse_event()) {
  47     input_stub_->InjectMouseEvent(message->mouse_event());
  48   } else {
  49     LOG(WARNING) << "Unknown event message received.";
  50   }
  51 }
  52
  53 }  // namespace protocol
  54 }  // namespace remoting