Index: remoting/protocol/message_reader.cc |
diff --git a/remoting/protocol/message_reader.cc b/remoting/protocol/message_reader.cc |
index d8324bef224961cd13587019184b339481dba087..e5825b1ee163c0dfa3e448dda0bcb4e125ae95ce 100644 |
--- a/remoting/protocol/message_reader.cc |
+++ b/remoting/protocol/message_reader.cc |
@@ -4,7 +4,6 @@ |
#include "remoting/protocol/message_reader.h" |
-#include "base/message_loop.h" |
#include "net/base/io_buffer.h" |
#include "net/base/net_errors.h" |
#include "net/socket/socket.h" |
@@ -18,7 +17,6 @@ static const int kReadBufferSize = 4096; |
MessageReader::MessageReader() |
: socket_(NULL), |
- message_loop_(NULL), |
read_pending_(false), |
pending_messages_(0), |
closed_(false), |
@@ -35,7 +33,6 @@ void MessageReader::Init(net::Socket* socket, |
message_received_callback_.reset(callback); |
DCHECK(socket); |
socket_ = socket; |
- message_loop_ = MessageLoop::current(); |
DoRead(); |
} |
@@ -105,12 +102,6 @@ void MessageReader::OnMessageDone(CompoundBuffer* message) { |
} |
void MessageReader::ProcessDoneEvent() { |
- if (MessageLoop::current() != message_loop_) { |
- message_loop_->PostTask(FROM_HERE, NewRunnableMethod( |
- this, &MessageReader::ProcessDoneEvent)); |
- return; |
- } |
- |
pending_messages_--; |
DCHECK_GE(pending_messages_, 0); |