Move PostTaskAndReplyWithStatus into task_runner_helpers.h

chrome/browser/extensions/api/declarative/declarative_api.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 "chrome/browser/extensions/api/declarative/declarative_api.h"
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
+#include "base/task_runner_util.h"
 #include "base/values.h"
 #include "chrome/browser/extensions/api/declarative/rules_registry_service.h"
 #include "chrome/browser/extensions/extension_system_factory.h"
 #include "chrome/browser/profiles/profile.h"
 #include "chrome/common/extensions/api/experimental.declarative.h"
 #include "content/public/browser/browser_thread.h"
 
 using extensions::api::experimental_declarative::Rule;
 
 namespace AddRules = extensions::api::experimental_declarative::AddRules;
@@ skipping 28 matching lines @@
 
   RulesRegistryService* rules_registry_service =
       ExtensionSystemFactory::GetForProfile(profile())->
       rules_registry_service();
   rules_registry_ = rules_registry_service->GetRulesRegistry(event_name);
   // Raw access to this function is not available to extensions, therefore
   // there should never be a request for a nonexisting rules registry.
   EXTENSION_FUNCTION_VALIDATE(rules_registry_);
 
   if (content::BrowserThread::CurrentlyOn(rules_registry_->GetOwnerThread())) {
-    RunImplOnCorrectThread();
-    SendResponseOnUIThread();
+    bool success = RunImplOnCorrectThread();
+    SendResponse(success);
   } else {
-    content::BrowserThread::PostTaskAndReply(
-        rules_registry_->GetOwnerThread(), FROM_HERE,
-        base::Bind(base::IgnoreResult(&RulesFunction::RunImplOnCorrectThread),
-                   this),
-        base::Bind(&RulesFunction::SendResponseOnUIThread, this));
+    scoped_refptr<base::MessageLoopProxy> message_loop_proxy =
+        content::BrowserThread::GetMessageLoopProxyForThread(
+            rules_registry_->GetOwnerThread());
+    base::PostTaskAndReplyWithResult(
+        message_loop_proxy,
+        FROM_HERE,
+        base::Bind(&RulesFunction::RunImplOnCorrectThread, this),
+        base::Bind(&RulesFunction::SendResponse, this));
   }
 
   return true;
 }
 
-void RulesFunction::SendResponseOnUIThread() {
-  SendResponse(error_.empty());
-}
-
 bool AddRulesFunction::RunImplOnCorrectThread() {
   scoped_ptr<AddRules::Params> params(AddRules::Params::Create(*args_));
   EXTENSION_FUNCTION_VALIDATE(params.get());
 
   error_ = rules_registry_->AddRules(extension_id(), params->rules);
 
   if (error_.empty())
     result_.reset(AddRules::Result::Create(params->rules));
 
   return error_.empty();
@@ skipping 26 matching lines @@
     error_ = rules_registry_->GetAllRules(extension_id(), &rules);
   }
 
   if (error_.empty())
     result_.reset(GetRules::Result::Create(rules));
 
   return error_.empty();
 }
 
 }  // namespace extensions