summaryrefslogtreecommitdiffstats
path: root/remoting/protocol/client_event_dispatcher.cc
diff options
context:
space:
mode:
authorsergeyu <sergeyu@chromium.org>2015-01-10 13:44:09 -0800
committerCommit bot <commit-bot@chromium.org>2015-01-10 21:44:59 +0000
commit203832d43af2d2c0cb92ca2a6ad3e59193c6836d (patch)
tree44cb36fdca1dcb557781260a676cf374ad0ff94b /remoting/protocol/client_event_dispatcher.cc
parentf4f051fe183f2595bb09d6ddcc9da895460c4429 (diff)
downloadchromium_src-203832d43af2d2c0cb92ca2a6ad3e59193c6836d.zip
chromium_src-203832d43af2d2c0cb92ca2a6ad3e59193c6836d.tar.gz
chromium_src-203832d43af2d2c0cb92ca2a6ad3e59193c6836d.tar.bz2
Cleanup channel dispatchers
Now ChannelDispatcherBase handles initialization of reader and writer, which makes all dispatcher classes simpler. ChannelDispatcherBase now can handle writer errors. Also renamed ProtobufMessageReader -> ProtobufMessageParser. Review URL: https://codereview.chromium.org/841773005 Cr-Commit-Position: refs/heads/master@{#310993}
Diffstat (limited to 'remoting/protocol/client_event_dispatcher.cc')
-rw-r--r--remoting/protocol/client_event_dispatcher.cc13
1 files changed, 3 insertions, 10 deletions
diff --git a/remoting/protocol/client_event_dispatcher.cc b/remoting/protocol/client_event_dispatcher.cc
index 983cba6..89e4bcf 100644
--- a/remoting/protocol/client_event_dispatcher.cc
+++ b/remoting/protocol/client_event_dispatcher.cc
@@ -20,13 +20,6 @@ ClientEventDispatcher::ClientEventDispatcher()
}
ClientEventDispatcher::~ClientEventDispatcher() {
- writer_.Close();
-}
-
-void ClientEventDispatcher::OnInitialized() {
- // TODO(garykac): Set write failed callback.
- writer_.Init(channel(),
- BufferedSocketWriter::WriteFailedCallback());
}
void ClientEventDispatcher::InjectKeyEvent(const KeyEvent& event) {
@@ -35,7 +28,7 @@ void ClientEventDispatcher::InjectKeyEvent(const KeyEvent& event) {
EventMessage message;
message.set_timestamp(base::Time::Now().ToInternalValue());
message.mutable_key_event()->CopyFrom(event);
- writer_.Write(SerializeAndFrameMessage(message), base::Closure());
+ writer()->Write(SerializeAndFrameMessage(message), base::Closure());
}
void ClientEventDispatcher::InjectTextEvent(const TextEvent& event) {
@@ -43,14 +36,14 @@ void ClientEventDispatcher::InjectTextEvent(const TextEvent& event) {
EventMessage message;
message.set_timestamp(base::Time::Now().ToInternalValue());
message.mutable_text_event()->CopyFrom(event);
- writer_.Write(SerializeAndFrameMessage(message), base::Closure());
+ writer()->Write(SerializeAndFrameMessage(message), base::Closure());
}
void ClientEventDispatcher::InjectMouseEvent(const MouseEvent& event) {
EventMessage message;
message.set_timestamp(base::Time::Now().ToInternalValue());
message.mutable_mouse_event()->CopyFrom(event);
- writer_.Write(SerializeAndFrameMessage(message), base::Closure());
+ writer()->Write(SerializeAndFrameMessage(message), base::Closure());
}
} // namespace protocol