write_on_cache_file.cc revision a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7 
1// Copyright 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 "chrome/browser/chromeos/drive/write_on_cache_file.h"
6
7#include "base/bind.h"
8#include "base/callback.h"
9#include "base/threading/sequenced_worker_pool.h"
10#include "chrome/browser/chromeos/drive/file_system_interface.h"
11#include "chrome/browser/chromeos/drive/file_system_util.h"
12#include "content/public/browser/browser_thread.h"
13
14using content::BrowserThread;
15
16namespace drive {
17
18namespace {
19
20// Runs |close_callback| and |reply|.
21void RunCloseCallbackAndReplyTask(const base::Closure& close_callback,
22                                  const FileOperationCallback& reply,
23                                  FileError error) {
24  if (!close_callback.is_null())
25    close_callback.Run();
26  DCHECK(!reply.is_null());
27  reply.Run(error);
28}
29
30// Runs |file_io_task_callback| in blocking pool and runs |close_callback|
31// in the UI thread after that.
32void WriteOnCacheFileAfterOpenFile(
33    const base::FilePath& drive_path,
34    const WriteOnCacheFileCallback& file_io_task_callback,
35    const FileOperationCallback& reply,
36    FileError error,
37    const base::FilePath& local_cache_path,
38    const base::Closure& close_callback) {
39  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
40
41  BrowserThread::GetBlockingPool()->PostTaskAndReply(
42      FROM_HERE,
43      base::Bind(file_io_task_callback, error, local_cache_path),
44      base::Bind(&RunCloseCallbackAndReplyTask, close_callback, reply, error));
45}
46
47}  // namespace
48
49void WriteOnCacheFile(FileSystemInterface* file_system,
50                      const base::FilePath& path,
51                      const std::string& mime_type,
52                      const WriteOnCacheFileCallback& callback) {
53  WriteOnCacheFileAndReply(file_system, path, mime_type, callback,
54                           base::Bind(&util::EmptyFileOperationCallback));
55}
56
57void WriteOnCacheFileAndReply(FileSystemInterface* file_system,
58                              const base::FilePath& path,
59                              const std::string& mime_type,
60                              const WriteOnCacheFileCallback& callback,
61                              const FileOperationCallback& reply) {
62  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
63  DCHECK(file_system);
64  DCHECK(!callback.is_null());
65  DCHECK(!reply.is_null());
66
67  file_system->OpenFile(
68      path,
69      OPEN_OR_CREATE_FILE,
70      mime_type,
71      base::Bind(&WriteOnCacheFileAfterOpenFile, path, callback, reply));
72}
73
74}  // namespace drive
75