Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(153)

Side by Side Diff: remoting/protocol/host_event_dispatcher.cc

Issue 1365663003: Add UMA histograms for more detailed latency tracking on the CRD host. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: fixed tests Created 5 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « remoting/protocol/host_event_dispatcher.h ('k') | remoting/protocol/performance_tracker.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 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 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "remoting/protocol/host_event_dispatcher.h" 5 #include "remoting/protocol/host_event_dispatcher.h"
6 6
7 #include "base/callback_helpers.h" 7 #include "base/callback_helpers.h"
8 #include "net/socket/stream_socket.h" 8 #include "net/socket/stream_socket.h"
9 #include "remoting/base/constants.h" 9 #include "remoting/base/constants.h"
10 #include "remoting/proto/event.pb.h" 10 #include "remoting/proto/event.pb.h"
11 #include "remoting/proto/internal.pb.h" 11 #include "remoting/proto/internal.pb.h"
12 #include "remoting/protocol/input_stub.h" 12 #include "remoting/protocol/input_stub.h"
13 13
14 namespace remoting { 14 namespace remoting {
15 namespace protocol { 15 namespace protocol {
16 16
17 HostEventDispatcher::HostEventDispatcher() 17 HostEventDispatcher::HostEventDispatcher()
18 : ChannelDispatcherBase(kEventChannelName), 18 : ChannelDispatcherBase(kEventChannelName),
19 input_stub_(nullptr), 19 input_stub_(nullptr),
20 parser_(base::Bind(&HostEventDispatcher::OnMessageReceived, 20 parser_(base::Bind(&HostEventDispatcher::OnMessageReceived,
21 base::Unretained(this)), 21 base::Unretained(this)),
22 reader()) { 22 reader()) {}
23 }
24 23
25 HostEventDispatcher::~HostEventDispatcher() { 24 HostEventDispatcher::~HostEventDispatcher() {}
26 }
27 25
28 void HostEventDispatcher::OnMessageReceived(scoped_ptr<EventMessage> message, 26 void HostEventDispatcher::OnMessageReceived(scoped_ptr<EventMessage> message,
29 const base::Closure& done_task) { 27 const base::Closure& done_task) {
30 DCHECK(input_stub_); 28 DCHECK(input_stub_);
31 29
32 base::ScopedClosureRunner done_runner(done_task); 30 base::ScopedClosureRunner done_runner(done_task);
33 31
34 if (message->has_timestamp() && !event_timestamp_callback_.is_null()) 32 if (!on_input_event_callback_.is_null())
35 event_timestamp_callback_.Run(message->timestamp()); 33 on_input_event_callback_.Run(message->timestamp());
36 34
37 if (message->has_key_event()) { 35 if (message->has_key_event()) {
38 const KeyEvent& event = message->key_event(); 36 const KeyEvent& event = message->key_event();
39 if (event.has_usb_keycode() && event.has_pressed()) { 37 if (event.has_usb_keycode() && event.has_pressed()) {
40 input_stub_->InjectKeyEvent(event); 38 input_stub_->InjectKeyEvent(event);
41 } else { 39 } else {
42 LOG(WARNING) << "Received invalid key event."; 40 LOG(WARNING) << "Received invalid key event.";
43 } 41 }
44 } else if (message->has_text_event()) { 42 } else if (message->has_text_event()) {
45 const TextEvent& event = message->text_event(); 43 const TextEvent& event = message->text_event();
46 if (event.has_text()) { 44 if (event.has_text()) {
47 input_stub_->InjectTextEvent(event); 45 input_stub_->InjectTextEvent(event);
48 } else { 46 } else {
49 LOG(WARNING) << "Received invalid text event."; 47 LOG(WARNING) << "Received invalid text event.";
50 } 48 }
51 } else if (message->has_mouse_event()) { 49 } else if (message->has_mouse_event()) {
52 input_stub_->InjectMouseEvent(message->mouse_event()); 50 input_stub_->InjectMouseEvent(message->mouse_event());
53 } else if (message->has_touch_event()) { 51 } else if (message->has_touch_event()) {
54 input_stub_->InjectTouchEvent(message->touch_event()); 52 input_stub_->InjectTouchEvent(message->touch_event());
55 } else { 53 } else {
56 LOG(WARNING) << "Unknown event message received."; 54 LOG(WARNING) << "Unknown event message received.";
57 } 55 }
58 } 56 }
59 57
60 } // namespace protocol 58 } // namespace protocol
61 } // namespace remoting 59 } // namespace remoting
OLDNEW
« no previous file with comments | « remoting/protocol/host_event_dispatcher.h ('k') | remoting/protocol/performance_tracker.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698