Blob support for IDB [Chromium]

content/browser/fileapi/copy_or_move_operation_delegate_unittest.cc

 // Copyright 2013 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 <map>
 #include <queue>
 
 #include "base/basictypes.h"
 #include "base/bind.h"
 #include "base/file_util.h"
@@ skipping 708 matching lines @@
   ScopedThreadStopper thread_stopper(&file_thread);
   ASSERT_TRUE(thread_stopper.is_valid());
 
   scoped_refptr<base::MessageLoopProxy> task_runner =
       file_thread.message_loop_proxy();
 
   scoped_ptr<webkit_blob::FileStreamReader> reader(
       webkit_blob::FileStreamReader::CreateForLocalFile(
           task_runner.get(), source_path, 0, base::Time()));
 
-  scoped_ptr<FileStreamWriter> writer(
-      FileStreamWriter::CreateForLocalFile(task_runner.get(), dest_path, 0));
+  scoped_ptr<FileStreamWriter> writer(FileStreamWriter::CreateForLocalFile(
+      task_runner.get(), dest_path, 0, true));
 
   std::vector<int64> progress;
   CopyOrMoveOperationDelegate::StreamCopyHelper helper(
       reader.Pass(), writer.Pass(),
       10,  // buffer size
       base::Bind(&RecordFileProgressCallback, base::Unretained(&progress)),
       base::TimeDelta());  // For testing, we need all the progress.
 
   base::PlatformFileError error = base::PLATFORM_FILE_ERROR_FAILED;
   base::RunLoop run_loop;
@@ skipping 31 matching lines @@
   ScopedThreadStopper thread_stopper(&file_thread);
   ASSERT_TRUE(thread_stopper.is_valid());
 
   scoped_refptr<base::MessageLoopProxy> task_runner =
       file_thread.message_loop_proxy();
 
   scoped_ptr<webkit_blob::FileStreamReader> reader(
       webkit_blob::FileStreamReader::CreateForLocalFile(
           task_runner.get(), source_path, 0, base::Time()));
 
-  scoped_ptr<FileStreamWriter> writer(
-      FileStreamWriter::CreateForLocalFile(task_runner.get(), dest_path, 0));
+  scoped_ptr<FileStreamWriter> writer(FileStreamWriter::CreateForLocalFile(
+      task_runner.get(), dest_path, 0, true));
 
   std::vector<int64> progress;
   CopyOrMoveOperationDelegate::StreamCopyHelper helper(
       reader.Pass(), writer.Pass(),
       10,  // buffer size
       base::Bind(&RecordFileProgressCallback, base::Unretained(&progress)),
       base::TimeDelta());  // For testing, we need all the progress.
 
   // Call Cancel() later.
   base::MessageLoopProxy::current()->PostTask(
       FROM_HERE,
       base::Bind(&CopyOrMoveOperationDelegate::StreamCopyHelper::Cancel,
                  base::Unretained(&helper)));
 
   base::PlatformFileError error = base::PLATFORM_FILE_ERROR_FAILED;
   base::RunLoop run_loop;
   helper.Run(base::Bind(&AssignAndQuit, &run_loop, &error));
   run_loop.Run();
 
   EXPECT_EQ(base::PLATFORM_FILE_ERROR_ABORT, error);
 }
 
 }  // namespace fileapi