diff options
author | sergeyu <sergeyu@chromium.org> | 2015-01-10 13:44:09 -0800 |
---|---|---|
committer | Commit bot <commit-bot@chromium.org> | 2015-01-10 21:44:59 +0000 |
commit | 203832d43af2d2c0cb92ca2a6ad3e59193c6836d (patch) | |
tree | 44cb36fdca1dcb557781260a676cf374ad0ff94b /remoting/protocol/client_event_dispatcher.cc | |
parent | f4f051fe183f2595bb09d6ddcc9da895460c4429 (diff) | |
download | chromium_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.cc | 13 |
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 |