Don't depend on MessageLoopProxy in remoting protocol code.

remoting/protocol/message_reader.cc

 // Copyright (c) 2012 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/bind.h"
 #include "base/callback.h"
 #include "base/location.h"
+#include "base/thread_task_runner_handle.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;
@@ skipping 64 matching lines @@
   std::vector<CompoundBuffer*> new_messages;
   while (true) {
     CompoundBuffer* buffer = message_decoder_.GetNextMessage();
     if (!buffer)
       break;
     new_messages.push_back(buffer);
   }
 
   pending_messages_ += new_messages.size();
 
-  // TODO(lambroslambrou): MessageLoopProxy::current() will not work from the
-  // plugin thread if this code is compiled into a separate binary.  Fix this.
   for (std::vector<CompoundBuffer*>::iterator it = new_messages.begin();
        it != new_messages.end(); ++it) {
     message_received_callback_.Run(
         scoped_ptr<CompoundBuffer>(*it),
         base::Bind(&MessageReader::OnMessageDone, this,
-                   base::MessageLoopProxy::current()));
+                   base::ThreadTaskRunnerHandle::Get()));
   }
 }
 
 void MessageReader::OnMessageDone(
-    scoped_refptr<base::MessageLoopProxy> message_loop) {
-  if (!message_loop->BelongsToCurrentThread()) {
-    message_loop->PostTask(
-        FROM_HERE,
-        base::Bind(&MessageReader::OnMessageDone, this, message_loop));
-    return;
+    scoped_refptr<base::SingleThreadTaskRunner> task_runner) {
+  if (task_runner->BelongsToCurrentThread()) {
+    ProcessDoneEvent();
+  } else {
+    task_runner->PostTask(
+        FROM_HERE, base::Bind(&MessageReader::ProcessDoneEvent, this));
   }
-  ProcessDoneEvent();
 }
 
 void MessageReader::ProcessDoneEvent() {
   pending_messages_--;
   DCHECK_GE(pending_messages_, 0);
 
   DoRead(); // Start next read if neccessary.
 }
 
 }  // namespace protocol
 }  // namespace remoting