Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(121)

Side by Side Diff: net/base/file_stream_unittest.cc

Issue 102873002: Move GetFileSize, NormalizeFilePath to base namespace (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 7 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « media/base/yuv_convert_unittest.cc ('k') | net/base/upload_file_element_reader.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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/message_loop.h" 10 #include "base/message_loop/message_loop.h"
(...skipping 207 matching lines...) Expand 10 before | Expand all | Expand 10 after
218 EXPECT_EQ(ERR_UNEXPECTED, avail); 218 EXPECT_EQ(ERR_UNEXPECTED, avail);
219 219
220 // Try reading... 220 // Try reading...
221 char buf[10]; 221 char buf[10];
222 int rv = stream.ReadSync(buf, arraysize(buf)); 222 int rv = stream.ReadSync(buf, arraysize(buf));
223 EXPECT_EQ(ERR_UNEXPECTED, rv); 223 EXPECT_EQ(ERR_UNEXPECTED, rv);
224 } 224 }
225 225
226 TEST_F(FileStreamTest, BasicRead) { 226 TEST_F(FileStreamTest, BasicRead) {
227 int64 file_size; 227 int64 file_size;
228 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); 228 bool ok = base::GetFileSize(temp_file_path(), &file_size);
229 EXPECT_TRUE(ok); 229 EXPECT_TRUE(ok);
230 230
231 FileStream stream(NULL, base::MessageLoopProxy::current()); 231 FileStream stream(NULL, base::MessageLoopProxy::current());
232 int flags = base::PLATFORM_FILE_OPEN | 232 int flags = base::PLATFORM_FILE_OPEN |
233 base::PLATFORM_FILE_READ; 233 base::PLATFORM_FILE_READ;
234 int rv = stream.OpenSync(temp_file_path(), flags); 234 int rv = stream.OpenSync(temp_file_path(), flags);
235 EXPECT_EQ(OK, rv); 235 EXPECT_EQ(OK, rv);
236 236
237 int64 total_bytes_avail = stream.Available(); 237 int64 total_bytes_avail = stream.Available();
238 EXPECT_EQ(file_size, total_bytes_avail); 238 EXPECT_EQ(file_size, total_bytes_avail);
239 239
240 int total_bytes_read = 0; 240 int total_bytes_read = 0;
241 241
242 std::string data_read; 242 std::string data_read;
243 for (;;) { 243 for (;;) {
244 char buf[4]; 244 char buf[4];
245 rv = stream.ReadSync(buf, arraysize(buf)); 245 rv = stream.ReadSync(buf, arraysize(buf));
246 EXPECT_LE(0, rv); 246 EXPECT_LE(0, rv);
247 if (rv <= 0) 247 if (rv <= 0)
248 break; 248 break;
249 total_bytes_read += rv; 249 total_bytes_read += rv;
250 data_read.append(buf, rv); 250 data_read.append(buf, rv);
251 } 251 }
252 EXPECT_EQ(file_size, total_bytes_read); 252 EXPECT_EQ(file_size, total_bytes_read);
253 EXPECT_EQ(kTestData, data_read); 253 EXPECT_EQ(kTestData, data_read);
254 } 254 }
255 255
256 TEST_F(FileStreamTest, AsyncRead) { 256 TEST_F(FileStreamTest, AsyncRead) {
257 int64 file_size; 257 int64 file_size;
258 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); 258 bool ok = base::GetFileSize(temp_file_path(), &file_size);
259 EXPECT_TRUE(ok); 259 EXPECT_TRUE(ok);
260 260
261 FileStream stream(NULL, base::MessageLoopProxy::current()); 261 FileStream stream(NULL, base::MessageLoopProxy::current());
262 int flags = base::PLATFORM_FILE_OPEN | 262 int flags = base::PLATFORM_FILE_OPEN |
263 base::PLATFORM_FILE_READ | 263 base::PLATFORM_FILE_READ |
264 base::PLATFORM_FILE_ASYNC; 264 base::PLATFORM_FILE_ASYNC;
265 TestCompletionCallback callback; 265 TestCompletionCallback callback;
266 int rv = stream.Open(temp_file_path(), flags, callback.callback()); 266 int rv = stream.Open(temp_file_path(), flags, callback.callback());
267 EXPECT_EQ(ERR_IO_PENDING, rv); 267 EXPECT_EQ(ERR_IO_PENDING, rv);
268 EXPECT_EQ(OK, callback.WaitForResult()); 268 EXPECT_EQ(OK, callback.WaitForResult());
(...skipping 14 matching lines...) Expand all
283 break; 283 break;
284 total_bytes_read += rv; 284 total_bytes_read += rv;
285 data_read.append(buf->data(), rv); 285 data_read.append(buf->data(), rv);
286 } 286 }
287 EXPECT_EQ(file_size, total_bytes_read); 287 EXPECT_EQ(file_size, total_bytes_read);
288 EXPECT_EQ(kTestData, data_read); 288 EXPECT_EQ(kTestData, data_read);
289 } 289 }
290 290
291 TEST_F(FileStreamTest, AsyncRead_EarlyDelete) { 291 TEST_F(FileStreamTest, AsyncRead_EarlyDelete) {
292 int64 file_size; 292 int64 file_size;
293 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); 293 bool ok = base::GetFileSize(temp_file_path(), &file_size);
294 EXPECT_TRUE(ok); 294 EXPECT_TRUE(ok);
295 295
296 scoped_ptr<FileStream> stream( 296 scoped_ptr<FileStream> stream(
297 new FileStream(NULL, base::MessageLoopProxy::current())); 297 new FileStream(NULL, base::MessageLoopProxy::current()));
298 int flags = base::PLATFORM_FILE_OPEN | 298 int flags = base::PLATFORM_FILE_OPEN |
299 base::PLATFORM_FILE_READ | 299 base::PLATFORM_FILE_READ |
300 base::PLATFORM_FILE_ASYNC; 300 base::PLATFORM_FILE_ASYNC;
301 TestCompletionCallback callback; 301 TestCompletionCallback callback;
302 int rv = stream->Open(temp_file_path(), flags, callback.callback()); 302 int rv = stream->Open(temp_file_path(), flags, callback.callback());
303 EXPECT_EQ(ERR_IO_PENDING, rv); 303 EXPECT_EQ(ERR_IO_PENDING, rv);
(...skipping 10 matching lines...) Expand all
314 // The callback should not be called if the request is cancelled. 314 // The callback should not be called if the request is cancelled.
315 base::RunLoop().RunUntilIdle(); 315 base::RunLoop().RunUntilIdle();
316 EXPECT_FALSE(callback.have_result()); 316 EXPECT_FALSE(callback.have_result());
317 } else { 317 } else {
318 EXPECT_EQ(std::string(kTestData, rv), std::string(buf->data(), rv)); 318 EXPECT_EQ(std::string(kTestData, rv), std::string(buf->data(), rv));
319 } 319 }
320 } 320 }
321 321
322 TEST_F(FileStreamTest, BasicRead_FromOffset) { 322 TEST_F(FileStreamTest, BasicRead_FromOffset) {
323 int64 file_size; 323 int64 file_size;
324 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); 324 bool ok = base::GetFileSize(temp_file_path(), &file_size);
325 EXPECT_TRUE(ok); 325 EXPECT_TRUE(ok);
326 326
327 FileStream stream(NULL, base::MessageLoopProxy::current()); 327 FileStream stream(NULL, base::MessageLoopProxy::current());
328 int flags = base::PLATFORM_FILE_OPEN | 328 int flags = base::PLATFORM_FILE_OPEN |
329 base::PLATFORM_FILE_READ; 329 base::PLATFORM_FILE_READ;
330 int rv = stream.OpenSync(temp_file_path(), flags); 330 int rv = stream.OpenSync(temp_file_path(), flags);
331 EXPECT_EQ(OK, rv); 331 EXPECT_EQ(OK, rv);
332 332
333 const int64 kOffset = 3; 333 const int64 kOffset = 3;
334 int64 new_offset = stream.SeekSync(FROM_BEGIN, kOffset); 334 int64 new_offset = stream.SeekSync(FROM_BEGIN, kOffset);
(...skipping 14 matching lines...) Expand all
349 total_bytes_read += rv; 349 total_bytes_read += rv;
350 data_read.append(buf, rv); 350 data_read.append(buf, rv);
351 } 351 }
352 EXPECT_EQ(file_size - kOffset, total_bytes_read); 352 EXPECT_EQ(file_size - kOffset, total_bytes_read);
353 EXPECT_TRUE(data_read == kTestData + kOffset); 353 EXPECT_TRUE(data_read == kTestData + kOffset);
354 EXPECT_EQ(kTestData + kOffset, data_read); 354 EXPECT_EQ(kTestData + kOffset, data_read);
355 } 355 }
356 356
357 TEST_F(FileStreamTest, AsyncRead_FromOffset) { 357 TEST_F(FileStreamTest, AsyncRead_FromOffset) {
358 int64 file_size; 358 int64 file_size;
359 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); 359 bool ok = base::GetFileSize(temp_file_path(), &file_size);
360 EXPECT_TRUE(ok); 360 EXPECT_TRUE(ok);
361 361
362 FileStream stream(NULL, base::MessageLoopProxy::current()); 362 FileStream stream(NULL, base::MessageLoopProxy::current());
363 int flags = base::PLATFORM_FILE_OPEN | 363 int flags = base::PLATFORM_FILE_OPEN |
364 base::PLATFORM_FILE_READ | 364 base::PLATFORM_FILE_READ |
365 base::PLATFORM_FILE_ASYNC; 365 base::PLATFORM_FILE_ASYNC;
366 TestCompletionCallback callback; 366 TestCompletionCallback callback;
367 int rv = stream.Open(temp_file_path(), flags, callback.callback()); 367 int rv = stream.Open(temp_file_path(), flags, callback.callback());
368 EXPECT_EQ(ERR_IO_PENDING, rv); 368 EXPECT_EQ(ERR_IO_PENDING, rv);
369 EXPECT_EQ(OK, callback.WaitForResult()); 369 EXPECT_EQ(OK, callback.WaitForResult());
(...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after
457 457
458 TEST_F(FileStreamTest, BasicWrite) { 458 TEST_F(FileStreamTest, BasicWrite) {
459 scoped_ptr<FileStream> stream( 459 scoped_ptr<FileStream> stream(
460 new FileStream(NULL, base::MessageLoopProxy::current())); 460 new FileStream(NULL, base::MessageLoopProxy::current()));
461 int flags = base::PLATFORM_FILE_CREATE_ALWAYS | 461 int flags = base::PLATFORM_FILE_CREATE_ALWAYS |
462 base::PLATFORM_FILE_WRITE; 462 base::PLATFORM_FILE_WRITE;
463 int rv = stream->OpenSync(temp_file_path(), flags); 463 int rv = stream->OpenSync(temp_file_path(), flags);
464 EXPECT_EQ(OK, rv); 464 EXPECT_EQ(OK, rv);
465 465
466 int64 file_size; 466 int64 file_size;
467 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); 467 bool ok = base::GetFileSize(temp_file_path(), &file_size);
468 EXPECT_TRUE(ok); 468 EXPECT_TRUE(ok);
469 EXPECT_EQ(0, file_size); 469 EXPECT_EQ(0, file_size);
470 470
471 rv = stream->WriteSync(kTestData, kTestDataSize); 471 rv = stream->WriteSync(kTestData, kTestDataSize);
472 EXPECT_EQ(kTestDataSize, rv); 472 EXPECT_EQ(kTestDataSize, rv);
473 stream.reset(); 473 stream.reset();
474 474
475 ok = file_util::GetFileSize(temp_file_path(), &file_size); 475 ok = base::GetFileSize(temp_file_path(), &file_size);
476 EXPECT_TRUE(ok); 476 EXPECT_TRUE(ok);
477 EXPECT_EQ(kTestDataSize, file_size); 477 EXPECT_EQ(kTestDataSize, file_size);
478 } 478 }
479 479
480 TEST_F(FileStreamTest, AsyncWrite) { 480 TEST_F(FileStreamTest, AsyncWrite) {
481 FileStream stream(NULL, base::MessageLoopProxy::current()); 481 FileStream stream(NULL, base::MessageLoopProxy::current());
482 int flags = base::PLATFORM_FILE_CREATE_ALWAYS | 482 int flags = base::PLATFORM_FILE_CREATE_ALWAYS |
483 base::PLATFORM_FILE_WRITE | 483 base::PLATFORM_FILE_WRITE |
484 base::PLATFORM_FILE_ASYNC; 484 base::PLATFORM_FILE_ASYNC;
485 TestCompletionCallback callback; 485 TestCompletionCallback callback;
486 int rv = stream.Open(temp_file_path(), flags, callback.callback()); 486 int rv = stream.Open(temp_file_path(), flags, callback.callback());
487 EXPECT_EQ(ERR_IO_PENDING, rv); 487 EXPECT_EQ(ERR_IO_PENDING, rv);
488 EXPECT_EQ(OK, callback.WaitForResult()); 488 EXPECT_EQ(OK, callback.WaitForResult());
489 489
490 int64 file_size; 490 int64 file_size;
491 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); 491 bool ok = base::GetFileSize(temp_file_path(), &file_size);
492 EXPECT_TRUE(ok); 492 EXPECT_TRUE(ok);
493 EXPECT_EQ(0, file_size); 493 EXPECT_EQ(0, file_size);
494 494
495 int total_bytes_written = 0; 495 int total_bytes_written = 0;
496 496
497 scoped_refptr<IOBufferWithSize> buf = CreateTestDataBuffer(); 497 scoped_refptr<IOBufferWithSize> buf = CreateTestDataBuffer();
498 scoped_refptr<DrainableIOBuffer> drainable = 498 scoped_refptr<DrainableIOBuffer> drainable =
499 new DrainableIOBuffer(buf.get(), buf->size()); 499 new DrainableIOBuffer(buf.get(), buf->size());
500 while (total_bytes_written != kTestDataSize) { 500 while (total_bytes_written != kTestDataSize) {
501 rv = stream.Write( 501 rv = stream.Write(
502 drainable.get(), drainable->BytesRemaining(), callback.callback()); 502 drainable.get(), drainable->BytesRemaining(), callback.callback());
503 if (rv == ERR_IO_PENDING) 503 if (rv == ERR_IO_PENDING)
504 rv = callback.WaitForResult(); 504 rv = callback.WaitForResult();
505 EXPECT_LT(0, rv); 505 EXPECT_LT(0, rv);
506 if (rv <= 0) 506 if (rv <= 0)
507 break; 507 break;
508 drainable->DidConsume(rv); 508 drainable->DidConsume(rv);
509 total_bytes_written += rv; 509 total_bytes_written += rv;
510 } 510 }
511 ok = file_util::GetFileSize(temp_file_path(), &file_size); 511 ok = base::GetFileSize(temp_file_path(), &file_size);
512 EXPECT_TRUE(ok); 512 EXPECT_TRUE(ok);
513 EXPECT_EQ(file_size, total_bytes_written); 513 EXPECT_EQ(file_size, total_bytes_written);
514 } 514 }
515 515
516 TEST_F(FileStreamTest, AsyncWrite_EarlyDelete) { 516 TEST_F(FileStreamTest, AsyncWrite_EarlyDelete) {
517 scoped_ptr<FileStream> stream( 517 scoped_ptr<FileStream> stream(
518 new FileStream(NULL, base::MessageLoopProxy::current())); 518 new FileStream(NULL, base::MessageLoopProxy::current()));
519 int flags = base::PLATFORM_FILE_CREATE_ALWAYS | 519 int flags = base::PLATFORM_FILE_CREATE_ALWAYS |
520 base::PLATFORM_FILE_WRITE | 520 base::PLATFORM_FILE_WRITE |
521 base::PLATFORM_FILE_ASYNC; 521 base::PLATFORM_FILE_ASYNC;
522 TestCompletionCallback callback; 522 TestCompletionCallback callback;
523 int rv = stream->Open(temp_file_path(), flags, callback.callback()); 523 int rv = stream->Open(temp_file_path(), flags, callback.callback());
524 EXPECT_EQ(ERR_IO_PENDING, rv); 524 EXPECT_EQ(ERR_IO_PENDING, rv);
525 EXPECT_EQ(OK, callback.WaitForResult()); 525 EXPECT_EQ(OK, callback.WaitForResult());
526 526
527 int64 file_size; 527 int64 file_size;
528 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); 528 bool ok = base::GetFileSize(temp_file_path(), &file_size);
529 EXPECT_TRUE(ok); 529 EXPECT_TRUE(ok);
530 EXPECT_EQ(0, file_size); 530 EXPECT_EQ(0, file_size);
531 531
532 scoped_refptr<IOBufferWithSize> buf = CreateTestDataBuffer(); 532 scoped_refptr<IOBufferWithSize> buf = CreateTestDataBuffer();
533 rv = stream->Write(buf.get(), buf->size(), callback.callback()); 533 rv = stream->Write(buf.get(), buf->size(), callback.callback());
534 stream.reset(); 534 stream.reset();
535 if (rv < 0) { 535 if (rv < 0) {
536 EXPECT_EQ(ERR_IO_PENDING, rv); 536 EXPECT_EQ(ERR_IO_PENDING, rv);
537 // The callback should not be called if the request is cancelled. 537 // The callback should not be called if the request is cancelled.
538 base::RunLoop().RunUntilIdle(); 538 base::RunLoop().RunUntilIdle();
539 EXPECT_FALSE(callback.have_result()); 539 EXPECT_FALSE(callback.have_result());
540 } else { 540 } else {
541 ok = file_util::GetFileSize(temp_file_path(), &file_size); 541 ok = base::GetFileSize(temp_file_path(), &file_size);
542 EXPECT_TRUE(ok); 542 EXPECT_TRUE(ok);
543 EXPECT_EQ(file_size, rv); 543 EXPECT_EQ(file_size, rv);
544 } 544 }
545 } 545 }
546 546
547 TEST_F(FileStreamTest, BasicWrite_FromOffset) { 547 TEST_F(FileStreamTest, BasicWrite_FromOffset) {
548 scoped_ptr<FileStream> stream( 548 scoped_ptr<FileStream> stream(
549 new FileStream(NULL, base::MessageLoopProxy::current())); 549 new FileStream(NULL, base::MessageLoopProxy::current()));
550 int flags = base::PLATFORM_FILE_OPEN | 550 int flags = base::PLATFORM_FILE_OPEN |
551 base::PLATFORM_FILE_WRITE; 551 base::PLATFORM_FILE_WRITE;
552 int rv = stream->OpenSync(temp_file_path(), flags); 552 int rv = stream->OpenSync(temp_file_path(), flags);
553 EXPECT_EQ(OK, rv); 553 EXPECT_EQ(OK, rv);
554 554
555 int64 file_size; 555 int64 file_size;
556 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); 556 bool ok = base::GetFileSize(temp_file_path(), &file_size);
557 EXPECT_TRUE(ok); 557 EXPECT_TRUE(ok);
558 EXPECT_EQ(kTestDataSize, file_size); 558 EXPECT_EQ(kTestDataSize, file_size);
559 559
560 const int64 kOffset = 0; 560 const int64 kOffset = 0;
561 int64 new_offset = stream->SeekSync(FROM_END, kOffset); 561 int64 new_offset = stream->SeekSync(FROM_END, kOffset);
562 EXPECT_EQ(kTestDataSize, new_offset); 562 EXPECT_EQ(kTestDataSize, new_offset);
563 563
564 rv = stream->WriteSync(kTestData, kTestDataSize); 564 rv = stream->WriteSync(kTestData, kTestDataSize);
565 EXPECT_EQ(kTestDataSize, rv); 565 EXPECT_EQ(kTestDataSize, rv);
566 stream.reset(); 566 stream.reset();
567 567
568 ok = file_util::GetFileSize(temp_file_path(), &file_size); 568 ok = base::GetFileSize(temp_file_path(), &file_size);
569 EXPECT_TRUE(ok); 569 EXPECT_TRUE(ok);
570 EXPECT_EQ(kTestDataSize * 2, file_size); 570 EXPECT_EQ(kTestDataSize * 2, file_size);
571 } 571 }
572 572
573 TEST_F(FileStreamTest, AsyncWrite_FromOffset) { 573 TEST_F(FileStreamTest, AsyncWrite_FromOffset) {
574 int64 file_size; 574 int64 file_size;
575 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); 575 bool ok = base::GetFileSize(temp_file_path(), &file_size);
576 EXPECT_TRUE(ok); 576 EXPECT_TRUE(ok);
577 577
578 FileStream stream(NULL, base::MessageLoopProxy::current()); 578 FileStream stream(NULL, base::MessageLoopProxy::current());
579 int flags = base::PLATFORM_FILE_OPEN | 579 int flags = base::PLATFORM_FILE_OPEN |
580 base::PLATFORM_FILE_WRITE | 580 base::PLATFORM_FILE_WRITE |
581 base::PLATFORM_FILE_ASYNC; 581 base::PLATFORM_FILE_ASYNC;
582 TestCompletionCallback callback; 582 TestCompletionCallback callback;
583 int rv = stream.Open(temp_file_path(), flags, callback.callback()); 583 int rv = stream.Open(temp_file_path(), flags, callback.callback());
584 EXPECT_EQ(ERR_IO_PENDING, rv); 584 EXPECT_EQ(ERR_IO_PENDING, rv);
585 EXPECT_EQ(OK, callback.WaitForResult()); 585 EXPECT_EQ(OK, callback.WaitForResult());
(...skipping 14 matching lines...) Expand all
600 rv = stream.Write( 600 rv = stream.Write(
601 drainable.get(), drainable->BytesRemaining(), callback.callback()); 601 drainable.get(), drainable->BytesRemaining(), callback.callback());
602 if (rv == ERR_IO_PENDING) 602 if (rv == ERR_IO_PENDING)
603 rv = callback.WaitForResult(); 603 rv = callback.WaitForResult();
604 EXPECT_LT(0, rv); 604 EXPECT_LT(0, rv);
605 if (rv <= 0) 605 if (rv <= 0)
606 break; 606 break;
607 drainable->DidConsume(rv); 607 drainable->DidConsume(rv);
608 total_bytes_written += rv; 608 total_bytes_written += rv;
609 } 609 }
610 ok = file_util::GetFileSize(temp_file_path(), &file_size); 610 ok = base::GetFileSize(temp_file_path(), &file_size);
611 EXPECT_TRUE(ok); 611 EXPECT_TRUE(ok);
612 EXPECT_EQ(file_size, kTestDataSize * 2); 612 EXPECT_EQ(file_size, kTestDataSize * 2);
613 } 613 }
614 614
615 TEST_F(FileStreamTest, BasicReadWrite) { 615 TEST_F(FileStreamTest, BasicReadWrite) {
616 int64 file_size; 616 int64 file_size;
617 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); 617 bool ok = base::GetFileSize(temp_file_path(), &file_size);
618 EXPECT_TRUE(ok); 618 EXPECT_TRUE(ok);
619 619
620 scoped_ptr<FileStream> stream( 620 scoped_ptr<FileStream> stream(
621 new FileStream(NULL, base::MessageLoopProxy::current())); 621 new FileStream(NULL, base::MessageLoopProxy::current()));
622 int flags = base::PLATFORM_FILE_OPEN | 622 int flags = base::PLATFORM_FILE_OPEN |
623 base::PLATFORM_FILE_READ | 623 base::PLATFORM_FILE_READ |
624 base::PLATFORM_FILE_WRITE; 624 base::PLATFORM_FILE_WRITE;
625 int rv = stream->OpenSync(temp_file_path(), flags); 625 int rv = stream->OpenSync(temp_file_path(), flags);
626 EXPECT_EQ(OK, rv); 626 EXPECT_EQ(OK, rv);
627 627
(...skipping 12 matching lines...) Expand all
640 total_bytes_read += rv; 640 total_bytes_read += rv;
641 data_read.append(buf, rv); 641 data_read.append(buf, rv);
642 } 642 }
643 EXPECT_EQ(file_size, total_bytes_read); 643 EXPECT_EQ(file_size, total_bytes_read);
644 EXPECT_TRUE(data_read == kTestData); 644 EXPECT_TRUE(data_read == kTestData);
645 645
646 rv = stream->WriteSync(kTestData, kTestDataSize); 646 rv = stream->WriteSync(kTestData, kTestDataSize);
647 EXPECT_EQ(kTestDataSize, rv); 647 EXPECT_EQ(kTestDataSize, rv);
648 stream.reset(); 648 stream.reset();
649 649
650 ok = file_util::GetFileSize(temp_file_path(), &file_size); 650 ok = base::GetFileSize(temp_file_path(), &file_size);
651 EXPECT_TRUE(ok); 651 EXPECT_TRUE(ok);
652 EXPECT_EQ(kTestDataSize * 2, file_size); 652 EXPECT_EQ(kTestDataSize * 2, file_size);
653 } 653 }
654 654
655 TEST_F(FileStreamTest, BasicWriteRead) { 655 TEST_F(FileStreamTest, BasicWriteRead) {
656 int64 file_size; 656 int64 file_size;
657 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); 657 bool ok = base::GetFileSize(temp_file_path(), &file_size);
658 EXPECT_TRUE(ok); 658 EXPECT_TRUE(ok);
659 659
660 scoped_ptr<FileStream> stream( 660 scoped_ptr<FileStream> stream(
661 new FileStream(NULL, base::MessageLoopProxy::current())); 661 new FileStream(NULL, base::MessageLoopProxy::current()));
662 int flags = base::PLATFORM_FILE_OPEN | 662 int flags = base::PLATFORM_FILE_OPEN |
663 base::PLATFORM_FILE_READ | 663 base::PLATFORM_FILE_READ |
664 base::PLATFORM_FILE_WRITE; 664 base::PLATFORM_FILE_WRITE;
665 int rv = stream->OpenSync(temp_file_path(), flags); 665 int rv = stream->OpenSync(temp_file_path(), flags);
666 EXPECT_EQ(OK, rv); 666 EXPECT_EQ(OK, rv);
667 667
(...skipping 16 matching lines...) Expand all
684 char buf[4]; 684 char buf[4];
685 rv = stream->ReadSync(buf, arraysize(buf)); 685 rv = stream->ReadSync(buf, arraysize(buf));
686 EXPECT_LE(0, rv); 686 EXPECT_LE(0, rv);
687 if (rv <= 0) 687 if (rv <= 0)
688 break; 688 break;
689 total_bytes_read += rv; 689 total_bytes_read += rv;
690 data_read.append(buf, rv); 690 data_read.append(buf, rv);
691 } 691 }
692 stream.reset(); 692 stream.reset();
693 693
694 ok = file_util::GetFileSize(temp_file_path(), &file_size); 694 ok = base::GetFileSize(temp_file_path(), &file_size);
695 EXPECT_TRUE(ok); 695 EXPECT_TRUE(ok);
696 EXPECT_EQ(kTestDataSize * 2, file_size); 696 EXPECT_EQ(kTestDataSize * 2, file_size);
697 EXPECT_EQ(kTestDataSize * 2, total_bytes_read); 697 EXPECT_EQ(kTestDataSize * 2, total_bytes_read);
698 698
699 const std::string kExpectedFileData = 699 const std::string kExpectedFileData =
700 std::string(kTestData) + std::string(kTestData); 700 std::string(kTestData) + std::string(kTestData);
701 EXPECT_EQ(kExpectedFileData, data_read); 701 EXPECT_EQ(kExpectedFileData, data_read);
702 } 702 }
703 703
704 TEST_F(FileStreamTest, BasicAsyncReadWrite) { 704 TEST_F(FileStreamTest, BasicAsyncReadWrite) {
705 int64 file_size; 705 int64 file_size;
706 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); 706 bool ok = base::GetFileSize(temp_file_path(), &file_size);
707 EXPECT_TRUE(ok); 707 EXPECT_TRUE(ok);
708 708
709 scoped_ptr<FileStream> stream( 709 scoped_ptr<FileStream> stream(
710 new FileStream(NULL, base::MessageLoopProxy::current())); 710 new FileStream(NULL, base::MessageLoopProxy::current()));
711 int flags = base::PLATFORM_FILE_OPEN | 711 int flags = base::PLATFORM_FILE_OPEN |
712 base::PLATFORM_FILE_READ | 712 base::PLATFORM_FILE_READ |
713 base::PLATFORM_FILE_WRITE | 713 base::PLATFORM_FILE_WRITE |
714 base::PLATFORM_FILE_ASYNC; 714 base::PLATFORM_FILE_ASYNC;
715 TestCompletionCallback callback; 715 TestCompletionCallback callback;
716 int rv = stream->Open(temp_file_path(), flags, callback.callback()); 716 int rv = stream->Open(temp_file_path(), flags, callback.callback());
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after
749 rv = callback.WaitForResult(); 749 rv = callback.WaitForResult();
750 EXPECT_LT(0, rv); 750 EXPECT_LT(0, rv);
751 if (rv <= 0) 751 if (rv <= 0)
752 break; 752 break;
753 drainable->DidConsume(rv); 753 drainable->DidConsume(rv);
754 total_bytes_written += rv; 754 total_bytes_written += rv;
755 } 755 }
756 756
757 stream.reset(); 757 stream.reset();
758 758
759 ok = file_util::GetFileSize(temp_file_path(), &file_size); 759 ok = base::GetFileSize(temp_file_path(), &file_size);
760 EXPECT_TRUE(ok); 760 EXPECT_TRUE(ok);
761 EXPECT_EQ(kTestDataSize * 2, file_size); 761 EXPECT_EQ(kTestDataSize * 2, file_size);
762 } 762 }
763 763
764 TEST_F(FileStreamTest, BasicAsyncWriteRead) { 764 TEST_F(FileStreamTest, BasicAsyncWriteRead) {
765 int64 file_size; 765 int64 file_size;
766 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); 766 bool ok = base::GetFileSize(temp_file_path(), &file_size);
767 EXPECT_TRUE(ok); 767 EXPECT_TRUE(ok);
768 768
769 scoped_ptr<FileStream> stream( 769 scoped_ptr<FileStream> stream(
770 new FileStream(NULL, base::MessageLoopProxy::current())); 770 new FileStream(NULL, base::MessageLoopProxy::current()));
771 int flags = base::PLATFORM_FILE_OPEN | 771 int flags = base::PLATFORM_FILE_OPEN |
772 base::PLATFORM_FILE_READ | 772 base::PLATFORM_FILE_READ |
773 base::PLATFORM_FILE_WRITE | 773 base::PLATFORM_FILE_WRITE |
774 base::PLATFORM_FILE_ASYNC; 774 base::PLATFORM_FILE_ASYNC;
775 TestCompletionCallback callback; 775 TestCompletionCallback callback;
776 int rv = stream->Open(temp_file_path(), flags, callback.callback()); 776 int rv = stream->Open(temp_file_path(), flags, callback.callback());
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after
819 if (rv == ERR_IO_PENDING) 819 if (rv == ERR_IO_PENDING)
820 rv = callback.WaitForResult(); 820 rv = callback.WaitForResult();
821 EXPECT_LE(0, rv); 821 EXPECT_LE(0, rv);
822 if (rv <= 0) 822 if (rv <= 0)
823 break; 823 break;
824 total_bytes_read += rv; 824 total_bytes_read += rv;
825 data_read.append(buf->data(), rv); 825 data_read.append(buf->data(), rv);
826 } 826 }
827 stream.reset(); 827 stream.reset();
828 828
829 ok = file_util::GetFileSize(temp_file_path(), &file_size); 829 ok = base::GetFileSize(temp_file_path(), &file_size);
830 EXPECT_TRUE(ok); 830 EXPECT_TRUE(ok);
831 EXPECT_EQ(kTestDataSize * 2, file_size); 831 EXPECT_EQ(kTestDataSize * 2, file_size);
832 832
833 EXPECT_EQ(kTestDataSize * 2, total_bytes_read); 833 EXPECT_EQ(kTestDataSize * 2, total_bytes_read);
834 const std::string kExpectedFileData = 834 const std::string kExpectedFileData =
835 std::string(kTestData) + std::string(kTestData); 835 std::string(kTestData) + std::string(kTestData);
836 EXPECT_EQ(kExpectedFileData, data_read); 836 EXPECT_EQ(kExpectedFileData, data_read);
837 } 837 }
838 838
839 class TestWriteReadCompletionCallback { 839 class TestWriteReadCompletionCallback {
(...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after
923 std::string* data_read_; 923 std::string* data_read_;
924 const CompletionCallback callback_; 924 const CompletionCallback callback_;
925 scoped_refptr<IOBufferWithSize> test_data_; 925 scoped_refptr<IOBufferWithSize> test_data_;
926 scoped_refptr<DrainableIOBuffer> drainable_; 926 scoped_refptr<DrainableIOBuffer> drainable_;
927 927
928 DISALLOW_COPY_AND_ASSIGN(TestWriteReadCompletionCallback); 928 DISALLOW_COPY_AND_ASSIGN(TestWriteReadCompletionCallback);
929 }; 929 };
930 930
931 TEST_F(FileStreamTest, AsyncWriteRead) { 931 TEST_F(FileStreamTest, AsyncWriteRead) {
932 int64 file_size; 932 int64 file_size;
933 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); 933 bool ok = base::GetFileSize(temp_file_path(), &file_size);
934 EXPECT_TRUE(ok); 934 EXPECT_TRUE(ok);
935 935
936 scoped_ptr<FileStream> stream( 936 scoped_ptr<FileStream> stream(
937 new FileStream(NULL, base::MessageLoopProxy::current())); 937 new FileStream(NULL, base::MessageLoopProxy::current()));
938 int flags = base::PLATFORM_FILE_OPEN | 938 int flags = base::PLATFORM_FILE_OPEN |
939 base::PLATFORM_FILE_READ | 939 base::PLATFORM_FILE_READ |
940 base::PLATFORM_FILE_WRITE | 940 base::PLATFORM_FILE_WRITE |
941 base::PLATFORM_FILE_ASYNC; 941 base::PLATFORM_FILE_ASYNC;
942 TestCompletionCallback open_callback; 942 TestCompletionCallback open_callback;
943 int rv = stream->Open(temp_file_path(), flags, open_callback.callback()); 943 int rv = stream->Open(temp_file_path(), flags, open_callback.callback());
(...skipping 14 matching lines...) Expand all
958 958
959 scoped_refptr<IOBufferWithSize> buf = CreateTestDataBuffer(); 959 scoped_refptr<IOBufferWithSize> buf = CreateTestDataBuffer();
960 rv = stream->Write(buf.get(), buf->size(), callback.callback()); 960 rv = stream->Write(buf.get(), buf->size(), callback.callback());
961 if (rv == ERR_IO_PENDING) 961 if (rv == ERR_IO_PENDING)
962 rv = callback.WaitForResult(); 962 rv = callback.WaitForResult();
963 EXPECT_LT(0, rv); 963 EXPECT_LT(0, rv);
964 EXPECT_EQ(kTestDataSize, total_bytes_written); 964 EXPECT_EQ(kTestDataSize, total_bytes_written);
965 965
966 stream.reset(); 966 stream.reset();
967 967
968 ok = file_util::GetFileSize(temp_file_path(), &file_size); 968 ok = base::GetFileSize(temp_file_path(), &file_size);
969 EXPECT_TRUE(ok); 969 EXPECT_TRUE(ok);
970 EXPECT_EQ(kTestDataSize * 2, file_size); 970 EXPECT_EQ(kTestDataSize * 2, file_size);
971 971
972 EXPECT_EQ(kTestDataSize * 2, total_bytes_read); 972 EXPECT_EQ(kTestDataSize * 2, total_bytes_read);
973 const std::string kExpectedFileData = 973 const std::string kExpectedFileData =
974 std::string(kTestData) + std::string(kTestData); 974 std::string(kTestData) + std::string(kTestData);
975 EXPECT_EQ(kExpectedFileData, data_read); 975 EXPECT_EQ(kExpectedFileData, data_read);
976 } 976 }
977 977
978 class TestWriteCloseCompletionCallback { 978 class TestWriteCloseCompletionCallback {
(...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after
1033 int* total_bytes_written_; 1033 int* total_bytes_written_;
1034 const CompletionCallback callback_; 1034 const CompletionCallback callback_;
1035 scoped_refptr<IOBufferWithSize> test_data_; 1035 scoped_refptr<IOBufferWithSize> test_data_;
1036 scoped_refptr<DrainableIOBuffer> drainable_; 1036 scoped_refptr<DrainableIOBuffer> drainable_;
1037 1037
1038 DISALLOW_COPY_AND_ASSIGN(TestWriteCloseCompletionCallback); 1038 DISALLOW_COPY_AND_ASSIGN(TestWriteCloseCompletionCallback);
1039 }; 1039 };
1040 1040
1041 TEST_F(FileStreamTest, AsyncWriteClose) { 1041 TEST_F(FileStreamTest, AsyncWriteClose) {
1042 int64 file_size; 1042 int64 file_size;
1043 bool ok = file_util::GetFileSize(temp_file_path(), &file_size); 1043 bool ok = base::GetFileSize(temp_file_path(), &file_size);
1044 EXPECT_TRUE(ok); 1044 EXPECT_TRUE(ok);
1045 1045
1046 scoped_ptr<FileStream> stream( 1046 scoped_ptr<FileStream> stream(
1047 new FileStream(NULL, base::MessageLoopProxy::current())); 1047 new FileStream(NULL, base::MessageLoopProxy::current()));
1048 int flags = base::PLATFORM_FILE_OPEN | 1048 int flags = base::PLATFORM_FILE_OPEN |
1049 base::PLATFORM_FILE_READ | 1049 base::PLATFORM_FILE_READ |
1050 base::PLATFORM_FILE_WRITE | 1050 base::PLATFORM_FILE_WRITE |
1051 base::PLATFORM_FILE_ASYNC; 1051 base::PLATFORM_FILE_ASYNC;
1052 TestCompletionCallback open_callback; 1052 TestCompletionCallback open_callback;
1053 int rv = stream->Open(temp_file_path(), flags, open_callback.callback()); 1053 int rv = stream->Open(temp_file_path(), flags, open_callback.callback());
(...skipping 11 matching lines...) Expand all
1065 1065
1066 scoped_refptr<IOBufferWithSize> buf = CreateTestDataBuffer(); 1066 scoped_refptr<IOBufferWithSize> buf = CreateTestDataBuffer();
1067 rv = stream->Write(buf.get(), buf->size(), callback.callback()); 1067 rv = stream->Write(buf.get(), buf->size(), callback.callback());
1068 if (rv == ERR_IO_PENDING) 1068 if (rv == ERR_IO_PENDING)
1069 total_bytes_written = callback.WaitForResult(); 1069 total_bytes_written = callback.WaitForResult();
1070 EXPECT_LT(0, total_bytes_written); 1070 EXPECT_LT(0, total_bytes_written);
1071 EXPECT_EQ(kTestDataSize, total_bytes_written); 1071 EXPECT_EQ(kTestDataSize, total_bytes_written);
1072 1072
1073 stream.reset(); 1073 stream.reset();
1074 1074
1075 ok = file_util::GetFileSize(temp_file_path(), &file_size); 1075 ok = base::GetFileSize(temp_file_path(), &file_size);
1076 EXPECT_TRUE(ok); 1076 EXPECT_TRUE(ok);
1077 EXPECT_EQ(kTestDataSize * 2, file_size); 1077 EXPECT_EQ(kTestDataSize * 2, file_size);
1078 } 1078 }
1079 1079
1080 // Tests truncating a file. 1080 // Tests truncating a file.
1081 TEST_F(FileStreamTest, Truncate) { 1081 TEST_F(FileStreamTest, Truncate) {
1082 int flags = base::PLATFORM_FILE_CREATE_ALWAYS | base::PLATFORM_FILE_WRITE; 1082 int flags = base::PLATFORM_FILE_CREATE_ALWAYS | base::PLATFORM_FILE_WRITE;
1083 1083
1084 scoped_ptr<FileStream> write_stream( 1084 scoped_ptr<FileStream> write_stream(
1085 new FileStream(NULL, base::MessageLoopProxy::current())); 1085 new FileStream(NULL, base::MessageLoopProxy::current()));
(...skipping 100 matching lines...) Expand 10 before | Expand all | Expand 10 after
1186 test_dir = test_dir.AppendASCII("file_stream_unittest"); 1186 test_dir = test_dir.AppendASCII("file_stream_unittest");
1187 ASSERT_TRUE(base::PathExists(test_dir)); 1187 ASSERT_TRUE(base::PathExists(test_dir));
1188 base::FilePath image_file = test_dir.Append(FILE_PATH_LITERAL("red.png")); 1188 base::FilePath image_file = test_dir.Append(FILE_PATH_LITERAL("red.png"));
1189 1189
1190 // Insert the image into MediaStore. MediaStore will do some conversions, and 1190 // Insert the image into MediaStore. MediaStore will do some conversions, and
1191 // return the content URI. 1191 // return the content URI.
1192 base::FilePath path = file_util::InsertImageIntoMediaStore(image_file); 1192 base::FilePath path = file_util::InsertImageIntoMediaStore(image_file);
1193 EXPECT_TRUE(path.IsContentUri()); 1193 EXPECT_TRUE(path.IsContentUri());
1194 EXPECT_TRUE(base::PathExists(path)); 1194 EXPECT_TRUE(base::PathExists(path));
1195 int64 file_size; 1195 int64 file_size;
1196 EXPECT_TRUE(file_util::GetFileSize(path, &file_size)); 1196 EXPECT_TRUE(base::GetFileSize(path, &file_size));
1197 EXPECT_LT(0, file_size); 1197 EXPECT_LT(0, file_size);
1198 1198
1199 FileStream stream(NULL, base::MessageLoopProxy::current()); 1199 FileStream stream(NULL, base::MessageLoopProxy::current());
1200 int flags = base::PLATFORM_FILE_OPEN | 1200 int flags = base::PLATFORM_FILE_OPEN |
1201 base::PLATFORM_FILE_READ | 1201 base::PLATFORM_FILE_READ |
1202 base::PLATFORM_FILE_ASYNC; 1202 base::PLATFORM_FILE_ASYNC;
1203 TestCompletionCallback callback; 1203 TestCompletionCallback callback;
1204 int rv = stream.Open(path, flags, callback.callback()); 1204 int rv = stream.Open(path, flags, callback.callback());
1205 EXPECT_EQ(ERR_IO_PENDING, rv); 1205 EXPECT_EQ(ERR_IO_PENDING, rv);
1206 EXPECT_EQ(OK, callback.WaitForResult()); 1206 EXPECT_EQ(OK, callback.WaitForResult());
(...skipping 15 matching lines...) Expand all
1222 total_bytes_read += rv; 1222 total_bytes_read += rv;
1223 data_read.append(buf->data(), rv); 1223 data_read.append(buf->data(), rv);
1224 } 1224 }
1225 EXPECT_EQ(file_size, total_bytes_read); 1225 EXPECT_EQ(file_size, total_bytes_read);
1226 } 1226 }
1227 #endif 1227 #endif
1228 1228
1229 } // namespace 1229 } // namespace
1230 1230
1231 } // namespace net 1231 } // namespace net
OLDNEW
« no previous file with comments | « media/base/yuv_convert_unittest.cc ('k') | net/base/upload_file_element_reader.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698