Change ownership of BackgroundSyncServiceImpl to BackgroundSyncContextImpl

content/browser/background_sync/background_sync_service_impl.cc

 // Copyright 2015 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 "content/browser/background_sync/background_sync_service_impl.h"
 
 #include "base/memory/weak_ptr.h"
 #include "content/browser/background_sync/background_sync_context_impl.h"
 #include "content/browser/background_sync/background_sync_registration.h"
 #include "content/public/browser/browser_thread.h"
@@ skipping 68 matching lines @@
 COMPILE_ASSERT_MATCHING_ENUM(BACKGROUND_SYNC_POWER_STATE_MAX,
                              SyncPowerState::POWER_STATE_AVOID_DRAINING);
 
 COMPILE_ASSERT_MATCHING_ENUM(BACKGROUND_SYNC_PERIODICITY_PERIODIC,
                              SyncPeriodicity::SYNC_PERIODIC);
 COMPILE_ASSERT_MATCHING_ENUM(BACKGROUND_SYNC_PERIODICITY_ONE_SHOT,
                              SyncPeriodicity::SYNC_ONE_SHOT);
 COMPILE_ASSERT_MATCHING_ENUM(BACKGROUND_SYNC_PERIODICITY_MAX,
                              SyncPeriodicity::SYNC_ONE_SHOT);
 
-// static
-void BackgroundSyncServiceImpl::Create(
-    const scoped_refptr<BackgroundSyncContextImpl>& background_sync_context,
-    mojo::InterfaceRequest<BackgroundSyncService> request) {
-  DCHECK_CURRENTLY_ON(BrowserThread::UI);
-  BrowserThread::PostTask(
-      BrowserThread::IO, FROM_HERE,
-      base::Bind(&BackgroundSyncServiceImpl::CreateOnIOThread,
-                 background_sync_context, base::Passed(&request)));
-}
-
 BackgroundSyncServiceImpl::~BackgroundSyncServiceImpl() {
-  // Should always be destroyed on the IO thread, but can't check that with
-  // DCHECK_CURRENTLY_ON because this class could be destroyed during thread
-  // shutdown, at which point that check doesn't work.
-}
-
-// static
-void BackgroundSyncServiceImpl::CreateOnIOThread(
-    const scoped_refptr<BackgroundSyncContextImpl>& background_sync_context,
-    mojo::InterfaceRequest<BackgroundSyncService> request) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
-  new BackgroundSyncServiceImpl(background_sync_context, request.Pass());
 }
 
 BackgroundSyncServiceImpl::BackgroundSyncServiceImpl(
     const scoped_refptr<BackgroundSyncContextImpl>& background_sync_context,
     mojo::InterfaceRequest<BackgroundSyncService> request)
     : background_sync_context_(background_sync_context),
       binding_(this, request.Pass()),
       weak_ptr_factory_(this) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
+
+  binding_.set_connection_error_handler(
+      base::Bind(&BackgroundSyncServiceImpl::OnConnectionError,
+                 base::Unretained(this) /* the channel is owned by this */));
+}
+
+void BackgroundSyncServiceImpl::OnConnectionError() {
+  background_sync_context_->ServiceHadConnectionError(this);
+  // |this| is now deleted.
 }
 
 void BackgroundSyncServiceImpl::Register(content::SyncRegistrationPtr options,
                                          int64_t sw_registration_id,
                                          const RegisterCallback& callback) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
 
   BackgroundSyncRegistrationOptions mgr_options =
       ToBackgroundSyncRegistrationOptions(options);
 
@@ skipping 86 matching lines @@
     const std::vector<BackgroundSyncRegistration>& result_registrations) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
   mojo::Array<content::SyncRegistrationPtr> mojo_registrations(0);
   for (const auto& registration : result_registrations)
     mojo_registrations.push_back(ToMojoRegistration(registration));
   callback.Run(static_cast<content::BackgroundSyncError>(status),
                mojo_registrations.Pass());
 }
 
 }  // namespace content