Fixed crash in the proxy. Reference has been passed between threads,

chrome/service/cloud_print/cloud_print_proxy_backend.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 "chrome/service/cloud_print/cloud_print_proxy_backend.h"
 
 #include <map>
 #include <vector>
 
 #include "base/file_util.h"
@@ skipping 64 matching lines @@
 
   // CloudPrintAuth::Client implementation.
   virtual void OnAuthenticationComplete(
       const std::string& access_token,
       const std::string& robot_oauth_refresh_token,
       const std::string& robot_email,
       const std::string& user_email);
   virtual void OnInvalidCredentials();
 
   // CloudPrintConnector::Client implementation.
-  virtual void OnPrintersAvailable(const printing::PrinterList& printers);
   virtual void OnAuthFailed();
 
   // notifier::TalkMediator::Delegate implementation.
   virtual void OnNotificationStateChange(
       bool notifications_enabled);
   virtual void OnIncomingNotification(
       const notifier::Notification& notification);
   virtual void OnOutgoingNotification();
 
  private:
@@ skipping 136 matching lines @@
 }
 
 void CloudPrintProxyBackend::Shutdown() {
   core_thread_.message_loop()->PostTask(FROM_HERE,
       NewRunnableMethod(core_.get(),
                         &CloudPrintProxyBackend::Core::DoShutdown));
   core_thread_.Stop();
   core_ = NULL;  // Releases reference to core_.
 }
 
-void CloudPrintProxyBackend::RegisterPrinters(
-    const printing::PrinterList& printer_list) {
-  core_thread_.message_loop()->PostTask(FROM_HERE,
-      NewRunnableMethod(
-          core_.get(),
-          &CloudPrintProxyBackend::Core::DoRegisterSelectedPrinters,
-          printer_list));
-}
-
 CloudPrintProxyBackend::Core::Core(
     CloudPrintProxyBackend* backend,
     const std::string& proxy_id,
     const GURL& cloud_print_server_url,
     const DictionaryValue* print_system_settings,
     const gaia::OAuthClientInfo& oauth_client_info,
     bool enable_job_poll)
       : backend_(backend),
         cloud_print_server_url_(cloud_print_server_url),
         proxy_id_(proxy_id),
@@ skipping 83 matching lines @@
   }
 }
 
 void CloudPrintProxyBackend::Core::OnInvalidCredentials() {
   DCHECK(MessageLoop::current() == backend_->core_thread_.message_loop());
   VLOG(1) << "CP_CONNECTOR: Auth Error";
   backend_->frontend_loop_->PostTask(FROM_HERE, NewRunnableMethod(this,
       &Core::NotifyAuthenticationFailed));
 }
 
-void CloudPrintProxyBackend::Core::OnPrintersAvailable(
-    const printing::PrinterList& printers) {
-  // Let the frontend know that we have a list of printers available.
-  backend_->frontend_loop_->PostTask(FROM_HERE, NewRunnableMethod(this,
-      &Core::NotifyPrinterListAvailable, printers));
-}
-
 void CloudPrintProxyBackend::Core::OnAuthFailed() {
   VLOG(1) << "CP_CONNECTOR: Authentication failed in connector.";
   // Let's stop connecter and refresh token. We'll restart connecter once
   // new token available.
   if (connector_->IsRunning())
     connector_->Stop();
 
   // Refresh Auth token.
   auth_->RefreshAccessToken();
 }
@@ skipping 28 matching lines @@
 
   // Important to delete the TalkMediator on this thread.
   if (talk_mediator_.get())
     talk_mediator_->Logout();
   talk_mediator_.reset();
   notifications_enabled_ = false;
   notifications_enabled_since_ = base::TimeTicks();
   token_store_.reset();
 }
 
-void CloudPrintProxyBackend::Core::DoRegisterSelectedPrinters(
-    const printing::PrinterList& printer_list) {
-  DCHECK(MessageLoop::current() == backend_->core_thread_.message_loop());
-  connector_->RegisterPrinters(printer_list);
-}
-
 void CloudPrintProxyBackend::Core::HandlePrinterNotification(
     const std::string& printer_id) {
   DCHECK(MessageLoop::current() == backend_->core_thread_.message_loop());
   VLOG(1) << "CP_CONNECTOR: Handle printer notification, id: " << printer_id;
   connector_->CheckForJobs(kJobFetchReasonNotified, printer_id);
 }
 
 void CloudPrintProxyBackend::Core::PollForJobs() {
   VLOG(1) << "CP_CONNECTOR: Polling for jobs.";
   DCHECK(MessageLoop::current() == backend_->core_thread_.message_loop());
@@ skipping 19 matching lines @@
   }
 }
 
 CloudPrintTokenStore* CloudPrintProxyBackend::Core::GetTokenStore() {
   DCHECK(MessageLoop::current() == backend_->core_thread_.message_loop());
   if (!token_store_.get())
     token_store_.reset(new CloudPrintTokenStore);
   return token_store_.get();
 }
 
-void CloudPrintProxyBackend::Core::NotifyPrinterListAvailable(
-    const printing::PrinterList& printer_list) {
-  DCHECK(MessageLoop::current() == backend_->frontend_loop_);
-  backend_->frontend_->OnPrinterListAvailable(printer_list);
-}
-
 void CloudPrintProxyBackend::Core::NotifyAuthenticated(
     const std::string& robot_oauth_refresh_token,
     const std::string& robot_email,
     const std::string& user_email) {
   DCHECK(MessageLoop::current() == backend_->frontend_loop_);
   backend_->frontend_->OnAuthenticated(robot_oauth_refresh_token,
                                        robot_email,
                                        user_email);
 }
 
@@ skipping 35 matching lines @@
 void CloudPrintProxyBackend::Core::OnIncomingNotification(
     const notifier::Notification& notification) {
   DCHECK(MessageLoop::current() == backend_->core_thread_.message_loop());
   VLOG(1) << "CP_CONNECTOR: Incoming notification.";
   if (0 == base::strcasecmp(kCloudPrintPushNotificationsSource,
                             notification.channel.c_str()))
     HandlePrinterNotification(notification.data);
 }
 
 void CloudPrintProxyBackend::Core::OnOutgoingNotification() {}