Support creating temporary files for sync file operations.

content/common/url_fetcher.cc

 // Copyright (c) 2011 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "content/common/url_fetcher.h"
 
 #include <set>
 
 #include "base/compiler_specific.h"
 #include "base/file_path.h"
@@ skipping 91 matching lines @@
    public:
     TempFileWriter(
         URLFetcher::Core* core,
         scoped_refptr<base::MessageLoopProxy> file_message_loop_proxy);
 
     ~TempFileWriter();
     void CreateTempFile();
     void DidCreateTempFile(base::PlatformFileError error_code,
                            base::PassPlatformFile file_handle,
                            FilePath file_path);
-    void DidCloseTempFile(base::PlatformFileError error_code);
-    void DidReopenTempFile(base::PlatformFileError error_code,
-                           base::PassPlatformFile file_handle,
-                           bool created);
 
     // Record |num_bytes_| response bytes in |core_->buffer_| to the file.
     void WriteBuffer(int num_bytes);
 
     // Called when a write has been done.  Continues writing if there are
     // any more bytes to write.  Otherwise, initiates a read in core_.
     void ContinueWrite(base::PlatformFileError error_code,
                        int bytes_written);
 
     // Drop ownership of the file at path |temp_file_|. This class
@@ skipping 184 matching lines @@
 }
 
 URLFetcher::Core::TempFileWriter::~TempFileWriter() {
   Destroy();
 }
 
 void URLFetcher::Core::TempFileWriter::CreateTempFile() {
   CHECK(file_message_loop_proxy_.get());
   base::FileUtilProxy::CreateTemporary(
       file_message_loop_proxy_,
+      0,  // No additional file flags.
       callback_factory_.NewCallback(
           &URLFetcher::Core::TempFileWriter::DidCreateTempFile));
 }
 
 void URLFetcher::Core::TempFileWriter::DidCreateTempFile(
     base::PlatformFileError error_code,
     base::PassPlatformFile file_handle,
     FilePath file_path) {
   if (base::PLATFORM_FILE_OK != error_code) {
     error_code_ = error_code;
     core_->InformDelegateFetchIsComplete();
     return;
   }
 
   temp_file_ = file_path;
-
-  // The file was opened with async writes enabled.   FileUtilProxy::Write()
-  // treats a write that returns IO_PENDING as an error, and does not inform
-  // the caller.  We need to close and reopen the file with asyncronus writes
-  // disabled.
-  // TODO(skerner): Make FileUtilProxy::Write() play nice with async IO.
-  base::FileUtilProxy::Close(
-      file_message_loop_proxy_,
-      file_handle.ReleaseValue(),
-      callback_factory_.NewCallback(
-          &URLFetcher::Core::TempFileWriter::DidCloseTempFile));
-}
-
-void URLFetcher::Core::TempFileWriter::DidCloseTempFile(
-    base::PlatformFileError error_code) {
-  if (base::PLATFORM_FILE_OK != error_code) {
-    error_code_ = error_code;
-    core_->InformDelegateFetchIsComplete();
-    return;
-  }
-
-  int file_flags =
-      base::PLATFORM_FILE_CREATE_ALWAYS |
-      base::PLATFORM_FILE_WRITE |
-      base::PLATFORM_FILE_TEMPORARY;
-
-  base::FileUtilProxy::CreateOrOpen(
-      file_message_loop_proxy_,
-      temp_file_,
-      file_flags,
-      callback_factory_.NewCallback(
-          &URLFetcher::Core::TempFileWriter::DidReopenTempFile));
-}
-
-void URLFetcher::Core::TempFileWriter::DidReopenTempFile(
-    base::PlatformFileError error_code,
-    base::PassPlatformFile file_handle,
-    bool created) {
-  if (base::PLATFORM_FILE_OK != error_code) {
-    error_code_ = error_code;
-    core_->InformDelegateFetchIsComplete();
-    return;
-  }
-
   temp_file_handle_ = file_handle.ReleaseValue();
   total_bytes_written_ = 0;
 
   core_->io_message_loop_proxy_->PostTask(
       FROM_HERE,
       NewRunnableMethod(core_, &Core::StartURLRequestWhenAppropriate));
 }
 
 void URLFetcher::Core::TempFileWriter::WriteBuffer(int num_bytes) {
   // Start writing to the temp file by setting the initial state
@@ skipping 643 matching lines @@
 }
 
 // static
 int URLFetcher::GetNumFetcherCores() {
   return Core::g_registry.Get().size();
 }
 
 URLFetcher::Delegate* URLFetcher::delegate() const {
   return core_->delegate();
 }