content/browser/background_sync/background_sync_context_impl.cc

   1 // Copyright 2015 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "content/browser/background_sync/background_sync_context_impl.h"
   6
   7 #include "base/bind.h"
   8 #include "base/stl_util.h"
   9 #include "content/browser/background_sync/background_sync_manager.h"
  10 #include "content/browser/background_sync/background_sync_service_impl.h"
  11 #include "content/browser/service_worker/service_worker_context_wrapper.h"
  12 #include "content/public/browser/browser_thread.h"
  13
  14 namespace content {
  15
  16 BackgroundSyncContextImpl::BackgroundSyncContextImpl() {
  17   DCHECK_CURRENTLY_ON(BrowserThread::UI);
  18 }
  19
  20 BackgroundSyncContextImpl::~BackgroundSyncContextImpl() {
  21   DCHECK(!background_sync_manager_);
  22   DCHECK(services_.empty());
  23 }
  24
  25 void BackgroundSyncContextImpl::Init(
  26     const scoped_refptr<ServiceWorkerContextWrapper>& context) {
  27   DCHECK_CURRENTLY_ON(BrowserThread::UI);
  28
  29   BrowserThread::PostTask(
  30       BrowserThread::IO, FROM_HERE,
  31       base::Bind(&BackgroundSyncContextImpl::CreateBackgroundSyncManager, this,
  32                  context));
  33 }
  34
  35 void BackgroundSyncContextImpl::Shutdown() {
  36   DCHECK_CURRENTLY_ON(BrowserThread::UI);
  37
  38   BrowserThread::PostTask(
  39       BrowserThread::IO, FROM_HERE,
  40       base::Bind(&BackgroundSyncContextImpl::ShutdownOnIO, this));
  41 }
  42
  43 void BackgroundSyncContextImpl::CreateService(
  44     mojo::InterfaceRequest<BackgroundSyncService> request) {
  45   DCHECK_CURRENTLY_ON(BrowserThread::UI);
  46
  47   BrowserThread::PostTask(
  48       BrowserThread::IO, FROM_HERE,
  49       base::Bind(&BackgroundSyncContextImpl::CreateServiceOnIOThread, this,
  50                  base::Passed(&request)));
  51 }
  52
  53 void BackgroundSyncContextImpl::ServiceHadConnectionError(
  54     BackgroundSyncServiceImpl* service) {
  55   DCHECK_CURRENTLY_ON(BrowserThread::IO);
  56   DCHECK(ContainsValue(services_, service));
  57
  58   services_.erase(service);
  59   delete service;
  60 }
  61
  62 BackgroundSyncManager* BackgroundSyncContextImpl::background_sync_manager()
  63     const {
  64   DCHECK_CURRENTLY_ON(BrowserThread::IO);
  65
  66   return background_sync_manager_.get();
  67 }
  68
  69 void BackgroundSyncContextImpl::CreateBackgroundSyncManager(
  70     const scoped_refptr<ServiceWorkerContextWrapper>& context) {
  71   DCHECK_CURRENTLY_ON(BrowserThread::IO);
  72   DCHECK(!background_sync_manager_);
  73
  74   background_sync_manager_ = BackgroundSyncManager::Create(context);
  75 }
  76
  77 void BackgroundSyncContextImpl::CreateServiceOnIOThread(
  78     mojo::InterfaceRequest<BackgroundSyncService> request) {
  79   DCHECK_CURRENTLY_ON(BrowserThread::IO);
  80   DCHECK(background_sync_manager_);
  81   services_.insert(new BackgroundSyncServiceImpl(this, request.Pass()));
  82 }
  83
  84 void BackgroundSyncContextImpl::ShutdownOnIO() {
  85   DCHECK_CURRENTLY_ON(BrowserThread::IO);
  86
  87   STLDeleteElements(&services_);
  88   background_sync_manager_.reset();
  89 }
  90
  91 }  // namespace content