| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "webkit/fileapi/file_system_file_stream_reader.h" | 5 #include "webkit/fileapi/file_system_file_stream_reader.h" |
| 6 | 6 |
| 7 #include <limits> | 7 #include <limits> |
| 8 #include <string> | 8 #include <string> |
| 9 | 9 |
| 10 #include "base/files/scoped_temp_dir.h" | 10 #include "base/files/scoped_temp_dir.h" |
| 11 #include "base/memory/scoped_ptr.h" | 11 #include "base/memory/scoped_ptr.h" |
| 12 #include "base/message_loop.h" | 12 #include "base/message_loop.h" |
| 13 #include "base/platform_file.h" | 13 #include "base/platform_file.h" |
| 14 #include "net/base/io_buffer.h" | 14 #include "net/base/io_buffer.h" |
| 15 #include "net/base/net_errors.h" | 15 #include "net/base/net_errors.h" |
| 16 #include "net/base/test_completion_callback.h" | 16 #include "net/base/test_completion_callback.h" |
| 17 #include "testing/gtest/include/gtest/gtest.h" | 17 #include "testing/gtest/include/gtest/gtest.h" |
| 18 #include "webkit/fileapi/external_mount_points.h" | 18 #include "webkit/fileapi/external_mount_points.h" |
| 19 #include "webkit/fileapi/file_system_context.h" | 19 #include "webkit/fileapi/file_system_context.h" |
| 20 #include "webkit/fileapi/file_system_file_util.h" | 20 #include "webkit/fileapi/file_system_file_util.h" |
| 21 #include "webkit/fileapi/file_system_operation_context.h" | 21 #include "webkit/fileapi/file_system_operation_context.h" |
| 22 #include "webkit/fileapi/file_system_task_runners.h" | 22 #include "webkit/fileapi/mock_file_system_context.h" |
| 23 #include "webkit/fileapi/mock_file_system_options.h" | |
| 24 #include "webkit/fileapi/sandbox_mount_point_provider.h" | 23 #include "webkit/fileapi/sandbox_mount_point_provider.h" |
| 25 #include "webkit/quota/mock_special_storage_policy.h" | |
| 26 | 24 |
| 27 namespace fileapi { | 25 namespace fileapi { |
| 28 | 26 |
| 29 namespace { | 27 namespace { |
| 30 | 28 |
| 31 const char kURLOrigin[] = "http://remote/"; | 29 const char kURLOrigin[] = "http://remote/"; |
| 32 const char kTestFileName[] = "test.dat"; | 30 const char kTestFileName[] = "test.dat"; |
| 33 const char kTestData[] = "0123456789"; | 31 const char kTestData[] = "0123456789"; |
| 34 const int kTestDataSize = arraysize(kTestData) - 1; | 32 const int kTestDataSize = arraysize(kTestData) - 1; |
| 35 | 33 |
| (...skipping 26 matching lines...) Expand all Loading... |
| 62 } // namespace | 60 } // namespace |
| 63 | 61 |
| 64 class FileSystemFileStreamReaderTest : public testing::Test { | 62 class FileSystemFileStreamReaderTest : public testing::Test { |
| 65 public: | 63 public: |
| 66 FileSystemFileStreamReaderTest() | 64 FileSystemFileStreamReaderTest() |
| 67 : message_loop_(MessageLoop::TYPE_IO) {} | 65 : message_loop_(MessageLoop::TYPE_IO) {} |
| 68 | 66 |
| 69 virtual void SetUp() OVERRIDE { | 67 virtual void SetUp() OVERRIDE { |
| 70 ASSERT_TRUE(temp_dir_.CreateUniqueTempDir()); | 68 ASSERT_TRUE(temp_dir_.CreateUniqueTempDir()); |
| 71 | 69 |
| 72 special_storage_policy_ = new quota::MockSpecialStoragePolicy; | 70 file_system_context_ = CreateFileSystemContextForTesting( |
| 73 file_system_context_ = | 71 NULL, temp_dir_.path()); |
| 74 new FileSystemContext( | |
| 75 FileSystemTaskRunners::CreateMockTaskRunners(), | |
| 76 ExternalMountPoints::CreateRefCounted().get(), | |
| 77 special_storage_policy_, | |
| 78 NULL, | |
| 79 temp_dir_.path(), | |
| 80 CreateDisallowFileAccessOptions()); | |
| 81 | 72 |
| 82 file_system_context_->sandbox_provider()->ValidateFileSystemRoot( | 73 file_system_context_->sandbox_provider()->ValidateFileSystemRoot( |
| 83 GURL(kURLOrigin), kFileSystemTypeTemporary, true, // create | 74 GURL(kURLOrigin), kFileSystemTypeTemporary, true, // create |
| 84 base::Bind(&OnValidateFileSystem)); | 75 base::Bind(&OnValidateFileSystem)); |
| 85 MessageLoop::current()->RunUntilIdle(); | 76 MessageLoop::current()->RunUntilIdle(); |
| 86 | 77 |
| 87 WriteFile(kTestFileName, kTestData, kTestDataSize, | 78 WriteFile(kTestFileName, kTestData, kTestDataSize, |
| 88 &test_file_modification_time_); | 79 &test_file_modification_time_); |
| 89 } | 80 } |
| 90 | 81 |
| (...skipping 57 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 148 | 139 |
| 149 FileSystemURL GetFileSystemURL(const std::string& file_name) { | 140 FileSystemURL GetFileSystemURL(const std::string& file_name) { |
| 150 return file_system_context_->CreateCrackedFileSystemURL( | 141 return file_system_context_->CreateCrackedFileSystemURL( |
| 151 GURL(kURLOrigin), | 142 GURL(kURLOrigin), |
| 152 kFileSystemTypeTemporary, | 143 kFileSystemTypeTemporary, |
| 153 base::FilePath().AppendASCII(file_name)); | 144 base::FilePath().AppendASCII(file_name)); |
| 154 } | 145 } |
| 155 | 146 |
| 156 MessageLoop message_loop_; | 147 MessageLoop message_loop_; |
| 157 base::ScopedTempDir temp_dir_; | 148 base::ScopedTempDir temp_dir_; |
| 158 scoped_refptr<quota::MockSpecialStoragePolicy> special_storage_policy_; | |
| 159 scoped_refptr<FileSystemContext> file_system_context_; | 149 scoped_refptr<FileSystemContext> file_system_context_; |
| 160 base::Time test_file_modification_time_; | 150 base::Time test_file_modification_time_; |
| 161 }; | 151 }; |
| 162 | 152 |
| 163 TEST_F(FileSystemFileStreamReaderTest, NonExistent) { | 153 TEST_F(FileSystemFileStreamReaderTest, NonExistent) { |
| 164 const char kFileName[] = "nonexistent"; | 154 const char kFileName[] = "nonexistent"; |
| 165 scoped_ptr<FileSystemFileStreamReader> reader( | 155 scoped_ptr<FileSystemFileStreamReader> reader( |
| 166 CreateFileReader(kFileName, 0, base::Time())); | 156 CreateFileReader(kFileName, 0, base::Time())); |
| 167 int result = 0; | 157 int result = 0; |
| 168 std::string data; | 158 std::string data; |
| (...skipping 113 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 282 new net::IOBufferWithSize(kTestDataSize)); | 272 new net::IOBufferWithSize(kTestDataSize)); |
| 283 int rv = reader->Read(buf, buf->size(), base::Bind(&NeverCalled)); | 273 int rv = reader->Read(buf, buf->size(), base::Bind(&NeverCalled)); |
| 284 ASSERT_TRUE(rv == net::ERR_IO_PENDING || rv >= 0); | 274 ASSERT_TRUE(rv == net::ERR_IO_PENDING || rv >= 0); |
| 285 | 275 |
| 286 // Delete immediately. | 276 // Delete immediately. |
| 287 // Should not crash; nor should NeverCalled be callback. | 277 // Should not crash; nor should NeverCalled be callback. |
| 288 reader.reset(); | 278 reader.reset(); |
| 289 } | 279 } |
| 290 | 280 |
| 291 } // namespace fileapi | 281 } // namespace fileapi |
| OLD | NEW |