src/webkit/common/blob/scoped_file.cc

   1 // Copyright (c) 2013 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 "webkit/common/blob/scoped_file.h"
   6
   7 #include "base/bind.h"
   8 #include "base/callback.h"
   9 #include "base/files/file_util_proxy.h"
  10 #include "base/location.h"
  11 #include "base/message_loop/message_loop_proxy.h"
  12 #include "base/task_runner.h"
  13
  14 namespace webkit_blob {
  15
  16 ScopedFile::ScopedFile()
  17     : scope_out_policy_(DONT_DELETE_ON_SCOPE_OUT) {
  18 }
  19
  20 ScopedFile::ScopedFile(
  21     const base::FilePath& path, ScopeOutPolicy policy,
  22     base::TaskRunner* file_task_runner)
  23     : path_(path),
  24       scope_out_policy_(policy),
  25       file_task_runner_(file_task_runner) {
  26   DCHECK(path.empty() || policy != DELETE_ON_SCOPE_OUT || file_task_runner)
  27       << "path:" << path.value()
  28       << " policy:" << policy
  29       << " runner:" << file_task_runner;
  30 }
  31
  32 ScopedFile::ScopedFile(RValue other) {
  33   MoveFrom(*other.object);
  34 }
  35
  36 ScopedFile::~ScopedFile() {
  37   Reset();
  38 }
  39
  40 void ScopedFile::AddScopeOutCallback(
  41     const ScopeOutCallback& callback,
  42     base::TaskRunner* callback_runner) {
  43   if (!callback_runner)
  44     callback_runner = base::MessageLoopProxy::current().get();
  45   scope_out_callbacks_.push_back(std::make_pair(callback, callback_runner));
  46 }
  47
  48 base::FilePath ScopedFile::Release() {
  49   base::FilePath path = path_;
  50   path_.clear();
  51   scope_out_callbacks_.clear();
  52   scope_out_policy_ = DONT_DELETE_ON_SCOPE_OUT;
  53   return path;
  54 }
  55
  56 void ScopedFile::Reset() {
  57   if (path_.empty())
  58     return;
  59
  60   for (ScopeOutCallbackList::iterator iter = scope_out_callbacks_.begin();
  61        iter != scope_out_callbacks_.end(); ++iter) {
  62     iter->second->PostTask(FROM_HERE, base::Bind(iter->first, path_));
  63   }
  64
  65   if (scope_out_policy_ == DELETE_ON_SCOPE_OUT) {
  66     base::FileUtilProxy::DeleteFile(file_task_runner_.get(),
  67                                     path_,
  68                                     false /* recursive */,
  69                                     base::FileUtilProxy::StatusCallback());
  70   }
  71
  72   // Clear all fields.
  73   Release();
  74 }
  75
  76 void ScopedFile::MoveFrom(ScopedFile& other) {
  77   Reset();
  78
  79   scope_out_policy_ = other.scope_out_policy_;
  80   scope_out_callbacks_.swap(other.scope_out_callbacks_);
  81   file_task_runner_ = other.file_task_runner_;
  82   path_ = other.Release();
  83 }
  84
  85 }  // namespace webkit_blob