content/browser/loader/temporary_file_stream.cc

   1 // Copyright 2014 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/loader/temporary_file_stream.h"
   6
   7 #include "base/bind.h"
   8 #include "base/callback.h"
   9 #include "base/files/file_proxy.h"
  10 #include "base/memory/ref_counted.h"
  11 #include "content/public/browser/browser_thread.h"
  12 #include "net/base/file_stream.h"
  13 #include "webkit/common/blob/shareable_file_reference.h"
  14
  15 using webkit_blob::ShareableFileReference;
  16
  17 namespace content {
  18
  19 namespace {
  20
  21 void DidCreateTemporaryFile(
  22     const CreateTemporaryFileStreamCallback& callback,
  23     scoped_ptr<base::FileProxy> file_proxy,
  24     base::File::Error error_code,
  25     const base::FilePath& file_path) {
  26   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
  27
  28   if (!file_proxy->IsValid()) {
  29     callback.Run(error_code, scoped_ptr<net::FileStream>(), NULL);
  30     return;
  31   }
  32
  33   // Cancelled or not, create the deletable_file so the temporary is cleaned up.
  34   scoped_refptr<ShareableFileReference> deletable_file =
  35       ShareableFileReference::GetOrCreate(
  36           file_path,
  37           ShareableFileReference::DELETE_ON_FINAL_RELEASE,
  38           BrowserThread::GetMessageLoopProxyForThread(
  39               BrowserThread::FILE).get());
  40
  41   scoped_ptr<net::FileStream> file_stream(
  42       new net::FileStream(file_proxy->TakeFile()));
  43
  44   callback.Run(error_code, file_stream.Pass(), deletable_file);
  45 }
  46
  47 }  // namespace
  48
  49 void CreateTemporaryFileStream(
  50     const CreateTemporaryFileStreamCallback& callback) {
  51   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
  52
  53   scoped_ptr<base::FileProxy> file_proxy(new base::FileProxy(
  54       BrowserThread::GetMessageLoopProxyForThread(BrowserThread::FILE).get()));
  55   base::FileProxy* proxy = file_proxy.get();
  56   proxy->CreateTemporary(
  57       base::File::FLAG_ASYNC,
  58       base::Bind(&DidCreateTemporaryFile, callback, Passed(&file_proxy)));
  59 }
  60
  61 }  // namespace content