Index: remoting/protocol/client_event_dispatcher.cc |
diff --git a/remoting/protocol/client_event_dispatcher.cc b/remoting/protocol/client_event_dispatcher.cc |
index 60c5d43e9383b43fd23df5f54ee9d0ae77a52858..c0da8373f2cdcf2e8cf08aa8149e35b3edcbd1cf 100644 |
--- a/remoting/protocol/client_event_dispatcher.cc |
+++ b/remoting/protocol/client_event_dispatcher.cc |
@@ -6,28 +6,28 @@ |
#include "base/message_loop_proxy.h" |
#include "base/time.h" |
+#include "net/socket/stream_socket.h" |
+#include "remoting/base/constants.h" |
#include "remoting/proto/event.pb.h" |
#include "remoting/proto/internal.pb.h" |
#include "remoting/protocol/buffered_socket_writer.h" |
-#include "remoting/protocol/session.h" |
#include "remoting/protocol/util.h" |
namespace remoting { |
namespace protocol { |
ClientEventDispatcher::ClientEventDispatcher() |
- : writer_(new BufferedSocketWriter(base::MessageLoopProxy::current())) { |
+ : ChannelDispatcherBase(kEventChannelName), |
+ writer_(new BufferedSocketWriter(base::MessageLoopProxy::current())) { |
} |
ClientEventDispatcher::~ClientEventDispatcher() { |
writer_->Close(); |
} |
-void ClientEventDispatcher::Init(Session* session) { |
- DCHECK(session); |
- |
+void ClientEventDispatcher::OnInitialized() { |
// TODO(garykac): Set write failed callback. |
- writer_->Init(session->event_channel(), |
+ writer_->Init(channel(), |
BufferedSocketWriter::WriteFailedCallback()); |
} |