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 "net/base/file_stream.h" | 5 #include "net/base/file_stream.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/callback.h" | 8 #include "base/callback.h" |
9 #include "base/file_util.h" | 9 #include "base/file_util.h" |
10 #include "base/message_loop.h" | 10 #include "base/message_loop.h" |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
47 private: | 47 private: |
48 FilePath temp_file_path_; | 48 FilePath temp_file_path_; |
49 }; | 49 }; |
50 | 50 |
51 namespace { | 51 namespace { |
52 | 52 |
53 TEST_F(FileStreamTest, BasicOpenClose) { | 53 TEST_F(FileStreamTest, BasicOpenClose) { |
54 base::PlatformFile file = base::kInvalidPlatformFileValue; | 54 base::PlatformFile file = base::kInvalidPlatformFileValue; |
55 { | 55 { |
56 FileStream stream(NULL); | 56 FileStream stream(NULL); |
57 int rv = stream.Open(temp_file_path(), | 57 int rv = stream.OpenSync(temp_file_path(), |
58 base::PLATFORM_FILE_OPEN | base::PLATFORM_FILE_READ); | 58 base::PLATFORM_FILE_OPEN | base::PLATFORM_FILE_READ); |
59 EXPECT_EQ(OK, rv); | 59 EXPECT_EQ(OK, rv); |
60 EXPECT_TRUE(stream.IsOpen()); | 60 EXPECT_TRUE(stream.IsOpen()); |
61 file = GetFile(stream); | 61 file = GetFile(stream); |
62 } | 62 } |
63 EXPECT_NE(base::kInvalidPlatformFileValue, file); | 63 EXPECT_NE(base::kInvalidPlatformFileValue, file); |
64 base::PlatformFileInfo info; | 64 base::PlatformFileInfo info; |
65 // The file should be closed. | 65 // The file should be closed. |
66 EXPECT_FALSE(base::GetPlatformFileInfo(file, &info)); | 66 EXPECT_FALSE(base::GetPlatformFileInfo(file, &info)); |
67 } | 67 } |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
101 | 101 |
102 // Seek to the beginning of the file and read. | 102 // Seek to the beginning of the file and read. |
103 FileStream read_stream(file, flags, NULL); | 103 FileStream read_stream(file, flags, NULL); |
104 ASSERT_EQ(0, read_stream.Seek(FROM_BEGIN, 0)); | 104 ASSERT_EQ(0, read_stream.Seek(FROM_BEGIN, 0)); |
105 ASSERT_EQ(kTestDataSize, read_stream.Available()); | 105 ASSERT_EQ(kTestDataSize, read_stream.Available()); |
106 // Read into buffer and compare. | 106 // Read into buffer and compare. |
107 char buffer[kTestDataSize]; | 107 char buffer[kTestDataSize]; |
108 ASSERT_EQ(kTestDataSize, | 108 ASSERT_EQ(kTestDataSize, |
109 read_stream.Read(buffer, kTestDataSize, CompletionCallback())); | 109 read_stream.Read(buffer, kTestDataSize, CompletionCallback())); |
110 ASSERT_EQ(0, memcmp(kTestData, buffer, kTestDataSize)); | 110 ASSERT_EQ(0, memcmp(kTestData, buffer, kTestDataSize)); |
111 read_stream.Close(); | 111 read_stream.CloseSync(); |
112 | 112 |
113 // 2. Test writing with a file handle. | 113 // 2. Test writing with a file handle. |
114 file_util::Delete(temp_file_path(), false); | 114 file_util::Delete(temp_file_path(), false); |
115 flags = base::PLATFORM_FILE_OPEN_ALWAYS | base::PLATFORM_FILE_WRITE; | 115 flags = base::PLATFORM_FILE_OPEN_ALWAYS | base::PLATFORM_FILE_WRITE; |
116 file = base::CreatePlatformFile(temp_file_path(), flags, &created, NULL); | 116 file = base::CreatePlatformFile(temp_file_path(), flags, &created, NULL); |
117 | 117 |
118 FileStream write_stream(file, flags, NULL); | 118 FileStream write_stream(file, flags, NULL); |
119 ASSERT_EQ(0, write_stream.Seek(FROM_BEGIN, 0)); | 119 ASSERT_EQ(0, write_stream.Seek(FROM_BEGIN, 0)); |
120 ASSERT_EQ(kTestDataSize, | 120 ASSERT_EQ(kTestDataSize, |
121 write_stream.Write(kTestData, kTestDataSize, CompletionCallback())); | 121 write_stream.Write(kTestData, kTestDataSize, CompletionCallback())); |
122 write_stream.Close(); | 122 write_stream.CloseSync(); |
123 | 123 |
124 // Read into buffer and compare to make sure the handle worked fine. | 124 // Read into buffer and compare to make sure the handle worked fine. |
125 ASSERT_EQ(kTestDataSize, | 125 ASSERT_EQ(kTestDataSize, |
126 file_util::ReadFile(temp_file_path(), buffer, kTestDataSize)); | 126 file_util::ReadFile(temp_file_path(), buffer, kTestDataSize)); |
127 ASSERT_EQ(0, memcmp(kTestData, buffer, kTestDataSize)); | 127 ASSERT_EQ(0, memcmp(kTestData, buffer, kTestDataSize)); |
128 } | 128 } |
129 | 129 |
130 TEST_F(FileStreamTest, UseClosedStream) { | 130 TEST_F(FileStreamTest, UseClosedStream) { |
131 FileStream stream(NULL); | 131 FileStream stream(NULL); |
132 | 132 |
(...skipping 14 matching lines...) Expand all Loading... |
147 } | 147 } |
148 | 148 |
149 TEST_F(FileStreamTest, BasicRead) { | 149 TEST_F(FileStreamTest, BasicRead) { |
150 int64 file_size; | 150 int64 file_size; |
151 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); | 151 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); |
152 EXPECT_TRUE(ok); | 152 EXPECT_TRUE(ok); |
153 | 153 |
154 FileStream stream(NULL); | 154 FileStream stream(NULL); |
155 int flags = base::PLATFORM_FILE_OPEN | | 155 int flags = base::PLATFORM_FILE_OPEN | |
156 base::PLATFORM_FILE_READ; | 156 base::PLATFORM_FILE_READ; |
157 int rv = stream.Open(temp_file_path(), flags); | 157 int rv = stream.OpenSync(temp_file_path(), flags); |
158 EXPECT_EQ(OK, rv); | 158 EXPECT_EQ(OK, rv); |
159 | 159 |
160 int64 total_bytes_avail = stream.Available(); | 160 int64 total_bytes_avail = stream.Available(); |
161 EXPECT_EQ(file_size, total_bytes_avail); | 161 EXPECT_EQ(file_size, total_bytes_avail); |
162 | 162 |
163 int total_bytes_read = 0; | 163 int total_bytes_read = 0; |
164 | 164 |
165 std::string data_read; | 165 std::string data_read; |
166 for (;;) { | 166 for (;;) { |
167 char buf[4]; | 167 char buf[4]; |
(...skipping 10 matching lines...) Expand all Loading... |
178 | 178 |
179 TEST_F(FileStreamTest, AsyncRead) { | 179 TEST_F(FileStreamTest, AsyncRead) { |
180 int64 file_size; | 180 int64 file_size; |
181 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); | 181 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); |
182 EXPECT_TRUE(ok); | 182 EXPECT_TRUE(ok); |
183 | 183 |
184 FileStream stream(NULL); | 184 FileStream stream(NULL); |
185 int flags = base::PLATFORM_FILE_OPEN | | 185 int flags = base::PLATFORM_FILE_OPEN | |
186 base::PLATFORM_FILE_READ | | 186 base::PLATFORM_FILE_READ | |
187 base::PLATFORM_FILE_ASYNC; | 187 base::PLATFORM_FILE_ASYNC; |
188 int rv = stream.Open(temp_file_path(), flags); | 188 int rv = stream.OpenSync(temp_file_path(), flags); |
189 EXPECT_EQ(OK, rv); | 189 EXPECT_EQ(OK, rv); |
190 | 190 |
191 int64 total_bytes_avail = stream.Available(); | 191 int64 total_bytes_avail = stream.Available(); |
192 EXPECT_EQ(file_size, total_bytes_avail); | 192 EXPECT_EQ(file_size, total_bytes_avail); |
193 | 193 |
194 TestCompletionCallback callback; | 194 TestCompletionCallback callback; |
195 | 195 |
196 int total_bytes_read = 0; | 196 int total_bytes_read = 0; |
197 | 197 |
198 std::string data_read; | 198 std::string data_read; |
(...skipping 14 matching lines...) Expand all Loading... |
213 | 213 |
214 TEST_F(FileStreamTest, AsyncRead_EarlyClose) { | 214 TEST_F(FileStreamTest, AsyncRead_EarlyClose) { |
215 int64 file_size; | 215 int64 file_size; |
216 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); | 216 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); |
217 EXPECT_TRUE(ok); | 217 EXPECT_TRUE(ok); |
218 | 218 |
219 FileStream stream(NULL); | 219 FileStream stream(NULL); |
220 int flags = base::PLATFORM_FILE_OPEN | | 220 int flags = base::PLATFORM_FILE_OPEN | |
221 base::PLATFORM_FILE_READ | | 221 base::PLATFORM_FILE_READ | |
222 base::PLATFORM_FILE_ASYNC; | 222 base::PLATFORM_FILE_ASYNC; |
223 int rv = stream.Open(temp_file_path(), flags); | 223 int rv = stream.OpenSync(temp_file_path(), flags); |
224 EXPECT_EQ(OK, rv); | 224 EXPECT_EQ(OK, rv); |
225 | 225 |
226 int64 total_bytes_avail = stream.Available(); | 226 int64 total_bytes_avail = stream.Available(); |
227 EXPECT_EQ(file_size, total_bytes_avail); | 227 EXPECT_EQ(file_size, total_bytes_avail); |
228 | 228 |
229 TestCompletionCallback callback; | 229 TestCompletionCallback callback; |
230 | 230 |
231 char buf[4]; | 231 char buf[4]; |
232 rv = stream.Read(buf, arraysize(buf), callback.callback()); | 232 rv = stream.Read(buf, arraysize(buf), callback.callback()); |
233 stream.Close(); | 233 stream.CloseSync(); |
234 if (rv < 0) { | 234 if (rv < 0) { |
235 EXPECT_EQ(ERR_IO_PENDING, rv); | 235 EXPECT_EQ(ERR_IO_PENDING, rv); |
236 // The callback should not be called if the request is cancelled. | 236 // The callback should not be called if the request is cancelled. |
237 MessageLoop::current()->RunAllPending(); | 237 MessageLoop::current()->RunAllPending(); |
238 EXPECT_FALSE(callback.have_result()); | 238 EXPECT_FALSE(callback.have_result()); |
239 } else { | 239 } else { |
240 EXPECT_EQ(std::string(kTestData, rv), std::string(buf, rv)); | 240 EXPECT_EQ(std::string(kTestData, rv), std::string(buf, rv)); |
241 } | 241 } |
242 } | 242 } |
243 | 243 |
244 TEST_F(FileStreamTest, BasicRead_FromOffset) { | 244 TEST_F(FileStreamTest, BasicRead_FromOffset) { |
245 int64 file_size; | 245 int64 file_size; |
246 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); | 246 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); |
247 EXPECT_TRUE(ok); | 247 EXPECT_TRUE(ok); |
248 | 248 |
249 FileStream stream(NULL); | 249 FileStream stream(NULL); |
250 int flags = base::PLATFORM_FILE_OPEN | | 250 int flags = base::PLATFORM_FILE_OPEN | |
251 base::PLATFORM_FILE_READ; | 251 base::PLATFORM_FILE_READ; |
252 int rv = stream.Open(temp_file_path(), flags); | 252 int rv = stream.OpenSync(temp_file_path(), flags); |
253 EXPECT_EQ(OK, rv); | 253 EXPECT_EQ(OK, rv); |
254 | 254 |
255 const int64 kOffset = 3; | 255 const int64 kOffset = 3; |
256 int64 new_offset = stream.Seek(FROM_BEGIN, kOffset); | 256 int64 new_offset = stream.Seek(FROM_BEGIN, kOffset); |
257 EXPECT_EQ(kOffset, new_offset); | 257 EXPECT_EQ(kOffset, new_offset); |
258 | 258 |
259 int64 total_bytes_avail = stream.Available(); | 259 int64 total_bytes_avail = stream.Available(); |
260 EXPECT_EQ(file_size - kOffset, total_bytes_avail); | 260 EXPECT_EQ(file_size - kOffset, total_bytes_avail); |
261 | 261 |
262 int64 total_bytes_read = 0; | 262 int64 total_bytes_read = 0; |
(...skipping 15 matching lines...) Expand all Loading... |
278 | 278 |
279 TEST_F(FileStreamTest, AsyncRead_FromOffset) { | 279 TEST_F(FileStreamTest, AsyncRead_FromOffset) { |
280 int64 file_size; | 280 int64 file_size; |
281 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); | 281 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); |
282 EXPECT_TRUE(ok); | 282 EXPECT_TRUE(ok); |
283 | 283 |
284 FileStream stream(NULL); | 284 FileStream stream(NULL); |
285 int flags = base::PLATFORM_FILE_OPEN | | 285 int flags = base::PLATFORM_FILE_OPEN | |
286 base::PLATFORM_FILE_READ | | 286 base::PLATFORM_FILE_READ | |
287 base::PLATFORM_FILE_ASYNC; | 287 base::PLATFORM_FILE_ASYNC; |
288 int rv = stream.Open(temp_file_path(), flags); | 288 int rv = stream.OpenSync(temp_file_path(), flags); |
289 EXPECT_EQ(OK, rv); | 289 EXPECT_EQ(OK, rv); |
290 | 290 |
291 const int64 kOffset = 3; | 291 const int64 kOffset = 3; |
292 int64 new_offset = stream.Seek(FROM_BEGIN, kOffset); | 292 int64 new_offset = stream.Seek(FROM_BEGIN, kOffset); |
293 EXPECT_EQ(kOffset, new_offset); | 293 EXPECT_EQ(kOffset, new_offset); |
294 | 294 |
295 int64 total_bytes_avail = stream.Available(); | 295 int64 total_bytes_avail = stream.Available(); |
296 EXPECT_EQ(file_size - kOffset, total_bytes_avail); | 296 EXPECT_EQ(file_size - kOffset, total_bytes_avail); |
297 | 297 |
298 TestCompletionCallback callback; | 298 TestCompletionCallback callback; |
(...skipping 13 matching lines...) Expand all Loading... |
312 data_read.append(buf, rv); | 312 data_read.append(buf, rv); |
313 } | 313 } |
314 EXPECT_EQ(file_size - kOffset, total_bytes_read); | 314 EXPECT_EQ(file_size - kOffset, total_bytes_read); |
315 EXPECT_EQ(kTestData + kOffset, data_read); | 315 EXPECT_EQ(kTestData + kOffset, data_read); |
316 } | 316 } |
317 | 317 |
318 TEST_F(FileStreamTest, SeekAround) { | 318 TEST_F(FileStreamTest, SeekAround) { |
319 FileStream stream(NULL); | 319 FileStream stream(NULL); |
320 int flags = base::PLATFORM_FILE_OPEN | | 320 int flags = base::PLATFORM_FILE_OPEN | |
321 base::PLATFORM_FILE_READ; | 321 base::PLATFORM_FILE_READ; |
322 int rv = stream.Open(temp_file_path(), flags); | 322 int rv = stream.OpenSync(temp_file_path(), flags); |
323 EXPECT_EQ(OK, rv); | 323 EXPECT_EQ(OK, rv); |
324 | 324 |
325 const int64 kOffset = 3; | 325 const int64 kOffset = 3; |
326 int64 new_offset = stream.Seek(FROM_BEGIN, kOffset); | 326 int64 new_offset = stream.Seek(FROM_BEGIN, kOffset); |
327 EXPECT_EQ(kOffset, new_offset); | 327 EXPECT_EQ(kOffset, new_offset); |
328 | 328 |
329 new_offset = stream.Seek(FROM_CURRENT, kOffset); | 329 new_offset = stream.Seek(FROM_CURRENT, kOffset); |
330 EXPECT_EQ(2 * kOffset, new_offset); | 330 EXPECT_EQ(2 * kOffset, new_offset); |
331 | 331 |
332 new_offset = stream.Seek(FROM_CURRENT, -kOffset); | 332 new_offset = stream.Seek(FROM_CURRENT, -kOffset); |
333 EXPECT_EQ(kOffset, new_offset); | 333 EXPECT_EQ(kOffset, new_offset); |
334 | 334 |
335 const int kTestDataLen = arraysize(kTestData) - 1; | 335 const int kTestDataLen = arraysize(kTestData) - 1; |
336 | 336 |
337 new_offset = stream.Seek(FROM_END, -kTestDataLen); | 337 new_offset = stream.Seek(FROM_END, -kTestDataLen); |
338 EXPECT_EQ(0, new_offset); | 338 EXPECT_EQ(0, new_offset); |
339 } | 339 } |
340 | 340 |
341 TEST_F(FileStreamTest, BasicWrite) { | 341 TEST_F(FileStreamTest, BasicWrite) { |
342 FileStream stream(NULL); | 342 FileStream stream(NULL); |
343 int flags = base::PLATFORM_FILE_CREATE_ALWAYS | | 343 int flags = base::PLATFORM_FILE_CREATE_ALWAYS | |
344 base::PLATFORM_FILE_WRITE; | 344 base::PLATFORM_FILE_WRITE; |
345 int rv = stream.Open(temp_file_path(), flags); | 345 int rv = stream.OpenSync(temp_file_path(), flags); |
346 EXPECT_EQ(OK, rv); | 346 EXPECT_EQ(OK, rv); |
347 | 347 |
348 int64 file_size; | 348 int64 file_size; |
349 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); | 349 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); |
350 EXPECT_TRUE(ok); | 350 EXPECT_TRUE(ok); |
351 EXPECT_EQ(0, file_size); | 351 EXPECT_EQ(0, file_size); |
352 | 352 |
353 rv = stream.Write(kTestData, kTestDataSize, CompletionCallback()); | 353 rv = stream.Write(kTestData, kTestDataSize, CompletionCallback()); |
354 EXPECT_EQ(kTestDataSize, rv); | 354 EXPECT_EQ(kTestDataSize, rv); |
355 stream.Close(); | 355 stream.CloseSync(); |
356 | 356 |
357 ok = file_util::GetFileSize(temp_file_path(), &file_size); | 357 ok = file_util::GetFileSize(temp_file_path(), &file_size); |
358 EXPECT_TRUE(ok); | 358 EXPECT_TRUE(ok); |
359 EXPECT_EQ(kTestDataSize, file_size); | 359 EXPECT_EQ(kTestDataSize, file_size); |
360 } | 360 } |
361 | 361 |
362 TEST_F(FileStreamTest, AsyncWrite) { | 362 TEST_F(FileStreamTest, AsyncWrite) { |
363 FileStream stream(NULL); | 363 FileStream stream(NULL); |
364 int flags = base::PLATFORM_FILE_CREATE_ALWAYS | | 364 int flags = base::PLATFORM_FILE_CREATE_ALWAYS | |
365 base::PLATFORM_FILE_WRITE | | 365 base::PLATFORM_FILE_WRITE | |
366 base::PLATFORM_FILE_ASYNC; | 366 base::PLATFORM_FILE_ASYNC; |
367 int rv = stream.Open(temp_file_path(), flags); | 367 int rv = stream.OpenSync(temp_file_path(), flags); |
368 EXPECT_EQ(OK, rv); | 368 EXPECT_EQ(OK, rv); |
369 | 369 |
370 int64 file_size; | 370 int64 file_size; |
371 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); | 371 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); |
372 EXPECT_TRUE(ok); | 372 EXPECT_TRUE(ok); |
373 EXPECT_EQ(0, file_size); | 373 EXPECT_EQ(0, file_size); |
374 | 374 |
375 TestCompletionCallback callback; | 375 TestCompletionCallback callback; |
376 int total_bytes_written = 0; | 376 int total_bytes_written = 0; |
377 | 377 |
(...skipping 11 matching lines...) Expand all Loading... |
389 ok = file_util::GetFileSize(temp_file_path(), &file_size); | 389 ok = file_util::GetFileSize(temp_file_path(), &file_size); |
390 EXPECT_TRUE(ok); | 390 EXPECT_TRUE(ok); |
391 EXPECT_EQ(file_size, total_bytes_written); | 391 EXPECT_EQ(file_size, total_bytes_written); |
392 } | 392 } |
393 | 393 |
394 TEST_F(FileStreamTest, AsyncWrite_EarlyClose) { | 394 TEST_F(FileStreamTest, AsyncWrite_EarlyClose) { |
395 FileStream stream(NULL); | 395 FileStream stream(NULL); |
396 int flags = base::PLATFORM_FILE_CREATE_ALWAYS | | 396 int flags = base::PLATFORM_FILE_CREATE_ALWAYS | |
397 base::PLATFORM_FILE_WRITE | | 397 base::PLATFORM_FILE_WRITE | |
398 base::PLATFORM_FILE_ASYNC; | 398 base::PLATFORM_FILE_ASYNC; |
399 int rv = stream.Open(temp_file_path(), flags); | 399 int rv = stream.OpenSync(temp_file_path(), flags); |
400 EXPECT_EQ(OK, rv); | 400 EXPECT_EQ(OK, rv); |
401 | 401 |
402 int64 file_size; | 402 int64 file_size; |
403 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); | 403 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); |
404 EXPECT_TRUE(ok); | 404 EXPECT_TRUE(ok); |
405 EXPECT_EQ(0, file_size); | 405 EXPECT_EQ(0, file_size); |
406 | 406 |
407 TestCompletionCallback callback; | 407 TestCompletionCallback callback; |
408 int total_bytes_written = 0; | 408 int total_bytes_written = 0; |
409 | 409 |
410 rv = stream.Write(kTestData + total_bytes_written, | 410 rv = stream.Write(kTestData + total_bytes_written, |
411 kTestDataSize - total_bytes_written, | 411 kTestDataSize - total_bytes_written, |
412 callback.callback()); | 412 callback.callback()); |
413 stream.Close(); | 413 stream.CloseSync(); |
414 if (rv < 0) { | 414 if (rv < 0) { |
415 EXPECT_EQ(ERR_IO_PENDING, rv); | 415 EXPECT_EQ(ERR_IO_PENDING, rv); |
416 // The callback should not be called if the request is cancelled. | 416 // The callback should not be called if the request is cancelled. |
417 MessageLoop::current()->RunAllPending(); | 417 MessageLoop::current()->RunAllPending(); |
418 EXPECT_FALSE(callback.have_result()); | 418 EXPECT_FALSE(callback.have_result()); |
419 } else { | 419 } else { |
420 ok = file_util::GetFileSize(temp_file_path(), &file_size); | 420 ok = file_util::GetFileSize(temp_file_path(), &file_size); |
421 EXPECT_TRUE(ok); | 421 EXPECT_TRUE(ok); |
422 EXPECT_EQ(file_size, rv); | 422 EXPECT_EQ(file_size, rv); |
423 } | 423 } |
424 } | 424 } |
425 | 425 |
426 TEST_F(FileStreamTest, BasicWrite_FromOffset) { | 426 TEST_F(FileStreamTest, BasicWrite_FromOffset) { |
427 FileStream stream(NULL); | 427 FileStream stream(NULL); |
428 int flags = base::PLATFORM_FILE_OPEN | | 428 int flags = base::PLATFORM_FILE_OPEN | |
429 base::PLATFORM_FILE_WRITE; | 429 base::PLATFORM_FILE_WRITE; |
430 int rv = stream.Open(temp_file_path(), flags); | 430 int rv = stream.OpenSync(temp_file_path(), flags); |
431 EXPECT_EQ(OK, rv); | 431 EXPECT_EQ(OK, rv); |
432 | 432 |
433 int64 file_size; | 433 int64 file_size; |
434 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); | 434 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); |
435 EXPECT_TRUE(ok); | 435 EXPECT_TRUE(ok); |
436 EXPECT_EQ(kTestDataSize, file_size); | 436 EXPECT_EQ(kTestDataSize, file_size); |
437 | 437 |
438 const int64 kOffset = 0; | 438 const int64 kOffset = 0; |
439 int64 new_offset = stream.Seek(FROM_END, kOffset); | 439 int64 new_offset = stream.Seek(FROM_END, kOffset); |
440 EXPECT_EQ(kTestDataSize, new_offset); | 440 EXPECT_EQ(kTestDataSize, new_offset); |
441 | 441 |
442 rv = stream.Write(kTestData, kTestDataSize, CompletionCallback()); | 442 rv = stream.Write(kTestData, kTestDataSize, CompletionCallback()); |
443 EXPECT_EQ(kTestDataSize, rv); | 443 EXPECT_EQ(kTestDataSize, rv); |
444 stream.Close(); | 444 stream.CloseSync(); |
445 | 445 |
446 ok = file_util::GetFileSize(temp_file_path(), &file_size); | 446 ok = file_util::GetFileSize(temp_file_path(), &file_size); |
447 EXPECT_TRUE(ok); | 447 EXPECT_TRUE(ok); |
448 EXPECT_EQ(kTestDataSize * 2, file_size); | 448 EXPECT_EQ(kTestDataSize * 2, file_size); |
449 } | 449 } |
450 | 450 |
451 TEST_F(FileStreamTest, AsyncWrite_FromOffset) { | 451 TEST_F(FileStreamTest, AsyncWrite_FromOffset) { |
452 int64 file_size; | 452 int64 file_size; |
453 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); | 453 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); |
454 EXPECT_TRUE(ok); | 454 EXPECT_TRUE(ok); |
455 | 455 |
456 FileStream stream(NULL); | 456 FileStream stream(NULL); |
457 int flags = base::PLATFORM_FILE_OPEN | | 457 int flags = base::PLATFORM_FILE_OPEN | |
458 base::PLATFORM_FILE_WRITE | | 458 base::PLATFORM_FILE_WRITE | |
459 base::PLATFORM_FILE_ASYNC; | 459 base::PLATFORM_FILE_ASYNC; |
460 int rv = stream.Open(temp_file_path(), flags); | 460 int rv = stream.OpenSync(temp_file_path(), flags); |
461 EXPECT_EQ(OK, rv); | 461 EXPECT_EQ(OK, rv); |
462 | 462 |
463 const int64 kOffset = 0; | 463 const int64 kOffset = 0; |
464 int64 new_offset = stream.Seek(FROM_END, kOffset); | 464 int64 new_offset = stream.Seek(FROM_END, kOffset); |
465 EXPECT_EQ(kTestDataSize, new_offset); | 465 EXPECT_EQ(kTestDataSize, new_offset); |
466 | 466 |
467 TestCompletionCallback callback; | 467 TestCompletionCallback callback; |
468 int total_bytes_written = 0; | 468 int total_bytes_written = 0; |
469 | 469 |
470 while (total_bytes_written != kTestDataSize) { | 470 while (total_bytes_written != kTestDataSize) { |
(...skipping 14 matching lines...) Expand all Loading... |
485 | 485 |
486 TEST_F(FileStreamTest, BasicReadWrite) { | 486 TEST_F(FileStreamTest, BasicReadWrite) { |
487 int64 file_size; | 487 int64 file_size; |
488 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); | 488 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); |
489 EXPECT_TRUE(ok); | 489 EXPECT_TRUE(ok); |
490 | 490 |
491 FileStream stream(NULL); | 491 FileStream stream(NULL); |
492 int flags = base::PLATFORM_FILE_OPEN | | 492 int flags = base::PLATFORM_FILE_OPEN | |
493 base::PLATFORM_FILE_READ | | 493 base::PLATFORM_FILE_READ | |
494 base::PLATFORM_FILE_WRITE; | 494 base::PLATFORM_FILE_WRITE; |
495 int rv = stream.Open(temp_file_path(), flags); | 495 int rv = stream.OpenSync(temp_file_path(), flags); |
496 EXPECT_EQ(OK, rv); | 496 EXPECT_EQ(OK, rv); |
497 | 497 |
498 int64 total_bytes_avail = stream.Available(); | 498 int64 total_bytes_avail = stream.Available(); |
499 EXPECT_EQ(file_size, total_bytes_avail); | 499 EXPECT_EQ(file_size, total_bytes_avail); |
500 | 500 |
501 int total_bytes_read = 0; | 501 int total_bytes_read = 0; |
502 | 502 |
503 std::string data_read; | 503 std::string data_read; |
504 for (;;) { | 504 for (;;) { |
505 char buf[4]; | 505 char buf[4]; |
506 rv = stream.Read(buf, arraysize(buf), CompletionCallback()); | 506 rv = stream.Read(buf, arraysize(buf), CompletionCallback()); |
507 EXPECT_LE(0, rv); | 507 EXPECT_LE(0, rv); |
508 if (rv <= 0) | 508 if (rv <= 0) |
509 break; | 509 break; |
510 total_bytes_read += rv; | 510 total_bytes_read += rv; |
511 data_read.append(buf, rv); | 511 data_read.append(buf, rv); |
512 } | 512 } |
513 EXPECT_EQ(file_size, total_bytes_read); | 513 EXPECT_EQ(file_size, total_bytes_read); |
514 EXPECT_TRUE(data_read == kTestData); | 514 EXPECT_TRUE(data_read == kTestData); |
515 | 515 |
516 rv = stream.Write(kTestData, kTestDataSize, CompletionCallback()); | 516 rv = stream.Write(kTestData, kTestDataSize, CompletionCallback()); |
517 EXPECT_EQ(kTestDataSize, rv); | 517 EXPECT_EQ(kTestDataSize, rv); |
518 stream.Close(); | 518 stream.CloseSync(); |
519 | 519 |
520 ok = file_util::GetFileSize(temp_file_path(), &file_size); | 520 ok = file_util::GetFileSize(temp_file_path(), &file_size); |
521 EXPECT_TRUE(ok); | 521 EXPECT_TRUE(ok); |
522 EXPECT_EQ(kTestDataSize * 2, file_size); | 522 EXPECT_EQ(kTestDataSize * 2, file_size); |
523 } | 523 } |
524 | 524 |
525 TEST_F(FileStreamTest, BasicWriteRead) { | 525 TEST_F(FileStreamTest, BasicWriteRead) { |
526 int64 file_size; | 526 int64 file_size; |
527 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); | 527 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); |
528 EXPECT_TRUE(ok); | 528 EXPECT_TRUE(ok); |
529 | 529 |
530 FileStream stream(NULL); | 530 FileStream stream(NULL); |
531 int flags = base::PLATFORM_FILE_OPEN | | 531 int flags = base::PLATFORM_FILE_OPEN | |
532 base::PLATFORM_FILE_READ | | 532 base::PLATFORM_FILE_READ | |
533 base::PLATFORM_FILE_WRITE; | 533 base::PLATFORM_FILE_WRITE; |
534 int rv = stream.Open(temp_file_path(), flags); | 534 int rv = stream.OpenSync(temp_file_path(), flags); |
535 EXPECT_EQ(OK, rv); | 535 EXPECT_EQ(OK, rv); |
536 | 536 |
537 int64 total_bytes_avail = stream.Available(); | 537 int64 total_bytes_avail = stream.Available(); |
538 EXPECT_EQ(file_size, total_bytes_avail); | 538 EXPECT_EQ(file_size, total_bytes_avail); |
539 | 539 |
540 int64 offset = stream.Seek(FROM_END, 0); | 540 int64 offset = stream.Seek(FROM_END, 0); |
541 EXPECT_EQ(offset, file_size); | 541 EXPECT_EQ(offset, file_size); |
542 | 542 |
543 rv = stream.Write(kTestData, kTestDataSize, CompletionCallback()); | 543 rv = stream.Write(kTestData, kTestDataSize, CompletionCallback()); |
544 EXPECT_EQ(kTestDataSize, rv); | 544 EXPECT_EQ(kTestDataSize, rv); |
545 | 545 |
546 offset = stream.Seek(FROM_BEGIN, 0); | 546 offset = stream.Seek(FROM_BEGIN, 0); |
547 EXPECT_EQ(0, offset); | 547 EXPECT_EQ(0, offset); |
548 | 548 |
549 int64 total_bytes_read = 0; | 549 int64 total_bytes_read = 0; |
550 | 550 |
551 std::string data_read; | 551 std::string data_read; |
552 for (;;) { | 552 for (;;) { |
553 char buf[4]; | 553 char buf[4]; |
554 rv = stream.Read(buf, arraysize(buf), CompletionCallback()); | 554 rv = stream.Read(buf, arraysize(buf), CompletionCallback()); |
555 EXPECT_LE(0, rv); | 555 EXPECT_LE(0, rv); |
556 if (rv <= 0) | 556 if (rv <= 0) |
557 break; | 557 break; |
558 total_bytes_read += rv; | 558 total_bytes_read += rv; |
559 data_read.append(buf, rv); | 559 data_read.append(buf, rv); |
560 } | 560 } |
561 stream.Close(); | 561 stream.CloseSync(); |
562 | 562 |
563 ok = file_util::GetFileSize(temp_file_path(), &file_size); | 563 ok = file_util::GetFileSize(temp_file_path(), &file_size); |
564 EXPECT_TRUE(ok); | 564 EXPECT_TRUE(ok); |
565 EXPECT_EQ(kTestDataSize * 2, file_size); | 565 EXPECT_EQ(kTestDataSize * 2, file_size); |
566 EXPECT_EQ(kTestDataSize * 2, total_bytes_read); | 566 EXPECT_EQ(kTestDataSize * 2, total_bytes_read); |
567 | 567 |
568 const std::string kExpectedFileData = | 568 const std::string kExpectedFileData = |
569 std::string(kTestData) + std::string(kTestData); | 569 std::string(kTestData) + std::string(kTestData); |
570 EXPECT_EQ(kExpectedFileData, data_read); | 570 EXPECT_EQ(kExpectedFileData, data_read); |
571 } | 571 } |
572 | 572 |
573 TEST_F(FileStreamTest, BasicAsyncReadWrite) { | 573 TEST_F(FileStreamTest, BasicAsyncReadWrite) { |
574 int64 file_size; | 574 int64 file_size; |
575 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); | 575 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); |
576 EXPECT_TRUE(ok); | 576 EXPECT_TRUE(ok); |
577 | 577 |
578 FileStream stream(NULL); | 578 FileStream stream(NULL); |
579 int flags = base::PLATFORM_FILE_OPEN | | 579 int flags = base::PLATFORM_FILE_OPEN | |
580 base::PLATFORM_FILE_READ | | 580 base::PLATFORM_FILE_READ | |
581 base::PLATFORM_FILE_WRITE | | 581 base::PLATFORM_FILE_WRITE | |
582 base::PLATFORM_FILE_ASYNC; | 582 base::PLATFORM_FILE_ASYNC; |
583 int rv = stream.Open(temp_file_path(), flags); | 583 int rv = stream.OpenSync(temp_file_path(), flags); |
584 EXPECT_EQ(OK, rv); | 584 EXPECT_EQ(OK, rv); |
585 | 585 |
586 int64 total_bytes_avail = stream.Available(); | 586 int64 total_bytes_avail = stream.Available(); |
587 EXPECT_EQ(file_size, total_bytes_avail); | 587 EXPECT_EQ(file_size, total_bytes_avail); |
588 | 588 |
589 TestCompletionCallback callback; | 589 TestCompletionCallback callback; |
590 int64 total_bytes_read = 0; | 590 int64 total_bytes_read = 0; |
591 | 591 |
592 std::string data_read; | 592 std::string data_read; |
593 for (;;) { | 593 for (;;) { |
(...skipping 17 matching lines...) Expand all Loading... |
611 kTestDataSize - total_bytes_written, | 611 kTestDataSize - total_bytes_written, |
612 callback.callback()); | 612 callback.callback()); |
613 if (rv == ERR_IO_PENDING) | 613 if (rv == ERR_IO_PENDING) |
614 rv = callback.WaitForResult(); | 614 rv = callback.WaitForResult(); |
615 EXPECT_LT(0, rv); | 615 EXPECT_LT(0, rv); |
616 if (rv <= 0) | 616 if (rv <= 0) |
617 break; | 617 break; |
618 total_bytes_written += rv; | 618 total_bytes_written += rv; |
619 } | 619 } |
620 | 620 |
621 stream.Close(); | 621 stream.CloseSync(); |
622 | 622 |
623 ok = file_util::GetFileSize(temp_file_path(), &file_size); | 623 ok = file_util::GetFileSize(temp_file_path(), &file_size); |
624 EXPECT_TRUE(ok); | 624 EXPECT_TRUE(ok); |
625 EXPECT_EQ(kTestDataSize * 2, file_size); | 625 EXPECT_EQ(kTestDataSize * 2, file_size); |
626 } | 626 } |
627 | 627 |
628 TEST_F(FileStreamTest, BasicAsyncWriteRead) { | 628 TEST_F(FileStreamTest, BasicAsyncWriteRead) { |
629 int64 file_size; | 629 int64 file_size; |
630 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); | 630 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); |
631 EXPECT_TRUE(ok); | 631 EXPECT_TRUE(ok); |
632 | 632 |
633 FileStream stream(NULL); | 633 FileStream stream(NULL); |
634 int flags = base::PLATFORM_FILE_OPEN | | 634 int flags = base::PLATFORM_FILE_OPEN | |
635 base::PLATFORM_FILE_READ | | 635 base::PLATFORM_FILE_READ | |
636 base::PLATFORM_FILE_WRITE | | 636 base::PLATFORM_FILE_WRITE | |
637 base::PLATFORM_FILE_ASYNC; | 637 base::PLATFORM_FILE_ASYNC; |
638 int rv = stream.Open(temp_file_path(), flags); | 638 int rv = stream.OpenSync(temp_file_path(), flags); |
639 EXPECT_EQ(OK, rv); | 639 EXPECT_EQ(OK, rv); |
640 | 640 |
641 int64 total_bytes_avail = stream.Available(); | 641 int64 total_bytes_avail = stream.Available(); |
642 EXPECT_EQ(file_size, total_bytes_avail); | 642 EXPECT_EQ(file_size, total_bytes_avail); |
643 | 643 |
644 int64 offset = stream.Seek(FROM_END, 0); | 644 int64 offset = stream.Seek(FROM_END, 0); |
645 EXPECT_EQ(offset, file_size); | 645 EXPECT_EQ(offset, file_size); |
646 | 646 |
647 TestCompletionCallback callback; | 647 TestCompletionCallback callback; |
648 int total_bytes_written = 0; | 648 int total_bytes_written = 0; |
(...skipping 22 matching lines...) Expand all Loading... |
671 char buf[4]; | 671 char buf[4]; |
672 rv = stream.Read(buf, arraysize(buf), callback.callback()); | 672 rv = stream.Read(buf, arraysize(buf), callback.callback()); |
673 if (rv == ERR_IO_PENDING) | 673 if (rv == ERR_IO_PENDING) |
674 rv = callback.WaitForResult(); | 674 rv = callback.WaitForResult(); |
675 EXPECT_LE(0, rv); | 675 EXPECT_LE(0, rv); |
676 if (rv <= 0) | 676 if (rv <= 0) |
677 break; | 677 break; |
678 total_bytes_read += rv; | 678 total_bytes_read += rv; |
679 data_read.append(buf, rv); | 679 data_read.append(buf, rv); |
680 } | 680 } |
681 stream.Close(); | 681 stream.CloseSync(); |
682 | 682 |
683 ok = file_util::GetFileSize(temp_file_path(), &file_size); | 683 ok = file_util::GetFileSize(temp_file_path(), &file_size); |
684 EXPECT_TRUE(ok); | 684 EXPECT_TRUE(ok); |
685 EXPECT_EQ(kTestDataSize * 2, file_size); | 685 EXPECT_EQ(kTestDataSize * 2, file_size); |
686 | 686 |
687 EXPECT_EQ(kTestDataSize * 2, total_bytes_read); | 687 EXPECT_EQ(kTestDataSize * 2, total_bytes_read); |
688 const std::string kExpectedFileData = | 688 const std::string kExpectedFileData = |
689 std::string(kTestData) + std::string(kTestData); | 689 std::string(kTestData) + std::string(kTestData); |
690 EXPECT_EQ(kExpectedFileData, data_read); | 690 EXPECT_EQ(kExpectedFileData, data_read); |
691 } | 691 } |
(...skipping 91 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
783 TEST_F(FileStreamTest, AsyncWriteRead) { | 783 TEST_F(FileStreamTest, AsyncWriteRead) { |
784 int64 file_size; | 784 int64 file_size; |
785 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); | 785 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); |
786 EXPECT_TRUE(ok); | 786 EXPECT_TRUE(ok); |
787 | 787 |
788 FileStream stream(NULL); | 788 FileStream stream(NULL); |
789 int flags = base::PLATFORM_FILE_OPEN | | 789 int flags = base::PLATFORM_FILE_OPEN | |
790 base::PLATFORM_FILE_READ | | 790 base::PLATFORM_FILE_READ | |
791 base::PLATFORM_FILE_WRITE | | 791 base::PLATFORM_FILE_WRITE | |
792 base::PLATFORM_FILE_ASYNC; | 792 base::PLATFORM_FILE_ASYNC; |
793 int rv = stream.Open(temp_file_path(), flags); | 793 int rv = stream.OpenSync(temp_file_path(), flags); |
794 EXPECT_EQ(OK, rv); | 794 EXPECT_EQ(OK, rv); |
795 | 795 |
796 int64 total_bytes_avail = stream.Available(); | 796 int64 total_bytes_avail = stream.Available(); |
797 EXPECT_EQ(file_size, total_bytes_avail); | 797 EXPECT_EQ(file_size, total_bytes_avail); |
798 | 798 |
799 int64 offset = stream.Seek(FROM_END, 0); | 799 int64 offset = stream.Seek(FROM_END, 0); |
800 EXPECT_EQ(offset, file_size); | 800 EXPECT_EQ(offset, file_size); |
801 | 801 |
802 int total_bytes_written = 0; | 802 int total_bytes_written = 0; |
803 int total_bytes_read = 0; | 803 int total_bytes_read = 0; |
804 std::string data_read; | 804 std::string data_read; |
805 TestWriteReadCompletionCallback callback(&stream, &total_bytes_written, | 805 TestWriteReadCompletionCallback callback(&stream, &total_bytes_written, |
806 &total_bytes_read, &data_read); | 806 &total_bytes_read, &data_read); |
807 | 807 |
808 rv = stream.Write(kTestData + total_bytes_written, | 808 rv = stream.Write(kTestData + total_bytes_written, |
809 kTestDataSize - static_cast<int>(total_bytes_written), | 809 kTestDataSize - static_cast<int>(total_bytes_written), |
810 callback.callback()); | 810 callback.callback()); |
811 if (rv == ERR_IO_PENDING) | 811 if (rv == ERR_IO_PENDING) |
812 rv = callback.WaitForResult(); | 812 rv = callback.WaitForResult(); |
813 EXPECT_LT(0, rv); | 813 EXPECT_LT(0, rv); |
814 EXPECT_EQ(kTestDataSize, total_bytes_written); | 814 EXPECT_EQ(kTestDataSize, total_bytes_written); |
815 | 815 |
816 stream.Close(); | 816 stream.CloseSync(); |
817 | 817 |
818 ok = file_util::GetFileSize(temp_file_path(), &file_size); | 818 ok = file_util::GetFileSize(temp_file_path(), &file_size); |
819 EXPECT_TRUE(ok); | 819 EXPECT_TRUE(ok); |
820 EXPECT_EQ(kTestDataSize * 2, file_size); | 820 EXPECT_EQ(kTestDataSize * 2, file_size); |
821 | 821 |
822 EXPECT_EQ(kTestDataSize * 2, total_bytes_read); | 822 EXPECT_EQ(kTestDataSize * 2, total_bytes_read); |
823 const std::string kExpectedFileData = | 823 const std::string kExpectedFileData = |
824 std::string(kTestData) + std::string(kTestData); | 824 std::string(kTestData) + std::string(kTestData); |
825 EXPECT_EQ(kExpectedFileData, data_read); | 825 EXPECT_EQ(kExpectedFileData, data_read); |
826 } | 826 } |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
860 // Recurse to finish writing all data. | 860 // Recurse to finish writing all data. |
861 int total_bytes_written = 0; | 861 int total_bytes_written = 0; |
862 TestWriteCloseCompletionCallback callback(stream_, &total_bytes_written); | 862 TestWriteCloseCompletionCallback callback(stream_, &total_bytes_written); |
863 rv = stream_->Write(kTestData + *total_bytes_written_, | 863 rv = stream_->Write(kTestData + *total_bytes_written_, |
864 kTestDataSize - *total_bytes_written_, | 864 kTestDataSize - *total_bytes_written_, |
865 callback.callback()); | 865 callback.callback()); |
866 DCHECK_EQ(ERR_IO_PENDING, rv); | 866 DCHECK_EQ(ERR_IO_PENDING, rv); |
867 rv = callback.WaitForResult(); | 867 rv = callback.WaitForResult(); |
868 *total_bytes_written_ += total_bytes_written; | 868 *total_bytes_written_ += total_bytes_written; |
869 } else { // We're done writing all data. Close the file. | 869 } else { // We're done writing all data. Close the file. |
870 stream_->Close(); | 870 stream_->CloseSync(); |
871 } | 871 } |
872 | 872 |
873 result_ = *total_bytes_written_; | 873 result_ = *total_bytes_written_; |
874 have_result_ = true; | 874 have_result_ = true; |
875 if (waiting_for_result_) | 875 if (waiting_for_result_) |
876 MessageLoop::current()->Quit(); | 876 MessageLoop::current()->Quit(); |
877 } | 877 } |
878 | 878 |
879 int result_; | 879 int result_; |
880 bool have_result_; | 880 bool have_result_; |
881 bool waiting_for_result_; | 881 bool waiting_for_result_; |
882 FileStream* stream_; | 882 FileStream* stream_; |
883 int* total_bytes_written_; | 883 int* total_bytes_written_; |
884 const CompletionCallback callback_; | 884 const CompletionCallback callback_; |
885 | 885 |
886 DISALLOW_COPY_AND_ASSIGN(TestWriteCloseCompletionCallback); | 886 DISALLOW_COPY_AND_ASSIGN(TestWriteCloseCompletionCallback); |
887 }; | 887 }; |
888 | 888 |
889 TEST_F(FileStreamTest, AsyncWriteClose) { | 889 TEST_F(FileStreamTest, AsyncWriteClose) { |
890 int64 file_size; | 890 int64 file_size; |
891 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); | 891 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); |
892 EXPECT_TRUE(ok); | 892 EXPECT_TRUE(ok); |
893 | 893 |
894 FileStream stream(NULL); | 894 FileStream stream(NULL); |
895 int flags = base::PLATFORM_FILE_OPEN | | 895 int flags = base::PLATFORM_FILE_OPEN | |
896 base::PLATFORM_FILE_READ | | 896 base::PLATFORM_FILE_READ | |
897 base::PLATFORM_FILE_WRITE | | 897 base::PLATFORM_FILE_WRITE | |
898 base::PLATFORM_FILE_ASYNC; | 898 base::PLATFORM_FILE_ASYNC; |
899 int rv = stream.Open(temp_file_path(), flags); | 899 int rv = stream.OpenSync(temp_file_path(), flags); |
900 EXPECT_EQ(OK, rv); | 900 EXPECT_EQ(OK, rv); |
901 | 901 |
902 int64 total_bytes_avail = stream.Available(); | 902 int64 total_bytes_avail = stream.Available(); |
903 EXPECT_EQ(file_size, total_bytes_avail); | 903 EXPECT_EQ(file_size, total_bytes_avail); |
904 | 904 |
905 int64 offset = stream.Seek(FROM_END, 0); | 905 int64 offset = stream.Seek(FROM_END, 0); |
906 EXPECT_EQ(offset, file_size); | 906 EXPECT_EQ(offset, file_size); |
907 | 907 |
908 int total_bytes_written = 0; | 908 int total_bytes_written = 0; |
909 TestWriteCloseCompletionCallback callback(&stream, &total_bytes_written); | 909 TestWriteCloseCompletionCallback callback(&stream, &total_bytes_written); |
910 | 910 |
911 rv = stream.Write(kTestData, kTestDataSize, callback.callback()); | 911 rv = stream.Write(kTestData, kTestDataSize, callback.callback()); |
912 if (rv == ERR_IO_PENDING) | 912 if (rv == ERR_IO_PENDING) |
913 total_bytes_written = callback.WaitForResult(); | 913 total_bytes_written = callback.WaitForResult(); |
914 EXPECT_LT(0, total_bytes_written); | 914 EXPECT_LT(0, total_bytes_written); |
915 EXPECT_EQ(kTestDataSize, total_bytes_written); | 915 EXPECT_EQ(kTestDataSize, total_bytes_written); |
916 | 916 |
917 ok = file_util::GetFileSize(temp_file_path(), &file_size); | 917 ok = file_util::GetFileSize(temp_file_path(), &file_size); |
918 EXPECT_TRUE(ok); | 918 EXPECT_TRUE(ok); |
919 EXPECT_EQ(kTestDataSize * 2, file_size); | 919 EXPECT_EQ(kTestDataSize * 2, file_size); |
920 } | 920 } |
921 | 921 |
922 // Tests truncating a file. | 922 // Tests truncating a file. |
923 TEST_F(FileStreamTest, Truncate) { | 923 TEST_F(FileStreamTest, Truncate) { |
924 int flags = base::PLATFORM_FILE_CREATE_ALWAYS | base::PLATFORM_FILE_WRITE; | 924 int flags = base::PLATFORM_FILE_CREATE_ALWAYS | base::PLATFORM_FILE_WRITE; |
925 | 925 |
926 FileStream write_stream(NULL); | 926 FileStream write_stream(NULL); |
927 ASSERT_EQ(OK, write_stream.Open(temp_file_path(), flags)); | 927 ASSERT_EQ(OK, write_stream.OpenSync(temp_file_path(), flags)); |
928 | 928 |
929 // Write some data to the file. | 929 // Write some data to the file. |
930 const char test_data[] = "0123456789"; | 930 const char test_data[] = "0123456789"; |
931 write_stream.Write(test_data, arraysize(test_data), CompletionCallback()); | 931 write_stream.Write(test_data, arraysize(test_data), CompletionCallback()); |
932 | 932 |
933 // Truncate the file. | 933 // Truncate the file. |
934 ASSERT_EQ(4, write_stream.Truncate(4)); | 934 ASSERT_EQ(4, write_stream.Truncate(4)); |
935 | 935 |
936 // Write again. | 936 // Write again. |
937 write_stream.Write(test_data, 4, CompletionCallback()); | 937 write_stream.Write(test_data, 4, CompletionCallback()); |
938 | 938 |
939 // Close the stream. | 939 // Close the stream. |
940 write_stream.Close(); | 940 write_stream.CloseSync(); |
941 | 941 |
942 // Read in the contents and make sure we get back what we expected. | 942 // Read in the contents and make sure we get back what we expected. |
943 std::string read_contents; | 943 std::string read_contents; |
944 EXPECT_TRUE(file_util::ReadFileToString(temp_file_path(), &read_contents)); | 944 EXPECT_TRUE(file_util::ReadFileToString(temp_file_path(), &read_contents)); |
945 | 945 |
946 EXPECT_EQ("01230123", read_contents); | 946 EXPECT_EQ("01230123", read_contents); |
947 } | 947 } |
948 | 948 |
949 } // namespace | 949 } // namespace |
950 | 950 |
951 } // namespace net | 951 } // namespace net |
OLD | NEW |