Change ownership of BackgroundSyncServiceImpl to BackgroundSyncContextImpl

content/browser/background_sync/background_sync_context_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_context_impl.h"
 
 #include "base/bind.h"
+#include "base/stl_util.h"
 #include "content/browser/background_sync/background_sync_manager.h"
+#include "content/browser/background_sync/background_sync_service_impl.h"
 #include "content/browser/service_worker/service_worker_context_wrapper.h"
 #include "content/public/browser/browser_thread.h"
 
 namespace content {
 
 BackgroundSyncContextImpl::BackgroundSyncContextImpl() {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
 }
 
 BackgroundSyncContextImpl::~BackgroundSyncContextImpl() {
+  DCHECK(!background_sync_manager_);
+  DCHECK(services_.empty());
 }
 
 void BackgroundSyncContextImpl::Init(
     const scoped_refptr<ServiceWorkerContextWrapper>& context) {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
 
   BrowserThread::PostTask(
       BrowserThread::IO, FROM_HERE,
       base::Bind(&BackgroundSyncContextImpl::CreateBackgroundSyncManager, this,
                  context));
 }
 
 void BackgroundSyncContextImpl::Shutdown() {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
 
   BrowserThread::PostTask(
       BrowserThread::IO, FROM_HERE,
       base::Bind(&BackgroundSyncContextImpl::ShutdownOnIO, this));
 }
 
+void BackgroundSyncContextImpl::CreateService(
+    mojo::InterfaceRequest<BackgroundSyncService> request) {
+  DCHECK_CURRENTLY_ON(BrowserThread::UI);
+
+  BrowserThread::PostTask(
+      BrowserThread::IO, FROM_HERE,
+      base::Bind(&BackgroundSyncContextImpl::CreateServiceOnIOThread, this,
+                 base::Passed(&request)));
+}
+
+void BackgroundSyncContextImpl::ServiceHadConnectionError(
+    BackgroundSyncServiceImpl* service) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+  DCHECK(ContainsValue(services_, service));
+
+  delete service;
+  services_.erase(service);

[davidben, 2015/08/13 14:54:30]

I don't think it can actually make a difference here, but this really should
happen in the other order. Using a freed pointer is scary.

[jkarlin, 2015/08/13 15:24:27]

Done.

+}
+
 BackgroundSyncManager* BackgroundSyncContextImpl::background_sync_manager()
     const {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
 
   return background_sync_manager_.get();
 }
 
 void BackgroundSyncContextImpl::CreateBackgroundSyncManager(
     const scoped_refptr<ServiceWorkerContextWrapper>& context) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
   DCHECK(!background_sync_manager_);
 
   background_sync_manager_ = BackgroundSyncManager::Create(context);
 }
 
+void BackgroundSyncContextImpl::CreateServiceOnIOThread(
+    mojo::InterfaceRequest<BackgroundSyncService> request) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+  if (!background_sync_manager_) {
+    // This can happen during shutdown if the render process uses the background
+    // sync API (creating this mojo channel request) after this object has
+    // already shutdown (the StoragePartition can shut down before the
+    // RenderProcessHost does).
+    LOG(WARNING) << "Service created after shutdown called";
+    return;
+  }
+  services_.insert(
+      new BackgroundSyncServiceImpl(make_scoped_refptr(this), request.Pass()));

[davidben, 2015/08/13 14:54:30]

Is this not a reference cycle?

[jkarlin, 2015/08/13 15:24:27]

*hangs head in shame*. Fixed.

+}
+
 void BackgroundSyncContextImpl::ShutdownOnIO() {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
 
+  STLDeleteElements(&services_);
   background_sync_manager_.reset();
 }
 
 }  // namespace content