Implementation of PostTaskAndReply() in MessageLoopProxy and BrowserThread.

content/browser/browser_thread_unittest.cc

 // Copyright (c) 2011 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 "base/bind.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/message_loop.h"
 #include "base/message_loop_proxy.h"
 #include "content/browser/browser_thread.h"
 #include "testing/gtest/include/gtest/gtest.h"
 #include "testing/platform_test.h"
 
 class BrowserThreadTest : public testing::Test {
  public:
   void Release() const {
@@ skipping 12 matching lines @@
   virtual void TearDown() {
     ui_thread_->Stop();
     file_thread_->Stop();
   }
 
   static void BasicFunction(MessageLoop* message_loop) {
     CHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
     message_loop->PostTask(FROM_HERE, new MessageLoop::QuitTask);
   }
 
+  static void DoNothing() {
+  }
+
   class DummyTask : public Task {
    public:
     explicit DummyTask(bool* deleted) : deleted_(deleted) { }
     ~DummyTask() {
       *deleted_ = true;
     }
 
     void Run() {
       CHECK(false);
     }
@@ skipping 76 matching lines @@
   MessageLoop::current()->Run();
 }
 
 TEST_F(BrowserThreadTest, ReleaseViaMessageLoopProxy) {
   scoped_refptr<base::MessageLoopProxy> message_loop_proxy =
       BrowserThread::GetMessageLoopProxyForThread(BrowserThread::UI);
   message_loop_proxy->ReleaseSoon(FROM_HERE, this);
   MessageLoop::current()->Run();
 }
 
+TEST_F(BrowserThreadTest, PostTaskAndReply) {
+  // Most of the heavy testing for PostTaskAndReply() is done inside the
+  // MessageLoopProxy test.  This just makes sure we get piped through at all.
+  ASSERT_TRUE(BrowserThread::PostTaskAndReply(
+      BrowserThread::FILE,
+      FROM_HERE,
+      base::Bind(&BrowserThreadTest::DoNothing),
+      base::Bind(&MessageLoop::Quit,
+                 base::Unretained(MessageLoop::current()->current()))));
+  MessageLoop::current()->Run();
+}
+
+
 TEST_F(BrowserThreadTest, TaskToNonExistentThreadIsDeletedViaMessageLoopProxy) {
   bool deleted = false;
   scoped_refptr<base::MessageLoopProxy> message_loop_proxy =
       BrowserThread::GetMessageLoopProxyForThread(BrowserThread::WEBKIT);
   message_loop_proxy->PostTask(FROM_HERE, new DummyTask(&deleted));
   EXPECT_TRUE(deleted);
 }
 
 TEST_F(BrowserThreadTest, PostTaskViaMessageLoopProxyAfterThreadExits) {
   scoped_ptr<BrowserThread> io_thread(new BrowserThread(BrowserThread::IO));
@@ skipping 13 matching lines @@
     scoped_ptr<BrowserThread> io_thread(new BrowserThread(BrowserThread::IO));
     io_thread->Start();
   }
   bool deleted = false;
   scoped_refptr<base::MessageLoopProxy> message_loop_proxy =
       BrowserThread::GetMessageLoopProxyForThread(BrowserThread::IO);
   bool ret = message_loop_proxy->PostTask(FROM_HERE, new DummyTask(&deleted));
   EXPECT_FALSE(ret);
   EXPECT_TRUE(deleted);
 }
-