Implementation of PostTaskAndReply() in MessageLoopProxy and BrowserThread.

base/task.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/task.h"
 
+#include "base/bind.h"
+#include "base/message_loop_proxy.h"
+
 Task::Task() {
 }
 
 Task::~Task() {
 }
 
 CancelableTask::CancelableTask() {
 }
 
 CancelableTask::~CancelableTask() {
@@ skipping 39 matching lines @@
   task_->Run();
   delete task_;
   task_ = NULL;
 }
 
 // Don't leak tasks by default.
 bool TaskClosureAdapter::kTaskLeakingDefault = false;
 
 }  // namespace subtle
 
+namespace internal {
+
+PostTaskAndReplyRelay::PostTaskAndReplyRelay(
+    const tracked_objects::Location& from_here,
+    const Closure& task,
+    const Closure& reply)
+    : from_here_(from_here),
+      origin_loop_(MessageLoopProxy::CreateForCurrentThread()) {
+  task_ = task;
+  reply_ = reply;
+}
+
+PostTaskAndReplyRelay::~PostTaskAndReplyRelay() {
+  DCHECK(origin_loop_->BelongsToCurrentThread());
+  task_.Reset();
+  reply_.Reset();
+}
+
+void PostTaskAndReplyRelay::Run() {
+  task_.Run();
+  origin_loop_->PostTask(
+      from_here_,
+      Bind(&PostTaskAndReplyRelay::RunReplyAndSelfDestruct,
+           base::Unretained(this)));
+}
+
+void PostTaskAndReplyRelay::RunReplyAndSelfDestruct() {
+  DCHECK(origin_loop_->BelongsToCurrentThread());
+  task_.Reset();
+
+  reply_.Run();
+
+  // Cue mission impossible theme.
+  delete this;
+}
+
+}  // namespace internal
+
 }  // namespace base