dbus: adding PostTaskToDBusThreadAndReply

dbus/bus.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 "dbus/bus.h"
 
 #include "base/bind.h"
 #include "base/logging.h"
 #include "base/message_loop.h"
 #include "base/message_loop_proxy.h"
@@ skipping 757 matching lines @@
   // It is safe and necessary to call dbus_connection_get_dispatch_status even
   // if the connection is lost. Otherwise we will miss "Disconnected" signal.
   // (crbug.com/174431)
   if (dbus_connection_get_dispatch_status(connection_) ==
       DBUS_DISPATCH_DATA_REMAINS) {
     while (dbus_connection_dispatch(connection_) ==
            DBUS_DISPATCH_DATA_REMAINS);
   }
 }
 
+void Bus::PostTaskToDBusThreadAndReply(
+    const tracked_objects::Location& from_here,
+    const base::Closure& task,
+    const base::Closure& reply) {
+  AssertOnOriginThread();
+
+  if (dbus_task_runner_.get()) {
+    if (!dbus_task_runner_->PostTaskAndReply(from_here, task, reply)) {
+      LOG(WARNING) << "Failed to post a task to the D-Bus thread message loop";
+    }
+  } else {
+    DCHECK(origin_task_runner_.get());
+    if (!origin_task_runner_->PostTaskAndReply(from_here, task, reply)) {
+      LOG(WARNING) << "Failed to post a task to the origin message loop";
+    }
+  }
+}
+
 void Bus::PostTaskToOriginThread(const tracked_objects::Location& from_here,
                                  const base::Closure& task) {
   DCHECK(origin_task_runner_.get());
   if (!origin_task_runner_->PostTask(from_here, task)) {
     LOG(WARNING) << "Failed to post a task to the origin message loop";
   }
 }
 
 void Bus::PostTaskToDBusThread(const tracked_objects::Location& from_here,
                                const base::Closure& task) {
@@ skipping 240 matching lines @@
                              kDisconnectedSignal)) {
     Bus* self = static_cast<Bus*>(data);
     self->AssertOnDBusThread();
     self->OnConnectionDisconnected(connection);
     return DBUS_HANDLER_RESULT_HANDLED;
   }
   return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
 }
 
 }  // namespace dbus