Remove dependency on content::BrowserThread from GCMDriver

chrome/browser/services/gcm/fake_gcm_client.cc

 // Copyright 2014 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/services/gcm/fake_gcm_client.h"
 
 #include "base/bind.h"
 #include "base/logging.h"
 #include "base/message_loop/message_loop.h"
+#include "base/sequenced_task_runner.h"
 #include "base/sys_byteorder.h"
 #include "base/time/time.h"
-#include "content/public/browser/browser_thread.h"
 #include "google_apis/gcm/base/encryptor.h"
 
 namespace gcm {
 
-FakeGCMClient::FakeGCMClient(StartMode start_mode)
+FakeGCMClient::FakeGCMClient(
+    StartMode start_mode,
+    const scoped_refptr<base::SequencedTaskRunner>& ui_thread,
+    const scoped_refptr<base::SequencedTaskRunner>& io_thread)
     : delegate_(NULL),
       status_(UNINITIALIZED),
       start_mode_(start_mode),
+      ui_thread_(ui_thread),
+      io_thread_(io_thread),
       weak_ptr_factory_(this) {
 }
 
 FakeGCMClient::~FakeGCMClient() {
 }
 
 void FakeGCMClient::Initialize(
     const checkin_proto::ChromeBuildProto& chrome_build_proto,
     const base::FilePath& store_path,
     const std::vector<std::string>& account_ids,
     const scoped_refptr<base::SequencedTaskRunner>& blocking_task_runner,
     const scoped_refptr<net::URLRequestContextGetter>&
         url_request_context_getter,
     scoped_ptr<Encryptor> encryptor,
     Delegate* delegate) {
   delegate_ = delegate;
 }
 
 void FakeGCMClient::Start() {
-  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
+  DCHECK(io_thread_->RunsTasksOnCurrentThread());
   DCHECK_NE(STARTED, status_);
 
   if (start_mode_ == DELAY_START)
     return;
   DoLoading();
 }
 
 void FakeGCMClient::DoLoading() {
   status_ = STARTED;
   base::MessageLoop::current()->PostTask(
       FROM_HERE,
       base::Bind(&FakeGCMClient::CheckinFinished,
                  weak_ptr_factory_.GetWeakPtr()));
 }
 
 void FakeGCMClient::Stop() {
-  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
+  DCHECK(io_thread_->RunsTasksOnCurrentThread());
   status_ = STOPPED;
 }
 
 void FakeGCMClient::CheckOut() {
-  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
+  DCHECK(io_thread_->RunsTasksOnCurrentThread());
   status_ = CHECKED_OUT;
 }
 
 void FakeGCMClient::Register(const std::string& app_id,
                              const std::vector<std::string>& sender_ids) {
-  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
+  DCHECK(io_thread_->RunsTasksOnCurrentThread());
 
   std::string registration_id = GetRegistrationIdFromSenderIds(sender_ids);
   base::MessageLoop::current()->PostTask(
       FROM_HERE,
       base::Bind(&FakeGCMClient::RegisterFinished,
                  weak_ptr_factory_.GetWeakPtr(),
                  app_id,
                  registration_id));
 }
 
 void FakeGCMClient::Unregister(const std::string& app_id) {
-  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
+  DCHECK(io_thread_->RunsTasksOnCurrentThread());
 
   base::MessageLoop::current()->PostTask(
       FROM_HERE,
       base::Bind(&FakeGCMClient::UnregisterFinished,
                  weak_ptr_factory_.GetWeakPtr(),
                  app_id));
 }
 
 void FakeGCMClient::Send(const std::string& app_id,
                          const std::string& receiver_id,
                          const OutgoingMessage& message) {
-  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::IO));
+  DCHECK(io_thread_->RunsTasksOnCurrentThread());
 
   base::MessageLoop::current()->PostTask(
       FROM_HERE,
       base::Bind(&FakeGCMClient::SendFinished,
                  weak_ptr_factory_.GetWeakPtr(),
                  app_id,
                  message));
 }
 
 void FakeGCMClient::SetRecording(bool recording) {
 }
 
 void FakeGCMClient::ClearActivityLogs() {
 }
 
 GCMClient::GCMStatistics FakeGCMClient::GetStatistics() const {
   return GCMClient::GCMStatistics();
 }
 
 void FakeGCMClient::PerformDelayedLoading() {
-  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+  DCHECK(ui_thread_->RunsTasksOnCurrentThread());
 
-  content::BrowserThread::PostTask(
-      content::BrowserThread::IO,
+  io_thread_->PostTask(
       FROM_HERE,
       base::Bind(&FakeGCMClient::DoLoading, weak_ptr_factory_.GetWeakPtr()));
 }
 
 void FakeGCMClient::ReceiveMessage(const std::string& app_id,
                                    const IncomingMessage& message) {
-  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+  DCHECK(ui_thread_->RunsTasksOnCurrentThread());
 
-  content::BrowserThread::PostTask(
-      content::BrowserThread::IO,
+  io_thread_->PostTask(
       FROM_HERE,
       base::Bind(&FakeGCMClient::MessageReceived,
                  weak_ptr_factory_.GetWeakPtr(),
                  app_id,
                  message));
 }
 
 void FakeGCMClient::DeleteMessages(const std::string& app_id) {
-  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+  DCHECK(ui_thread_->RunsTasksOnCurrentThread());
 
-  content::BrowserThread::PostTask(
-      content::BrowserThread::IO,
+  io_thread_->PostTask(
       FROM_HERE,
       base::Bind(&FakeGCMClient::MessagesDeleted,
                  weak_ptr_factory_.GetWeakPtr(),
                  app_id));
 }
 
 // static
 std::string FakeGCMClient::GetRegistrationIdFromSenderIds(
     const std::vector<std::string>& sender_ids) {
   // GCMService normalizes the sender IDs by making them sorted.
@@ skipping 61 matching lines @@
 }
 
 void FakeGCMClient::MessageSendError(
     const std::string& app_id,
     const GCMClient::SendErrorDetails& send_error_details) {
   if (delegate_)
     delegate_->OnMessageSendError(app_id, send_error_details);
 }
 
 }  // namespace gcm