Use MessageLoopProxy for network message loop.

remoting/protocol/message_reader.cc

 // Copyright (c) 2010 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #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"
 #include "remoting/base/compound_buffer.h"
 #include "remoting/proto/internal.pb.h"
 
 namespace remoting {
 namespace protocol {
 
 static const int kReadBufferSize = 4096;
 
 MessageReader::MessageReader()
     : socket_(NULL),
-      message_loop_(NULL),
       read_pending_(false),
       pending_messages_(0),
       closed_(false),
       ALLOW_THIS_IN_INITIALIZER_LIST(
           read_callback_(this, &MessageReader::OnRead)) {
 }
 
 MessageReader::~MessageReader() {
   CHECK_EQ(pending_messages_, 0);
 }
 
 void MessageReader::Init(net::Socket* socket,
                          MessageReceivedCallback* callback) {
   message_received_callback_.reset(callback);
   DCHECK(socket);
   socket_ = socket;
-  message_loop_ = MessageLoop::current();
   DoRead();
 }
 
 void MessageReader::DoRead() {
   // Don't try to read again if there is another read pending or we
   // have messages that we haven't finished processing yet.
   while (!closed_ && !read_pending_ && pending_messages_ == 0) {
     read_buffer_ = new net::IOBuffer(kReadBufferSize);
     int result = socket_->Read(
         read_buffer_, kReadBufferSize, &read_callback_);
@@ skipping 49 matching lines @@
         this, &MessageReader::OnMessageDone, *it));
   }
 }
 
 void MessageReader::OnMessageDone(CompoundBuffer* message) {
   delete message;
   ProcessDoneEvent();
 }
 
 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);
 
   DoRead(); // Start next read if neccessary.
 }
 
 }  // namespace protocol
 }  // namespace remoting