| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 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 | 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 "chrome/browser/chromeos/file_system_provider/fileapi/file_stream_reade
r.h" | 5 #include "chrome/browser/chromeos/file_system_provider/fileapi/file_stream_reade
r.h" |
| 6 | 6 |
| 7 #include <string> | 7 #include <string> |
| 8 #include <vector> | 8 #include <vector> |
| 9 | 9 |
| 10 #include "base/files/file.h" | 10 #include "base/files/file.h" |
| (...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 74 // TearDown(). | 74 // TearDown(). |
| 75 KeyedService* CreateService(content::BrowserContext* context) { | 75 KeyedService* CreateService(content::BrowserContext* context) { |
| 76 return new Service(Profile::FromBrowserContext(context), | 76 return new Service(Profile::FromBrowserContext(context), |
| 77 extensions::ExtensionRegistry::Get(context)); | 77 extensions::ExtensionRegistry::Get(context)); |
| 78 } | 78 } |
| 79 | 79 |
| 80 } // namespace | 80 } // namespace |
| 81 | 81 |
| 82 class FileSystemProviderFileStreamReader : public testing::Test { | 82 class FileSystemProviderFileStreamReader : public testing::Test { |
| 83 protected: | 83 protected: |
| 84 FileSystemProviderFileStreamReader() {} | 84 FileSystemProviderFileStreamReader() : profile_(NULL), fake_file_(NULL) {} |
| 85 virtual ~FileSystemProviderFileStreamReader() {} | 85 virtual ~FileSystemProviderFileStreamReader() {} |
| 86 | 86 |
| 87 virtual void SetUp() OVERRIDE { | 87 virtual void SetUp() OVERRIDE { |
| 88 ASSERT_TRUE(data_dir_.CreateUniqueTempDir()); | 88 ASSERT_TRUE(data_dir_.CreateUniqueTempDir()); |
| 89 profile_manager_.reset( | 89 profile_manager_.reset( |
| 90 new TestingProfileManager(TestingBrowserProcess::GetGlobal())); | 90 new TestingProfileManager(TestingBrowserProcess::GetGlobal())); |
| 91 ASSERT_TRUE(profile_manager_->SetUp()); | 91 ASSERT_TRUE(profile_manager_->SetUp()); |
| 92 profile_ = profile_manager_->CreateTestingProfile("testing-profile"); | 92 profile_ = profile_manager_->CreateTestingProfile("testing-profile"); |
| 93 | 93 |
| 94 ServiceFactory::GetInstance()->SetTestingFactory(profile_, &CreateService); | 94 ServiceFactory::GetInstance()->SetTestingFactory(profile_, &CreateService); |
| 95 Service* service = Service::Get(profile_); // Owned by its factory. | 95 Service* service = Service::Get(profile_); // Owned by its factory. |
| 96 service->SetFileSystemFactoryForTesting( | 96 service->SetFileSystemFactoryForTesting( |
| 97 base::Bind(&FakeProvidedFileSystem::Create)); | 97 base::Bind(&FakeProvidedFileSystem::Create)); |
| 98 | 98 |
| 99 const bool result = service->MountFileSystem(kExtensionId, | 99 const bool result = service->MountFileSystem(kExtensionId, |
| 100 kFileSystemId, | 100 kFileSystemId, |
| 101 "Testing File System", | 101 "Testing File System", |
| 102 false /* writable */); | 102 false /* writable */); |
| 103 ASSERT_TRUE(result); | 103 ASSERT_TRUE(result); |
| 104 FakeProvidedFileSystem* provided_file_system = | 104 FakeProvidedFileSystem* provided_file_system = |
| 105 static_cast<FakeProvidedFileSystem*>( | 105 static_cast<FakeProvidedFileSystem*>( |
| 106 service->GetProvidedFileSystem(kExtensionId, kFileSystemId)); | 106 service->GetProvidedFileSystem(kExtensionId, kFileSystemId)); |
| 107 ASSERT_TRUE(provided_file_system); | 107 ASSERT_TRUE(provided_file_system); |
| 108 ASSERT_TRUE(provided_file_system->GetEntry( | 108 fake_file_ = provided_file_system->GetEntry( |
| 109 base::FilePath::FromUTF8Unsafe(kFakeFilePath), &fake_file_)); | 109 base::FilePath::FromUTF8Unsafe(kFakeFilePath)); |
| 110 ASSERT_TRUE(fake_file_); |
| 110 const ProvidedFileSystemInfo& file_system_info = | 111 const ProvidedFileSystemInfo& file_system_info = |
| 111 service->GetProvidedFileSystem(kExtensionId, kFileSystemId) | 112 service->GetProvidedFileSystem(kExtensionId, kFileSystemId) |
| 112 ->GetFileSystemInfo(); | 113 ->GetFileSystemInfo(); |
| 113 const std::string mount_point_name = | 114 const std::string mount_point_name = |
| 114 file_system_info.mount_path().BaseName().AsUTF8Unsafe(); | 115 file_system_info.mount_path().BaseName().AsUTF8Unsafe(); |
| 115 | 116 |
| 116 file_url_ = CreateFileSystemURL( | 117 file_url_ = CreateFileSystemURL( |
| 117 mount_point_name, base::FilePath::FromUTF8Unsafe(kFakeFilePath + 1)); | 118 mount_point_name, base::FilePath::FromUTF8Unsafe(kFakeFilePath + 1)); |
| 118 ASSERT_TRUE(file_url_.is_valid()); | 119 ASSERT_TRUE(file_url_.is_valid()); |
| 119 wrong_file_url_ = CreateFileSystemURL( | 120 wrong_file_url_ = CreateFileSystemURL( |
| 120 mount_point_name, base::FilePath::FromUTF8Unsafe("im-not-here.txt")); | 121 mount_point_name, base::FilePath::FromUTF8Unsafe("im-not-here.txt")); |
| 121 ASSERT_TRUE(wrong_file_url_.is_valid()); | 122 ASSERT_TRUE(wrong_file_url_.is_valid()); |
| 122 } | 123 } |
| 123 | 124 |
| 124 virtual void TearDown() OVERRIDE { | 125 virtual void TearDown() OVERRIDE { |
| 125 // Setting the testing factory to NULL will destroy the created service | 126 // Setting the testing factory to NULL will destroy the created service |
| 126 // associated with the testing profile. | 127 // associated with the testing profile. |
| 127 ServiceFactory::GetInstance()->SetTestingFactory(profile_, NULL); | 128 ServiceFactory::GetInstance()->SetTestingFactory(profile_, NULL); |
| 128 } | 129 } |
| 129 | 130 |
| 130 content::TestBrowserThreadBundle thread_bundle_; | 131 content::TestBrowserThreadBundle thread_bundle_; |
| 131 base::ScopedTempDir data_dir_; | 132 base::ScopedTempDir data_dir_; |
| 132 scoped_ptr<TestingProfileManager> profile_manager_; | 133 scoped_ptr<TestingProfileManager> profile_manager_; |
| 133 TestingProfile* profile_; // Owned by TestingProfileManager. | 134 TestingProfile* profile_; // Owned by TestingProfileManager. |
| 134 FakeEntry fake_file_; | 135 const FakeEntry* fake_file_; // Owned by FakePRovidedFileSystem. |
| 135 storage::FileSystemURL file_url_; | 136 storage::FileSystemURL file_url_; |
| 136 storage::FileSystemURL wrong_file_url_; | 137 storage::FileSystemURL wrong_file_url_; |
| 137 }; | 138 }; |
| 138 | 139 |
| 139 TEST_F(FileSystemProviderFileStreamReader, Read_AllAtOnce) { | 140 TEST_F(FileSystemProviderFileStreamReader, Read_AllAtOnce) { |
| 140 EventLogger logger; | 141 EventLogger logger; |
| 141 | 142 |
| 142 const int64 initial_offset = 0; | 143 const int64 initial_offset = 0; |
| 143 FileStreamReader reader( | 144 FileStreamReader reader( |
| 144 NULL, file_url_, initial_offset, fake_file_.metadata.modification_time); | 145 NULL, file_url_, initial_offset, fake_file_->metadata->modification_time); |
| 145 scoped_refptr<net::IOBuffer> io_buffer( | 146 scoped_refptr<net::IOBuffer> io_buffer( |
| 146 new net::IOBuffer(fake_file_.metadata.size)); | 147 new net::IOBuffer(fake_file_->metadata->size)); |
| 147 | 148 |
| 148 const int result = | 149 const int result = |
| 149 reader.Read(io_buffer.get(), | 150 reader.Read(io_buffer.get(), |
| 150 fake_file_.metadata.size, | 151 fake_file_->metadata->size, |
| 151 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); | 152 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); |
| 152 EXPECT_EQ(net::ERR_IO_PENDING, result); | 153 EXPECT_EQ(net::ERR_IO_PENDING, result); |
| 153 base::RunLoop().RunUntilIdle(); | 154 base::RunLoop().RunUntilIdle(); |
| 154 | 155 |
| 155 ASSERT_EQ(1u, logger.results().size()); | 156 ASSERT_EQ(1u, logger.results().size()); |
| 156 EXPECT_LT(0, logger.results()[0]); | 157 EXPECT_LT(0, logger.results()[0]); |
| 157 EXPECT_EQ(fake_file_.metadata.size, logger.results()[0]); | 158 EXPECT_EQ(fake_file_->metadata->size, logger.results()[0]); |
| 158 | 159 |
| 159 std::string buffer_as_string(io_buffer->data(), fake_file_.metadata.size); | 160 std::string buffer_as_string(io_buffer->data(), fake_file_->metadata->size); |
| 160 EXPECT_EQ(fake_file_.contents, buffer_as_string); | 161 EXPECT_EQ(fake_file_->contents, buffer_as_string); |
| 161 } | 162 } |
| 162 | 163 |
| 163 TEST_F(FileSystemProviderFileStreamReader, Read_WrongFile) { | 164 TEST_F(FileSystemProviderFileStreamReader, Read_WrongFile) { |
| 164 EventLogger logger; | 165 EventLogger logger; |
| 165 | 166 |
| 166 const int64 initial_offset = 0; | 167 const int64 initial_offset = 0; |
| 167 FileStreamReader reader(NULL, | 168 FileStreamReader reader(NULL, |
| 168 wrong_file_url_, | 169 wrong_file_url_, |
| 169 initial_offset, | 170 initial_offset, |
| 170 fake_file_.metadata.modification_time); | 171 fake_file_->metadata->modification_time); |
| 171 scoped_refptr<net::IOBuffer> io_buffer( | 172 scoped_refptr<net::IOBuffer> io_buffer( |
| 172 new net::IOBuffer(fake_file_.metadata.size)); | 173 new net::IOBuffer(fake_file_->metadata->size)); |
| 173 | 174 |
| 174 const int result = | 175 const int result = |
| 175 reader.Read(io_buffer.get(), | 176 reader.Read(io_buffer.get(), |
| 176 fake_file_.metadata.size, | 177 fake_file_->metadata->size, |
| 177 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); | 178 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); |
| 178 EXPECT_EQ(net::ERR_IO_PENDING, result); | 179 EXPECT_EQ(net::ERR_IO_PENDING, result); |
| 179 base::RunLoop().RunUntilIdle(); | 180 base::RunLoop().RunUntilIdle(); |
| 180 | 181 |
| 181 ASSERT_EQ(1u, logger.results().size()); | 182 ASSERT_EQ(1u, logger.results().size()); |
| 182 EXPECT_EQ(net::ERR_FILE_NOT_FOUND, logger.results()[0]); | 183 EXPECT_EQ(net::ERR_FILE_NOT_FOUND, logger.results()[0]); |
| 183 } | 184 } |
| 184 | 185 |
| 185 TEST_F(FileSystemProviderFileStreamReader, Read_InChunks) { | 186 TEST_F(FileSystemProviderFileStreamReader, Read_InChunks) { |
| 186 EventLogger logger; | 187 EventLogger logger; |
| 187 | 188 |
| 188 const int64 initial_offset = 0; | 189 const int64 initial_offset = 0; |
| 189 FileStreamReader reader( | 190 FileStreamReader reader( |
| 190 NULL, file_url_, initial_offset, fake_file_.metadata.modification_time); | 191 NULL, file_url_, initial_offset, fake_file_->metadata->modification_time); |
| 191 | 192 |
| 192 for (int64 offset = 0; offset < fake_file_.metadata.size; ++offset) { | 193 for (int64 offset = 0; offset < fake_file_->metadata->size; ++offset) { |
| 193 scoped_refptr<net::IOBuffer> io_buffer(new net::IOBuffer(1)); | 194 scoped_refptr<net::IOBuffer> io_buffer(new net::IOBuffer(1)); |
| 194 const int result = | 195 const int result = |
| 195 reader.Read(io_buffer.get(), | 196 reader.Read(io_buffer.get(), |
| 196 1, | 197 1, |
| 197 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); | 198 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); |
| 198 EXPECT_EQ(net::ERR_IO_PENDING, result); | 199 EXPECT_EQ(net::ERR_IO_PENDING, result); |
| 199 base::RunLoop().RunUntilIdle(); | 200 base::RunLoop().RunUntilIdle(); |
| 200 ASSERT_EQ(offset + 1, static_cast<int64>(logger.results().size())); | 201 ASSERT_EQ(offset + 1, static_cast<int64>(logger.results().size())); |
| 201 EXPECT_EQ(1, logger.results()[offset]); | 202 EXPECT_EQ(1, logger.results()[offset]); |
| 202 EXPECT_EQ(fake_file_.contents[offset], io_buffer->data()[0]); | 203 EXPECT_EQ(fake_file_->contents[offset], io_buffer->data()[0]); |
| 203 } | 204 } |
| 204 } | 205 } |
| 205 | 206 |
| 206 TEST_F(FileSystemProviderFileStreamReader, Read_Slice) { | 207 TEST_F(FileSystemProviderFileStreamReader, Read_Slice) { |
| 207 EventLogger logger; | 208 EventLogger logger; |
| 208 | 209 |
| 209 // Trim first 3 and last 3 characters. | 210 // Trim first 3 and last 3 characters. |
| 210 const int64 initial_offset = 3; | 211 const int64 initial_offset = 3; |
| 211 const int length = fake_file_.metadata.size - initial_offset - 3; | 212 const int length = fake_file_->metadata->size - initial_offset - 3; |
| 212 ASSERT_GT(fake_file_.metadata.size, initial_offset); | 213 ASSERT_GT(fake_file_->metadata->size, initial_offset); |
| 213 ASSERT_LT(0, length); | 214 ASSERT_LT(0, length); |
| 214 | 215 |
| 215 FileStreamReader reader( | 216 FileStreamReader reader( |
| 216 NULL, file_url_, initial_offset, fake_file_.metadata.modification_time); | 217 NULL, file_url_, initial_offset, fake_file_->metadata->modification_time); |
| 217 scoped_refptr<net::IOBuffer> io_buffer(new net::IOBuffer(length)); | 218 scoped_refptr<net::IOBuffer> io_buffer(new net::IOBuffer(length)); |
| 218 | 219 |
| 219 const int result = | 220 const int result = |
| 220 reader.Read(io_buffer.get(), | 221 reader.Read(io_buffer.get(), |
| 221 length, | 222 length, |
| 222 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); | 223 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); |
| 223 EXPECT_EQ(net::ERR_IO_PENDING, result); | 224 EXPECT_EQ(net::ERR_IO_PENDING, result); |
| 224 base::RunLoop().RunUntilIdle(); | 225 base::RunLoop().RunUntilIdle(); |
| 225 | 226 |
| 226 ASSERT_EQ(1u, logger.results().size()); | 227 ASSERT_EQ(1u, logger.results().size()); |
| 227 EXPECT_EQ(length, logger.results()[0]); | 228 EXPECT_EQ(length, logger.results()[0]); |
| 228 | 229 |
| 229 std::string buffer_as_string(io_buffer->data(), length); | 230 std::string buffer_as_string(io_buffer->data(), length); |
| 230 std::string expected_buffer(fake_file_.contents.data() + initial_offset, | 231 std::string expected_buffer(fake_file_->contents.data() + initial_offset, |
| 231 length); | 232 length); |
| 232 EXPECT_EQ(expected_buffer, buffer_as_string); | 233 EXPECT_EQ(expected_buffer, buffer_as_string); |
| 233 } | 234 } |
| 234 | 235 |
| 235 TEST_F(FileSystemProviderFileStreamReader, Read_Beyond) { | 236 TEST_F(FileSystemProviderFileStreamReader, Read_Beyond) { |
| 236 EventLogger logger; | 237 EventLogger logger; |
| 237 | 238 |
| 238 // Request reading 1KB more than available. | 239 // Request reading 1KB more than available. |
| 239 const int64 initial_offset = 0; | 240 const int64 initial_offset = 0; |
| 240 const int length = fake_file_.metadata.size + 1024; | 241 const int length = fake_file_->metadata->size + 1024; |
| 241 | 242 |
| 242 FileStreamReader reader( | 243 FileStreamReader reader( |
| 243 NULL, file_url_, initial_offset, fake_file_.metadata.modification_time); | 244 NULL, file_url_, initial_offset, fake_file_->metadata->modification_time); |
| 244 scoped_refptr<net::IOBuffer> io_buffer(new net::IOBuffer(length)); | 245 scoped_refptr<net::IOBuffer> io_buffer(new net::IOBuffer(length)); |
| 245 | 246 |
| 246 const int result = | 247 const int result = |
| 247 reader.Read(io_buffer.get(), | 248 reader.Read(io_buffer.get(), |
| 248 length, | 249 length, |
| 249 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); | 250 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); |
| 250 EXPECT_EQ(net::ERR_IO_PENDING, result); | 251 EXPECT_EQ(net::ERR_IO_PENDING, result); |
| 251 base::RunLoop().RunUntilIdle(); | 252 base::RunLoop().RunUntilIdle(); |
| 252 | 253 |
| 253 ASSERT_EQ(1u, logger.results().size()); | 254 ASSERT_EQ(1u, logger.results().size()); |
| 254 EXPECT_LT(0, logger.results()[0]); | 255 EXPECT_LT(0, logger.results()[0]); |
| 255 EXPECT_EQ(fake_file_.metadata.size, logger.results()[0]); | 256 EXPECT_EQ(fake_file_->metadata->size, logger.results()[0]); |
| 256 | 257 |
| 257 std::string buffer_as_string(io_buffer->data(), fake_file_.metadata.size); | 258 std::string buffer_as_string(io_buffer->data(), fake_file_->metadata->size); |
| 258 EXPECT_EQ(fake_file_.contents, buffer_as_string); | 259 EXPECT_EQ(fake_file_->contents, buffer_as_string); |
| 259 } | 260 } |
| 260 | 261 |
| 261 TEST_F(FileSystemProviderFileStreamReader, Read_ModifiedFile) { | 262 TEST_F(FileSystemProviderFileStreamReader, Read_ModifiedFile) { |
| 262 EventLogger logger; | 263 EventLogger logger; |
| 263 | 264 |
| 264 const int64 initial_offset = 0; | 265 const int64 initial_offset = 0; |
| 265 FileStreamReader reader(NULL, file_url_, initial_offset, base::Time::Max()); | 266 FileStreamReader reader(NULL, file_url_, initial_offset, base::Time::Max()); |
| 266 | 267 |
| 267 scoped_refptr<net::IOBuffer> io_buffer( | 268 scoped_refptr<net::IOBuffer> io_buffer( |
| 268 new net::IOBuffer(fake_file_.metadata.size)); | 269 new net::IOBuffer(fake_file_->metadata->size)); |
| 269 const int result = | 270 const int result = |
| 270 reader.Read(io_buffer.get(), | 271 reader.Read(io_buffer.get(), |
| 271 fake_file_.metadata.size, | 272 fake_file_->metadata->size, |
| 272 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); | 273 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); |
| 273 | 274 |
| 274 EXPECT_EQ(net::ERR_IO_PENDING, result); | 275 EXPECT_EQ(net::ERR_IO_PENDING, result); |
| 275 base::RunLoop().RunUntilIdle(); | 276 base::RunLoop().RunUntilIdle(); |
| 276 | 277 |
| 277 ASSERT_EQ(1u, logger.results().size()); | 278 ASSERT_EQ(1u, logger.results().size()); |
| 278 EXPECT_EQ(net::ERR_UPLOAD_FILE_CHANGED, logger.results()[0]); | 279 EXPECT_EQ(net::ERR_UPLOAD_FILE_CHANGED, logger.results()[0]); |
| 279 } | 280 } |
| 280 | 281 |
| 281 TEST_F(FileSystemProviderFileStreamReader, Read_ExpectedModificationTimeNull) { | 282 TEST_F(FileSystemProviderFileStreamReader, Read_ExpectedModificationTimeNull) { |
| 282 EventLogger logger; | 283 EventLogger logger; |
| 283 | 284 |
| 284 const int64 initial_offset = 0; | 285 const int64 initial_offset = 0; |
| 285 FileStreamReader reader(NULL, file_url_, initial_offset, base::Time()); | 286 FileStreamReader reader(NULL, file_url_, initial_offset, base::Time()); |
| 286 | 287 |
| 287 scoped_refptr<net::IOBuffer> io_buffer( | 288 scoped_refptr<net::IOBuffer> io_buffer( |
| 288 new net::IOBuffer(fake_file_.metadata.size)); | 289 new net::IOBuffer(fake_file_->metadata->size)); |
| 289 const int result = | 290 const int result = |
| 290 reader.Read(io_buffer.get(), | 291 reader.Read(io_buffer.get(), |
| 291 fake_file_.metadata.size, | 292 fake_file_->metadata->size, |
| 292 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); | 293 base::Bind(&EventLogger::OnRead, logger.GetWeakPtr())); |
| 293 | 294 |
| 294 EXPECT_EQ(net::ERR_IO_PENDING, result); | 295 EXPECT_EQ(net::ERR_IO_PENDING, result); |
| 295 base::RunLoop().RunUntilIdle(); | 296 base::RunLoop().RunUntilIdle(); |
| 296 | 297 |
| 297 ASSERT_EQ(1u, logger.results().size()); | 298 ASSERT_EQ(1u, logger.results().size()); |
| 298 EXPECT_EQ(fake_file_.metadata.size, logger.results()[0]); | 299 EXPECT_EQ(fake_file_->metadata->size, logger.results()[0]); |
| 299 | 300 |
| 300 std::string buffer_as_string(io_buffer->data(), fake_file_.metadata.size); | 301 std::string buffer_as_string(io_buffer->data(), fake_file_->metadata->size); |
| 301 EXPECT_EQ(fake_file_.contents, buffer_as_string); | 302 EXPECT_EQ(fake_file_->contents, buffer_as_string); |
| 302 } | 303 } |
| 303 | 304 |
| 304 TEST_F(FileSystemProviderFileStreamReader, GetLength) { | 305 TEST_F(FileSystemProviderFileStreamReader, GetLength) { |
| 305 EventLogger logger; | 306 EventLogger logger; |
| 306 | 307 |
| 307 const int64 initial_offset = 0; | 308 const int64 initial_offset = 0; |
| 308 FileStreamReader reader( | 309 FileStreamReader reader( |
| 309 NULL, file_url_, initial_offset, fake_file_.metadata.modification_time); | 310 NULL, file_url_, initial_offset, fake_file_->metadata->modification_time); |
| 310 | 311 |
| 311 const int result = reader.GetLength( | 312 const int result = reader.GetLength( |
| 312 base::Bind(&EventLogger::OnGetLength, logger.GetWeakPtr())); | 313 base::Bind(&EventLogger::OnGetLength, logger.GetWeakPtr())); |
| 313 EXPECT_EQ(net::ERR_IO_PENDING, result); | 314 EXPECT_EQ(net::ERR_IO_PENDING, result); |
| 314 base::RunLoop().RunUntilIdle(); | 315 base::RunLoop().RunUntilIdle(); |
| 315 | 316 |
| 316 ASSERT_EQ(1u, logger.results().size()); | 317 ASSERT_EQ(1u, logger.results().size()); |
| 317 EXPECT_LT(0, logger.results()[0]); | 318 EXPECT_LT(0, logger.results()[0]); |
| 318 EXPECT_EQ(fake_file_.metadata.size, logger.results()[0]); | 319 EXPECT_EQ(fake_file_->metadata->size, logger.results()[0]); |
| 319 } | 320 } |
| 320 | 321 |
| 321 TEST_F(FileSystemProviderFileStreamReader, GetLength_WrongFile) { | 322 TEST_F(FileSystemProviderFileStreamReader, GetLength_WrongFile) { |
| 322 EventLogger logger; | 323 EventLogger logger; |
| 323 | 324 |
| 324 const int64 initial_offset = 0; | 325 const int64 initial_offset = 0; |
| 325 FileStreamReader reader(NULL, | 326 FileStreamReader reader(NULL, |
| 326 wrong_file_url_, | 327 wrong_file_url_, |
| 327 initial_offset, | 328 initial_offset, |
| 328 fake_file_.metadata.modification_time); | 329 fake_file_->metadata->modification_time); |
| 329 | 330 |
| 330 const int result = reader.GetLength( | 331 const int result = reader.GetLength( |
| 331 base::Bind(&EventLogger::OnGetLength, logger.GetWeakPtr())); | 332 base::Bind(&EventLogger::OnGetLength, logger.GetWeakPtr())); |
| 332 EXPECT_EQ(net::ERR_IO_PENDING, result); | 333 EXPECT_EQ(net::ERR_IO_PENDING, result); |
| 333 base::RunLoop().RunUntilIdle(); | 334 base::RunLoop().RunUntilIdle(); |
| 334 | 335 |
| 335 ASSERT_EQ(1u, logger.results().size()); | 336 ASSERT_EQ(1u, logger.results().size()); |
| 336 EXPECT_EQ(net::ERR_FILE_NOT_FOUND, logger.results()[0]); | 337 EXPECT_EQ(net::ERR_FILE_NOT_FOUND, logger.results()[0]); |
| 337 } | 338 } |
| 338 | 339 |
| (...skipping 19 matching lines...) Expand all Loading... |
| 358 const int64 initial_offset = 0; | 359 const int64 initial_offset = 0; |
| 359 FileStreamReader reader(NULL, file_url_, initial_offset, base::Time()); | 360 FileStreamReader reader(NULL, file_url_, initial_offset, base::Time()); |
| 360 | 361 |
| 361 const int result = reader.GetLength( | 362 const int result = reader.GetLength( |
| 362 base::Bind(&EventLogger::OnGetLength, logger.GetWeakPtr())); | 363 base::Bind(&EventLogger::OnGetLength, logger.GetWeakPtr())); |
| 363 EXPECT_EQ(net::ERR_IO_PENDING, result); | 364 EXPECT_EQ(net::ERR_IO_PENDING, result); |
| 364 base::RunLoop().RunUntilIdle(); | 365 base::RunLoop().RunUntilIdle(); |
| 365 | 366 |
| 366 ASSERT_EQ(1u, logger.results().size()); | 367 ASSERT_EQ(1u, logger.results().size()); |
| 367 EXPECT_LT(0, logger.results()[0]); | 368 EXPECT_LT(0, logger.results()[0]); |
| 368 EXPECT_EQ(fake_file_.metadata.size, logger.results()[0]); | 369 EXPECT_EQ(fake_file_->metadata->size, logger.results()[0]); |
| 369 } | 370 } |
| 370 | 371 |
| 371 } // namespace file_system_provider | 372 } // namespace file_system_provider |
| 372 } // namespace chromeos | 373 } // namespace chromeos |
| OLD | NEW |