Rename webkit_blob::FileReader to FileStreamReader.

webkit/blob/local_file_stream_reader_unittest.cc

 // Copyright (c) 2012 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 "webkit/blob/local_file_reader.h"
+#include "webkit/blob/local_file_stream_reader.h"
 
 #include <string>
 
 #include "base/file_path.h"
 #include "base/file_util.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/message_loop.h"
 #include "base/platform_file.h"
 #include "base/scoped_temp_dir.h"
 #include "base/threading/thread.h"
 #include "net/base/io_buffer.h"
 #include "net/base/net_errors.h"
 #include "net/base/test_completion_callback.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 namespace webkit_blob {
 
 namespace {
 
 const char kTestData[] = "0123456789";
 const int kTestDataSize = arraysize(kTestData) - 1;
 
-void ReadFromReader(LocalFileReader* reader,
+void ReadFromReader(LocalFileStreamReader* reader,
                     std::string* data, size_t size,
                     int* result) {
   ASSERT_TRUE(reader != NULL);
   ASSERT_TRUE(result != NULL);
   *result = net::OK;
   net::TestCompletionCallback callback;
   size_t total_bytes_read = 0;
   while (total_bytes_read < size) {
     scoped_refptr<net::IOBufferWithSize> buf(
         new net::IOBufferWithSize(size - total_bytes_read));
@@ skipping 11 matching lines @@
 
 void NeverCalled(int) { ADD_FAILURE(); }
 void EmptyCallback() {}
 
 void QuitLoop() {
   MessageLoop::current()->Quit();
 }
 
 }  // namespace
 
-class LocalFileReaderTest : public testing::Test {
+class LocalFileStreamReaderTest : public testing::Test {
  public:
-  LocalFileReaderTest()
+  LocalFileStreamReaderTest()
       : message_loop_(MessageLoop::TYPE_IO),
         file_thread_("FileUtilProxyTestFileThread") {}
 
   virtual void SetUp() OVERRIDE {
     ASSERT_TRUE(file_thread_.Start());
     ASSERT_TRUE(dir_.CreateUniqueTempDir());
 
     file_util::WriteFile(test_path(), kTestData, kTestDataSize);
     base::PlatformFileInfo info;
     ASSERT_TRUE(file_util::GetFileInfo(test_path(), &info));
     test_file_modification_time_ = info.last_modified;
   }
 
   virtual void TearDown() OVERRIDE {
     // Give another chance for deleted streams to perform Close.
     MessageLoop::current()->RunAllPending();
     file_thread_.Stop();
   }
 
  protected:
-  LocalFileReader* CreateFileReader(
+  LocalFileStreamReader* CreateFileReader(
       const FilePath& path,
       int64 initial_offset,
       const base::Time& expected_modification_time) {
-    return new LocalFileReader(
+    return new LocalFileStreamReader(
             file_task_runner(),
             path,
             initial_offset,
             expected_modification_time);
   }
 
   void TouchTestFile() {
     base::Time new_modified_time =
         test_file_modification_time() - base::TimeDelta::FromSeconds(1);
     ASSERT_TRUE(file_util::TouchFile(test_path(),
@@ skipping 17 matching lines @@
     MessageLoop::current()->Run();
   }
 
  private:
   MessageLoop message_loop_;
   base::Thread file_thread_;
   ScopedTempDir dir_;
   base::Time test_file_modification_time_;
 };
 
-TEST_F(LocalFileReaderTest, NonExistent) {
+TEST_F(LocalFileStreamReaderTest, NonExistent) {
   FilePath nonexistent_path = test_dir().AppendASCII("nonexistent");
-  scoped_ptr<LocalFileReader> reader(
+  scoped_ptr<LocalFileStreamReader> reader(
       CreateFileReader(nonexistent_path, 0, base::Time()));
   int result = 0;
   std::string data;
   ReadFromReader(reader.get(), &data, 10, &result);
   ASSERT_EQ(net::ERR_FILE_NOT_FOUND, result);
   ASSERT_EQ(0U, data.size());
 }
 
-TEST_F(LocalFileReaderTest, Empty) {
+TEST_F(LocalFileStreamReaderTest, Empty) {
   FilePath empty_path = test_dir().AppendASCII("empty");
   base::PlatformFileError error = base::PLATFORM_FILE_OK;
   base::PlatformFile file = base::CreatePlatformFile(
       empty_path,
       base::PLATFORM_FILE_CREATE | base::PLATFORM_FILE_READ,
       NULL, &error);
   ASSERT_EQ(base::PLATFORM_FILE_OK, error);
   ASSERT_NE(base::kInvalidPlatformFileValue, file);
   base::ClosePlatformFile(file);
 
-  scoped_ptr<LocalFileReader> reader(
+  scoped_ptr<LocalFileStreamReader> reader(
       CreateFileReader(empty_path, 0, base::Time()));
   int result = 0;
   std::string data;
   ReadFromReader(reader.get(), &data, 10, &result);
   ASSERT_EQ(net::OK, result);
   ASSERT_EQ(0U, data.size());
 
   net::TestInt64CompletionCallback callback;
   result = reader->GetLength(callback.callback());
   if (result == net::ERR_IO_PENDING)
     result = callback.WaitForResult();
   ASSERT_EQ(0, result);
 }
 
-TEST_F(LocalFileReaderTest, GetLengthNormal) {
-  scoped_ptr<LocalFileReader> reader(
+TEST_F(LocalFileStreamReaderTest, GetLengthNormal) {
+  scoped_ptr<LocalFileStreamReader> reader(
       CreateFileReader(test_path(), 0, test_file_modification_time()));
   net::TestInt64CompletionCallback callback;
   int result = reader->GetLength(callback.callback());
   if (result == net::ERR_IO_PENDING)
     result = callback.WaitForResult();
   ASSERT_EQ(kTestDataSize, result);
 }
 
-TEST_F(LocalFileReaderTest, GetLengthAfterModified) {
+TEST_F(LocalFileStreamReaderTest, GetLengthAfterModified) {
   // Touch file so that the file's modification time becomes different
   // from what we expect.
   TouchTestFile();
 
-  scoped_ptr<LocalFileReader> reader(
+  scoped_ptr<LocalFileStreamReader> reader(
       CreateFileReader(test_path(), 0, test_file_modification_time()));
   net::TestInt64CompletionCallback callback;
   int result = reader->GetLength(callback.callback());
   if (result == net::ERR_IO_PENDING)
     result = callback.WaitForResult();
   ASSERT_EQ(net::ERR_UPLOAD_FILE_CHANGED, result);
 
   // With NULL expected modification time this should work.
   reader.reset(CreateFileReader(test_path(), 0, base::Time()));
   result = reader->GetLength(callback.callback());
   if (result == net::ERR_IO_PENDING)
     result = callback.WaitForResult();
   ASSERT_EQ(kTestDataSize, result);
 }
 
-TEST_F(LocalFileReaderTest, GetLengthWithOffset) {
-  scoped_ptr<LocalFileReader> reader(
+TEST_F(LocalFileStreamReaderTest, GetLengthWithOffset) {
+  scoped_ptr<LocalFileStreamReader> reader(
       CreateFileReader(test_path(), 3, base::Time()));
   net::TestInt64CompletionCallback callback;
   int result = reader->GetLength(callback.callback());
   if (result == net::ERR_IO_PENDING)
     result = callback.WaitForResult();
   // Initial offset does not affect the result of GetLength.
   ASSERT_EQ(kTestDataSize, result);
 }
 
-TEST_F(LocalFileReaderTest, ReadNormal) {
-  scoped_ptr<LocalFileReader> reader(
+TEST_F(LocalFileStreamReaderTest, ReadNormal) {
+  scoped_ptr<LocalFileStreamReader> reader(
       CreateFileReader(test_path(), 0, test_file_modification_time()));
   int result = 0;
   std::string data;
   ReadFromReader(reader.get(), &data, kTestDataSize, &result);
   ASSERT_EQ(net::OK, result);
   ASSERT_EQ(kTestData, data);
 }
 
-TEST_F(LocalFileReaderTest, ReadAfterModified) {
+TEST_F(LocalFileStreamReaderTest, ReadAfterModified) {
   // Touch file so that the file's modification time becomes different
   // from what we expect.
   TouchTestFile();
 
-  scoped_ptr<LocalFileReader> reader(
+  scoped_ptr<LocalFileStreamReader> reader(
       CreateFileReader(test_path(), 0, test_file_modification_time()));
   int result = 0;
   std::string data;
   ReadFromReader(reader.get(), &data, kTestDataSize, &result);
   ASSERT_EQ(net::ERR_UPLOAD_FILE_CHANGED, result);
   ASSERT_EQ(0U, data.size());
 
   // With NULL expected modification time this should work.
   data.clear();
   reader.reset(CreateFileReader(test_path(), 0, base::Time()));
   ReadFromReader(reader.get(), &data, kTestDataSize, &result);
   ASSERT_EQ(net::OK, result);
   ASSERT_EQ(kTestData, data);
 }
 
-TEST_F(LocalFileReaderTest, ReadWithOffset) {
-  scoped_ptr<LocalFileReader> reader(
+TEST_F(LocalFileStreamReaderTest, ReadWithOffset) {
+  scoped_ptr<LocalFileStreamReader> reader(
       CreateFileReader(test_path(), 3, base::Time()));
   int result = 0;
   std::string data;
   ReadFromReader(reader.get(), &data, kTestDataSize, &result);
   ASSERT_EQ(net::OK, result);
   ASSERT_EQ(&kTestData[3], data);
 }
 
-TEST_F(LocalFileReaderTest, DeleteWithUnfinishedRead) {
-  scoped_ptr<LocalFileReader> reader(
+TEST_F(LocalFileStreamReaderTest, DeleteWithUnfinishedRead) {
+  scoped_ptr<LocalFileStreamReader> reader(
       CreateFileReader(test_path(), 0, base::Time()));
 
   net::TestCompletionCallback callback;
   scoped_refptr<net::IOBufferWithSize> buf(
       new net::IOBufferWithSize(kTestDataSize));
   int rv = reader->Read(buf, buf->size(), base::Bind(&NeverCalled));
   ASSERT_TRUE(rv == net::ERR_IO_PENDING || rv >= 0);
 
   // Delete immediately.
   // Should not crash; nor should NeverCalled be callback.
   reader.reset();
   EnsureFileTaskFinished();
 }
 
 }  // namespace webkit_blob