content/browser/cache_storage/cache_storage_scheduler.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/cache_storage/cache_storage_scheduler.h"
   6
   7 #include <string>
   8
   9 #include "base/bind.h"
  10 #include "base/location.h"
  11 #include "base/logging.h"
  12 #include "base/single_thread_task_runner.h"
  13 #include "base/thread_task_runner_handle.h"
  14
  15 namespace content {
  16
  17 CacheStorageScheduler::CacheStorageScheduler() : operation_running_(false) {
  18 }
  19
  20 CacheStorageScheduler::~CacheStorageScheduler() {
  21 }
  22
  23 void CacheStorageScheduler::ScheduleOperation(const base::Closure& closure) {
  24   pending_operations_.push_back(closure);
  25   RunOperationIfIdle();
  26 }
  27
  28 void CacheStorageScheduler::CompleteOperationAndRunNext() {
  29   DCHECK(operation_running_);
  30   operation_running_ = false;
  31   RunOperationIfIdle();
  32 }
  33
  34 bool CacheStorageScheduler::ScheduledOperations() const {
  35   return operation_running_ || !pending_operations_.empty();
  36 }
  37
  38 void CacheStorageScheduler::RunOperationIfIdle() {
  39   if (!operation_running_ && !pending_operations_.empty()) {
  40     operation_running_ = true;
  41     // TODO(jkarlin): Run multiple operations in parallel where allowed.
  42     base::Closure closure = pending_operations_.front();
  43     pending_operations_.pop_front();
  44     base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
  45                                                   base::Bind(closure));
  46   }
  47 }
  48
  49 }  // namespace content