| 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 <utility> | 5 #include <utility> |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/bind_helpers.h" | 8 #include "base/bind_helpers.h" |
| 9 #include "base/files/file.h" | 9 #include "base/files/file.h" |
| 10 #include "base/files/file_util.h" | 10 #include "base/files/file_util.h" |
| (...skipping 10 matching lines...) Expand all Loading... |
| 21 #include "net/disk_cache/blockfile/entry_impl.h" | 21 #include "net/disk_cache/blockfile/entry_impl.h" |
| 22 #include "net/disk_cache/disk_cache_test_base.h" | 22 #include "net/disk_cache/disk_cache_test_base.h" |
| 23 #include "net/disk_cache/disk_cache_test_util.h" | 23 #include "net/disk_cache/disk_cache_test_util.h" |
| 24 #include "net/disk_cache/memory/mem_entry_impl.h" | 24 #include "net/disk_cache/memory/mem_entry_impl.h" |
| 25 #include "net/disk_cache/simple/simple_backend_impl.h" | 25 #include "net/disk_cache/simple/simple_backend_impl.h" |
| 26 #include "net/disk_cache/simple/simple_entry_format.h" | 26 #include "net/disk_cache/simple/simple_entry_format.h" |
| 27 #include "net/disk_cache/simple/simple_entry_impl.h" | 27 #include "net/disk_cache/simple/simple_entry_impl.h" |
| 28 #include "net/disk_cache/simple/simple_synchronous_entry.h" | 28 #include "net/disk_cache/simple/simple_synchronous_entry.h" |
| 29 #include "net/disk_cache/simple/simple_test_util.h" | 29 #include "net/disk_cache/simple/simple_test_util.h" |
| 30 #include "net/disk_cache/simple/simple_util.h" | 30 #include "net/disk_cache/simple/simple_util.h" |
| 31 #include "net/test/gtest_util.h" |
| 32 #include "testing/gmock/include/gmock/gmock.h" |
| 31 #include "testing/gtest/include/gtest/gtest.h" | 33 #include "testing/gtest/include/gtest/gtest.h" |
| 32 | 34 |
| 35 using net::test::IsError; |
| 36 using net::test::IsOk; |
| 37 |
| 33 using base::Time; | 38 using base::Time; |
| 34 using disk_cache::ScopedEntryPtr; | 39 using disk_cache::ScopedEntryPtr; |
| 35 | 40 |
| 36 // Tests that can run with different types of caches. | 41 // Tests that can run with different types of caches. |
| 37 class DiskCacheEntryTest : public DiskCacheTestWithCache { | 42 class DiskCacheEntryTest : public DiskCacheTestWithCache { |
| 38 public: | 43 public: |
| 39 void InternalSyncIOBackground(disk_cache::Entry* entry); | 44 void InternalSyncIOBackground(disk_cache::Entry* entry); |
| 40 void ExternalSyncIOBackground(disk_cache::Entry* entry); | 45 void ExternalSyncIOBackground(disk_cache::Entry* entry); |
| 41 | 46 |
| 42 protected: | 47 protected: |
| (...skipping 91 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 134 EXPECT_EQ(0, entry->WriteData( | 139 EXPECT_EQ(0, entry->WriteData( |
| 135 1, 0, NULL, 0, net::CompletionCallback(), true)); | 140 1, 0, NULL, 0, net::CompletionCallback(), true)); |
| 136 } | 141 } |
| 137 | 142 |
| 138 // We need to support synchronous IO even though it is not a supported operation | 143 // We need to support synchronous IO even though it is not a supported operation |
| 139 // from the point of view of the disk cache's public interface, because we use | 144 // from the point of view of the disk cache's public interface, because we use |
| 140 // it internally, not just by a few tests, but as part of the implementation | 145 // it internally, not just by a few tests, but as part of the implementation |
| 141 // (see sparse_control.cc, for example). | 146 // (see sparse_control.cc, for example). |
| 142 void DiskCacheEntryTest::InternalSyncIO() { | 147 void DiskCacheEntryTest::InternalSyncIO() { |
| 143 disk_cache::Entry* entry = NULL; | 148 disk_cache::Entry* entry = NULL; |
| 144 ASSERT_EQ(net::OK, CreateEntry("the first key", &entry)); | 149 ASSERT_THAT(CreateEntry("the first key", &entry), IsOk()); |
| 145 ASSERT_TRUE(NULL != entry); | 150 ASSERT_TRUE(NULL != entry); |
| 146 | 151 |
| 147 // The bulk of the test runs from within the callback, on the cache thread. | 152 // The bulk of the test runs from within the callback, on the cache thread. |
| 148 RunTaskForTest(base::Bind(&DiskCacheEntryTest::InternalSyncIOBackground, | 153 RunTaskForTest(base::Bind(&DiskCacheEntryTest::InternalSyncIOBackground, |
| 149 base::Unretained(this), | 154 base::Unretained(this), |
| 150 entry)); | 155 entry)); |
| 151 | 156 |
| 152 | 157 |
| 153 entry->Doom(); | 158 entry->Doom(); |
| 154 entry->Close(); | 159 entry->Close(); |
| 155 FlushQueueForTest(); | 160 FlushQueueForTest(); |
| 156 EXPECT_EQ(0, cache_->GetEntryCount()); | 161 EXPECT_EQ(0, cache_->GetEntryCount()); |
| 157 } | 162 } |
| 158 | 163 |
| 159 TEST_F(DiskCacheEntryTest, InternalSyncIO) { | 164 TEST_F(DiskCacheEntryTest, InternalSyncIO) { |
| 160 InitCache(); | 165 InitCache(); |
| 161 InternalSyncIO(); | 166 InternalSyncIO(); |
| 162 } | 167 } |
| 163 | 168 |
| 164 TEST_F(DiskCacheEntryTest, MemoryOnlyInternalSyncIO) { | 169 TEST_F(DiskCacheEntryTest, MemoryOnlyInternalSyncIO) { |
| 165 SetMemoryOnlyMode(); | 170 SetMemoryOnlyMode(); |
| 166 InitCache(); | 171 InitCache(); |
| 167 InternalSyncIO(); | 172 InternalSyncIO(); |
| 168 } | 173 } |
| 169 | 174 |
| 170 void DiskCacheEntryTest::InternalAsyncIO() { | 175 void DiskCacheEntryTest::InternalAsyncIO() { |
| 171 disk_cache::Entry* entry = NULL; | 176 disk_cache::Entry* entry = NULL; |
| 172 ASSERT_EQ(net::OK, CreateEntry("the first key", &entry)); | 177 ASSERT_THAT(CreateEntry("the first key", &entry), IsOk()); |
| 173 ASSERT_TRUE(NULL != entry); | 178 ASSERT_TRUE(NULL != entry); |
| 174 | 179 |
| 175 // Avoid using internal buffers for the test. We have to write something to | 180 // Avoid using internal buffers for the test. We have to write something to |
| 176 // the entry and close it so that we flush the internal buffer to disk. After | 181 // the entry and close it so that we flush the internal buffer to disk. After |
| 177 // that, IO operations will be really hitting the disk. We don't care about | 182 // that, IO operations will be really hitting the disk. We don't care about |
| 178 // the content, so just extending the entry is enough (all extensions zero- | 183 // the content, so just extending the entry is enough (all extensions zero- |
| 179 // fill any holes). | 184 // fill any holes). |
| 180 EXPECT_EQ(0, WriteData(entry, 0, 15 * 1024, NULL, 0, false)); | 185 EXPECT_EQ(0, WriteData(entry, 0, 15 * 1024, NULL, 0, false)); |
| 181 EXPECT_EQ(0, WriteData(entry, 1, 15 * 1024, NULL, 0, false)); | 186 EXPECT_EQ(0, WriteData(entry, 1, 15 * 1024, NULL, 0, false)); |
| 182 entry->Close(); | 187 entry->Close(); |
| 183 ASSERT_EQ(net::OK, OpenEntry("the first key", &entry)); | 188 ASSERT_THAT(OpenEntry("the first key", &entry), IsOk()); |
| 184 | 189 |
| 185 MessageLoopHelper helper; | 190 MessageLoopHelper helper; |
| 186 // Let's verify that each IO goes to the right callback object. | 191 // Let's verify that each IO goes to the right callback object. |
| 187 CallbackTest callback1(&helper, false); | 192 CallbackTest callback1(&helper, false); |
| 188 CallbackTest callback2(&helper, false); | 193 CallbackTest callback2(&helper, false); |
| 189 CallbackTest callback3(&helper, false); | 194 CallbackTest callback3(&helper, false); |
| 190 CallbackTest callback4(&helper, false); | 195 CallbackTest callback4(&helper, false); |
| 191 CallbackTest callback5(&helper, false); | 196 CallbackTest callback5(&helper, false); |
| 192 CallbackTest callback6(&helper, false); | 197 CallbackTest callback6(&helper, false); |
| 193 CallbackTest callback7(&helper, false); | 198 CallbackTest callback7(&helper, false); |
| (...skipping 223 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 417 | 422 |
| 418 // We need to delete the memory buffer on this thread. | 423 // We need to delete the memory buffer on this thread. |
| 419 EXPECT_EQ(0, entry->WriteData( | 424 EXPECT_EQ(0, entry->WriteData( |
| 420 0, 0, NULL, 0, net::CompletionCallback(), true)); | 425 0, 0, NULL, 0, net::CompletionCallback(), true)); |
| 421 EXPECT_EQ(0, entry->WriteData( | 426 EXPECT_EQ(0, entry->WriteData( |
| 422 1, 0, NULL, 0, net::CompletionCallback(), true)); | 427 1, 0, NULL, 0, net::CompletionCallback(), true)); |
| 423 } | 428 } |
| 424 | 429 |
| 425 void DiskCacheEntryTest::ExternalSyncIO() { | 430 void DiskCacheEntryTest::ExternalSyncIO() { |
| 426 disk_cache::Entry* entry; | 431 disk_cache::Entry* entry; |
| 427 ASSERT_EQ(net::OK, CreateEntry("the first key", &entry)); | 432 ASSERT_THAT(CreateEntry("the first key", &entry), IsOk()); |
| 428 | 433 |
| 429 // The bulk of the test runs from within the callback, on the cache thread. | 434 // The bulk of the test runs from within the callback, on the cache thread. |
| 430 RunTaskForTest(base::Bind(&DiskCacheEntryTest::ExternalSyncIOBackground, | 435 RunTaskForTest(base::Bind(&DiskCacheEntryTest::ExternalSyncIOBackground, |
| 431 base::Unretained(this), | 436 base::Unretained(this), |
| 432 entry)); | 437 entry)); |
| 433 | 438 |
| 434 entry->Doom(); | 439 entry->Doom(); |
| 435 entry->Close(); | 440 entry->Close(); |
| 436 FlushQueueForTest(); | 441 FlushQueueForTest(); |
| 437 EXPECT_EQ(0, cache_->GetEntryCount()); | 442 EXPECT_EQ(0, cache_->GetEntryCount()); |
| (...skipping 11 matching lines...) Expand all Loading... |
| 449 } | 454 } |
| 450 | 455 |
| 451 TEST_F(DiskCacheEntryTest, MemoryOnlyExternalSyncIO) { | 456 TEST_F(DiskCacheEntryTest, MemoryOnlyExternalSyncIO) { |
| 452 SetMemoryOnlyMode(); | 457 SetMemoryOnlyMode(); |
| 453 InitCache(); | 458 InitCache(); |
| 454 ExternalSyncIO(); | 459 ExternalSyncIO(); |
| 455 } | 460 } |
| 456 | 461 |
| 457 void DiskCacheEntryTest::ExternalAsyncIO() { | 462 void DiskCacheEntryTest::ExternalAsyncIO() { |
| 458 disk_cache::Entry* entry; | 463 disk_cache::Entry* entry; |
| 459 ASSERT_EQ(net::OK, CreateEntry("the first key", &entry)); | 464 ASSERT_THAT(CreateEntry("the first key", &entry), IsOk()); |
| 460 | 465 |
| 461 int expected = 0; | 466 int expected = 0; |
| 462 | 467 |
| 463 MessageLoopHelper helper; | 468 MessageLoopHelper helper; |
| 464 // Let's verify that each IO goes to the right callback object. | 469 // Let's verify that each IO goes to the right callback object. |
| 465 CallbackTest callback1(&helper, false); | 470 CallbackTest callback1(&helper, false); |
| 466 CallbackTest callback2(&helper, false); | 471 CallbackTest callback2(&helper, false); |
| 467 CallbackTest callback3(&helper, false); | 472 CallbackTest callback3(&helper, false); |
| 468 CallbackTest callback4(&helper, false); | 473 CallbackTest callback4(&helper, false); |
| 469 CallbackTest callback5(&helper, false); | 474 CallbackTest callback5(&helper, false); |
| (...skipping 146 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 616 | 621 |
| 617 TEST_F(DiskCacheEntryTest, MemoryOnlyExternalAsyncIO) { | 622 TEST_F(DiskCacheEntryTest, MemoryOnlyExternalAsyncIO) { |
| 618 SetMemoryOnlyMode(); | 623 SetMemoryOnlyMode(); |
| 619 InitCache(); | 624 InitCache(); |
| 620 ExternalAsyncIO(); | 625 ExternalAsyncIO(); |
| 621 } | 626 } |
| 622 | 627 |
| 623 // Tests that IOBuffers are not referenced after IO completes. | 628 // Tests that IOBuffers are not referenced after IO completes. |
| 624 void DiskCacheEntryTest::ReleaseBuffer(int stream_index) { | 629 void DiskCacheEntryTest::ReleaseBuffer(int stream_index) { |
| 625 disk_cache::Entry* entry = NULL; | 630 disk_cache::Entry* entry = NULL; |
| 626 ASSERT_EQ(net::OK, CreateEntry("the first key", &entry)); | 631 ASSERT_THAT(CreateEntry("the first key", &entry), IsOk()); |
| 627 ASSERT_TRUE(NULL != entry); | 632 ASSERT_TRUE(NULL != entry); |
| 628 | 633 |
| 629 const int kBufferSize = 1024; | 634 const int kBufferSize = 1024; |
| 630 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kBufferSize)); | 635 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kBufferSize)); |
| 631 CacheTestFillBuffer(buffer->data(), kBufferSize, false); | 636 CacheTestFillBuffer(buffer->data(), kBufferSize, false); |
| 632 | 637 |
| 633 net::ReleaseBufferCompletionCallback cb(buffer.get()); | 638 net::ReleaseBufferCompletionCallback cb(buffer.get()); |
| 634 int rv = entry->WriteData( | 639 int rv = entry->WriteData( |
| 635 stream_index, 0, buffer.get(), kBufferSize, cb.callback(), false); | 640 stream_index, 0, buffer.get(), kBufferSize, cb.callback(), false); |
| 636 EXPECT_EQ(kBufferSize, cb.GetResult(rv)); | 641 EXPECT_EQ(kBufferSize, cb.GetResult(rv)); |
| 637 entry->Close(); | 642 entry->Close(); |
| 638 } | 643 } |
| 639 | 644 |
| 640 TEST_F(DiskCacheEntryTest, ReleaseBuffer) { | 645 TEST_F(DiskCacheEntryTest, ReleaseBuffer) { |
| 641 InitCache(); | 646 InitCache(); |
| 642 cache_impl_->SetFlags(disk_cache::kNoBuffering); | 647 cache_impl_->SetFlags(disk_cache::kNoBuffering); |
| 643 ReleaseBuffer(0); | 648 ReleaseBuffer(0); |
| 644 } | 649 } |
| 645 | 650 |
| 646 TEST_F(DiskCacheEntryTest, MemoryOnlyReleaseBuffer) { | 651 TEST_F(DiskCacheEntryTest, MemoryOnlyReleaseBuffer) { |
| 647 SetMemoryOnlyMode(); | 652 SetMemoryOnlyMode(); |
| 648 InitCache(); | 653 InitCache(); |
| 649 ReleaseBuffer(0); | 654 ReleaseBuffer(0); |
| 650 } | 655 } |
| 651 | 656 |
| 652 void DiskCacheEntryTest::StreamAccess() { | 657 void DiskCacheEntryTest::StreamAccess() { |
| 653 disk_cache::Entry* entry = NULL; | 658 disk_cache::Entry* entry = NULL; |
| 654 ASSERT_EQ(net::OK, CreateEntry("the first key", &entry)); | 659 ASSERT_THAT(CreateEntry("the first key", &entry), IsOk()); |
| 655 ASSERT_TRUE(NULL != entry); | 660 ASSERT_TRUE(NULL != entry); |
| 656 | 661 |
| 657 const int kBufferSize = 1024; | 662 const int kBufferSize = 1024; |
| 658 const int kNumStreams = 3; | 663 const int kNumStreams = 3; |
| 659 scoped_refptr<net::IOBuffer> reference_buffers[kNumStreams]; | 664 scoped_refptr<net::IOBuffer> reference_buffers[kNumStreams]; |
| 660 for (int i = 0; i < kNumStreams; i++) { | 665 for (int i = 0; i < kNumStreams; i++) { |
| 661 reference_buffers[i] = new net::IOBuffer(kBufferSize); | 666 reference_buffers[i] = new net::IOBuffer(kBufferSize); |
| 662 CacheTestFillBuffer(reference_buffers[i]->data(), kBufferSize, false); | 667 CacheTestFillBuffer(reference_buffers[i]->data(), kBufferSize, false); |
| 663 } | 668 } |
| 664 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kBufferSize)); | 669 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kBufferSize)); |
| 665 for (int i = 0; i < kNumStreams; i++) { | 670 for (int i = 0; i < kNumStreams; i++) { |
| 666 EXPECT_EQ( | 671 EXPECT_EQ( |
| 667 kBufferSize, | 672 kBufferSize, |
| 668 WriteData(entry, i, 0, reference_buffers[i].get(), kBufferSize, false)); | 673 WriteData(entry, i, 0, reference_buffers[i].get(), kBufferSize, false)); |
| 669 memset(buffer1->data(), 0, kBufferSize); | 674 memset(buffer1->data(), 0, kBufferSize); |
| 670 EXPECT_EQ(kBufferSize, ReadData(entry, i, 0, buffer1.get(), kBufferSize)); | 675 EXPECT_EQ(kBufferSize, ReadData(entry, i, 0, buffer1.get(), kBufferSize)); |
| 671 EXPECT_EQ( | 676 EXPECT_EQ( |
| 672 0, memcmp(reference_buffers[i]->data(), buffer1->data(), kBufferSize)); | 677 0, memcmp(reference_buffers[i]->data(), buffer1->data(), kBufferSize)); |
| 673 } | 678 } |
| 674 EXPECT_EQ(net::ERR_INVALID_ARGUMENT, | 679 EXPECT_EQ(net::ERR_INVALID_ARGUMENT, |
| 675 ReadData(entry, kNumStreams, 0, buffer1.get(), kBufferSize)); | 680 ReadData(entry, kNumStreams, 0, buffer1.get(), kBufferSize)); |
| 676 entry->Close(); | 681 entry->Close(); |
| 677 | 682 |
| 678 // Open the entry and read it in chunks, including a read past the end. | 683 // Open the entry and read it in chunks, including a read past the end. |
| 679 ASSERT_EQ(net::OK, OpenEntry("the first key", &entry)); | 684 ASSERT_THAT(OpenEntry("the first key", &entry), IsOk()); |
| 680 ASSERT_TRUE(NULL != entry); | 685 ASSERT_TRUE(NULL != entry); |
| 681 const int kReadBufferSize = 600; | 686 const int kReadBufferSize = 600; |
| 682 const int kFinalReadSize = kBufferSize - kReadBufferSize; | 687 const int kFinalReadSize = kBufferSize - kReadBufferSize; |
| 683 static_assert(kFinalReadSize < kReadBufferSize, | 688 static_assert(kFinalReadSize < kReadBufferSize, |
| 684 "should be exactly two reads"); | 689 "should be exactly two reads"); |
| 685 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kReadBufferSize)); | 690 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kReadBufferSize)); |
| 686 for (int i = 0; i < kNumStreams; i++) { | 691 for (int i = 0; i < kNumStreams; i++) { |
| 687 memset(buffer2->data(), 0, kReadBufferSize); | 692 memset(buffer2->data(), 0, kReadBufferSize); |
| 688 EXPECT_EQ(kReadBufferSize, | 693 EXPECT_EQ(kReadBufferSize, |
| 689 ReadData(entry, i, 0, buffer2.get(), kReadBufferSize)); | 694 ReadData(entry, i, 0, buffer2.get(), kReadBufferSize)); |
| (...skipping 21 matching lines...) Expand all Loading... |
| 711 | 716 |
| 712 TEST_F(DiskCacheEntryTest, MemoryOnlyStreamAccess) { | 717 TEST_F(DiskCacheEntryTest, MemoryOnlyStreamAccess) { |
| 713 SetMemoryOnlyMode(); | 718 SetMemoryOnlyMode(); |
| 714 InitCache(); | 719 InitCache(); |
| 715 StreamAccess(); | 720 StreamAccess(); |
| 716 } | 721 } |
| 717 | 722 |
| 718 void DiskCacheEntryTest::GetKey() { | 723 void DiskCacheEntryTest::GetKey() { |
| 719 std::string key("the first key"); | 724 std::string key("the first key"); |
| 720 disk_cache::Entry* entry; | 725 disk_cache::Entry* entry; |
| 721 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 726 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 722 EXPECT_EQ(key, entry->GetKey()) << "short key"; | 727 EXPECT_EQ(key, entry->GetKey()) << "short key"; |
| 723 entry->Close(); | 728 entry->Close(); |
| 724 | 729 |
| 725 int seed = static_cast<int>(Time::Now().ToInternalValue()); | 730 int seed = static_cast<int>(Time::Now().ToInternalValue()); |
| 726 srand(seed); | 731 srand(seed); |
| 727 char key_buffer[20000]; | 732 char key_buffer[20000]; |
| 728 | 733 |
| 729 CacheTestFillBuffer(key_buffer, 3000, true); | 734 CacheTestFillBuffer(key_buffer, 3000, true); |
| 730 key_buffer[1000] = '\0'; | 735 key_buffer[1000] = '\0'; |
| 731 | 736 |
| 732 key = key_buffer; | 737 key = key_buffer; |
| 733 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 738 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 734 EXPECT_TRUE(key == entry->GetKey()) << "1000 bytes key"; | 739 EXPECT_TRUE(key == entry->GetKey()) << "1000 bytes key"; |
| 735 entry->Close(); | 740 entry->Close(); |
| 736 | 741 |
| 737 key_buffer[1000] = 'p'; | 742 key_buffer[1000] = 'p'; |
| 738 key_buffer[3000] = '\0'; | 743 key_buffer[3000] = '\0'; |
| 739 key = key_buffer; | 744 key = key_buffer; |
| 740 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 745 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 741 EXPECT_TRUE(key == entry->GetKey()) << "medium size key"; | 746 EXPECT_TRUE(key == entry->GetKey()) << "medium size key"; |
| 742 entry->Close(); | 747 entry->Close(); |
| 743 | 748 |
| 744 CacheTestFillBuffer(key_buffer, sizeof(key_buffer), true); | 749 CacheTestFillBuffer(key_buffer, sizeof(key_buffer), true); |
| 745 key_buffer[19999] = '\0'; | 750 key_buffer[19999] = '\0'; |
| 746 | 751 |
| 747 key = key_buffer; | 752 key = key_buffer; |
| 748 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 753 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 749 EXPECT_TRUE(key == entry->GetKey()) << "long key"; | 754 EXPECT_TRUE(key == entry->GetKey()) << "long key"; |
| 750 entry->Close(); | 755 entry->Close(); |
| 751 | 756 |
| 752 CacheTestFillBuffer(key_buffer, 0x4000, true); | 757 CacheTestFillBuffer(key_buffer, 0x4000, true); |
| 753 key_buffer[0x4000] = '\0'; | 758 key_buffer[0x4000] = '\0'; |
| 754 | 759 |
| 755 key = key_buffer; | 760 key = key_buffer; |
| 756 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 761 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 757 EXPECT_TRUE(key == entry->GetKey()) << "16KB key"; | 762 EXPECT_TRUE(key == entry->GetKey()) << "16KB key"; |
| 758 entry->Close(); | 763 entry->Close(); |
| 759 } | 764 } |
| 760 | 765 |
| 761 TEST_F(DiskCacheEntryTest, GetKey) { | 766 TEST_F(DiskCacheEntryTest, GetKey) { |
| 762 InitCache(); | 767 InitCache(); |
| 763 GetKey(); | 768 GetKey(); |
| 764 } | 769 } |
| 765 | 770 |
| 766 TEST_F(DiskCacheEntryTest, MemoryOnlyGetKey) { | 771 TEST_F(DiskCacheEntryTest, MemoryOnlyGetKey) { |
| 767 SetMemoryOnlyMode(); | 772 SetMemoryOnlyMode(); |
| 768 InitCache(); | 773 InitCache(); |
| 769 GetKey(); | 774 GetKey(); |
| 770 } | 775 } |
| 771 | 776 |
| 772 void DiskCacheEntryTest::GetTimes(int stream_index) { | 777 void DiskCacheEntryTest::GetTimes(int stream_index) { |
| 773 std::string key("the first key"); | 778 std::string key("the first key"); |
| 774 disk_cache::Entry* entry; | 779 disk_cache::Entry* entry; |
| 775 | 780 |
| 776 Time t1 = Time::Now(); | 781 Time t1 = Time::Now(); |
| 777 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 782 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 778 EXPECT_TRUE(entry->GetLastModified() >= t1); | 783 EXPECT_TRUE(entry->GetLastModified() >= t1); |
| 779 EXPECT_TRUE(entry->GetLastModified() == entry->GetLastUsed()); | 784 EXPECT_TRUE(entry->GetLastModified() == entry->GetLastUsed()); |
| 780 | 785 |
| 781 AddDelay(); | 786 AddDelay(); |
| 782 Time t2 = Time::Now(); | 787 Time t2 = Time::Now(); |
| 783 EXPECT_TRUE(t2 > t1); | 788 EXPECT_TRUE(t2 > t1); |
| 784 EXPECT_EQ(0, WriteData(entry, stream_index, 200, NULL, 0, false)); | 789 EXPECT_EQ(0, WriteData(entry, stream_index, 200, NULL, 0, false)); |
| 785 if (type_ == net::APP_CACHE) { | 790 if (type_ == net::APP_CACHE) { |
| 786 EXPECT_TRUE(entry->GetLastModified() < t2); | 791 EXPECT_TRUE(entry->GetLastModified() < t2); |
| 787 } else { | 792 } else { |
| (...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 827 | 832 |
| 828 TEST_F(DiskCacheEntryTest, ShaderCacheGetTimes) { | 833 TEST_F(DiskCacheEntryTest, ShaderCacheGetTimes) { |
| 829 SetCacheType(net::SHADER_CACHE); | 834 SetCacheType(net::SHADER_CACHE); |
| 830 InitCache(); | 835 InitCache(); |
| 831 GetTimes(0); | 836 GetTimes(0); |
| 832 } | 837 } |
| 833 | 838 |
| 834 void DiskCacheEntryTest::GrowData(int stream_index) { | 839 void DiskCacheEntryTest::GrowData(int stream_index) { |
| 835 std::string key1("the first key"); | 840 std::string key1("the first key"); |
| 836 disk_cache::Entry* entry; | 841 disk_cache::Entry* entry; |
| 837 ASSERT_EQ(net::OK, CreateEntry(key1, &entry)); | 842 ASSERT_THAT(CreateEntry(key1, &entry), IsOk()); |
| 838 | 843 |
| 839 const int kSize = 20000; | 844 const int kSize = 20000; |
| 840 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize)); | 845 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize)); |
| 841 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize)); | 846 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize)); |
| 842 CacheTestFillBuffer(buffer1->data(), kSize, false); | 847 CacheTestFillBuffer(buffer1->data(), kSize, false); |
| 843 memset(buffer2->data(), 0, kSize); | 848 memset(buffer2->data(), 0, kSize); |
| 844 | 849 |
| 845 base::strlcpy(buffer1->data(), "the data", kSize); | 850 base::strlcpy(buffer1->data(), "the data", kSize); |
| 846 EXPECT_EQ(10, WriteData(entry, stream_index, 0, buffer1.get(), 10, false)); | 851 EXPECT_EQ(10, WriteData(entry, stream_index, 0, buffer1.get(), 10, false)); |
| 847 EXPECT_EQ(10, ReadData(entry, stream_index, 0, buffer2.get(), 10)); | 852 EXPECT_EQ(10, ReadData(entry, stream_index, 0, buffer2.get(), 10)); |
| 848 EXPECT_STREQ("the data", buffer2->data()); | 853 EXPECT_STREQ("the data", buffer2->data()); |
| 849 EXPECT_EQ(10, entry->GetDataSize(stream_index)); | 854 EXPECT_EQ(10, entry->GetDataSize(stream_index)); |
| 850 | 855 |
| 851 EXPECT_EQ(2000, | 856 EXPECT_EQ(2000, |
| 852 WriteData(entry, stream_index, 0, buffer1.get(), 2000, false)); | 857 WriteData(entry, stream_index, 0, buffer1.get(), 2000, false)); |
| 853 EXPECT_EQ(2000, entry->GetDataSize(stream_index)); | 858 EXPECT_EQ(2000, entry->GetDataSize(stream_index)); |
| 854 EXPECT_EQ(2000, ReadData(entry, stream_index, 0, buffer2.get(), 2000)); | 859 EXPECT_EQ(2000, ReadData(entry, stream_index, 0, buffer2.get(), 2000)); |
| 855 EXPECT_TRUE(!memcmp(buffer1->data(), buffer2->data(), 2000)); | 860 EXPECT_TRUE(!memcmp(buffer1->data(), buffer2->data(), 2000)); |
| 856 | 861 |
| 857 EXPECT_EQ(20000, | 862 EXPECT_EQ(20000, |
| 858 WriteData(entry, stream_index, 0, buffer1.get(), kSize, false)); | 863 WriteData(entry, stream_index, 0, buffer1.get(), kSize, false)); |
| 859 EXPECT_EQ(20000, entry->GetDataSize(stream_index)); | 864 EXPECT_EQ(20000, entry->GetDataSize(stream_index)); |
| 860 EXPECT_EQ(20000, ReadData(entry, stream_index, 0, buffer2.get(), kSize)); | 865 EXPECT_EQ(20000, ReadData(entry, stream_index, 0, buffer2.get(), kSize)); |
| 861 EXPECT_TRUE(!memcmp(buffer1->data(), buffer2->data(), kSize)); | 866 EXPECT_TRUE(!memcmp(buffer1->data(), buffer2->data(), kSize)); |
| 862 entry->Close(); | 867 entry->Close(); |
| 863 | 868 |
| 864 memset(buffer2->data(), 0, kSize); | 869 memset(buffer2->data(), 0, kSize); |
| 865 std::string key2("Second key"); | 870 std::string key2("Second key"); |
| 866 ASSERT_EQ(net::OK, CreateEntry(key2, &entry)); | 871 ASSERT_THAT(CreateEntry(key2, &entry), IsOk()); |
| 867 EXPECT_EQ(10, WriteData(entry, stream_index, 0, buffer1.get(), 10, false)); | 872 EXPECT_EQ(10, WriteData(entry, stream_index, 0, buffer1.get(), 10, false)); |
| 868 EXPECT_EQ(10, entry->GetDataSize(stream_index)); | 873 EXPECT_EQ(10, entry->GetDataSize(stream_index)); |
| 869 entry->Close(); | 874 entry->Close(); |
| 870 | 875 |
| 871 // Go from an internal address to a bigger block size. | 876 // Go from an internal address to a bigger block size. |
| 872 ASSERT_EQ(net::OK, OpenEntry(key2, &entry)); | 877 ASSERT_THAT(OpenEntry(key2, &entry), IsOk()); |
| 873 EXPECT_EQ(2000, | 878 EXPECT_EQ(2000, |
| 874 WriteData(entry, stream_index, 0, buffer1.get(), 2000, false)); | 879 WriteData(entry, stream_index, 0, buffer1.get(), 2000, false)); |
| 875 EXPECT_EQ(2000, entry->GetDataSize(stream_index)); | 880 EXPECT_EQ(2000, entry->GetDataSize(stream_index)); |
| 876 EXPECT_EQ(2000, ReadData(entry, stream_index, 0, buffer2.get(), 2000)); | 881 EXPECT_EQ(2000, ReadData(entry, stream_index, 0, buffer2.get(), 2000)); |
| 877 EXPECT_TRUE(!memcmp(buffer1->data(), buffer2->data(), 2000)); | 882 EXPECT_TRUE(!memcmp(buffer1->data(), buffer2->data(), 2000)); |
| 878 entry->Close(); | 883 entry->Close(); |
| 879 memset(buffer2->data(), 0, kSize); | 884 memset(buffer2->data(), 0, kSize); |
| 880 | 885 |
| 881 // Go from an internal address to an external one. | 886 // Go from an internal address to an external one. |
| 882 ASSERT_EQ(net::OK, OpenEntry(key2, &entry)); | 887 ASSERT_THAT(OpenEntry(key2, &entry), IsOk()); |
| 883 EXPECT_EQ(20000, | 888 EXPECT_EQ(20000, |
| 884 WriteData(entry, stream_index, 0, buffer1.get(), kSize, false)); | 889 WriteData(entry, stream_index, 0, buffer1.get(), kSize, false)); |
| 885 EXPECT_EQ(20000, entry->GetDataSize(stream_index)); | 890 EXPECT_EQ(20000, entry->GetDataSize(stream_index)); |
| 886 EXPECT_EQ(20000, ReadData(entry, stream_index, 0, buffer2.get(), kSize)); | 891 EXPECT_EQ(20000, ReadData(entry, stream_index, 0, buffer2.get(), kSize)); |
| 887 EXPECT_TRUE(!memcmp(buffer1->data(), buffer2->data(), kSize)); | 892 EXPECT_TRUE(!memcmp(buffer1->data(), buffer2->data(), kSize)); |
| 888 entry->Close(); | 893 entry->Close(); |
| 889 | 894 |
| 890 // Double check the size from disk. | 895 // Double check the size from disk. |
| 891 ASSERT_EQ(net::OK, OpenEntry(key2, &entry)); | 896 ASSERT_THAT(OpenEntry(key2, &entry), IsOk()); |
| 892 EXPECT_EQ(20000, entry->GetDataSize(stream_index)); | 897 EXPECT_EQ(20000, entry->GetDataSize(stream_index)); |
| 893 | 898 |
| 894 // Now extend the entry without actual data. | 899 // Now extend the entry without actual data. |
| 895 EXPECT_EQ(0, WriteData(entry, stream_index, 45500, buffer1.get(), 0, false)); | 900 EXPECT_EQ(0, WriteData(entry, stream_index, 45500, buffer1.get(), 0, false)); |
| 896 entry->Close(); | 901 entry->Close(); |
| 897 | 902 |
| 898 // And check again from disk. | 903 // And check again from disk. |
| 899 ASSERT_EQ(net::OK, OpenEntry(key2, &entry)); | 904 ASSERT_THAT(OpenEntry(key2, &entry), IsOk()); |
| 900 EXPECT_EQ(45500, entry->GetDataSize(stream_index)); | 905 EXPECT_EQ(45500, entry->GetDataSize(stream_index)); |
| 901 entry->Close(); | 906 entry->Close(); |
| 902 } | 907 } |
| 903 | 908 |
| 904 TEST_F(DiskCacheEntryTest, GrowData) { | 909 TEST_F(DiskCacheEntryTest, GrowData) { |
| 905 InitCache(); | 910 InitCache(); |
| 906 GrowData(0); | 911 GrowData(0); |
| 907 } | 912 } |
| 908 | 913 |
| 909 TEST_F(DiskCacheEntryTest, GrowDataNoBuffer) { | 914 TEST_F(DiskCacheEntryTest, GrowDataNoBuffer) { |
| 910 InitCache(); | 915 InitCache(); |
| 911 cache_impl_->SetFlags(disk_cache::kNoBuffering); | 916 cache_impl_->SetFlags(disk_cache::kNoBuffering); |
| 912 GrowData(0); | 917 GrowData(0); |
| 913 } | 918 } |
| 914 | 919 |
| 915 TEST_F(DiskCacheEntryTest, MemoryOnlyGrowData) { | 920 TEST_F(DiskCacheEntryTest, MemoryOnlyGrowData) { |
| 916 SetMemoryOnlyMode(); | 921 SetMemoryOnlyMode(); |
| 917 InitCache(); | 922 InitCache(); |
| 918 GrowData(0); | 923 GrowData(0); |
| 919 } | 924 } |
| 920 | 925 |
| 921 void DiskCacheEntryTest::TruncateData(int stream_index) { | 926 void DiskCacheEntryTest::TruncateData(int stream_index) { |
| 922 std::string key("the first key"); | 927 std::string key("the first key"); |
| 923 disk_cache::Entry* entry; | 928 disk_cache::Entry* entry; |
| 924 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 929 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 925 | 930 |
| 926 const int kSize1 = 20000; | 931 const int kSize1 = 20000; |
| 927 const int kSize2 = 20000; | 932 const int kSize2 = 20000; |
| 928 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize1)); | 933 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize1)); |
| 929 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize2)); | 934 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize2)); |
| 930 | 935 |
| 931 CacheTestFillBuffer(buffer1->data(), kSize1, false); | 936 CacheTestFillBuffer(buffer1->data(), kSize1, false); |
| 932 memset(buffer2->data(), 0, kSize2); | 937 memset(buffer2->data(), 0, kSize2); |
| 933 | 938 |
| 934 // Simple truncation: | 939 // Simple truncation: |
| 935 EXPECT_EQ(200, WriteData(entry, stream_index, 0, buffer1.get(), 200, false)); | 940 EXPECT_EQ(200, WriteData(entry, stream_index, 0, buffer1.get(), 200, false)); |
| 936 EXPECT_EQ(200, entry->GetDataSize(stream_index)); | 941 EXPECT_EQ(200, entry->GetDataSize(stream_index)); |
| 937 EXPECT_EQ(100, WriteData(entry, stream_index, 0, buffer1.get(), 100, false)); | 942 EXPECT_EQ(100, WriteData(entry, stream_index, 0, buffer1.get(), 100, false)); |
| 938 EXPECT_EQ(200, entry->GetDataSize(stream_index)); | 943 EXPECT_EQ(200, entry->GetDataSize(stream_index)); |
| 939 EXPECT_EQ(100, WriteData(entry, stream_index, 0, buffer1.get(), 100, true)); | 944 EXPECT_EQ(100, WriteData(entry, stream_index, 0, buffer1.get(), 100, true)); |
| 940 EXPECT_EQ(100, entry->GetDataSize(stream_index)); | 945 EXPECT_EQ(100, entry->GetDataSize(stream_index)); |
| 941 EXPECT_EQ(0, WriteData(entry, stream_index, 50, buffer1.get(), 0, true)); | 946 EXPECT_EQ(0, WriteData(entry, stream_index, 50, buffer1.get(), 0, true)); |
| 942 EXPECT_EQ(50, entry->GetDataSize(stream_index)); | 947 EXPECT_EQ(50, entry->GetDataSize(stream_index)); |
| 943 EXPECT_EQ(0, WriteData(entry, stream_index, 0, buffer1.get(), 0, true)); | 948 EXPECT_EQ(0, WriteData(entry, stream_index, 0, buffer1.get(), 0, true)); |
| 944 EXPECT_EQ(0, entry->GetDataSize(stream_index)); | 949 EXPECT_EQ(0, entry->GetDataSize(stream_index)); |
| 945 entry->Close(); | 950 entry->Close(); |
| 946 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 951 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 947 | 952 |
| 948 // Go to an external file. | 953 // Go to an external file. |
| 949 EXPECT_EQ(20000, | 954 EXPECT_EQ(20000, |
| 950 WriteData(entry, stream_index, 0, buffer1.get(), 20000, true)); | 955 WriteData(entry, stream_index, 0, buffer1.get(), 20000, true)); |
| 951 EXPECT_EQ(20000, entry->GetDataSize(stream_index)); | 956 EXPECT_EQ(20000, entry->GetDataSize(stream_index)); |
| 952 EXPECT_EQ(20000, ReadData(entry, stream_index, 0, buffer2.get(), 20000)); | 957 EXPECT_EQ(20000, ReadData(entry, stream_index, 0, buffer2.get(), 20000)); |
| 953 EXPECT_TRUE(!memcmp(buffer1->data(), buffer2->data(), 20000)); | 958 EXPECT_TRUE(!memcmp(buffer1->data(), buffer2->data(), 20000)); |
| 954 memset(buffer2->data(), 0, kSize2); | 959 memset(buffer2->data(), 0, kSize2); |
| 955 | 960 |
| 956 // External file truncation | 961 // External file truncation |
| (...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 996 | 1001 |
| 997 TEST_F(DiskCacheEntryTest, MemoryOnlyTruncateData) { | 1002 TEST_F(DiskCacheEntryTest, MemoryOnlyTruncateData) { |
| 998 SetMemoryOnlyMode(); | 1003 SetMemoryOnlyMode(); |
| 999 InitCache(); | 1004 InitCache(); |
| 1000 TruncateData(0); | 1005 TruncateData(0); |
| 1001 } | 1006 } |
| 1002 | 1007 |
| 1003 void DiskCacheEntryTest::ZeroLengthIO(int stream_index) { | 1008 void DiskCacheEntryTest::ZeroLengthIO(int stream_index) { |
| 1004 std::string key("the first key"); | 1009 std::string key("the first key"); |
| 1005 disk_cache::Entry* entry; | 1010 disk_cache::Entry* entry; |
| 1006 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 1011 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 1007 | 1012 |
| 1008 EXPECT_EQ(0, ReadData(entry, stream_index, 0, NULL, 0)); | 1013 EXPECT_EQ(0, ReadData(entry, stream_index, 0, NULL, 0)); |
| 1009 EXPECT_EQ(0, WriteData(entry, stream_index, 0, NULL, 0, false)); | 1014 EXPECT_EQ(0, WriteData(entry, stream_index, 0, NULL, 0, false)); |
| 1010 | 1015 |
| 1011 // This write should extend the entry. | 1016 // This write should extend the entry. |
| 1012 EXPECT_EQ(0, WriteData(entry, stream_index, 1000, NULL, 0, false)); | 1017 EXPECT_EQ(0, WriteData(entry, stream_index, 1000, NULL, 0, false)); |
| 1013 EXPECT_EQ(0, ReadData(entry, stream_index, 500, NULL, 0)); | 1018 EXPECT_EQ(0, ReadData(entry, stream_index, 500, NULL, 0)); |
| 1014 EXPECT_EQ(0, ReadData(entry, stream_index, 2000, NULL, 0)); | 1019 EXPECT_EQ(0, ReadData(entry, stream_index, 2000, NULL, 0)); |
| 1015 EXPECT_EQ(1000, entry->GetDataSize(stream_index)); | 1020 EXPECT_EQ(1000, entry->GetDataSize(stream_index)); |
| 1016 | 1021 |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1053 SetMemoryOnlyMode(); | 1058 SetMemoryOnlyMode(); |
| 1054 InitCache(); | 1059 InitCache(); |
| 1055 ZeroLengthIO(0); | 1060 ZeroLengthIO(0); |
| 1056 } | 1061 } |
| 1057 | 1062 |
| 1058 // Tests that we handle the content correctly when buffering, a feature of the | 1063 // Tests that we handle the content correctly when buffering, a feature of the |
| 1059 // standard cache that permits fast responses to certain reads. | 1064 // standard cache that permits fast responses to certain reads. |
| 1060 void DiskCacheEntryTest::Buffering() { | 1065 void DiskCacheEntryTest::Buffering() { |
| 1061 std::string key("the first key"); | 1066 std::string key("the first key"); |
| 1062 disk_cache::Entry* entry; | 1067 disk_cache::Entry* entry; |
| 1063 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 1068 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 1064 | 1069 |
| 1065 const int kSize = 200; | 1070 const int kSize = 200; |
| 1066 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize)); | 1071 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize)); |
| 1067 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize)); | 1072 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize)); |
| 1068 CacheTestFillBuffer(buffer1->data(), kSize, true); | 1073 CacheTestFillBuffer(buffer1->data(), kSize, true); |
| 1069 CacheTestFillBuffer(buffer2->data(), kSize, true); | 1074 CacheTestFillBuffer(buffer2->data(), kSize, true); |
| 1070 | 1075 |
| 1071 EXPECT_EQ(kSize, WriteData(entry, 1, 0, buffer1.get(), kSize, false)); | 1076 EXPECT_EQ(kSize, WriteData(entry, 1, 0, buffer1.get(), kSize, false)); |
| 1072 entry->Close(); | 1077 entry->Close(); |
| 1073 | 1078 |
| 1074 // Write a little more and read what we wrote before. | 1079 // Write a little more and read what we wrote before. |
| 1075 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 1080 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 1076 EXPECT_EQ(kSize, WriteData(entry, 1, 5000, buffer1.get(), kSize, false)); | 1081 EXPECT_EQ(kSize, WriteData(entry, 1, 5000, buffer1.get(), kSize, false)); |
| 1077 EXPECT_EQ(kSize, ReadData(entry, 1, 0, buffer2.get(), kSize)); | 1082 EXPECT_EQ(kSize, ReadData(entry, 1, 0, buffer2.get(), kSize)); |
| 1078 EXPECT_TRUE(!memcmp(buffer2->data(), buffer1->data(), kSize)); | 1083 EXPECT_TRUE(!memcmp(buffer2->data(), buffer1->data(), kSize)); |
| 1079 | 1084 |
| 1080 // Now go to an external file. | 1085 // Now go to an external file. |
| 1081 EXPECT_EQ(kSize, WriteData(entry, 1, 18000, buffer1.get(), kSize, false)); | 1086 EXPECT_EQ(kSize, WriteData(entry, 1, 18000, buffer1.get(), kSize, false)); |
| 1082 entry->Close(); | 1087 entry->Close(); |
| 1083 | 1088 |
| 1084 // Write something else and verify old data. | 1089 // Write something else and verify old data. |
| 1085 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 1090 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 1086 EXPECT_EQ(kSize, WriteData(entry, 1, 10000, buffer1.get(), kSize, false)); | 1091 EXPECT_EQ(kSize, WriteData(entry, 1, 10000, buffer1.get(), kSize, false)); |
| 1087 CacheTestFillBuffer(buffer2->data(), kSize, true); | 1092 CacheTestFillBuffer(buffer2->data(), kSize, true); |
| 1088 EXPECT_EQ(kSize, ReadData(entry, 1, 5000, buffer2.get(), kSize)); | 1093 EXPECT_EQ(kSize, ReadData(entry, 1, 5000, buffer2.get(), kSize)); |
| 1089 EXPECT_TRUE(!memcmp(buffer2->data(), buffer1->data(), kSize)); | 1094 EXPECT_TRUE(!memcmp(buffer2->data(), buffer1->data(), kSize)); |
| 1090 CacheTestFillBuffer(buffer2->data(), kSize, true); | 1095 CacheTestFillBuffer(buffer2->data(), kSize, true); |
| 1091 EXPECT_EQ(kSize, ReadData(entry, 1, 0, buffer2.get(), kSize)); | 1096 EXPECT_EQ(kSize, ReadData(entry, 1, 0, buffer2.get(), kSize)); |
| 1092 EXPECT_TRUE(!memcmp(buffer2->data(), buffer1->data(), kSize)); | 1097 EXPECT_TRUE(!memcmp(buffer2->data(), buffer1->data(), kSize)); |
| 1093 CacheTestFillBuffer(buffer2->data(), kSize, true); | 1098 CacheTestFillBuffer(buffer2->data(), kSize, true); |
| 1094 EXPECT_EQ(kSize, ReadData(entry, 1, 18000, buffer2.get(), kSize)); | 1099 EXPECT_EQ(kSize, ReadData(entry, 1, 18000, buffer2.get(), kSize)); |
| 1095 EXPECT_TRUE(!memcmp(buffer2->data(), buffer1->data(), kSize)); | 1100 EXPECT_TRUE(!memcmp(buffer2->data(), buffer1->data(), kSize)); |
| 1096 | 1101 |
| 1097 // Extend the file some more. | 1102 // Extend the file some more. |
| 1098 EXPECT_EQ(kSize, WriteData(entry, 1, 23000, buffer1.get(), kSize, false)); | 1103 EXPECT_EQ(kSize, WriteData(entry, 1, 23000, buffer1.get(), kSize, false)); |
| 1099 entry->Close(); | 1104 entry->Close(); |
| 1100 | 1105 |
| 1101 // And now make sure that we can deal with data in both places (ram/disk). | 1106 // And now make sure that we can deal with data in both places (ram/disk). |
| 1102 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 1107 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 1103 EXPECT_EQ(kSize, WriteData(entry, 1, 17000, buffer1.get(), kSize, false)); | 1108 EXPECT_EQ(kSize, WriteData(entry, 1, 17000, buffer1.get(), kSize, false)); |
| 1104 | 1109 |
| 1105 // We should not overwrite the data at 18000 with this. | 1110 // We should not overwrite the data at 18000 with this. |
| 1106 EXPECT_EQ(kSize, WriteData(entry, 1, 19000, buffer1.get(), kSize, false)); | 1111 EXPECT_EQ(kSize, WriteData(entry, 1, 19000, buffer1.get(), kSize, false)); |
| 1107 CacheTestFillBuffer(buffer2->data(), kSize, true); | 1112 CacheTestFillBuffer(buffer2->data(), kSize, true); |
| 1108 EXPECT_EQ(kSize, ReadData(entry, 1, 18000, buffer2.get(), kSize)); | 1113 EXPECT_EQ(kSize, ReadData(entry, 1, 18000, buffer2.get(), kSize)); |
| 1109 EXPECT_TRUE(!memcmp(buffer2->data(), buffer1->data(), kSize)); | 1114 EXPECT_TRUE(!memcmp(buffer2->data(), buffer1->data(), kSize)); |
| 1110 CacheTestFillBuffer(buffer2->data(), kSize, true); | 1115 CacheTestFillBuffer(buffer2->data(), kSize, true); |
| 1111 EXPECT_EQ(kSize, ReadData(entry, 1, 17000, buffer2.get(), kSize)); | 1116 EXPECT_EQ(kSize, ReadData(entry, 1, 17000, buffer2.get(), kSize)); |
| 1112 EXPECT_TRUE(!memcmp(buffer2->data(), buffer1->data(), kSize)); | 1117 EXPECT_TRUE(!memcmp(buffer2->data(), buffer1->data(), kSize)); |
| (...skipping 28 matching lines...) Expand all Loading... |
| 1141 TEST_F(DiskCacheEntryTest, BufferingNoBuffer) { | 1146 TEST_F(DiskCacheEntryTest, BufferingNoBuffer) { |
| 1142 InitCache(); | 1147 InitCache(); |
| 1143 cache_impl_->SetFlags(disk_cache::kNoBuffering); | 1148 cache_impl_->SetFlags(disk_cache::kNoBuffering); |
| 1144 Buffering(); | 1149 Buffering(); |
| 1145 } | 1150 } |
| 1146 | 1151 |
| 1147 // Checks that entries are zero length when created. | 1152 // Checks that entries are zero length when created. |
| 1148 void DiskCacheEntryTest::SizeAtCreate() { | 1153 void DiskCacheEntryTest::SizeAtCreate() { |
| 1149 const char key[] = "the first key"; | 1154 const char key[] = "the first key"; |
| 1150 disk_cache::Entry* entry; | 1155 disk_cache::Entry* entry; |
| 1151 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 1156 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 1152 | 1157 |
| 1153 const int kNumStreams = 3; | 1158 const int kNumStreams = 3; |
| 1154 for (int i = 0; i < kNumStreams; ++i) | 1159 for (int i = 0; i < kNumStreams; ++i) |
| 1155 EXPECT_EQ(0, entry->GetDataSize(i)); | 1160 EXPECT_EQ(0, entry->GetDataSize(i)); |
| 1156 entry->Close(); | 1161 entry->Close(); |
| 1157 } | 1162 } |
| 1158 | 1163 |
| 1159 TEST_F(DiskCacheEntryTest, SizeAtCreate) { | 1164 TEST_F(DiskCacheEntryTest, SizeAtCreate) { |
| 1160 InitCache(); | 1165 InitCache(); |
| 1161 SizeAtCreate(); | 1166 SizeAtCreate(); |
| 1162 } | 1167 } |
| 1163 | 1168 |
| 1164 TEST_F(DiskCacheEntryTest, MemoryOnlySizeAtCreate) { | 1169 TEST_F(DiskCacheEntryTest, MemoryOnlySizeAtCreate) { |
| 1165 SetMemoryOnlyMode(); | 1170 SetMemoryOnlyMode(); |
| 1166 InitCache(); | 1171 InitCache(); |
| 1167 SizeAtCreate(); | 1172 SizeAtCreate(); |
| 1168 } | 1173 } |
| 1169 | 1174 |
| 1170 // Some extra tests to make sure that buffering works properly when changing | 1175 // Some extra tests to make sure that buffering works properly when changing |
| 1171 // the entry size. | 1176 // the entry size. |
| 1172 void DiskCacheEntryTest::SizeChanges(int stream_index) { | 1177 void DiskCacheEntryTest::SizeChanges(int stream_index) { |
| 1173 std::string key("the first key"); | 1178 std::string key("the first key"); |
| 1174 disk_cache::Entry* entry; | 1179 disk_cache::Entry* entry; |
| 1175 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 1180 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 1176 | 1181 |
| 1177 const int kSize = 200; | 1182 const int kSize = 200; |
| 1178 const char zeros[kSize] = {}; | 1183 const char zeros[kSize] = {}; |
| 1179 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize)); | 1184 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize)); |
| 1180 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize)); | 1185 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize)); |
| 1181 CacheTestFillBuffer(buffer1->data(), kSize, true); | 1186 CacheTestFillBuffer(buffer1->data(), kSize, true); |
| 1182 CacheTestFillBuffer(buffer2->data(), kSize, true); | 1187 CacheTestFillBuffer(buffer2->data(), kSize, true); |
| 1183 | 1188 |
| 1184 EXPECT_EQ(kSize, | 1189 EXPECT_EQ(kSize, |
| 1185 WriteData(entry, stream_index, 0, buffer1.get(), kSize, true)); | 1190 WriteData(entry, stream_index, 0, buffer1.get(), kSize, true)); |
| 1186 EXPECT_EQ(kSize, | 1191 EXPECT_EQ(kSize, |
| 1187 WriteData(entry, stream_index, 17000, buffer1.get(), kSize, true)); | 1192 WriteData(entry, stream_index, 17000, buffer1.get(), kSize, true)); |
| 1188 EXPECT_EQ(kSize, | 1193 EXPECT_EQ(kSize, |
| 1189 WriteData(entry, stream_index, 23000, buffer1.get(), kSize, true)); | 1194 WriteData(entry, stream_index, 23000, buffer1.get(), kSize, true)); |
| 1190 entry->Close(); | 1195 entry->Close(); |
| 1191 | 1196 |
| 1192 // Extend the file and read between the old size and the new write. | 1197 // Extend the file and read between the old size and the new write. |
| 1193 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 1198 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 1194 EXPECT_EQ(23000 + kSize, entry->GetDataSize(stream_index)); | 1199 EXPECT_EQ(23000 + kSize, entry->GetDataSize(stream_index)); |
| 1195 EXPECT_EQ(kSize, | 1200 EXPECT_EQ(kSize, |
| 1196 WriteData(entry, stream_index, 25000, buffer1.get(), kSize, true)); | 1201 WriteData(entry, stream_index, 25000, buffer1.get(), kSize, true)); |
| 1197 EXPECT_EQ(25000 + kSize, entry->GetDataSize(stream_index)); | 1202 EXPECT_EQ(25000 + kSize, entry->GetDataSize(stream_index)); |
| 1198 EXPECT_EQ(kSize, ReadData(entry, stream_index, 24000, buffer2.get(), kSize)); | 1203 EXPECT_EQ(kSize, ReadData(entry, stream_index, 24000, buffer2.get(), kSize)); |
| 1199 EXPECT_TRUE(!memcmp(buffer2->data(), zeros, kSize)); | 1204 EXPECT_TRUE(!memcmp(buffer2->data(), zeros, kSize)); |
| 1200 | 1205 |
| 1201 // Read at the end of the old file size. | 1206 // Read at the end of the old file size. |
| 1202 EXPECT_EQ( | 1207 EXPECT_EQ( |
| 1203 kSize, | 1208 kSize, |
| (...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1242 // And now reduce the size below the old size. | 1247 // And now reduce the size below the old size. |
| 1243 EXPECT_EQ(kSize, | 1248 EXPECT_EQ(kSize, |
| 1244 WriteData(entry, stream_index, 19000, buffer1.get(), kSize, true)); | 1249 WriteData(entry, stream_index, 19000, buffer1.get(), kSize, true)); |
| 1245 EXPECT_EQ(19000 + kSize, entry->GetDataSize(stream_index)); | 1250 EXPECT_EQ(19000 + kSize, entry->GetDataSize(stream_index)); |
| 1246 EXPECT_EQ(kSize, ReadData(entry, stream_index, 18900, buffer2.get(), kSize)); | 1251 EXPECT_EQ(kSize, ReadData(entry, stream_index, 18900, buffer2.get(), kSize)); |
| 1247 EXPECT_TRUE(!memcmp(buffer2->data(), zeros, 100)); | 1252 EXPECT_TRUE(!memcmp(buffer2->data(), zeros, 100)); |
| 1248 EXPECT_TRUE(!memcmp(buffer2->data() + 100, buffer1->data(), kSize - 100)); | 1253 EXPECT_TRUE(!memcmp(buffer2->data() + 100, buffer1->data(), kSize - 100)); |
| 1249 | 1254 |
| 1250 // Verify that the actual file is truncated. | 1255 // Verify that the actual file is truncated. |
| 1251 entry->Close(); | 1256 entry->Close(); |
| 1252 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 1257 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 1253 EXPECT_EQ(19000 + kSize, entry->GetDataSize(stream_index)); | 1258 EXPECT_EQ(19000 + kSize, entry->GetDataSize(stream_index)); |
| 1254 | 1259 |
| 1255 // Extend the newly opened file with a zero length write, expect zero fill. | 1260 // Extend the newly opened file with a zero length write, expect zero fill. |
| 1256 EXPECT_EQ( | 1261 EXPECT_EQ( |
| 1257 0, | 1262 0, |
| 1258 WriteData(entry, stream_index, 20000 + kSize, buffer1.get(), 0, false)); | 1263 WriteData(entry, stream_index, 20000 + kSize, buffer1.get(), 0, false)); |
| 1259 EXPECT_EQ(kSize, | 1264 EXPECT_EQ(kSize, |
| 1260 ReadData(entry, stream_index, 19000 + kSize, buffer1.get(), kSize)); | 1265 ReadData(entry, stream_index, 19000 + kSize, buffer1.get(), kSize)); |
| 1261 EXPECT_EQ(0, memcmp(buffer1->data(), zeros, kSize)); | 1266 EXPECT_EQ(0, memcmp(buffer1->data(), zeros, kSize)); |
| 1262 | 1267 |
| 1263 entry->Close(); | 1268 entry->Close(); |
| 1264 } | 1269 } |
| 1265 | 1270 |
| 1266 TEST_F(DiskCacheEntryTest, SizeChanges) { | 1271 TEST_F(DiskCacheEntryTest, SizeChanges) { |
| 1267 InitCache(); | 1272 InitCache(); |
| 1268 SizeChanges(1); | 1273 SizeChanges(1); |
| 1269 } | 1274 } |
| 1270 | 1275 |
| 1271 TEST_F(DiskCacheEntryTest, SizeChangesNoBuffer) { | 1276 TEST_F(DiskCacheEntryTest, SizeChangesNoBuffer) { |
| 1272 InitCache(); | 1277 InitCache(); |
| 1273 cache_impl_->SetFlags(disk_cache::kNoBuffering); | 1278 cache_impl_->SetFlags(disk_cache::kNoBuffering); |
| 1274 SizeChanges(1); | 1279 SizeChanges(1); |
| 1275 } | 1280 } |
| 1276 | 1281 |
| 1277 // Write more than the total cache capacity but to a single entry. |size| is the | 1282 // Write more than the total cache capacity but to a single entry. |size| is the |
| 1278 // amount of bytes to write each time. | 1283 // amount of bytes to write each time. |
| 1279 void DiskCacheEntryTest::ReuseEntry(int size, int stream_index) { | 1284 void DiskCacheEntryTest::ReuseEntry(int size, int stream_index) { |
| 1280 std::string key1("the first key"); | 1285 std::string key1("the first key"); |
| 1281 disk_cache::Entry* entry; | 1286 disk_cache::Entry* entry; |
| 1282 ASSERT_EQ(net::OK, CreateEntry(key1, &entry)); | 1287 ASSERT_THAT(CreateEntry(key1, &entry), IsOk()); |
| 1283 | 1288 |
| 1284 entry->Close(); | 1289 entry->Close(); |
| 1285 std::string key2("the second key"); | 1290 std::string key2("the second key"); |
| 1286 ASSERT_EQ(net::OK, CreateEntry(key2, &entry)); | 1291 ASSERT_THAT(CreateEntry(key2, &entry), IsOk()); |
| 1287 | 1292 |
| 1288 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(size)); | 1293 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(size)); |
| 1289 CacheTestFillBuffer(buffer->data(), size, false); | 1294 CacheTestFillBuffer(buffer->data(), size, false); |
| 1290 | 1295 |
| 1291 for (int i = 0; i < 15; i++) { | 1296 for (int i = 0; i < 15; i++) { |
| 1292 EXPECT_EQ(0, WriteData(entry, stream_index, 0, buffer.get(), 0, true)); | 1297 EXPECT_EQ(0, WriteData(entry, stream_index, 0, buffer.get(), 0, true)); |
| 1293 EXPECT_EQ(size, | 1298 EXPECT_EQ(size, |
| 1294 WriteData(entry, stream_index, 0, buffer.get(), size, false)); | 1299 WriteData(entry, stream_index, 0, buffer.get(), size, false)); |
| 1295 entry->Close(); | 1300 entry->Close(); |
| 1296 ASSERT_EQ(net::OK, OpenEntry(key2, &entry)); | 1301 ASSERT_THAT(OpenEntry(key2, &entry), IsOk()); |
| 1297 } | 1302 } |
| 1298 | 1303 |
| 1299 entry->Close(); | 1304 entry->Close(); |
| 1300 ASSERT_EQ(net::OK, OpenEntry(key1, &entry)) << "have not evicted this entry"; | 1305 ASSERT_EQ(net::OK, OpenEntry(key1, &entry)) << "have not evicted this entry"; |
| 1301 entry->Close(); | 1306 entry->Close(); |
| 1302 } | 1307 } |
| 1303 | 1308 |
| 1304 TEST_F(DiskCacheEntryTest, ReuseExternalEntry) { | 1309 TEST_F(DiskCacheEntryTest, ReuseExternalEntry) { |
| 1305 SetMaxSize(200 * 1024); | 1310 SetMaxSize(200 * 1024); |
| 1306 InitCache(); | 1311 InitCache(); |
| (...skipping 17 matching lines...) Expand all Loading... |
| 1324 SetMemoryOnlyMode(); | 1329 SetMemoryOnlyMode(); |
| 1325 SetMaxSize(100 * 1024); | 1330 SetMaxSize(100 * 1024); |
| 1326 InitCache(); | 1331 InitCache(); |
| 1327 ReuseEntry(10 * 1024, 0); | 1332 ReuseEntry(10 * 1024, 0); |
| 1328 } | 1333 } |
| 1329 | 1334 |
| 1330 // Reading somewhere that was not written should return zeros. | 1335 // Reading somewhere that was not written should return zeros. |
| 1331 void DiskCacheEntryTest::InvalidData(int stream_index) { | 1336 void DiskCacheEntryTest::InvalidData(int stream_index) { |
| 1332 std::string key("the first key"); | 1337 std::string key("the first key"); |
| 1333 disk_cache::Entry* entry; | 1338 disk_cache::Entry* entry; |
| 1334 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 1339 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 1335 | 1340 |
| 1336 const int kSize1 = 20000; | 1341 const int kSize1 = 20000; |
| 1337 const int kSize2 = 20000; | 1342 const int kSize2 = 20000; |
| 1338 const int kSize3 = 20000; | 1343 const int kSize3 = 20000; |
| 1339 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize1)); | 1344 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize1)); |
| 1340 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize2)); | 1345 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize2)); |
| 1341 scoped_refptr<net::IOBuffer> buffer3(new net::IOBuffer(kSize3)); | 1346 scoped_refptr<net::IOBuffer> buffer3(new net::IOBuffer(kSize3)); |
| 1342 | 1347 |
| 1343 CacheTestFillBuffer(buffer1->data(), kSize1, false); | 1348 CacheTestFillBuffer(buffer1->data(), kSize1, false); |
| 1344 memset(buffer2->data(), 0, kSize2); | 1349 memset(buffer2->data(), 0, kSize2); |
| 1345 | 1350 |
| 1346 // Simple data grow: | 1351 // Simple data grow: |
| 1347 EXPECT_EQ(200, | 1352 EXPECT_EQ(200, |
| 1348 WriteData(entry, stream_index, 400, buffer1.get(), 200, false)); | 1353 WriteData(entry, stream_index, 400, buffer1.get(), 200, false)); |
| 1349 EXPECT_EQ(600, entry->GetDataSize(stream_index)); | 1354 EXPECT_EQ(600, entry->GetDataSize(stream_index)); |
| 1350 EXPECT_EQ(100, ReadData(entry, stream_index, 300, buffer3.get(), 100)); | 1355 EXPECT_EQ(100, ReadData(entry, stream_index, 300, buffer3.get(), 100)); |
| 1351 EXPECT_TRUE(!memcmp(buffer3->data(), buffer2->data(), 100)); | 1356 EXPECT_TRUE(!memcmp(buffer3->data(), buffer2->data(), 100)); |
| 1352 entry->Close(); | 1357 entry->Close(); |
| 1353 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 1358 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 1354 | 1359 |
| 1355 // The entry is now on disk. Load it and extend it. | 1360 // The entry is now on disk. Load it and extend it. |
| 1356 EXPECT_EQ(200, | 1361 EXPECT_EQ(200, |
| 1357 WriteData(entry, stream_index, 800, buffer1.get(), 200, false)); | 1362 WriteData(entry, stream_index, 800, buffer1.get(), 200, false)); |
| 1358 EXPECT_EQ(1000, entry->GetDataSize(stream_index)); | 1363 EXPECT_EQ(1000, entry->GetDataSize(stream_index)); |
| 1359 EXPECT_EQ(100, ReadData(entry, stream_index, 700, buffer3.get(), 100)); | 1364 EXPECT_EQ(100, ReadData(entry, stream_index, 700, buffer3.get(), 100)); |
| 1360 EXPECT_TRUE(!memcmp(buffer3->data(), buffer2->data(), 100)); | 1365 EXPECT_TRUE(!memcmp(buffer3->data(), buffer2->data(), 100)); |
| 1361 entry->Close(); | 1366 entry->Close(); |
| 1362 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 1367 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 1363 | 1368 |
| 1364 // This time using truncate. | 1369 // This time using truncate. |
| 1365 EXPECT_EQ(200, | 1370 EXPECT_EQ(200, |
| 1366 WriteData(entry, stream_index, 1800, buffer1.get(), 200, true)); | 1371 WriteData(entry, stream_index, 1800, buffer1.get(), 200, true)); |
| 1367 EXPECT_EQ(2000, entry->GetDataSize(stream_index)); | 1372 EXPECT_EQ(2000, entry->GetDataSize(stream_index)); |
| 1368 EXPECT_EQ(100, ReadData(entry, stream_index, 1500, buffer3.get(), 100)); | 1373 EXPECT_EQ(100, ReadData(entry, stream_index, 1500, buffer3.get(), 100)); |
| 1369 EXPECT_TRUE(!memcmp(buffer3->data(), buffer2->data(), 100)); | 1374 EXPECT_TRUE(!memcmp(buffer3->data(), buffer2->data(), 100)); |
| 1370 | 1375 |
| 1371 // Go to an external file. | 1376 // Go to an external file. |
| 1372 EXPECT_EQ(200, | 1377 EXPECT_EQ(200, |
| (...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1413 TEST_F(DiskCacheEntryTest, MemoryOnlyInvalidData) { | 1418 TEST_F(DiskCacheEntryTest, MemoryOnlyInvalidData) { |
| 1414 SetMemoryOnlyMode(); | 1419 SetMemoryOnlyMode(); |
| 1415 InitCache(); | 1420 InitCache(); |
| 1416 InvalidData(0); | 1421 InvalidData(0); |
| 1417 } | 1422 } |
| 1418 | 1423 |
| 1419 // Tests that the cache preserves the buffer of an IO operation. | 1424 // Tests that the cache preserves the buffer of an IO operation. |
| 1420 void DiskCacheEntryTest::ReadWriteDestroyBuffer(int stream_index) { | 1425 void DiskCacheEntryTest::ReadWriteDestroyBuffer(int stream_index) { |
| 1421 std::string key("the first key"); | 1426 std::string key("the first key"); |
| 1422 disk_cache::Entry* entry; | 1427 disk_cache::Entry* entry; |
| 1423 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 1428 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 1424 | 1429 |
| 1425 const int kSize = 200; | 1430 const int kSize = 200; |
| 1426 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize)); | 1431 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize)); |
| 1427 CacheTestFillBuffer(buffer->data(), kSize, false); | 1432 CacheTestFillBuffer(buffer->data(), kSize, false); |
| 1428 | 1433 |
| 1429 net::TestCompletionCallback cb; | 1434 net::TestCompletionCallback cb; |
| 1430 EXPECT_EQ(net::ERR_IO_PENDING, | 1435 EXPECT_EQ(net::ERR_IO_PENDING, |
| 1431 entry->WriteData( | 1436 entry->WriteData( |
| 1432 stream_index, 0, buffer.get(), kSize, cb.callback(), false)); | 1437 stream_index, 0, buffer.get(), kSize, cb.callback(), false)); |
| 1433 | 1438 |
| (...skipping 15 matching lines...) Expand all Loading... |
| 1449 } | 1454 } |
| 1450 | 1455 |
| 1451 TEST_F(DiskCacheEntryTest, ReadWriteDestroyBuffer) { | 1456 TEST_F(DiskCacheEntryTest, ReadWriteDestroyBuffer) { |
| 1452 InitCache(); | 1457 InitCache(); |
| 1453 ReadWriteDestroyBuffer(0); | 1458 ReadWriteDestroyBuffer(0); |
| 1454 } | 1459 } |
| 1455 | 1460 |
| 1456 void DiskCacheEntryTest::DoomNormalEntry() { | 1461 void DiskCacheEntryTest::DoomNormalEntry() { |
| 1457 std::string key("the first key"); | 1462 std::string key("the first key"); |
| 1458 disk_cache::Entry* entry; | 1463 disk_cache::Entry* entry; |
| 1459 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 1464 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 1460 entry->Doom(); | 1465 entry->Doom(); |
| 1461 entry->Close(); | 1466 entry->Close(); |
| 1462 | 1467 |
| 1463 const int kSize = 20000; | 1468 const int kSize = 20000; |
| 1464 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize)); | 1469 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize)); |
| 1465 CacheTestFillBuffer(buffer->data(), kSize, true); | 1470 CacheTestFillBuffer(buffer->data(), kSize, true); |
| 1466 buffer->data()[19999] = '\0'; | 1471 buffer->data()[19999] = '\0'; |
| 1467 | 1472 |
| 1468 key = buffer->data(); | 1473 key = buffer->data(); |
| 1469 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 1474 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 1470 EXPECT_EQ(20000, WriteData(entry, 0, 0, buffer.get(), kSize, false)); | 1475 EXPECT_EQ(20000, WriteData(entry, 0, 0, buffer.get(), kSize, false)); |
| 1471 EXPECT_EQ(20000, WriteData(entry, 1, 0, buffer.get(), kSize, false)); | 1476 EXPECT_EQ(20000, WriteData(entry, 1, 0, buffer.get(), kSize, false)); |
| 1472 entry->Doom(); | 1477 entry->Doom(); |
| 1473 entry->Close(); | 1478 entry->Close(); |
| 1474 | 1479 |
| 1475 FlushQueueForTest(); | 1480 FlushQueueForTest(); |
| 1476 EXPECT_EQ(0, cache_->GetEntryCount()); | 1481 EXPECT_EQ(0, cache_->GetEntryCount()); |
| 1477 } | 1482 } |
| 1478 | 1483 |
| 1479 TEST_F(DiskCacheEntryTest, DoomEntry) { | 1484 TEST_F(DiskCacheEntryTest, DoomEntry) { |
| 1480 InitCache(); | 1485 InitCache(); |
| 1481 DoomNormalEntry(); | 1486 DoomNormalEntry(); |
| 1482 } | 1487 } |
| 1483 | 1488 |
| 1484 TEST_F(DiskCacheEntryTest, MemoryOnlyDoomEntry) { | 1489 TEST_F(DiskCacheEntryTest, MemoryOnlyDoomEntry) { |
| 1485 SetMemoryOnlyMode(); | 1490 SetMemoryOnlyMode(); |
| 1486 InitCache(); | 1491 InitCache(); |
| 1487 DoomNormalEntry(); | 1492 DoomNormalEntry(); |
| 1488 } | 1493 } |
| 1489 | 1494 |
| 1490 // Tests dooming an entry that's linked to an open entry. | 1495 // Tests dooming an entry that's linked to an open entry. |
| 1491 void DiskCacheEntryTest::DoomEntryNextToOpenEntry() { | 1496 void DiskCacheEntryTest::DoomEntryNextToOpenEntry() { |
| 1492 disk_cache::Entry* entry1; | 1497 disk_cache::Entry* entry1; |
| 1493 disk_cache::Entry* entry2; | 1498 disk_cache::Entry* entry2; |
| 1494 ASSERT_EQ(net::OK, CreateEntry("fixed", &entry1)); | 1499 ASSERT_THAT(CreateEntry("fixed", &entry1), IsOk()); |
| 1495 entry1->Close(); | 1500 entry1->Close(); |
| 1496 ASSERT_EQ(net::OK, CreateEntry("foo", &entry1)); | 1501 ASSERT_THAT(CreateEntry("foo", &entry1), IsOk()); |
| 1497 entry1->Close(); | 1502 entry1->Close(); |
| 1498 ASSERT_EQ(net::OK, CreateEntry("bar", &entry1)); | 1503 ASSERT_THAT(CreateEntry("bar", &entry1), IsOk()); |
| 1499 entry1->Close(); | 1504 entry1->Close(); |
| 1500 | 1505 |
| 1501 ASSERT_EQ(net::OK, OpenEntry("foo", &entry1)); | 1506 ASSERT_THAT(OpenEntry("foo", &entry1), IsOk()); |
| 1502 ASSERT_EQ(net::OK, OpenEntry("bar", &entry2)); | 1507 ASSERT_THAT(OpenEntry("bar", &entry2), IsOk()); |
| 1503 entry2->Doom(); | 1508 entry2->Doom(); |
| 1504 entry2->Close(); | 1509 entry2->Close(); |
| 1505 | 1510 |
| 1506 ASSERT_EQ(net::OK, OpenEntry("foo", &entry2)); | 1511 ASSERT_THAT(OpenEntry("foo", &entry2), IsOk()); |
| 1507 entry2->Doom(); | 1512 entry2->Doom(); |
| 1508 entry2->Close(); | 1513 entry2->Close(); |
| 1509 entry1->Close(); | 1514 entry1->Close(); |
| 1510 | 1515 |
| 1511 ASSERT_EQ(net::OK, OpenEntry("fixed", &entry1)); | 1516 ASSERT_THAT(OpenEntry("fixed", &entry1), IsOk()); |
| 1512 entry1->Close(); | 1517 entry1->Close(); |
| 1513 } | 1518 } |
| 1514 | 1519 |
| 1515 TEST_F(DiskCacheEntryTest, DoomEntryNextToOpenEntry) { | 1520 TEST_F(DiskCacheEntryTest, DoomEntryNextToOpenEntry) { |
| 1516 InitCache(); | 1521 InitCache(); |
| 1517 DoomEntryNextToOpenEntry(); | 1522 DoomEntryNextToOpenEntry(); |
| 1518 } | 1523 } |
| 1519 | 1524 |
| 1520 TEST_F(DiskCacheEntryTest, NewEvictionDoomEntryNextToOpenEntry) { | 1525 TEST_F(DiskCacheEntryTest, NewEvictionDoomEntryNextToOpenEntry) { |
| 1521 SetNewEviction(); | 1526 SetNewEviction(); |
| 1522 InitCache(); | 1527 InitCache(); |
| 1523 DoomEntryNextToOpenEntry(); | 1528 DoomEntryNextToOpenEntry(); |
| 1524 } | 1529 } |
| 1525 | 1530 |
| 1526 TEST_F(DiskCacheEntryTest, AppCacheDoomEntryNextToOpenEntry) { | 1531 TEST_F(DiskCacheEntryTest, AppCacheDoomEntryNextToOpenEntry) { |
| 1527 SetCacheType(net::APP_CACHE); | 1532 SetCacheType(net::APP_CACHE); |
| 1528 InitCache(); | 1533 InitCache(); |
| 1529 DoomEntryNextToOpenEntry(); | 1534 DoomEntryNextToOpenEntry(); |
| 1530 } | 1535 } |
| 1531 | 1536 |
| 1532 // Verify that basic operations work as expected with doomed entries. | 1537 // Verify that basic operations work as expected with doomed entries. |
| 1533 void DiskCacheEntryTest::DoomedEntry(int stream_index) { | 1538 void DiskCacheEntryTest::DoomedEntry(int stream_index) { |
| 1534 std::string key("the first key"); | 1539 std::string key("the first key"); |
| 1535 disk_cache::Entry* entry; | 1540 disk_cache::Entry* entry; |
| 1536 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 1541 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 1537 entry->Doom(); | 1542 entry->Doom(); |
| 1538 | 1543 |
| 1539 FlushQueueForTest(); | 1544 FlushQueueForTest(); |
| 1540 EXPECT_EQ(0, cache_->GetEntryCount()); | 1545 EXPECT_EQ(0, cache_->GetEntryCount()); |
| 1541 Time initial = Time::Now(); | 1546 Time initial = Time::Now(); |
| 1542 AddDelay(); | 1547 AddDelay(); |
| 1543 | 1548 |
| 1544 const int kSize1 = 2000; | 1549 const int kSize1 = 2000; |
| 1545 const int kSize2 = 2000; | 1550 const int kSize2 = 2000; |
| 1546 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize1)); | 1551 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize1)); |
| (...skipping 22 matching lines...) Expand all Loading... |
| 1569 InitCache(); | 1574 InitCache(); |
| 1570 DoomedEntry(0); | 1575 DoomedEntry(0); |
| 1571 } | 1576 } |
| 1572 | 1577 |
| 1573 // Tests that we discard entries if the data is missing. | 1578 // Tests that we discard entries if the data is missing. |
| 1574 TEST_F(DiskCacheEntryTest, MissingData) { | 1579 TEST_F(DiskCacheEntryTest, MissingData) { |
| 1575 InitCache(); | 1580 InitCache(); |
| 1576 | 1581 |
| 1577 std::string key("the first key"); | 1582 std::string key("the first key"); |
| 1578 disk_cache::Entry* entry; | 1583 disk_cache::Entry* entry; |
| 1579 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 1584 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 1580 | 1585 |
| 1581 // Write to an external file. | 1586 // Write to an external file. |
| 1582 const int kSize = 20000; | 1587 const int kSize = 20000; |
| 1583 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize)); | 1588 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize)); |
| 1584 CacheTestFillBuffer(buffer->data(), kSize, false); | 1589 CacheTestFillBuffer(buffer->data(), kSize, false); |
| 1585 EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer.get(), kSize, false)); | 1590 EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer.get(), kSize, false)); |
| 1586 entry->Close(); | 1591 entry->Close(); |
| 1587 FlushQueueForTest(); | 1592 FlushQueueForTest(); |
| 1588 | 1593 |
| 1589 disk_cache::Addr address(0x80000001); | 1594 disk_cache::Addr address(0x80000001); |
| 1590 base::FilePath name = cache_impl_->GetFileName(address); | 1595 base::FilePath name = cache_impl_->GetFileName(address); |
| 1591 EXPECT_TRUE(base::DeleteFile(name, false)); | 1596 EXPECT_TRUE(base::DeleteFile(name, false)); |
| 1592 | 1597 |
| 1593 // Attempt to read the data. | 1598 // Attempt to read the data. |
| 1594 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 1599 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 1595 EXPECT_EQ(net::ERR_FILE_NOT_FOUND, | 1600 EXPECT_EQ(net::ERR_FILE_NOT_FOUND, |
| 1596 ReadData(entry, 0, 0, buffer.get(), kSize)); | 1601 ReadData(entry, 0, 0, buffer.get(), kSize)); |
| 1597 entry->Close(); | 1602 entry->Close(); |
| 1598 | 1603 |
| 1599 // The entry should be gone. | 1604 // The entry should be gone. |
| 1600 ASSERT_NE(net::OK, OpenEntry(key, &entry)); | 1605 ASSERT_NE(net::OK, OpenEntry(key, &entry)); |
| 1601 } | 1606 } |
| 1602 | 1607 |
| 1603 // Test that child entries in a memory cache backend are not visible from | 1608 // Test that child entries in a memory cache backend are not visible from |
| 1604 // enumerations. | 1609 // enumerations. |
| 1605 TEST_F(DiskCacheEntryTest, MemoryOnlyEnumerationWithSparseEntries) { | 1610 TEST_F(DiskCacheEntryTest, MemoryOnlyEnumerationWithSparseEntries) { |
| 1606 SetMemoryOnlyMode(); | 1611 SetMemoryOnlyMode(); |
| 1607 InitCache(); | 1612 InitCache(); |
| 1608 | 1613 |
| 1609 const int kSize = 4096; | 1614 const int kSize = 4096; |
| 1610 scoped_refptr<net::IOBuffer> buf(new net::IOBuffer(kSize)); | 1615 scoped_refptr<net::IOBuffer> buf(new net::IOBuffer(kSize)); |
| 1611 CacheTestFillBuffer(buf->data(), kSize, false); | 1616 CacheTestFillBuffer(buf->data(), kSize, false); |
| 1612 | 1617 |
| 1613 std::string key("the first key"); | 1618 std::string key("the first key"); |
| 1614 disk_cache::Entry* parent_entry; | 1619 disk_cache::Entry* parent_entry; |
| 1615 ASSERT_EQ(net::OK, CreateEntry(key, &parent_entry)); | 1620 ASSERT_THAT(CreateEntry(key, &parent_entry), IsOk()); |
| 1616 | 1621 |
| 1617 // Writes to the parent entry. | 1622 // Writes to the parent entry. |
| 1618 EXPECT_EQ(kSize, | 1623 EXPECT_EQ(kSize, |
| 1619 parent_entry->WriteSparseData( | 1624 parent_entry->WriteSparseData( |
| 1620 0, buf.get(), kSize, net::CompletionCallback())); | 1625 0, buf.get(), kSize, net::CompletionCallback())); |
| 1621 | 1626 |
| 1622 // This write creates a child entry and writes to it. | 1627 // This write creates a child entry and writes to it. |
| 1623 EXPECT_EQ(kSize, | 1628 EXPECT_EQ(kSize, |
| 1624 parent_entry->WriteSparseData( | 1629 parent_entry->WriteSparseData( |
| 1625 8192, buf.get(), kSize, net::CompletionCallback())); | 1630 8192, buf.get(), kSize, net::CompletionCallback())); |
| (...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1673 scoped_refptr<net::IOBuffer> buf_1(new net::IOBuffer(size)); | 1678 scoped_refptr<net::IOBuffer> buf_1(new net::IOBuffer(size)); |
| 1674 memset(buf_1->data(), 0, size); | 1679 memset(buf_1->data(), 0, size); |
| 1675 int ret = entry->ReadSparseData(offset, buf_1.get(), size, cb.callback()); | 1680 int ret = entry->ReadSparseData(offset, buf_1.get(), size, cb.callback()); |
| 1676 EXPECT_EQ(size, cb.GetResult(ret)); | 1681 EXPECT_EQ(size, cb.GetResult(ret)); |
| 1677 EXPECT_EQ(0, memcmp(buf_1->data(), buffer, size)); | 1682 EXPECT_EQ(0, memcmp(buf_1->data(), buffer, size)); |
| 1678 } | 1683 } |
| 1679 | 1684 |
| 1680 void DiskCacheEntryTest::BasicSparseIO() { | 1685 void DiskCacheEntryTest::BasicSparseIO() { |
| 1681 std::string key("the first key"); | 1686 std::string key("the first key"); |
| 1682 disk_cache::Entry* entry; | 1687 disk_cache::Entry* entry; |
| 1683 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 1688 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 1684 | 1689 |
| 1685 const int kSize = 2048; | 1690 const int kSize = 2048; |
| 1686 scoped_refptr<net::IOBuffer> buf_1(new net::IOBuffer(kSize)); | 1691 scoped_refptr<net::IOBuffer> buf_1(new net::IOBuffer(kSize)); |
| 1687 scoped_refptr<net::IOBuffer> buf_2(new net::IOBuffer(kSize)); | 1692 scoped_refptr<net::IOBuffer> buf_2(new net::IOBuffer(kSize)); |
| 1688 CacheTestFillBuffer(buf_1->data(), kSize, false); | 1693 CacheTestFillBuffer(buf_1->data(), kSize, false); |
| 1689 | 1694 |
| 1690 // Write at offset 0. | 1695 // Write at offset 0. |
| 1691 VerifySparseIO(entry, 0, buf_1.get(), kSize, buf_2.get()); | 1696 VerifySparseIO(entry, 0, buf_1.get(), kSize, buf_2.get()); |
| 1692 | 1697 |
| 1693 // Write at offset 0x400000 (4 MB). | 1698 // Write at offset 0x400000 (4 MB). |
| 1694 VerifySparseIO(entry, 0x400000, buf_1.get(), kSize, buf_2.get()); | 1699 VerifySparseIO(entry, 0x400000, buf_1.get(), kSize, buf_2.get()); |
| 1695 | 1700 |
| 1696 // Write at offset 0x800000000 (32 GB). | 1701 // Write at offset 0x800000000 (32 GB). |
| 1697 VerifySparseIO(entry, 0x800000000LL, buf_1.get(), kSize, buf_2.get()); | 1702 VerifySparseIO(entry, 0x800000000LL, buf_1.get(), kSize, buf_2.get()); |
| 1698 | 1703 |
| 1699 entry->Close(); | 1704 entry->Close(); |
| 1700 | 1705 |
| 1701 // Check everything again. | 1706 // Check everything again. |
| 1702 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 1707 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 1703 VerifyContentSparseIO(entry, 0, buf_1->data(), kSize); | 1708 VerifyContentSparseIO(entry, 0, buf_1->data(), kSize); |
| 1704 VerifyContentSparseIO(entry, 0x400000, buf_1->data(), kSize); | 1709 VerifyContentSparseIO(entry, 0x400000, buf_1->data(), kSize); |
| 1705 VerifyContentSparseIO(entry, 0x800000000LL, buf_1->data(), kSize); | 1710 VerifyContentSparseIO(entry, 0x800000000LL, buf_1->data(), kSize); |
| 1706 entry->Close(); | 1711 entry->Close(); |
| 1707 } | 1712 } |
| 1708 | 1713 |
| 1709 TEST_F(DiskCacheEntryTest, BasicSparseIO) { | 1714 TEST_F(DiskCacheEntryTest, BasicSparseIO) { |
| 1710 InitCache(); | 1715 InitCache(); |
| 1711 BasicSparseIO(); | 1716 BasicSparseIO(); |
| 1712 } | 1717 } |
| 1713 | 1718 |
| 1714 TEST_F(DiskCacheEntryTest, MemoryOnlyBasicSparseIO) { | 1719 TEST_F(DiskCacheEntryTest, MemoryOnlyBasicSparseIO) { |
| 1715 SetMemoryOnlyMode(); | 1720 SetMemoryOnlyMode(); |
| 1716 InitCache(); | 1721 InitCache(); |
| 1717 BasicSparseIO(); | 1722 BasicSparseIO(); |
| 1718 } | 1723 } |
| 1719 | 1724 |
| 1720 void DiskCacheEntryTest::HugeSparseIO() { | 1725 void DiskCacheEntryTest::HugeSparseIO() { |
| 1721 std::string key("the first key"); | 1726 std::string key("the first key"); |
| 1722 disk_cache::Entry* entry; | 1727 disk_cache::Entry* entry; |
| 1723 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 1728 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 1724 | 1729 |
| 1725 // Write 1.2 MB so that we cover multiple entries. | 1730 // Write 1.2 MB so that we cover multiple entries. |
| 1726 const int kSize = 1200 * 1024; | 1731 const int kSize = 1200 * 1024; |
| 1727 scoped_refptr<net::IOBuffer> buf_1(new net::IOBuffer(kSize)); | 1732 scoped_refptr<net::IOBuffer> buf_1(new net::IOBuffer(kSize)); |
| 1728 scoped_refptr<net::IOBuffer> buf_2(new net::IOBuffer(kSize)); | 1733 scoped_refptr<net::IOBuffer> buf_2(new net::IOBuffer(kSize)); |
| 1729 CacheTestFillBuffer(buf_1->data(), kSize, false); | 1734 CacheTestFillBuffer(buf_1->data(), kSize, false); |
| 1730 | 1735 |
| 1731 // Write at offset 0x20F0000 (33 MB - 64 KB). | 1736 // Write at offset 0x20F0000 (33 MB - 64 KB). |
| 1732 VerifySparseIO(entry, 0x20F0000, buf_1.get(), kSize, buf_2.get()); | 1737 VerifySparseIO(entry, 0x20F0000, buf_1.get(), kSize, buf_2.get()); |
| 1733 entry->Close(); | 1738 entry->Close(); |
| 1734 | 1739 |
| 1735 // Check it again. | 1740 // Check it again. |
| 1736 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 1741 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 1737 VerifyContentSparseIO(entry, 0x20F0000, buf_1->data(), kSize); | 1742 VerifyContentSparseIO(entry, 0x20F0000, buf_1->data(), kSize); |
| 1738 entry->Close(); | 1743 entry->Close(); |
| 1739 } | 1744 } |
| 1740 | 1745 |
| 1741 TEST_F(DiskCacheEntryTest, HugeSparseIO) { | 1746 TEST_F(DiskCacheEntryTest, HugeSparseIO) { |
| 1742 InitCache(); | 1747 InitCache(); |
| 1743 HugeSparseIO(); | 1748 HugeSparseIO(); |
| 1744 } | 1749 } |
| 1745 | 1750 |
| 1746 TEST_F(DiskCacheEntryTest, MemoryOnlyHugeSparseIO) { | 1751 TEST_F(DiskCacheEntryTest, MemoryOnlyHugeSparseIO) { |
| 1747 SetMemoryOnlyMode(); | 1752 SetMemoryOnlyMode(); |
| 1748 InitCache(); | 1753 InitCache(); |
| 1749 HugeSparseIO(); | 1754 HugeSparseIO(); |
| 1750 } | 1755 } |
| 1751 | 1756 |
| 1752 void DiskCacheEntryTest::GetAvailableRange() { | 1757 void DiskCacheEntryTest::GetAvailableRange() { |
| 1753 std::string key("the first key"); | 1758 std::string key("the first key"); |
| 1754 disk_cache::Entry* entry; | 1759 disk_cache::Entry* entry; |
| 1755 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 1760 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 1756 | 1761 |
| 1757 const int kSize = 16 * 1024; | 1762 const int kSize = 16 * 1024; |
| 1758 scoped_refptr<net::IOBuffer> buf(new net::IOBuffer(kSize)); | 1763 scoped_refptr<net::IOBuffer> buf(new net::IOBuffer(kSize)); |
| 1759 CacheTestFillBuffer(buf->data(), kSize, false); | 1764 CacheTestFillBuffer(buf->data(), kSize, false); |
| 1760 | 1765 |
| 1761 // Write at offset 0x20F0000 (33 MB - 64 KB), and 0x20F4400 (33 MB - 47 KB). | 1766 // Write at offset 0x20F0000 (33 MB - 64 KB), and 0x20F4400 (33 MB - 47 KB). |
| 1762 EXPECT_EQ(kSize, WriteSparseData(entry, 0x20F0000, buf.get(), kSize)); | 1767 EXPECT_EQ(kSize, WriteSparseData(entry, 0x20F0000, buf.get(), kSize)); |
| 1763 EXPECT_EQ(kSize, WriteSparseData(entry, 0x20F4400, buf.get(), kSize)); | 1768 EXPECT_EQ(kSize, WriteSparseData(entry, 0x20F4400, buf.get(), kSize)); |
| 1764 | 1769 |
| 1765 // We stop at the first empty block. | 1770 // We stop at the first empty block. |
| (...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1822 InitCache(); | 1827 InitCache(); |
| 1823 GetAvailableRange(); | 1828 GetAvailableRange(); |
| 1824 } | 1829 } |
| 1825 | 1830 |
| 1826 // Tests that non-sequential writes that are not aligned with the minimum sparse | 1831 // Tests that non-sequential writes that are not aligned with the minimum sparse |
| 1827 // data granularity (1024 bytes) do in fact result in dropped data. | 1832 // data granularity (1024 bytes) do in fact result in dropped data. |
| 1828 TEST_F(DiskCacheEntryTest, SparseWriteDropped) { | 1833 TEST_F(DiskCacheEntryTest, SparseWriteDropped) { |
| 1829 InitCache(); | 1834 InitCache(); |
| 1830 std::string key("the first key"); | 1835 std::string key("the first key"); |
| 1831 disk_cache::Entry* entry; | 1836 disk_cache::Entry* entry; |
| 1832 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 1837 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 1833 | 1838 |
| 1834 const int kSize = 180; | 1839 const int kSize = 180; |
| 1835 scoped_refptr<net::IOBuffer> buf_1(new net::IOBuffer(kSize)); | 1840 scoped_refptr<net::IOBuffer> buf_1(new net::IOBuffer(kSize)); |
| 1836 scoped_refptr<net::IOBuffer> buf_2(new net::IOBuffer(kSize)); | 1841 scoped_refptr<net::IOBuffer> buf_2(new net::IOBuffer(kSize)); |
| 1837 CacheTestFillBuffer(buf_1->data(), kSize, false); | 1842 CacheTestFillBuffer(buf_1->data(), kSize, false); |
| 1838 | 1843 |
| 1839 // Do small writes (180 bytes) that get increasingly close to a 1024-byte | 1844 // Do small writes (180 bytes) that get increasingly close to a 1024-byte |
| 1840 // boundary. All data should be dropped until a boundary is crossed, at which | 1845 // boundary. All data should be dropped until a boundary is crossed, at which |
| 1841 // point the data after the boundary is saved (at least for a while). | 1846 // point the data after the boundary is saved (at least for a while). |
| 1842 int offset = 1024 - 500; | 1847 int offset = 1024 - 500; |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1879 rv = entry->GetAvailableRange(offset, kSize, &start, cb.callback()); | 1884 rv = entry->GetAvailableRange(offset, kSize, &start, cb.callback()); |
| 1880 EXPECT_EQ(0, cb.GetResult(rv)); | 1885 EXPECT_EQ(0, cb.GetResult(rv)); |
| 1881 entry->Close(); | 1886 entry->Close(); |
| 1882 } | 1887 } |
| 1883 | 1888 |
| 1884 // Tests that small sequential writes are not dropped. | 1889 // Tests that small sequential writes are not dropped. |
| 1885 TEST_F(DiskCacheEntryTest, SparseSquentialWriteNotDropped) { | 1890 TEST_F(DiskCacheEntryTest, SparseSquentialWriteNotDropped) { |
| 1886 InitCache(); | 1891 InitCache(); |
| 1887 std::string key("the first key"); | 1892 std::string key("the first key"); |
| 1888 disk_cache::Entry* entry; | 1893 disk_cache::Entry* entry; |
| 1889 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 1894 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 1890 | 1895 |
| 1891 const int kSize = 180; | 1896 const int kSize = 180; |
| 1892 scoped_refptr<net::IOBuffer> buf_1(new net::IOBuffer(kSize)); | 1897 scoped_refptr<net::IOBuffer> buf_1(new net::IOBuffer(kSize)); |
| 1893 scoped_refptr<net::IOBuffer> buf_2(new net::IOBuffer(kSize)); | 1898 scoped_refptr<net::IOBuffer> buf_2(new net::IOBuffer(kSize)); |
| 1894 CacheTestFillBuffer(buf_1->data(), kSize, false); | 1899 CacheTestFillBuffer(buf_1->data(), kSize, false); |
| 1895 | 1900 |
| 1896 // Any starting offset is fine as long as it is 1024-bytes aligned. | 1901 // Any starting offset is fine as long as it is 1024-bytes aligned. |
| 1897 int rv = 0; | 1902 int rv = 0; |
| 1898 net::TestCompletionCallback cb; | 1903 net::TestCompletionCallback cb; |
| 1899 int64_t start; | 1904 int64_t start; |
| 1900 int64_t offset = 1024 * 11; | 1905 int64_t offset = 1024 * 11; |
| 1901 for (; offset < 20000; offset += kSize) { | 1906 for (; offset < 20000; offset += kSize) { |
| 1902 rv = entry->WriteSparseData(offset, buf_1.get(), kSize, cb.callback()); | 1907 rv = entry->WriteSparseData(offset, buf_1.get(), kSize, cb.callback()); |
| 1903 EXPECT_EQ(kSize, cb.GetResult(rv)); | 1908 EXPECT_EQ(kSize, cb.GetResult(rv)); |
| 1904 | 1909 |
| 1905 rv = entry->GetAvailableRange(offset, kSize, &start, cb.callback()); | 1910 rv = entry->GetAvailableRange(offset, kSize, &start, cb.callback()); |
| 1906 EXPECT_EQ(kSize, cb.GetResult(rv)); | 1911 EXPECT_EQ(kSize, cb.GetResult(rv)); |
| 1907 EXPECT_EQ(offset, start); | 1912 EXPECT_EQ(offset, start); |
| 1908 | 1913 |
| 1909 rv = entry->ReadSparseData(offset, buf_2.get(), kSize, cb.callback()); | 1914 rv = entry->ReadSparseData(offset, buf_2.get(), kSize, cb.callback()); |
| 1910 EXPECT_EQ(kSize, cb.GetResult(rv)); | 1915 EXPECT_EQ(kSize, cb.GetResult(rv)); |
| 1911 EXPECT_EQ(0, memcmp(buf_1.get()->data(), buf_2.get()->data(), kSize)); | 1916 EXPECT_EQ(0, memcmp(buf_1.get()->data(), buf_2.get()->data(), kSize)); |
| 1912 } | 1917 } |
| 1913 | 1918 |
| 1914 entry->Close(); | 1919 entry->Close(); |
| 1915 FlushQueueForTest(); | 1920 FlushQueueForTest(); |
| 1916 | 1921 |
| 1917 // Verify again the last write made. | 1922 // Verify again the last write made. |
| 1918 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 1923 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 1919 offset -= kSize; | 1924 offset -= kSize; |
| 1920 rv = entry->GetAvailableRange(offset, kSize, &start, cb.callback()); | 1925 rv = entry->GetAvailableRange(offset, kSize, &start, cb.callback()); |
| 1921 EXPECT_EQ(kSize, cb.GetResult(rv)); | 1926 EXPECT_EQ(kSize, cb.GetResult(rv)); |
| 1922 EXPECT_EQ(offset, start); | 1927 EXPECT_EQ(offset, start); |
| 1923 | 1928 |
| 1924 rv = entry->ReadSparseData(offset, buf_2.get(), kSize, cb.callback()); | 1929 rv = entry->ReadSparseData(offset, buf_2.get(), kSize, cb.callback()); |
| 1925 EXPECT_EQ(kSize, cb.GetResult(rv)); | 1930 EXPECT_EQ(kSize, cb.GetResult(rv)); |
| 1926 EXPECT_EQ(0, memcmp(buf_1.get()->data(), buf_2.get()->data(), kSize)); | 1931 EXPECT_EQ(0, memcmp(buf_1.get()->data(), buf_2.get()->data(), kSize)); |
| 1927 | 1932 |
| 1928 entry->Close(); | 1933 entry->Close(); |
| 1929 } | 1934 } |
| 1930 | 1935 |
| 1931 void DiskCacheEntryTest::CouldBeSparse() { | 1936 void DiskCacheEntryTest::CouldBeSparse() { |
| 1932 std::string key("the first key"); | 1937 std::string key("the first key"); |
| 1933 disk_cache::Entry* entry; | 1938 disk_cache::Entry* entry; |
| 1934 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 1939 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 1935 | 1940 |
| 1936 const int kSize = 16 * 1024; | 1941 const int kSize = 16 * 1024; |
| 1937 scoped_refptr<net::IOBuffer> buf(new net::IOBuffer(kSize)); | 1942 scoped_refptr<net::IOBuffer> buf(new net::IOBuffer(kSize)); |
| 1938 CacheTestFillBuffer(buf->data(), kSize, false); | 1943 CacheTestFillBuffer(buf->data(), kSize, false); |
| 1939 | 1944 |
| 1940 // Write at offset 0x20F0000 (33 MB - 64 KB). | 1945 // Write at offset 0x20F0000 (33 MB - 64 KB). |
| 1941 EXPECT_EQ(kSize, WriteSparseData(entry, 0x20F0000, buf.get(), kSize)); | 1946 EXPECT_EQ(kSize, WriteSparseData(entry, 0x20F0000, buf.get(), kSize)); |
| 1942 | 1947 |
| 1943 EXPECT_TRUE(entry->CouldBeSparse()); | 1948 EXPECT_TRUE(entry->CouldBeSparse()); |
| 1944 entry->Close(); | 1949 entry->Close(); |
| 1945 | 1950 |
| 1946 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 1951 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 1947 EXPECT_TRUE(entry->CouldBeSparse()); | 1952 EXPECT_TRUE(entry->CouldBeSparse()); |
| 1948 entry->Close(); | 1953 entry->Close(); |
| 1949 | 1954 |
| 1950 // Now verify a regular entry. | 1955 // Now verify a regular entry. |
| 1951 key.assign("another key"); | 1956 key.assign("another key"); |
| 1952 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 1957 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 1953 EXPECT_FALSE(entry->CouldBeSparse()); | 1958 EXPECT_FALSE(entry->CouldBeSparse()); |
| 1954 | 1959 |
| 1955 EXPECT_EQ(kSize, WriteData(entry, 0, 0, buf.get(), kSize, false)); | 1960 EXPECT_EQ(kSize, WriteData(entry, 0, 0, buf.get(), kSize, false)); |
| 1956 EXPECT_EQ(kSize, WriteData(entry, 1, 0, buf.get(), kSize, false)); | 1961 EXPECT_EQ(kSize, WriteData(entry, 1, 0, buf.get(), kSize, false)); |
| 1957 EXPECT_EQ(kSize, WriteData(entry, 2, 0, buf.get(), kSize, false)); | 1962 EXPECT_EQ(kSize, WriteData(entry, 2, 0, buf.get(), kSize, false)); |
| 1958 | 1963 |
| 1959 EXPECT_FALSE(entry->CouldBeSparse()); | 1964 EXPECT_FALSE(entry->CouldBeSparse()); |
| 1960 entry->Close(); | 1965 entry->Close(); |
| 1961 | 1966 |
| 1962 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 1967 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 1963 EXPECT_FALSE(entry->CouldBeSparse()); | 1968 EXPECT_FALSE(entry->CouldBeSparse()); |
| 1964 entry->Close(); | 1969 entry->Close(); |
| 1965 } | 1970 } |
| 1966 | 1971 |
| 1967 TEST_F(DiskCacheEntryTest, CouldBeSparse) { | 1972 TEST_F(DiskCacheEntryTest, CouldBeSparse) { |
| 1968 InitCache(); | 1973 InitCache(); |
| 1969 CouldBeSparse(); | 1974 CouldBeSparse(); |
| 1970 } | 1975 } |
| 1971 | 1976 |
| 1972 TEST_F(DiskCacheEntryTest, MemoryCouldBeSparse) { | 1977 TEST_F(DiskCacheEntryTest, MemoryCouldBeSparse) { |
| 1973 SetMemoryOnlyMode(); | 1978 SetMemoryOnlyMode(); |
| 1974 InitCache(); | 1979 InitCache(); |
| 1975 CouldBeSparse(); | 1980 CouldBeSparse(); |
| 1976 } | 1981 } |
| 1977 | 1982 |
| 1978 TEST_F(DiskCacheEntryTest, MemoryOnlyMisalignedSparseIO) { | 1983 TEST_F(DiskCacheEntryTest, MemoryOnlyMisalignedSparseIO) { |
| 1979 SetMemoryOnlyMode(); | 1984 SetMemoryOnlyMode(); |
| 1980 InitCache(); | 1985 InitCache(); |
| 1981 | 1986 |
| 1982 const int kSize = 8192; | 1987 const int kSize = 8192; |
| 1983 scoped_refptr<net::IOBuffer> buf_1(new net::IOBuffer(kSize)); | 1988 scoped_refptr<net::IOBuffer> buf_1(new net::IOBuffer(kSize)); |
| 1984 scoped_refptr<net::IOBuffer> buf_2(new net::IOBuffer(kSize)); | 1989 scoped_refptr<net::IOBuffer> buf_2(new net::IOBuffer(kSize)); |
| 1985 CacheTestFillBuffer(buf_1->data(), kSize, false); | 1990 CacheTestFillBuffer(buf_1->data(), kSize, false); |
| 1986 | 1991 |
| 1987 std::string key("the first key"); | 1992 std::string key("the first key"); |
| 1988 disk_cache::Entry* entry; | 1993 disk_cache::Entry* entry; |
| 1989 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 1994 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 1990 | 1995 |
| 1991 // This loop writes back to back starting from offset 0 and 9000. | 1996 // This loop writes back to back starting from offset 0 and 9000. |
| 1992 for (int i = 0; i < kSize; i += 1024) { | 1997 for (int i = 0; i < kSize; i += 1024) { |
| 1993 scoped_refptr<net::WrappedIOBuffer> buf_3( | 1998 scoped_refptr<net::WrappedIOBuffer> buf_3( |
| 1994 new net::WrappedIOBuffer(buf_1->data() + i)); | 1999 new net::WrappedIOBuffer(buf_1->data() + i)); |
| 1995 VerifySparseIO(entry, i, buf_3.get(), 1024, buf_2.get()); | 2000 VerifySparseIO(entry, i, buf_3.get(), 1024, buf_2.get()); |
| 1996 VerifySparseIO(entry, 9000 + i, buf_3.get(), 1024, buf_2.get()); | 2001 VerifySparseIO(entry, 9000 + i, buf_3.get(), 1024, buf_2.get()); |
| 1997 } | 2002 } |
| 1998 | 2003 |
| 1999 // Make sure we have data written. | 2004 // Make sure we have data written. |
| 2000 VerifyContentSparseIO(entry, 0, buf_1->data(), kSize); | 2005 VerifyContentSparseIO(entry, 0, buf_1->data(), kSize); |
| 2001 VerifyContentSparseIO(entry, 9000, buf_1->data(), kSize); | 2006 VerifyContentSparseIO(entry, 9000, buf_1->data(), kSize); |
| 2002 | 2007 |
| 2003 // This tests a large write that spans 3 entries from a misaligned offset. | 2008 // This tests a large write that spans 3 entries from a misaligned offset. |
| 2004 VerifySparseIO(entry, 20481, buf_1.get(), 8192, buf_2.get()); | 2009 VerifySparseIO(entry, 20481, buf_1.get(), 8192, buf_2.get()); |
| 2005 | 2010 |
| 2006 entry->Close(); | 2011 entry->Close(); |
| 2007 } | 2012 } |
| 2008 | 2013 |
| 2009 TEST_F(DiskCacheEntryTest, MemoryOnlyMisalignedGetAvailableRange) { | 2014 TEST_F(DiskCacheEntryTest, MemoryOnlyMisalignedGetAvailableRange) { |
| 2010 SetMemoryOnlyMode(); | 2015 SetMemoryOnlyMode(); |
| 2011 InitCache(); | 2016 InitCache(); |
| 2012 | 2017 |
| 2013 const int kSize = 8192; | 2018 const int kSize = 8192; |
| 2014 scoped_refptr<net::IOBuffer> buf(new net::IOBuffer(kSize)); | 2019 scoped_refptr<net::IOBuffer> buf(new net::IOBuffer(kSize)); |
| 2015 CacheTestFillBuffer(buf->data(), kSize, false); | 2020 CacheTestFillBuffer(buf->data(), kSize, false); |
| 2016 | 2021 |
| 2017 disk_cache::Entry* entry; | 2022 disk_cache::Entry* entry; |
| 2018 std::string key("the first key"); | 2023 std::string key("the first key"); |
| 2019 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 2024 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 2020 | 2025 |
| 2021 // Writes in the middle of an entry. | 2026 // Writes in the middle of an entry. |
| 2022 EXPECT_EQ( | 2027 EXPECT_EQ( |
| 2023 1024, | 2028 1024, |
| 2024 entry->WriteSparseData(0, buf.get(), 1024, net::CompletionCallback())); | 2029 entry->WriteSparseData(0, buf.get(), 1024, net::CompletionCallback())); |
| 2025 EXPECT_EQ( | 2030 EXPECT_EQ( |
| 2026 1024, | 2031 1024, |
| 2027 entry->WriteSparseData(5120, buf.get(), 1024, net::CompletionCallback())); | 2032 entry->WriteSparseData(5120, buf.get(), 1024, net::CompletionCallback())); |
| 2028 EXPECT_EQ(1024, | 2033 EXPECT_EQ(1024, |
| 2029 entry->WriteSparseData( | 2034 entry->WriteSparseData( |
| (...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2068 rv = entry->GetAvailableRange(40000, 20000, &start, cb.callback()); | 2073 rv = entry->GetAvailableRange(40000, 20000, &start, cb.callback()); |
| 2069 EXPECT_EQ(8192, cb.GetResult(rv)); | 2074 EXPECT_EQ(8192, cb.GetResult(rv)); |
| 2070 EXPECT_EQ(50000, start); | 2075 EXPECT_EQ(50000, start); |
| 2071 | 2076 |
| 2072 entry->Close(); | 2077 entry->Close(); |
| 2073 } | 2078 } |
| 2074 | 2079 |
| 2075 void DiskCacheEntryTest::UpdateSparseEntry() { | 2080 void DiskCacheEntryTest::UpdateSparseEntry() { |
| 2076 std::string key("the first key"); | 2081 std::string key("the first key"); |
| 2077 disk_cache::Entry* entry1; | 2082 disk_cache::Entry* entry1; |
| 2078 ASSERT_EQ(net::OK, CreateEntry(key, &entry1)); | 2083 ASSERT_THAT(CreateEntry(key, &entry1), IsOk()); |
| 2079 | 2084 |
| 2080 const int kSize = 2048; | 2085 const int kSize = 2048; |
| 2081 scoped_refptr<net::IOBuffer> buf_1(new net::IOBuffer(kSize)); | 2086 scoped_refptr<net::IOBuffer> buf_1(new net::IOBuffer(kSize)); |
| 2082 scoped_refptr<net::IOBuffer> buf_2(new net::IOBuffer(kSize)); | 2087 scoped_refptr<net::IOBuffer> buf_2(new net::IOBuffer(kSize)); |
| 2083 CacheTestFillBuffer(buf_1->data(), kSize, false); | 2088 CacheTestFillBuffer(buf_1->data(), kSize, false); |
| 2084 | 2089 |
| 2085 // Write at offset 0. | 2090 // Write at offset 0. |
| 2086 VerifySparseIO(entry1, 0, buf_1.get(), kSize, buf_2.get()); | 2091 VerifySparseIO(entry1, 0, buf_1.get(), kSize, buf_2.get()); |
| 2087 entry1->Close(); | 2092 entry1->Close(); |
| 2088 | 2093 |
| 2089 // Write at offset 2048. | 2094 // Write at offset 2048. |
| 2090 ASSERT_EQ(net::OK, OpenEntry(key, &entry1)); | 2095 ASSERT_THAT(OpenEntry(key, &entry1), IsOk()); |
| 2091 VerifySparseIO(entry1, 2048, buf_1.get(), kSize, buf_2.get()); | 2096 VerifySparseIO(entry1, 2048, buf_1.get(), kSize, buf_2.get()); |
| 2092 | 2097 |
| 2093 disk_cache::Entry* entry2; | 2098 disk_cache::Entry* entry2; |
| 2094 ASSERT_EQ(net::OK, CreateEntry("the second key", &entry2)); | 2099 ASSERT_THAT(CreateEntry("the second key", &entry2), IsOk()); |
| 2095 | 2100 |
| 2096 entry1->Close(); | 2101 entry1->Close(); |
| 2097 entry2->Close(); | 2102 entry2->Close(); |
| 2098 FlushQueueForTest(); | 2103 FlushQueueForTest(); |
| 2099 if (memory_only_ || simple_cache_mode_) | 2104 if (memory_only_ || simple_cache_mode_) |
| 2100 EXPECT_EQ(2, cache_->GetEntryCount()); | 2105 EXPECT_EQ(2, cache_->GetEntryCount()); |
| 2101 else | 2106 else |
| 2102 EXPECT_EQ(3, cache_->GetEntryCount()); | 2107 EXPECT_EQ(3, cache_->GetEntryCount()); |
| 2103 } | 2108 } |
| 2104 | 2109 |
| 2105 TEST_F(DiskCacheEntryTest, UpdateSparseEntry) { | 2110 TEST_F(DiskCacheEntryTest, UpdateSparseEntry) { |
| 2106 SetCacheType(net::MEDIA_CACHE); | 2111 SetCacheType(net::MEDIA_CACHE); |
| 2107 InitCache(); | 2112 InitCache(); |
| 2108 UpdateSparseEntry(); | 2113 UpdateSparseEntry(); |
| 2109 } | 2114 } |
| 2110 | 2115 |
| 2111 TEST_F(DiskCacheEntryTest, MemoryOnlyUpdateSparseEntry) { | 2116 TEST_F(DiskCacheEntryTest, MemoryOnlyUpdateSparseEntry) { |
| 2112 SetMemoryOnlyMode(); | 2117 SetMemoryOnlyMode(); |
| 2113 SetCacheType(net::MEDIA_CACHE); | 2118 SetCacheType(net::MEDIA_CACHE); |
| 2114 InitCache(); | 2119 InitCache(); |
| 2115 UpdateSparseEntry(); | 2120 UpdateSparseEntry(); |
| 2116 } | 2121 } |
| 2117 | 2122 |
| 2118 void DiskCacheEntryTest::DoomSparseEntry() { | 2123 void DiskCacheEntryTest::DoomSparseEntry() { |
| 2119 std::string key1("the first key"); | 2124 std::string key1("the first key"); |
| 2120 std::string key2("the second key"); | 2125 std::string key2("the second key"); |
| 2121 disk_cache::Entry *entry1, *entry2; | 2126 disk_cache::Entry *entry1, *entry2; |
| 2122 ASSERT_EQ(net::OK, CreateEntry(key1, &entry1)); | 2127 ASSERT_THAT(CreateEntry(key1, &entry1), IsOk()); |
| 2123 ASSERT_EQ(net::OK, CreateEntry(key2, &entry2)); | 2128 ASSERT_THAT(CreateEntry(key2, &entry2), IsOk()); |
| 2124 | 2129 |
| 2125 const int kSize = 4 * 1024; | 2130 const int kSize = 4 * 1024; |
| 2126 scoped_refptr<net::IOBuffer> buf(new net::IOBuffer(kSize)); | 2131 scoped_refptr<net::IOBuffer> buf(new net::IOBuffer(kSize)); |
| 2127 CacheTestFillBuffer(buf->data(), kSize, false); | 2132 CacheTestFillBuffer(buf->data(), kSize, false); |
| 2128 | 2133 |
| 2129 int64_t offset = 1024; | 2134 int64_t offset = 1024; |
| 2130 // Write to a bunch of ranges. | 2135 // Write to a bunch of ranges. |
| 2131 for (int i = 0; i < 12; i++) { | 2136 for (int i = 0; i < 12; i++) { |
| 2132 EXPECT_EQ(kSize, WriteSparseData(entry1, offset, buf.get(), kSize)); | 2137 EXPECT_EQ(kSize, WriteSparseData(entry1, offset, buf.get(), kSize)); |
| 2133 // Keep the second map under the default size. | 2138 // Keep the second map under the default size. |
| 2134 if (i < 9) | 2139 if (i < 9) |
| 2135 EXPECT_EQ(kSize, WriteSparseData(entry2, offset, buf.get(), kSize)); | 2140 EXPECT_EQ(kSize, WriteSparseData(entry2, offset, buf.get(), kSize)); |
| 2136 | 2141 |
| 2137 offset *= 4; | 2142 offset *= 4; |
| 2138 } | 2143 } |
| 2139 | 2144 |
| 2140 if (memory_only_ || simple_cache_mode_) | 2145 if (memory_only_ || simple_cache_mode_) |
| 2141 EXPECT_EQ(2, cache_->GetEntryCount()); | 2146 EXPECT_EQ(2, cache_->GetEntryCount()); |
| 2142 else | 2147 else |
| 2143 EXPECT_EQ(15, cache_->GetEntryCount()); | 2148 EXPECT_EQ(15, cache_->GetEntryCount()); |
| 2144 | 2149 |
| 2145 // Doom the first entry while it's still open. | 2150 // Doom the first entry while it's still open. |
| 2146 entry1->Doom(); | 2151 entry1->Doom(); |
| 2147 entry1->Close(); | 2152 entry1->Close(); |
| 2148 entry2->Close(); | 2153 entry2->Close(); |
| 2149 | 2154 |
| 2150 // Doom the second entry after it's fully saved. | 2155 // Doom the second entry after it's fully saved. |
| 2151 EXPECT_EQ(net::OK, DoomEntry(key2)); | 2156 EXPECT_THAT(DoomEntry(key2), IsOk()); |
| 2152 | 2157 |
| 2153 // Make sure we do all needed work. This may fail for entry2 if between Close | 2158 // Make sure we do all needed work. This may fail for entry2 if between Close |
| 2154 // and DoomEntry the system decides to remove all traces of the file from the | 2159 // and DoomEntry the system decides to remove all traces of the file from the |
| 2155 // system cache so we don't see that there is pending IO. | 2160 // system cache so we don't see that there is pending IO. |
| 2156 base::RunLoop().RunUntilIdle(); | 2161 base::RunLoop().RunUntilIdle(); |
| 2157 | 2162 |
| 2158 if (memory_only_) { | 2163 if (memory_only_) { |
| 2159 EXPECT_EQ(0, cache_->GetEntryCount()); | 2164 EXPECT_EQ(0, cache_->GetEntryCount()); |
| 2160 } else { | 2165 } else { |
| 2161 if (5 == cache_->GetEntryCount()) { | 2166 if (5 == cache_->GetEntryCount()) { |
| (...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2201 DISALLOW_COPY_AND_ASSIGN(SparseTestCompletionCallback); | 2206 DISALLOW_COPY_AND_ASSIGN(SparseTestCompletionCallback); |
| 2202 }; | 2207 }; |
| 2203 | 2208 |
| 2204 // Tests that we don't crash when the backend is deleted while we are working | 2209 // Tests that we don't crash when the backend is deleted while we are working |
| 2205 // deleting the sub-entries of a sparse entry. | 2210 // deleting the sub-entries of a sparse entry. |
| 2206 TEST_F(DiskCacheEntryTest, DoomSparseEntry2) { | 2211 TEST_F(DiskCacheEntryTest, DoomSparseEntry2) { |
| 2207 UseCurrentThread(); | 2212 UseCurrentThread(); |
| 2208 InitCache(); | 2213 InitCache(); |
| 2209 std::string key("the key"); | 2214 std::string key("the key"); |
| 2210 disk_cache::Entry* entry; | 2215 disk_cache::Entry* entry; |
| 2211 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 2216 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 2212 | 2217 |
| 2213 const int kSize = 4 * 1024; | 2218 const int kSize = 4 * 1024; |
| 2214 scoped_refptr<net::IOBuffer> buf(new net::IOBuffer(kSize)); | 2219 scoped_refptr<net::IOBuffer> buf(new net::IOBuffer(kSize)); |
| 2215 CacheTestFillBuffer(buf->data(), kSize, false); | 2220 CacheTestFillBuffer(buf->data(), kSize, false); |
| 2216 | 2221 |
| 2217 int64_t offset = 1024; | 2222 int64_t offset = 1024; |
| 2218 // Write to a bunch of ranges. | 2223 // Write to a bunch of ranges. |
| 2219 for (int i = 0; i < 12; i++) { | 2224 for (int i = 0; i < 12; i++) { |
| 2220 EXPECT_EQ(kSize, | 2225 EXPECT_EQ(kSize, |
| 2221 entry->WriteSparseData( | 2226 entry->WriteSparseData( |
| 2222 offset, buf.get(), kSize, net::CompletionCallback())); | 2227 offset, buf.get(), kSize, net::CompletionCallback())); |
| 2223 offset *= 4; | 2228 offset *= 4; |
| 2224 } | 2229 } |
| 2225 EXPECT_EQ(9, cache_->GetEntryCount()); | 2230 EXPECT_EQ(9, cache_->GetEntryCount()); |
| 2226 | 2231 |
| 2227 entry->Close(); | 2232 entry->Close(); |
| 2228 disk_cache::Backend* cache = cache_.get(); | 2233 disk_cache::Backend* cache = cache_.get(); |
| 2229 SparseTestCompletionCallback cb(std::move(cache_)); | 2234 SparseTestCompletionCallback cb(std::move(cache_)); |
| 2230 int rv = cache->DoomEntry(key, cb.callback()); | 2235 int rv = cache->DoomEntry(key, cb.callback()); |
| 2231 EXPECT_EQ(net::ERR_IO_PENDING, rv); | 2236 EXPECT_THAT(rv, IsError(net::ERR_IO_PENDING)); |
| 2232 EXPECT_EQ(net::OK, cb.WaitForResult()); | 2237 EXPECT_THAT(cb.WaitForResult(), IsOk()); |
| 2233 } | 2238 } |
| 2234 | 2239 |
| 2235 void DiskCacheEntryTest::PartialSparseEntry() { | 2240 void DiskCacheEntryTest::PartialSparseEntry() { |
| 2236 std::string key("the first key"); | 2241 std::string key("the first key"); |
| 2237 disk_cache::Entry* entry; | 2242 disk_cache::Entry* entry; |
| 2238 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 2243 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 2239 | 2244 |
| 2240 // We should be able to deal with IO that is not aligned to the block size | 2245 // We should be able to deal with IO that is not aligned to the block size |
| 2241 // of a sparse entry, at least to write a big range without leaving holes. | 2246 // of a sparse entry, at least to write a big range without leaving holes. |
| 2242 const int kSize = 4 * 1024; | 2247 const int kSize = 4 * 1024; |
| 2243 const int kSmallSize = 128; | 2248 const int kSmallSize = 128; |
| 2244 scoped_refptr<net::IOBuffer> buf1(new net::IOBuffer(kSize)); | 2249 scoped_refptr<net::IOBuffer> buf1(new net::IOBuffer(kSize)); |
| 2245 CacheTestFillBuffer(buf1->data(), kSize, false); | 2250 CacheTestFillBuffer(buf1->data(), kSize, false); |
| 2246 | 2251 |
| 2247 // The first write is just to extend the entry. The third write occupies | 2252 // The first write is just to extend the entry. The third write occupies |
| 2248 // a 1KB block partially, it may not be written internally depending on the | 2253 // a 1KB block partially, it may not be written internally depending on the |
| 2249 // implementation. | 2254 // implementation. |
| 2250 EXPECT_EQ(kSize, WriteSparseData(entry, 20000, buf1.get(), kSize)); | 2255 EXPECT_EQ(kSize, WriteSparseData(entry, 20000, buf1.get(), kSize)); |
| 2251 EXPECT_EQ(kSize, WriteSparseData(entry, 500, buf1.get(), kSize)); | 2256 EXPECT_EQ(kSize, WriteSparseData(entry, 500, buf1.get(), kSize)); |
| 2252 EXPECT_EQ(kSmallSize, | 2257 EXPECT_EQ(kSmallSize, |
| 2253 WriteSparseData(entry, 1080321, buf1.get(), kSmallSize)); | 2258 WriteSparseData(entry, 1080321, buf1.get(), kSmallSize)); |
| 2254 entry->Close(); | 2259 entry->Close(); |
| 2255 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 2260 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 2256 | 2261 |
| 2257 scoped_refptr<net::IOBuffer> buf2(new net::IOBuffer(kSize)); | 2262 scoped_refptr<net::IOBuffer> buf2(new net::IOBuffer(kSize)); |
| 2258 memset(buf2->data(), 0, kSize); | 2263 memset(buf2->data(), 0, kSize); |
| 2259 EXPECT_EQ(0, ReadSparseData(entry, 8000, buf2.get(), kSize)); | 2264 EXPECT_EQ(0, ReadSparseData(entry, 8000, buf2.get(), kSize)); |
| 2260 | 2265 |
| 2261 EXPECT_EQ(500, ReadSparseData(entry, kSize, buf2.get(), kSize)); | 2266 EXPECT_EQ(500, ReadSparseData(entry, kSize, buf2.get(), kSize)); |
| 2262 EXPECT_EQ(0, memcmp(buf2->data(), buf1->data() + kSize - 500, 500)); | 2267 EXPECT_EQ(0, memcmp(buf2->data(), buf1->data() + kSize - 500, 500)); |
| 2263 EXPECT_EQ(0, ReadSparseData(entry, 0, buf2.get(), kSize)); | 2268 EXPECT_EQ(0, ReadSparseData(entry, 0, buf2.get(), kSize)); |
| 2264 | 2269 |
| 2265 // This read should not change anything. | 2270 // This read should not change anything. |
| (...skipping 68 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2334 SetMemoryOnlyMode(); | 2339 SetMemoryOnlyMode(); |
| 2335 InitCache(); | 2340 InitCache(); |
| 2336 PartialSparseEntry(); | 2341 PartialSparseEntry(); |
| 2337 } | 2342 } |
| 2338 | 2343 |
| 2339 // Tests that corrupt sparse children are removed automatically. | 2344 // Tests that corrupt sparse children are removed automatically. |
| 2340 TEST_F(DiskCacheEntryTest, CleanupSparseEntry) { | 2345 TEST_F(DiskCacheEntryTest, CleanupSparseEntry) { |
| 2341 InitCache(); | 2346 InitCache(); |
| 2342 std::string key("the first key"); | 2347 std::string key("the first key"); |
| 2343 disk_cache::Entry* entry; | 2348 disk_cache::Entry* entry; |
| 2344 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 2349 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 2345 | 2350 |
| 2346 const int kSize = 4 * 1024; | 2351 const int kSize = 4 * 1024; |
| 2347 scoped_refptr<net::IOBuffer> buf1(new net::IOBuffer(kSize)); | 2352 scoped_refptr<net::IOBuffer> buf1(new net::IOBuffer(kSize)); |
| 2348 CacheTestFillBuffer(buf1->data(), kSize, false); | 2353 CacheTestFillBuffer(buf1->data(), kSize, false); |
| 2349 | 2354 |
| 2350 const int k1Meg = 1024 * 1024; | 2355 const int k1Meg = 1024 * 1024; |
| 2351 EXPECT_EQ(kSize, WriteSparseData(entry, 8192, buf1.get(), kSize)); | 2356 EXPECT_EQ(kSize, WriteSparseData(entry, 8192, buf1.get(), kSize)); |
| 2352 EXPECT_EQ(kSize, WriteSparseData(entry, k1Meg + 8192, buf1.get(), kSize)); | 2357 EXPECT_EQ(kSize, WriteSparseData(entry, k1Meg + 8192, buf1.get(), kSize)); |
| 2353 EXPECT_EQ(kSize, WriteSparseData(entry, 2 * k1Meg + 8192, buf1.get(), kSize)); | 2358 EXPECT_EQ(kSize, WriteSparseData(entry, 2 * k1Meg + 8192, buf1.get(), kSize)); |
| 2354 entry->Close(); | 2359 entry->Close(); |
| 2355 EXPECT_EQ(4, cache_->GetEntryCount()); | 2360 EXPECT_EQ(4, cache_->GetEntryCount()); |
| 2356 | 2361 |
| 2357 std::unique_ptr<TestIterator> iter = CreateIterator(); | 2362 std::unique_ptr<TestIterator> iter = CreateIterator(); |
| 2358 int count = 0; | 2363 int count = 0; |
| 2359 std::string child_key[2]; | 2364 std::string child_key[2]; |
| 2360 while (iter->OpenNextEntry(&entry) == net::OK) { | 2365 while (iter->OpenNextEntry(&entry) == net::OK) { |
| 2361 ASSERT_TRUE(entry != NULL); | 2366 ASSERT_TRUE(entry != NULL); |
| 2362 // Writing to an entry will alter the LRU list and invalidate the iterator. | 2367 // Writing to an entry will alter the LRU list and invalidate the iterator. |
| 2363 if (entry->GetKey() != key && count < 2) | 2368 if (entry->GetKey() != key && count < 2) |
| 2364 child_key[count++] = entry->GetKey(); | 2369 child_key[count++] = entry->GetKey(); |
| 2365 entry->Close(); | 2370 entry->Close(); |
| 2366 } | 2371 } |
| 2367 for (int i = 0; i < 2; i++) { | 2372 for (int i = 0; i < 2; i++) { |
| 2368 ASSERT_EQ(net::OK, OpenEntry(child_key[i], &entry)); | 2373 ASSERT_THAT(OpenEntry(child_key[i], &entry), IsOk()); |
| 2369 // Overwrite the header's magic and signature. | 2374 // Overwrite the header's magic and signature. |
| 2370 EXPECT_EQ(12, WriteData(entry, 2, 0, buf1.get(), 12, false)); | 2375 EXPECT_EQ(12, WriteData(entry, 2, 0, buf1.get(), 12, false)); |
| 2371 entry->Close(); | 2376 entry->Close(); |
| 2372 } | 2377 } |
| 2373 | 2378 |
| 2374 EXPECT_EQ(4, cache_->GetEntryCount()); | 2379 EXPECT_EQ(4, cache_->GetEntryCount()); |
| 2375 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 2380 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 2376 | 2381 |
| 2377 // Two children should be gone. One while reading and one while writing. | 2382 // Two children should be gone. One while reading and one while writing. |
| 2378 EXPECT_EQ(0, ReadSparseData(entry, 2 * k1Meg + 8192, buf1.get(), kSize)); | 2383 EXPECT_EQ(0, ReadSparseData(entry, 2 * k1Meg + 8192, buf1.get(), kSize)); |
| 2379 EXPECT_EQ(kSize, WriteSparseData(entry, k1Meg + 16384, buf1.get(), kSize)); | 2384 EXPECT_EQ(kSize, WriteSparseData(entry, k1Meg + 16384, buf1.get(), kSize)); |
| 2380 EXPECT_EQ(0, ReadSparseData(entry, k1Meg + 8192, buf1.get(), kSize)); | 2385 EXPECT_EQ(0, ReadSparseData(entry, k1Meg + 8192, buf1.get(), kSize)); |
| 2381 | 2386 |
| 2382 // We never touched this one. | 2387 // We never touched this one. |
| 2383 EXPECT_EQ(kSize, ReadSparseData(entry, 8192, buf1.get(), kSize)); | 2388 EXPECT_EQ(kSize, ReadSparseData(entry, 8192, buf1.get(), kSize)); |
| 2384 entry->Close(); | 2389 entry->Close(); |
| 2385 | 2390 |
| 2386 // We re-created one of the corrupt children. | 2391 // We re-created one of the corrupt children. |
| 2387 EXPECT_EQ(3, cache_->GetEntryCount()); | 2392 EXPECT_EQ(3, cache_->GetEntryCount()); |
| 2388 } | 2393 } |
| 2389 | 2394 |
| 2390 TEST_F(DiskCacheEntryTest, CancelSparseIO) { | 2395 TEST_F(DiskCacheEntryTest, CancelSparseIO) { |
| 2391 UseCurrentThread(); | 2396 UseCurrentThread(); |
| 2392 InitCache(); | 2397 InitCache(); |
| 2393 std::string key("the first key"); | 2398 std::string key("the first key"); |
| 2394 disk_cache::Entry* entry; | 2399 disk_cache::Entry* entry; |
| 2395 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 2400 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 2396 | 2401 |
| 2397 const int kSize = 40 * 1024; | 2402 const int kSize = 40 * 1024; |
| 2398 scoped_refptr<net::IOBuffer> buf(new net::IOBuffer(kSize)); | 2403 scoped_refptr<net::IOBuffer> buf(new net::IOBuffer(kSize)); |
| 2399 CacheTestFillBuffer(buf->data(), kSize, false); | 2404 CacheTestFillBuffer(buf->data(), kSize, false); |
| 2400 | 2405 |
| 2401 // This will open and write two "real" entries. | 2406 // This will open and write two "real" entries. |
| 2402 net::TestCompletionCallback cb1, cb2, cb3, cb4, cb5; | 2407 net::TestCompletionCallback cb1, cb2, cb3, cb4, cb5; |
| 2403 int rv = entry->WriteSparseData( | 2408 int rv = entry->WriteSparseData( |
| 2404 1024 * 1024 - 4096, buf.get(), kSize, cb1.callback()); | 2409 1024 * 1024 - 4096, buf.get(), kSize, cb1.callback()); |
| 2405 EXPECT_EQ(net::ERR_IO_PENDING, rv); | 2410 EXPECT_THAT(rv, IsError(net::ERR_IO_PENDING)); |
| 2406 | 2411 |
| 2407 int64_t offset = 0; | 2412 int64_t offset = 0; |
| 2408 rv = entry->GetAvailableRange(offset, kSize, &offset, cb5.callback()); | 2413 rv = entry->GetAvailableRange(offset, kSize, &offset, cb5.callback()); |
| 2409 rv = cb5.GetResult(rv); | 2414 rv = cb5.GetResult(rv); |
| 2410 if (!cb1.have_result()) { | 2415 if (!cb1.have_result()) { |
| 2411 // We may or may not have finished writing to the entry. If we have not, | 2416 // We may or may not have finished writing to the entry. If we have not, |
| 2412 // we cannot start another operation at this time. | 2417 // we cannot start another operation at this time. |
| 2413 EXPECT_EQ(net::ERR_CACHE_OPERATION_NOT_SUPPORTED, rv); | 2418 EXPECT_THAT(rv, IsError(net::ERR_CACHE_OPERATION_NOT_SUPPORTED)); |
| 2414 } | 2419 } |
| 2415 | 2420 |
| 2416 // We cancel the pending operation, and register multiple notifications. | 2421 // We cancel the pending operation, and register multiple notifications. |
| 2417 entry->CancelSparseIO(); | 2422 entry->CancelSparseIO(); |
| 2418 EXPECT_EQ(net::ERR_IO_PENDING, entry->ReadyForSparseIO(cb2.callback())); | 2423 EXPECT_THAT(entry->ReadyForSparseIO(cb2.callback()), |
| 2419 EXPECT_EQ(net::ERR_IO_PENDING, entry->ReadyForSparseIO(cb3.callback())); | 2424 IsError(net::ERR_IO_PENDING)); |
| 2425 EXPECT_THAT(entry->ReadyForSparseIO(cb3.callback()), |
| 2426 IsError(net::ERR_IO_PENDING)); |
| 2420 entry->CancelSparseIO(); // Should be a no op at this point. | 2427 entry->CancelSparseIO(); // Should be a no op at this point. |
| 2421 EXPECT_EQ(net::ERR_IO_PENDING, entry->ReadyForSparseIO(cb4.callback())); | 2428 EXPECT_THAT(entry->ReadyForSparseIO(cb4.callback()), |
| 2429 IsError(net::ERR_IO_PENDING)); |
| 2422 | 2430 |
| 2423 if (!cb1.have_result()) { | 2431 if (!cb1.have_result()) { |
| 2424 EXPECT_EQ(net::ERR_CACHE_OPERATION_NOT_SUPPORTED, | 2432 EXPECT_EQ(net::ERR_CACHE_OPERATION_NOT_SUPPORTED, |
| 2425 entry->ReadSparseData( | 2433 entry->ReadSparseData( |
| 2426 offset, buf.get(), kSize, net::CompletionCallback())); | 2434 offset, buf.get(), kSize, net::CompletionCallback())); |
| 2427 EXPECT_EQ(net::ERR_CACHE_OPERATION_NOT_SUPPORTED, | 2435 EXPECT_EQ(net::ERR_CACHE_OPERATION_NOT_SUPPORTED, |
| 2428 entry->WriteSparseData( | 2436 entry->WriteSparseData( |
| 2429 offset, buf.get(), kSize, net::CompletionCallback())); | 2437 offset, buf.get(), kSize, net::CompletionCallback())); |
| 2430 } | 2438 } |
| 2431 | 2439 |
| 2432 // Now see if we receive all notifications. Note that we should not be able | 2440 // Now see if we receive all notifications. Note that we should not be able |
| 2433 // to write everything (unless the timing of the system is really weird). | 2441 // to write everything (unless the timing of the system is really weird). |
| 2434 rv = cb1.WaitForResult(); | 2442 rv = cb1.WaitForResult(); |
| 2435 EXPECT_TRUE(rv == 4096 || rv == kSize); | 2443 EXPECT_TRUE(rv == 4096 || rv == kSize); |
| 2436 EXPECT_EQ(net::OK, cb2.WaitForResult()); | 2444 EXPECT_THAT(cb2.WaitForResult(), IsOk()); |
| 2437 EXPECT_EQ(net::OK, cb3.WaitForResult()); | 2445 EXPECT_THAT(cb3.WaitForResult(), IsOk()); |
| 2438 EXPECT_EQ(net::OK, cb4.WaitForResult()); | 2446 EXPECT_THAT(cb4.WaitForResult(), IsOk()); |
| 2439 | 2447 |
| 2440 rv = entry->GetAvailableRange(offset, kSize, &offset, cb5.callback()); | 2448 rv = entry->GetAvailableRange(offset, kSize, &offset, cb5.callback()); |
| 2441 EXPECT_EQ(0, cb5.GetResult(rv)); | 2449 EXPECT_EQ(0, cb5.GetResult(rv)); |
| 2442 entry->Close(); | 2450 entry->Close(); |
| 2443 } | 2451 } |
| 2444 | 2452 |
| 2445 // Tests that we perform sanity checks on an entry's key. Note that there are | 2453 // Tests that we perform sanity checks on an entry's key. Note that there are |
| 2446 // other tests that exercise sanity checks by using saved corrupt files. | 2454 // other tests that exercise sanity checks by using saved corrupt files. |
| 2447 TEST_F(DiskCacheEntryTest, KeySanityCheck) { | 2455 TEST_F(DiskCacheEntryTest, KeySanityCheck) { |
| 2448 UseCurrentThread(); | 2456 UseCurrentThread(); |
| 2449 InitCache(); | 2457 InitCache(); |
| 2450 std::string key("the first key"); | 2458 std::string key("the first key"); |
| 2451 disk_cache::Entry* entry; | 2459 disk_cache::Entry* entry; |
| 2452 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 2460 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 2453 | 2461 |
| 2454 disk_cache::EntryImpl* entry_impl = | 2462 disk_cache::EntryImpl* entry_impl = |
| 2455 static_cast<disk_cache::EntryImpl*>(entry); | 2463 static_cast<disk_cache::EntryImpl*>(entry); |
| 2456 disk_cache::EntryStore* store = entry_impl->entry()->Data(); | 2464 disk_cache::EntryStore* store = entry_impl->entry()->Data(); |
| 2457 | 2465 |
| 2458 // We have reserved space for a short key (one block), let's say that the key | 2466 // We have reserved space for a short key (one block), let's say that the key |
| 2459 // takes more than one block, and remove the NULLs after the actual key. | 2467 // takes more than one block, and remove the NULLs after the actual key. |
| 2460 store->key_len = 800; | 2468 store->key_len = 800; |
| 2461 memset(store->key + key.size(), 'k', sizeof(store->key) - key.size()); | 2469 memset(store->key + key.size(), 'k', sizeof(store->key) - key.size()); |
| 2462 entry_impl->entry()->set_modified(); | 2470 entry_impl->entry()->set_modified(); |
| (...skipping 14 matching lines...) Expand all Loading... |
| 2477 TEST_F(DiskCacheEntryTest, SimpleCacheExternalAsyncIO) { | 2485 TEST_F(DiskCacheEntryTest, SimpleCacheExternalAsyncIO) { |
| 2478 SetSimpleCacheMode(); | 2486 SetSimpleCacheMode(); |
| 2479 InitCache(); | 2487 InitCache(); |
| 2480 ExternalAsyncIO(); | 2488 ExternalAsyncIO(); |
| 2481 } | 2489 } |
| 2482 | 2490 |
| 2483 TEST_F(DiskCacheEntryTest, SimpleCacheReleaseBuffer) { | 2491 TEST_F(DiskCacheEntryTest, SimpleCacheReleaseBuffer) { |
| 2484 SetSimpleCacheMode(); | 2492 SetSimpleCacheMode(); |
| 2485 InitCache(); | 2493 InitCache(); |
| 2486 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { | 2494 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { |
| 2487 EXPECT_EQ(net::OK, DoomAllEntries()); | 2495 EXPECT_THAT(DoomAllEntries(), IsOk()); |
| 2488 ReleaseBuffer(i); | 2496 ReleaseBuffer(i); |
| 2489 } | 2497 } |
| 2490 } | 2498 } |
| 2491 | 2499 |
| 2492 TEST_F(DiskCacheEntryTest, SimpleCacheStreamAccess) { | 2500 TEST_F(DiskCacheEntryTest, SimpleCacheStreamAccess) { |
| 2493 SetSimpleCacheMode(); | 2501 SetSimpleCacheMode(); |
| 2494 InitCache(); | 2502 InitCache(); |
| 2495 StreamAccess(); | 2503 StreamAccess(); |
| 2496 } | 2504 } |
| 2497 | 2505 |
| 2498 TEST_F(DiskCacheEntryTest, SimpleCacheGetKey) { | 2506 TEST_F(DiskCacheEntryTest, SimpleCacheGetKey) { |
| 2499 SetSimpleCacheMode(); | 2507 SetSimpleCacheMode(); |
| 2500 InitCache(); | 2508 InitCache(); |
| 2501 GetKey(); | 2509 GetKey(); |
| 2502 } | 2510 } |
| 2503 | 2511 |
| 2504 TEST_F(DiskCacheEntryTest, SimpleCacheGetTimes) { | 2512 TEST_F(DiskCacheEntryTest, SimpleCacheGetTimes) { |
| 2505 SetSimpleCacheMode(); | 2513 SetSimpleCacheMode(); |
| 2506 InitCache(); | 2514 InitCache(); |
| 2507 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { | 2515 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { |
| 2508 EXPECT_EQ(net::OK, DoomAllEntries()); | 2516 EXPECT_THAT(DoomAllEntries(), IsOk()); |
| 2509 GetTimes(i); | 2517 GetTimes(i); |
| 2510 } | 2518 } |
| 2511 } | 2519 } |
| 2512 | 2520 |
| 2513 TEST_F(DiskCacheEntryTest, SimpleCacheGrowData) { | 2521 TEST_F(DiskCacheEntryTest, SimpleCacheGrowData) { |
| 2514 SetSimpleCacheMode(); | 2522 SetSimpleCacheMode(); |
| 2515 InitCache(); | 2523 InitCache(); |
| 2516 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { | 2524 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { |
| 2517 EXPECT_EQ(net::OK, DoomAllEntries()); | 2525 EXPECT_THAT(DoomAllEntries(), IsOk()); |
| 2518 GrowData(i); | 2526 GrowData(i); |
| 2519 } | 2527 } |
| 2520 } | 2528 } |
| 2521 | 2529 |
| 2522 TEST_F(DiskCacheEntryTest, SimpleCacheTruncateData) { | 2530 TEST_F(DiskCacheEntryTest, SimpleCacheTruncateData) { |
| 2523 SetSimpleCacheMode(); | 2531 SetSimpleCacheMode(); |
| 2524 InitCache(); | 2532 InitCache(); |
| 2525 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { | 2533 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { |
| 2526 EXPECT_EQ(net::OK, DoomAllEntries()); | 2534 EXPECT_THAT(DoomAllEntries(), IsOk()); |
| 2527 TruncateData(i); | 2535 TruncateData(i); |
| 2528 } | 2536 } |
| 2529 } | 2537 } |
| 2530 | 2538 |
| 2531 TEST_F(DiskCacheEntryTest, SimpleCacheZeroLengthIO) { | 2539 TEST_F(DiskCacheEntryTest, SimpleCacheZeroLengthIO) { |
| 2532 SetSimpleCacheMode(); | 2540 SetSimpleCacheMode(); |
| 2533 InitCache(); | 2541 InitCache(); |
| 2534 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { | 2542 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { |
| 2535 EXPECT_EQ(net::OK, DoomAllEntries()); | 2543 EXPECT_THAT(DoomAllEntries(), IsOk()); |
| 2536 ZeroLengthIO(i); | 2544 ZeroLengthIO(i); |
| 2537 } | 2545 } |
| 2538 } | 2546 } |
| 2539 | 2547 |
| 2540 TEST_F(DiskCacheEntryTest, SimpleCacheSizeAtCreate) { | 2548 TEST_F(DiskCacheEntryTest, SimpleCacheSizeAtCreate) { |
| 2541 SetSimpleCacheMode(); | 2549 SetSimpleCacheMode(); |
| 2542 InitCache(); | 2550 InitCache(); |
| 2543 SizeAtCreate(); | 2551 SizeAtCreate(); |
| 2544 } | 2552 } |
| 2545 | 2553 |
| 2546 TEST_F(DiskCacheEntryTest, SimpleCacheReuseExternalEntry) { | 2554 TEST_F(DiskCacheEntryTest, SimpleCacheReuseExternalEntry) { |
| 2547 SetSimpleCacheMode(); | 2555 SetSimpleCacheMode(); |
| 2548 SetMaxSize(200 * 1024); | 2556 SetMaxSize(200 * 1024); |
| 2549 InitCache(); | 2557 InitCache(); |
| 2550 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { | 2558 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { |
| 2551 EXPECT_EQ(net::OK, DoomAllEntries()); | 2559 EXPECT_THAT(DoomAllEntries(), IsOk()); |
| 2552 ReuseEntry(20 * 1024, i); | 2560 ReuseEntry(20 * 1024, i); |
| 2553 } | 2561 } |
| 2554 } | 2562 } |
| 2555 | 2563 |
| 2556 TEST_F(DiskCacheEntryTest, SimpleCacheReuseInternalEntry) { | 2564 TEST_F(DiskCacheEntryTest, SimpleCacheReuseInternalEntry) { |
| 2557 SetSimpleCacheMode(); | 2565 SetSimpleCacheMode(); |
| 2558 SetMaxSize(100 * 1024); | 2566 SetMaxSize(100 * 1024); |
| 2559 InitCache(); | 2567 InitCache(); |
| 2560 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { | 2568 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { |
| 2561 EXPECT_EQ(net::OK, DoomAllEntries()); | 2569 EXPECT_THAT(DoomAllEntries(), IsOk()); |
| 2562 ReuseEntry(10 * 1024, i); | 2570 ReuseEntry(10 * 1024, i); |
| 2563 } | 2571 } |
| 2564 } | 2572 } |
| 2565 | 2573 |
| 2566 TEST_F(DiskCacheEntryTest, SimpleCacheSizeChanges) { | 2574 TEST_F(DiskCacheEntryTest, SimpleCacheSizeChanges) { |
| 2567 SetSimpleCacheMode(); | 2575 SetSimpleCacheMode(); |
| 2568 InitCache(); | 2576 InitCache(); |
| 2569 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { | 2577 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { |
| 2570 EXPECT_EQ(net::OK, DoomAllEntries()); | 2578 EXPECT_THAT(DoomAllEntries(), IsOk()); |
| 2571 SizeChanges(i); | 2579 SizeChanges(i); |
| 2572 } | 2580 } |
| 2573 } | 2581 } |
| 2574 | 2582 |
| 2575 TEST_F(DiskCacheEntryTest, SimpleCacheInvalidData) { | 2583 TEST_F(DiskCacheEntryTest, SimpleCacheInvalidData) { |
| 2576 SetSimpleCacheMode(); | 2584 SetSimpleCacheMode(); |
| 2577 InitCache(); | 2585 InitCache(); |
| 2578 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { | 2586 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { |
| 2579 EXPECT_EQ(net::OK, DoomAllEntries()); | 2587 EXPECT_THAT(DoomAllEntries(), IsOk()); |
| 2580 InvalidData(i); | 2588 InvalidData(i); |
| 2581 } | 2589 } |
| 2582 } | 2590 } |
| 2583 | 2591 |
| 2584 TEST_F(DiskCacheEntryTest, SimpleCacheReadWriteDestroyBuffer) { | 2592 TEST_F(DiskCacheEntryTest, SimpleCacheReadWriteDestroyBuffer) { |
| 2585 // Proving that the test works well with optimistic operations enabled is | 2593 // Proving that the test works well with optimistic operations enabled is |
| 2586 // subtle, instead run only in APP_CACHE mode to disable optimistic | 2594 // subtle, instead run only in APP_CACHE mode to disable optimistic |
| 2587 // operations. Stream 0 always uses optimistic operations, so the test is not | 2595 // operations. Stream 0 always uses optimistic operations, so the test is not |
| 2588 // run on stream 0. | 2596 // run on stream 0. |
| 2589 SetCacheType(net::APP_CACHE); | 2597 SetCacheType(net::APP_CACHE); |
| 2590 SetSimpleCacheMode(); | 2598 SetSimpleCacheMode(); |
| 2591 InitCache(); | 2599 InitCache(); |
| 2592 for (int i = 1; i < disk_cache::kSimpleEntryStreamCount; ++i) { | 2600 for (int i = 1; i < disk_cache::kSimpleEntryStreamCount; ++i) { |
| 2593 EXPECT_EQ(net::OK, DoomAllEntries()); | 2601 EXPECT_THAT(DoomAllEntries(), IsOk()); |
| 2594 ReadWriteDestroyBuffer(i); | 2602 ReadWriteDestroyBuffer(i); |
| 2595 } | 2603 } |
| 2596 } | 2604 } |
| 2597 | 2605 |
| 2598 TEST_F(DiskCacheEntryTest, SimpleCacheDoomEntry) { | 2606 TEST_F(DiskCacheEntryTest, SimpleCacheDoomEntry) { |
| 2599 SetSimpleCacheMode(); | 2607 SetSimpleCacheMode(); |
| 2600 InitCache(); | 2608 InitCache(); |
| 2601 DoomNormalEntry(); | 2609 DoomNormalEntry(); |
| 2602 } | 2610 } |
| 2603 | 2611 |
| 2604 TEST_F(DiskCacheEntryTest, SimpleCacheDoomEntryNextToOpenEntry) { | 2612 TEST_F(DiskCacheEntryTest, SimpleCacheDoomEntryNextToOpenEntry) { |
| 2605 SetSimpleCacheMode(); | 2613 SetSimpleCacheMode(); |
| 2606 InitCache(); | 2614 InitCache(); |
| 2607 DoomEntryNextToOpenEntry(); | 2615 DoomEntryNextToOpenEntry(); |
| 2608 } | 2616 } |
| 2609 | 2617 |
| 2610 TEST_F(DiskCacheEntryTest, SimpleCacheDoomedEntry) { | 2618 TEST_F(DiskCacheEntryTest, SimpleCacheDoomedEntry) { |
| 2611 SetSimpleCacheMode(); | 2619 SetSimpleCacheMode(); |
| 2612 InitCache(); | 2620 InitCache(); |
| 2613 // Stream 2 is excluded because the implementation does not support writing to | 2621 // Stream 2 is excluded because the implementation does not support writing to |
| 2614 // it on a doomed entry, if it was previously lazily omitted. | 2622 // it on a doomed entry, if it was previously lazily omitted. |
| 2615 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount - 1; ++i) { | 2623 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount - 1; ++i) { |
| 2616 EXPECT_EQ(net::OK, DoomAllEntries()); | 2624 EXPECT_THAT(DoomAllEntries(), IsOk()); |
| 2617 DoomedEntry(i); | 2625 DoomedEntry(i); |
| 2618 } | 2626 } |
| 2619 } | 2627 } |
| 2620 | 2628 |
| 2621 // Creates an entry with corrupted last byte in stream 0. | 2629 // Creates an entry with corrupted last byte in stream 0. |
| 2622 // Requires SimpleCacheMode. | 2630 // Requires SimpleCacheMode. |
| 2623 bool DiskCacheEntryTest::SimpleCacheMakeBadChecksumEntry(const std::string& key, | 2631 bool DiskCacheEntryTest::SimpleCacheMakeBadChecksumEntry(const std::string& key, |
| 2624 int* data_size) { | 2632 int* data_size) { |
| 2625 disk_cache::Entry* entry = NULL; | 2633 disk_cache::Entry* entry = NULL; |
| 2626 | 2634 |
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2658 SetSimpleCacheMode(); | 2666 SetSimpleCacheMode(); |
| 2659 InitCache(); | 2667 InitCache(); |
| 2660 | 2668 |
| 2661 const char key[] = "the first key"; | 2669 const char key[] = "the first key"; |
| 2662 int size_unused; | 2670 int size_unused; |
| 2663 ASSERT_TRUE(SimpleCacheMakeBadChecksumEntry(key, &size_unused)); | 2671 ASSERT_TRUE(SimpleCacheMakeBadChecksumEntry(key, &size_unused)); |
| 2664 | 2672 |
| 2665 disk_cache::Entry* entry = NULL; | 2673 disk_cache::Entry* entry = NULL; |
| 2666 | 2674 |
| 2667 // Open the entry. | 2675 // Open the entry. |
| 2668 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 2676 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 2669 ScopedEntryPtr entry_closer(entry); | 2677 ScopedEntryPtr entry_closer(entry); |
| 2670 | 2678 |
| 2671 const int kReadBufferSize = 200; | 2679 const int kReadBufferSize = 200; |
| 2672 EXPECT_GE(kReadBufferSize, entry->GetDataSize(1)); | 2680 EXPECT_GE(kReadBufferSize, entry->GetDataSize(1)); |
| 2673 scoped_refptr<net::IOBuffer> read_buffer(new net::IOBuffer(kReadBufferSize)); | 2681 scoped_refptr<net::IOBuffer> read_buffer(new net::IOBuffer(kReadBufferSize)); |
| 2674 EXPECT_EQ(net::ERR_CACHE_CHECKSUM_MISMATCH, | 2682 EXPECT_EQ(net::ERR_CACHE_CHECKSUM_MISMATCH, |
| 2675 ReadData(entry, 1, 0, read_buffer.get(), kReadBufferSize)); | 2683 ReadData(entry, 1, 0, read_buffer.get(), kReadBufferSize)); |
| 2676 } | 2684 } |
| 2677 | 2685 |
| 2678 // Tests that an entry that has had an IO error occur can still be Doomed(). | 2686 // Tests that an entry that has had an IO error occur can still be Doomed(). |
| 2679 TEST_F(DiskCacheEntryTest, SimpleCacheErrorThenDoom) { | 2687 TEST_F(DiskCacheEntryTest, SimpleCacheErrorThenDoom) { |
| 2680 SetSimpleCacheMode(); | 2688 SetSimpleCacheMode(); |
| 2681 InitCache(); | 2689 InitCache(); |
| 2682 | 2690 |
| 2683 const char key[] = "the first key"; | 2691 const char key[] = "the first key"; |
| 2684 int size_unused; | 2692 int size_unused; |
| 2685 ASSERT_TRUE(SimpleCacheMakeBadChecksumEntry(key, &size_unused)); | 2693 ASSERT_TRUE(SimpleCacheMakeBadChecksumEntry(key, &size_unused)); |
| 2686 | 2694 |
| 2687 disk_cache::Entry* entry = NULL; | 2695 disk_cache::Entry* entry = NULL; |
| 2688 | 2696 |
| 2689 // Open the entry, forcing an IO error. | 2697 // Open the entry, forcing an IO error. |
| 2690 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 2698 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 2691 ScopedEntryPtr entry_closer(entry); | 2699 ScopedEntryPtr entry_closer(entry); |
| 2692 | 2700 |
| 2693 const int kReadBufferSize = 200; | 2701 const int kReadBufferSize = 200; |
| 2694 EXPECT_GE(kReadBufferSize, entry->GetDataSize(1)); | 2702 EXPECT_GE(kReadBufferSize, entry->GetDataSize(1)); |
| 2695 scoped_refptr<net::IOBuffer> read_buffer(new net::IOBuffer(kReadBufferSize)); | 2703 scoped_refptr<net::IOBuffer> read_buffer(new net::IOBuffer(kReadBufferSize)); |
| 2696 EXPECT_EQ(net::ERR_CACHE_CHECKSUM_MISMATCH, | 2704 EXPECT_EQ(net::ERR_CACHE_CHECKSUM_MISMATCH, |
| 2697 ReadData(entry, 1, 0, read_buffer.get(), kReadBufferSize)); | 2705 ReadData(entry, 1, 0, read_buffer.get(), kReadBufferSize)); |
| 2698 | 2706 |
| 2699 entry->Doom(); // Should not crash. | 2707 entry->Doom(); // Should not crash. |
| 2700 } | 2708 } |
| 2701 | 2709 |
| 2702 bool TruncatePath(const base::FilePath& file_path, int64_t length) { | 2710 bool TruncatePath(const base::FilePath& file_path, int64_t length) { |
| 2703 base::File file(file_path, base::File::FLAG_WRITE | base::File::FLAG_OPEN); | 2711 base::File file(file_path, base::File::FLAG_WRITE | base::File::FLAG_OPEN); |
| 2704 if (!file.IsValid()) | 2712 if (!file.IsValid()) |
| 2705 return false; | 2713 return false; |
| 2706 return file.SetLength(length); | 2714 return file.SetLength(length); |
| 2707 } | 2715 } |
| 2708 | 2716 |
| 2709 TEST_F(DiskCacheEntryTest, SimpleCacheNoEOF) { | 2717 TEST_F(DiskCacheEntryTest, SimpleCacheNoEOF) { |
| 2710 SetSimpleCacheMode(); | 2718 SetSimpleCacheMode(); |
| 2711 InitCache(); | 2719 InitCache(); |
| 2712 | 2720 |
| 2713 const std::string key("the first key"); | 2721 const std::string key("the first key"); |
| 2714 | 2722 |
| 2715 disk_cache::Entry* entry = NULL; | 2723 disk_cache::Entry* entry = NULL; |
| 2716 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 2724 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 2717 disk_cache::Entry* null = NULL; | 2725 disk_cache::Entry* null = NULL; |
| 2718 EXPECT_NE(null, entry); | 2726 EXPECT_NE(null, entry); |
| 2719 entry->Close(); | 2727 entry->Close(); |
| 2720 entry = NULL; | 2728 entry = NULL; |
| 2721 | 2729 |
| 2722 // Force the entry to flush to disk, so subsequent platform file operations | 2730 // Force the entry to flush to disk, so subsequent platform file operations |
| 2723 // succed. | 2731 // succed. |
| 2724 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 2732 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 2725 entry->Close(); | 2733 entry->Close(); |
| 2726 entry = NULL; | 2734 entry = NULL; |
| 2727 | 2735 |
| 2728 // Truncate the file such that the length isn't sufficient to have an EOF | 2736 // Truncate the file such that the length isn't sufficient to have an EOF |
| 2729 // record. | 2737 // record. |
| 2730 int kTruncationBytes = -static_cast<int>(sizeof(disk_cache::SimpleFileEOF)); | 2738 int kTruncationBytes = -static_cast<int>(sizeof(disk_cache::SimpleFileEOF)); |
| 2731 const base::FilePath entry_path = cache_path_.AppendASCII( | 2739 const base::FilePath entry_path = cache_path_.AppendASCII( |
| 2732 disk_cache::simple_util::GetFilenameFromKeyAndFileIndex(key, 0)); | 2740 disk_cache::simple_util::GetFilenameFromKeyAndFileIndex(key, 0)); |
| 2733 const int64_t invalid_size = disk_cache::simple_util::GetFileSizeFromDataSize( | 2741 const int64_t invalid_size = disk_cache::simple_util::GetFileSizeFromDataSize( |
| 2734 key.size(), kTruncationBytes); | 2742 key.size(), kTruncationBytes); |
| 2735 EXPECT_TRUE(TruncatePath(entry_path, invalid_size)); | 2743 EXPECT_TRUE(TruncatePath(entry_path, invalid_size)); |
| 2736 EXPECT_EQ(net::ERR_FAILED, OpenEntry(key, &entry)); | 2744 EXPECT_THAT(OpenEntry(key, &entry), IsError(net::ERR_FAILED)); |
| 2737 DisableIntegrityCheck(); | 2745 DisableIntegrityCheck(); |
| 2738 } | 2746 } |
| 2739 | 2747 |
| 2740 TEST_F(DiskCacheEntryTest, SimpleCacheNonOptimisticOperationsBasic) { | 2748 TEST_F(DiskCacheEntryTest, SimpleCacheNonOptimisticOperationsBasic) { |
| 2741 // Test sequence: | 2749 // Test sequence: |
| 2742 // Create, Write, Read, Close. | 2750 // Create, Write, Read, Close. |
| 2743 SetCacheType(net::APP_CACHE); // APP_CACHE doesn't use optimistic operations. | 2751 SetCacheType(net::APP_CACHE); // APP_CACHE doesn't use optimistic operations. |
| 2744 SetSimpleCacheMode(); | 2752 SetSimpleCacheMode(); |
| 2745 InitCache(); | 2753 InitCache(); |
| 2746 disk_cache::Entry* const null_entry = NULL; | 2754 disk_cache::Entry* const null_entry = NULL; |
| 2747 | 2755 |
| 2748 disk_cache::Entry* entry = NULL; | 2756 disk_cache::Entry* entry = NULL; |
| 2749 EXPECT_EQ(net::OK, CreateEntry("my key", &entry)); | 2757 EXPECT_THAT(CreateEntry("my key", &entry), IsOk()); |
| 2750 ASSERT_NE(null_entry, entry); | 2758 ASSERT_NE(null_entry, entry); |
| 2751 ScopedEntryPtr entry_closer(entry); | 2759 ScopedEntryPtr entry_closer(entry); |
| 2752 | 2760 |
| 2753 const int kBufferSize = 10; | 2761 const int kBufferSize = 10; |
| 2754 scoped_refptr<net::IOBufferWithSize> write_buffer( | 2762 scoped_refptr<net::IOBufferWithSize> write_buffer( |
| 2755 new net::IOBufferWithSize(kBufferSize)); | 2763 new net::IOBufferWithSize(kBufferSize)); |
| 2756 CacheTestFillBuffer(write_buffer->data(), write_buffer->size(), false); | 2764 CacheTestFillBuffer(write_buffer->data(), write_buffer->size(), false); |
| 2757 EXPECT_EQ( | 2765 EXPECT_EQ( |
| 2758 write_buffer->size(), | 2766 write_buffer->size(), |
| 2759 WriteData(entry, 1, 0, write_buffer.get(), write_buffer->size(), false)); | 2767 WriteData(entry, 1, 0, write_buffer.get(), write_buffer->size(), false)); |
| (...skipping 14 matching lines...) Expand all Loading... |
| 2774 | 2782 |
| 2775 MessageLoopHelper helper; | 2783 MessageLoopHelper helper; |
| 2776 CallbackTest create_callback(&helper, false); | 2784 CallbackTest create_callback(&helper, false); |
| 2777 | 2785 |
| 2778 int expected_callback_runs = 0; | 2786 int expected_callback_runs = 0; |
| 2779 const int kBufferSize = 10; | 2787 const int kBufferSize = 10; |
| 2780 scoped_refptr<net::IOBufferWithSize> write_buffer( | 2788 scoped_refptr<net::IOBufferWithSize> write_buffer( |
| 2781 new net::IOBufferWithSize(kBufferSize)); | 2789 new net::IOBufferWithSize(kBufferSize)); |
| 2782 | 2790 |
| 2783 disk_cache::Entry* entry = NULL; | 2791 disk_cache::Entry* entry = NULL; |
| 2784 EXPECT_EQ(net::OK, CreateEntry("my key", &entry)); | 2792 EXPECT_THAT(CreateEntry("my key", &entry), IsOk()); |
| 2785 ASSERT_NE(null_entry, entry); | 2793 ASSERT_NE(null_entry, entry); |
| 2786 ScopedEntryPtr entry_closer(entry); | 2794 ScopedEntryPtr entry_closer(entry); |
| 2787 | 2795 |
| 2788 CacheTestFillBuffer(write_buffer->data(), write_buffer->size(), false); | 2796 CacheTestFillBuffer(write_buffer->data(), write_buffer->size(), false); |
| 2789 CallbackTest write_callback(&helper, false); | 2797 CallbackTest write_callback(&helper, false); |
| 2790 int ret = entry->WriteData( | 2798 int ret = entry->WriteData( |
| 2791 1, | 2799 1, |
| 2792 0, | 2800 0, |
| 2793 write_buffer.get(), | 2801 write_buffer.get(), |
| 2794 write_buffer->size(), | 2802 write_buffer->size(), |
| 2795 base::Bind(&CallbackTest::Run, base::Unretained(&write_callback)), | 2803 base::Bind(&CallbackTest::Run, base::Unretained(&write_callback)), |
| 2796 false); | 2804 false); |
| 2797 ASSERT_EQ(net::ERR_IO_PENDING, ret); | 2805 ASSERT_THAT(ret, IsError(net::ERR_IO_PENDING)); |
| 2798 helper.WaitUntilCacheIoFinished(++expected_callback_runs); | 2806 helper.WaitUntilCacheIoFinished(++expected_callback_runs); |
| 2799 } | 2807 } |
| 2800 | 2808 |
| 2801 TEST_F(DiskCacheEntryTest, | 2809 TEST_F(DiskCacheEntryTest, |
| 2802 SimpleCacheNonOptimisticOperationsBasicsWithoutWaiting) { | 2810 SimpleCacheNonOptimisticOperationsBasicsWithoutWaiting) { |
| 2803 // Test sequence: | 2811 // Test sequence: |
| 2804 // Create, Write, Read, Close. | 2812 // Create, Write, Read, Close. |
| 2805 SetCacheType(net::APP_CACHE); // APP_CACHE doesn't use optimistic operations. | 2813 SetCacheType(net::APP_CACHE); // APP_CACHE doesn't use optimistic operations. |
| 2806 SetSimpleCacheMode(); | 2814 SetSimpleCacheMode(); |
| 2807 InitCache(); | 2815 InitCache(); |
| 2808 disk_cache::Entry* const null_entry = NULL; | 2816 disk_cache::Entry* const null_entry = NULL; |
| 2809 MessageLoopHelper helper; | 2817 MessageLoopHelper helper; |
| 2810 | 2818 |
| 2811 disk_cache::Entry* entry = NULL; | 2819 disk_cache::Entry* entry = NULL; |
| 2812 // Note that |entry| is only set once CreateEntry() completed which is why we | 2820 // Note that |entry| is only set once CreateEntry() completed which is why we |
| 2813 // have to wait (i.e. use the helper CreateEntry() function). | 2821 // have to wait (i.e. use the helper CreateEntry() function). |
| 2814 EXPECT_EQ(net::OK, CreateEntry("my key", &entry)); | 2822 EXPECT_THAT(CreateEntry("my key", &entry), IsOk()); |
| 2815 ASSERT_NE(null_entry, entry); | 2823 ASSERT_NE(null_entry, entry); |
| 2816 ScopedEntryPtr entry_closer(entry); | 2824 ScopedEntryPtr entry_closer(entry); |
| 2817 | 2825 |
| 2818 const int kBufferSize = 10; | 2826 const int kBufferSize = 10; |
| 2819 scoped_refptr<net::IOBufferWithSize> write_buffer( | 2827 scoped_refptr<net::IOBufferWithSize> write_buffer( |
| 2820 new net::IOBufferWithSize(kBufferSize)); | 2828 new net::IOBufferWithSize(kBufferSize)); |
| 2821 CacheTestFillBuffer(write_buffer->data(), write_buffer->size(), false); | 2829 CacheTestFillBuffer(write_buffer->data(), write_buffer->size(), false); |
| 2822 CallbackTest write_callback(&helper, false); | 2830 CallbackTest write_callback(&helper, false); |
| 2823 int ret = entry->WriteData( | 2831 int ret = entry->WriteData( |
| 2824 1, | 2832 1, |
| 2825 0, | 2833 0, |
| 2826 write_buffer.get(), | 2834 write_buffer.get(), |
| 2827 write_buffer->size(), | 2835 write_buffer->size(), |
| 2828 base::Bind(&CallbackTest::Run, base::Unretained(&write_callback)), | 2836 base::Bind(&CallbackTest::Run, base::Unretained(&write_callback)), |
| 2829 false); | 2837 false); |
| 2830 EXPECT_EQ(net::ERR_IO_PENDING, ret); | 2838 EXPECT_THAT(ret, IsError(net::ERR_IO_PENDING)); |
| 2831 int expected_callback_runs = 1; | 2839 int expected_callback_runs = 1; |
| 2832 | 2840 |
| 2833 scoped_refptr<net::IOBufferWithSize> read_buffer( | 2841 scoped_refptr<net::IOBufferWithSize> read_buffer( |
| 2834 new net::IOBufferWithSize(kBufferSize)); | 2842 new net::IOBufferWithSize(kBufferSize)); |
| 2835 CallbackTest read_callback(&helper, false); | 2843 CallbackTest read_callback(&helper, false); |
| 2836 ret = entry->ReadData( | 2844 ret = entry->ReadData( |
| 2837 1, | 2845 1, |
| 2838 0, | 2846 0, |
| 2839 read_buffer.get(), | 2847 read_buffer.get(), |
| 2840 read_buffer->size(), | 2848 read_buffer->size(), |
| 2841 base::Bind(&CallbackTest::Run, base::Unretained(&read_callback))); | 2849 base::Bind(&CallbackTest::Run, base::Unretained(&read_callback))); |
| 2842 EXPECT_EQ(net::ERR_IO_PENDING, ret); | 2850 EXPECT_THAT(ret, IsError(net::ERR_IO_PENDING)); |
| 2843 ++expected_callback_runs; | 2851 ++expected_callback_runs; |
| 2844 | 2852 |
| 2845 helper.WaitUntilCacheIoFinished(expected_callback_runs); | 2853 helper.WaitUntilCacheIoFinished(expected_callback_runs); |
| 2846 ASSERT_EQ(read_buffer->size(), write_buffer->size()); | 2854 ASSERT_EQ(read_buffer->size(), write_buffer->size()); |
| 2847 EXPECT_EQ( | 2855 EXPECT_EQ( |
| 2848 0, | 2856 0, |
| 2849 memcmp(read_buffer->data(), write_buffer->data(), read_buffer->size())); | 2857 memcmp(read_buffer->data(), write_buffer->data(), read_buffer->size())); |
| 2850 } | 2858 } |
| 2851 | 2859 |
| 2852 TEST_F(DiskCacheEntryTest, SimpleCacheOptimistic) { | 2860 TEST_F(DiskCacheEntryTest, SimpleCacheOptimistic) { |
| (...skipping 135 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2988 disk_cache::Entry* entry = NULL; | 2996 disk_cache::Entry* entry = NULL; |
| 2989 ASSERT_EQ(net::OK, | 2997 ASSERT_EQ(net::OK, |
| 2990 cache_->CreateEntry(key, &entry, net::CompletionCallback())); | 2998 cache_->CreateEntry(key, &entry, net::CompletionCallback())); |
| 2991 EXPECT_NE(null, entry); | 2999 EXPECT_NE(null, entry); |
| 2992 entry->Close(); | 3000 entry->Close(); |
| 2993 | 3001 |
| 2994 net::TestCompletionCallback cb; | 3002 net::TestCompletionCallback cb; |
| 2995 disk_cache::Entry* entry2 = NULL; | 3003 disk_cache::Entry* entry2 = NULL; |
| 2996 ASSERT_EQ(net::ERR_IO_PENDING, | 3004 ASSERT_EQ(net::ERR_IO_PENDING, |
| 2997 cache_->OpenEntry(key, &entry2, cb.callback())); | 3005 cache_->OpenEntry(key, &entry2, cb.callback())); |
| 2998 ASSERT_EQ(net::OK, cb.GetResult(net::ERR_IO_PENDING)); | 3006 ASSERT_THAT(cb.GetResult(net::ERR_IO_PENDING), IsOk()); |
| 2999 ScopedEntryPtr entry_closer(entry2); | 3007 ScopedEntryPtr entry_closer(entry2); |
| 3000 | 3008 |
| 3001 EXPECT_NE(null, entry2); | 3009 EXPECT_NE(null, entry2); |
| 3002 EXPECT_EQ(entry, entry2); | 3010 EXPECT_EQ(entry, entry2); |
| 3003 | 3011 |
| 3004 // Check that we are not leaking. | 3012 // Check that we are not leaking. |
| 3005 EXPECT_TRUE( | 3013 EXPECT_TRUE( |
| 3006 static_cast<disk_cache::SimpleEntryImpl*>(entry2)->HasOneRef()); | 3014 static_cast<disk_cache::SimpleEntryImpl*>(entry2)->HasOneRef()); |
| 3007 } | 3015 } |
| 3008 | 3016 |
| (...skipping 14 matching lines...) Expand all Loading... |
| 3023 ASSERT_EQ(net::OK, | 3031 ASSERT_EQ(net::OK, |
| 3024 cache_->CreateEntry(key, &entry, net::CompletionCallback())); | 3032 cache_->CreateEntry(key, &entry, net::CompletionCallback())); |
| 3025 EXPECT_NE(null, entry); | 3033 EXPECT_NE(null, entry); |
| 3026 entry->Close(); | 3034 entry->Close(); |
| 3027 | 3035 |
| 3028 // Lets do a Write so we block until both the Close and the Write | 3036 // Lets do a Write so we block until both the Close and the Write |
| 3029 // operation finishes. Write must fail since we are writing in a closed entry. | 3037 // operation finishes. Write must fail since we are writing in a closed entry. |
| 3030 EXPECT_EQ( | 3038 EXPECT_EQ( |
| 3031 net::ERR_IO_PENDING, | 3039 net::ERR_IO_PENDING, |
| 3032 entry->WriteData(1, 0, buffer1.get(), kSize1, cb.callback(), false)); | 3040 entry->WriteData(1, 0, buffer1.get(), kSize1, cb.callback(), false)); |
| 3033 EXPECT_EQ(net::ERR_FAILED, cb.GetResult(net::ERR_IO_PENDING)); | 3041 EXPECT_THAT(cb.GetResult(net::ERR_IO_PENDING), IsError(net::ERR_FAILED)); |
| 3034 | 3042 |
| 3035 // Finish running the pending tasks so that we fully complete the close | 3043 // Finish running the pending tasks so that we fully complete the close |
| 3036 // operation and destroy the entry object. | 3044 // operation and destroy the entry object. |
| 3037 base::RunLoop().RunUntilIdle(); | 3045 base::RunLoop().RunUntilIdle(); |
| 3038 | 3046 |
| 3039 // At this point the |entry| must have been destroyed, and called | 3047 // At this point the |entry| must have been destroyed, and called |
| 3040 // RemoveSelfFromBackend(). | 3048 // RemoveSelfFromBackend(). |
| 3041 disk_cache::Entry* entry2 = NULL; | 3049 disk_cache::Entry* entry2 = NULL; |
| 3042 ASSERT_EQ(net::ERR_IO_PENDING, | 3050 ASSERT_EQ(net::ERR_IO_PENDING, |
| 3043 cache_->OpenEntry(key, &entry2, cb.callback())); | 3051 cache_->OpenEntry(key, &entry2, cb.callback())); |
| 3044 ASSERT_EQ(net::OK, cb.GetResult(net::ERR_IO_PENDING)); | 3052 ASSERT_THAT(cb.GetResult(net::ERR_IO_PENDING), IsOk()); |
| 3045 EXPECT_NE(null, entry2); | 3053 EXPECT_NE(null, entry2); |
| 3046 | 3054 |
| 3047 disk_cache::Entry* entry3 = NULL; | 3055 disk_cache::Entry* entry3 = NULL; |
| 3048 ASSERT_EQ(net::ERR_IO_PENDING, | 3056 ASSERT_EQ(net::ERR_IO_PENDING, |
| 3049 cache_->OpenEntry(key, &entry3, cb.callback())); | 3057 cache_->OpenEntry(key, &entry3, cb.callback())); |
| 3050 ASSERT_EQ(net::OK, cb.GetResult(net::ERR_IO_PENDING)); | 3058 ASSERT_THAT(cb.GetResult(net::ERR_IO_PENDING), IsOk()); |
| 3051 EXPECT_NE(null, entry3); | 3059 EXPECT_NE(null, entry3); |
| 3052 EXPECT_EQ(entry2, entry3); | 3060 EXPECT_EQ(entry2, entry3); |
| 3053 entry3->Close(); | 3061 entry3->Close(); |
| 3054 | 3062 |
| 3055 // The previous Close doesn't actually closes the entry since we opened it | 3063 // The previous Close doesn't actually closes the entry since we opened it |
| 3056 // twice, so the next Write operation must succeed and it must be able to | 3064 // twice, so the next Write operation must succeed and it must be able to |
| 3057 // perform it optimistically, since there is no operation running on this | 3065 // perform it optimistically, since there is no operation running on this |
| 3058 // entry. | 3066 // entry. |
| 3059 EXPECT_EQ(kSize1, | 3067 EXPECT_EQ(kSize1, |
| 3060 entry2->WriteData( | 3068 entry2->WriteData( |
| (...skipping 129 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3190 net::TestCompletionCallback cb; | 3198 net::TestCompletionCallback cb; |
| 3191 const int kSize1 = 10; | 3199 const int kSize1 = 10; |
| 3192 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize1)); | 3200 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize1)); |
| 3193 CacheTestFillBuffer(buffer1->data(), kSize1, false); | 3201 CacheTestFillBuffer(buffer1->data(), kSize1, false); |
| 3194 disk_cache::Entry* entry = NULL; | 3202 disk_cache::Entry* entry = NULL; |
| 3195 | 3203 |
| 3196 ASSERT_EQ(net::OK, | 3204 ASSERT_EQ(net::OK, |
| 3197 cache_->CreateEntry(key, &entry, net::CompletionCallback())); | 3205 cache_->CreateEntry(key, &entry, net::CompletionCallback())); |
| 3198 EXPECT_NE(null, entry); | 3206 EXPECT_NE(null, entry); |
| 3199 | 3207 |
| 3200 EXPECT_EQ(net::ERR_IO_PENDING, cache_->DoomEntry(key, cb.callback())); | 3208 EXPECT_THAT(cache_->DoomEntry(key, cb.callback()), |
| 3201 EXPECT_EQ(net::OK, cb.GetResult(net::ERR_IO_PENDING)); | 3209 IsError(net::ERR_IO_PENDING)); |
| 3210 EXPECT_THAT(cb.GetResult(net::ERR_IO_PENDING), IsOk()); |
| 3202 | 3211 |
| 3203 EXPECT_EQ( | 3212 EXPECT_EQ( |
| 3204 kSize1, | 3213 kSize1, |
| 3205 entry->WriteData(0, 0, buffer1.get(), kSize1, cb.callback(), false)); | 3214 entry->WriteData(0, 0, buffer1.get(), kSize1, cb.callback(), false)); |
| 3206 | 3215 |
| 3207 entry->Close(); | 3216 entry->Close(); |
| 3208 | 3217 |
| 3209 // Finish running the pending tasks so that we fully complete the close | 3218 // Finish running the pending tasks so that we fully complete the close |
| 3210 // operation and destroy the entry object. | 3219 // operation and destroy the entry object. |
| 3211 base::RunLoop().RunUntilIdle(); | 3220 base::RunLoop().RunUntilIdle(); |
| (...skipping 27 matching lines...) Expand all Loading... |
| 3239 | 3248 |
| 3240 net::TestCompletionCallback doom_callback; | 3249 net::TestCompletionCallback doom_callback; |
| 3241 EXPECT_EQ(net::ERR_IO_PENDING, | 3250 EXPECT_EQ(net::ERR_IO_PENDING, |
| 3242 cache_->DoomEntry(key, doom_callback.callback())); | 3251 cache_->DoomEntry(key, doom_callback.callback())); |
| 3243 | 3252 |
| 3244 disk_cache::Entry* entry2 = NULL; | 3253 disk_cache::Entry* entry2 = NULL; |
| 3245 ASSERT_EQ(net::OK, | 3254 ASSERT_EQ(net::OK, |
| 3246 create_callback.GetResult( | 3255 create_callback.GetResult( |
| 3247 cache_->CreateEntry(key, &entry2, create_callback.callback()))); | 3256 cache_->CreateEntry(key, &entry2, create_callback.callback()))); |
| 3248 ScopedEntryPtr entry2_closer(entry2); | 3257 ScopedEntryPtr entry2_closer(entry2); |
| 3249 EXPECT_EQ(net::OK, doom_callback.GetResult(net::ERR_IO_PENDING)); | 3258 EXPECT_THAT(doom_callback.GetResult(net::ERR_IO_PENDING), IsOk()); |
| 3250 } | 3259 } |
| 3251 | 3260 |
| 3252 TEST_F(DiskCacheEntryTest, SimpleCacheDoomDoom) { | 3261 TEST_F(DiskCacheEntryTest, SimpleCacheDoomDoom) { |
| 3253 // Test sequence: | 3262 // Test sequence: |
| 3254 // Create, Doom, Create, Doom (1st entry), Open. | 3263 // Create, Doom, Create, Doom (1st entry), Open. |
| 3255 SetSimpleCacheMode(); | 3264 SetSimpleCacheMode(); |
| 3256 InitCache(); | 3265 InitCache(); |
| 3257 disk_cache::Entry* null = NULL; | 3266 disk_cache::Entry* null = NULL; |
| 3258 | 3267 |
| 3259 const char key[] = "the first key"; | 3268 const char key[] = "the first key"; |
| 3260 | 3269 |
| 3261 disk_cache::Entry* entry1 = NULL; | 3270 disk_cache::Entry* entry1 = NULL; |
| 3262 ASSERT_EQ(net::OK, CreateEntry(key, &entry1)); | 3271 ASSERT_THAT(CreateEntry(key, &entry1), IsOk()); |
| 3263 ScopedEntryPtr entry1_closer(entry1); | 3272 ScopedEntryPtr entry1_closer(entry1); |
| 3264 EXPECT_NE(null, entry1); | 3273 EXPECT_NE(null, entry1); |
| 3265 | 3274 |
| 3266 EXPECT_EQ(net::OK, DoomEntry(key)); | 3275 EXPECT_THAT(DoomEntry(key), IsOk()); |
| 3267 | 3276 |
| 3268 disk_cache::Entry* entry2 = NULL; | 3277 disk_cache::Entry* entry2 = NULL; |
| 3269 ASSERT_EQ(net::OK, CreateEntry(key, &entry2)); | 3278 ASSERT_THAT(CreateEntry(key, &entry2), IsOk()); |
| 3270 ScopedEntryPtr entry2_closer(entry2); | 3279 ScopedEntryPtr entry2_closer(entry2); |
| 3271 EXPECT_NE(null, entry2); | 3280 EXPECT_NE(null, entry2); |
| 3272 | 3281 |
| 3273 // Redundantly dooming entry1 should not delete entry2. | 3282 // Redundantly dooming entry1 should not delete entry2. |
| 3274 disk_cache::SimpleEntryImpl* simple_entry1 = | 3283 disk_cache::SimpleEntryImpl* simple_entry1 = |
| 3275 static_cast<disk_cache::SimpleEntryImpl*>(entry1); | 3284 static_cast<disk_cache::SimpleEntryImpl*>(entry1); |
| 3276 net::TestCompletionCallback cb; | 3285 net::TestCompletionCallback cb; |
| 3277 EXPECT_EQ(net::OK, | 3286 EXPECT_EQ(net::OK, |
| 3278 cb.GetResult(simple_entry1->DoomEntry(cb.callback()))); | 3287 cb.GetResult(simple_entry1->DoomEntry(cb.callback()))); |
| 3279 | 3288 |
| 3280 disk_cache::Entry* entry3 = NULL; | 3289 disk_cache::Entry* entry3 = NULL; |
| 3281 ASSERT_EQ(net::OK, OpenEntry(key, &entry3)); | 3290 ASSERT_THAT(OpenEntry(key, &entry3), IsOk()); |
| 3282 ScopedEntryPtr entry3_closer(entry3); | 3291 ScopedEntryPtr entry3_closer(entry3); |
| 3283 EXPECT_NE(null, entry3); | 3292 EXPECT_NE(null, entry3); |
| 3284 } | 3293 } |
| 3285 | 3294 |
| 3286 TEST_F(DiskCacheEntryTest, SimpleCacheDoomCreateDoom) { | 3295 TEST_F(DiskCacheEntryTest, SimpleCacheDoomCreateDoom) { |
| 3287 // Test sequence: | 3296 // Test sequence: |
| 3288 // Create, Doom, Create, Doom. | 3297 // Create, Doom, Create, Doom. |
| 3289 SetSimpleCacheMode(); | 3298 SetSimpleCacheMode(); |
| 3290 InitCache(); | 3299 InitCache(); |
| 3291 | 3300 |
| 3292 disk_cache::Entry* null = NULL; | 3301 disk_cache::Entry* null = NULL; |
| 3293 | 3302 |
| 3294 const char key[] = "the first key"; | 3303 const char key[] = "the first key"; |
| 3295 | 3304 |
| 3296 disk_cache::Entry* entry1 = NULL; | 3305 disk_cache::Entry* entry1 = NULL; |
| 3297 ASSERT_EQ(net::OK, CreateEntry(key, &entry1)); | 3306 ASSERT_THAT(CreateEntry(key, &entry1), IsOk()); |
| 3298 ScopedEntryPtr entry1_closer(entry1); | 3307 ScopedEntryPtr entry1_closer(entry1); |
| 3299 EXPECT_NE(null, entry1); | 3308 EXPECT_NE(null, entry1); |
| 3300 | 3309 |
| 3301 entry1->Doom(); | 3310 entry1->Doom(); |
| 3302 | 3311 |
| 3303 disk_cache::Entry* entry2 = NULL; | 3312 disk_cache::Entry* entry2 = NULL; |
| 3304 ASSERT_EQ(net::OK, CreateEntry(key, &entry2)); | 3313 ASSERT_THAT(CreateEntry(key, &entry2), IsOk()); |
| 3305 ScopedEntryPtr entry2_closer(entry2); | 3314 ScopedEntryPtr entry2_closer(entry2); |
| 3306 EXPECT_NE(null, entry2); | 3315 EXPECT_NE(null, entry2); |
| 3307 | 3316 |
| 3308 entry2->Doom(); | 3317 entry2->Doom(); |
| 3309 | 3318 |
| 3310 // This test passes if it doesn't crash. | 3319 // This test passes if it doesn't crash. |
| 3311 } | 3320 } |
| 3312 | 3321 |
| 3313 TEST_F(DiskCacheEntryTest, SimpleCacheDoomCloseCreateCloseOpen) { | 3322 TEST_F(DiskCacheEntryTest, SimpleCacheDoomCloseCreateCloseOpen) { |
| 3314 // Test sequence: Create, Doom, Close, Create, Close, Open. | 3323 // Test sequence: Create, Doom, Close, Create, Close, Open. |
| 3315 SetSimpleCacheMode(); | 3324 SetSimpleCacheMode(); |
| 3316 InitCache(); | 3325 InitCache(); |
| 3317 | 3326 |
| 3318 disk_cache::Entry* null = NULL; | 3327 disk_cache::Entry* null = NULL; |
| 3319 | 3328 |
| 3320 const char key[] = "this is a key"; | 3329 const char key[] = "this is a key"; |
| 3321 | 3330 |
| 3322 disk_cache::Entry* entry1 = NULL; | 3331 disk_cache::Entry* entry1 = NULL; |
| 3323 ASSERT_EQ(net::OK, CreateEntry(key, &entry1)); | 3332 ASSERT_THAT(CreateEntry(key, &entry1), IsOk()); |
| 3324 ScopedEntryPtr entry1_closer(entry1); | 3333 ScopedEntryPtr entry1_closer(entry1); |
| 3325 EXPECT_NE(null, entry1); | 3334 EXPECT_NE(null, entry1); |
| 3326 | 3335 |
| 3327 entry1->Doom(); | 3336 entry1->Doom(); |
| 3328 entry1_closer.reset(); | 3337 entry1_closer.reset(); |
| 3329 entry1 = NULL; | 3338 entry1 = NULL; |
| 3330 | 3339 |
| 3331 disk_cache::Entry* entry2 = NULL; | 3340 disk_cache::Entry* entry2 = NULL; |
| 3332 ASSERT_EQ(net::OK, CreateEntry(key, &entry2)); | 3341 ASSERT_THAT(CreateEntry(key, &entry2), IsOk()); |
| 3333 ScopedEntryPtr entry2_closer(entry2); | 3342 ScopedEntryPtr entry2_closer(entry2); |
| 3334 EXPECT_NE(null, entry2); | 3343 EXPECT_NE(null, entry2); |
| 3335 | 3344 |
| 3336 entry2_closer.reset(); | 3345 entry2_closer.reset(); |
| 3337 entry2 = NULL; | 3346 entry2 = NULL; |
| 3338 | 3347 |
| 3339 disk_cache::Entry* entry3 = NULL; | 3348 disk_cache::Entry* entry3 = NULL; |
| 3340 ASSERT_EQ(net::OK, OpenEntry(key, &entry3)); | 3349 ASSERT_THAT(OpenEntry(key, &entry3), IsOk()); |
| 3341 ScopedEntryPtr entry3_closer(entry3); | 3350 ScopedEntryPtr entry3_closer(entry3); |
| 3342 EXPECT_NE(null, entry3); | 3351 EXPECT_NE(null, entry3); |
| 3343 } | 3352 } |
| 3344 | 3353 |
| 3345 // Checks that an optimistic Create would fail later on a racing Open. | 3354 // Checks that an optimistic Create would fail later on a racing Open. |
| 3346 TEST_F(DiskCacheEntryTest, SimpleCacheOptimisticCreateFailsOnOpen) { | 3355 TEST_F(DiskCacheEntryTest, SimpleCacheOptimisticCreateFailsOnOpen) { |
| 3347 SetSimpleCacheMode(); | 3356 SetSimpleCacheMode(); |
| 3348 InitCache(); | 3357 InitCache(); |
| 3349 | 3358 |
| 3350 // Create a corrupt file in place of a future entry. Optimistic create should | 3359 // Create a corrupt file in place of a future entry. Optimistic create should |
| 3351 // initially succeed, but realize later that creation failed. | 3360 // initially succeed, but realize later that creation failed. |
| 3352 const std::string key = "the key"; | 3361 const std::string key = "the key"; |
| 3353 net::TestCompletionCallback cb; | 3362 net::TestCompletionCallback cb; |
| 3354 disk_cache::Entry* entry = NULL; | 3363 disk_cache::Entry* entry = NULL; |
| 3355 disk_cache::Entry* entry2 = NULL; | 3364 disk_cache::Entry* entry2 = NULL; |
| 3356 | 3365 |
| 3357 EXPECT_TRUE(disk_cache::simple_util::CreateCorruptFileForTests( | 3366 EXPECT_TRUE(disk_cache::simple_util::CreateCorruptFileForTests( |
| 3358 key, cache_path_)); | 3367 key, cache_path_)); |
| 3359 EXPECT_EQ(net::OK, cache_->CreateEntry(key, &entry, cb.callback())); | 3368 EXPECT_THAT(cache_->CreateEntry(key, &entry, cb.callback()), IsOk()); |
| 3360 ASSERT_TRUE(entry); | 3369 ASSERT_TRUE(entry); |
| 3361 ScopedEntryPtr entry_closer(entry); | 3370 ScopedEntryPtr entry_closer(entry); |
| 3362 ASSERT_NE(net::OK, OpenEntry(key, &entry2)); | 3371 ASSERT_NE(net::OK, OpenEntry(key, &entry2)); |
| 3363 | 3372 |
| 3364 // Check that we are not leaking. | 3373 // Check that we are not leaking. |
| 3365 EXPECT_TRUE( | 3374 EXPECT_TRUE( |
| 3366 static_cast<disk_cache::SimpleEntryImpl*>(entry)->HasOneRef()); | 3375 static_cast<disk_cache::SimpleEntryImpl*>(entry)->HasOneRef()); |
| 3367 | 3376 |
| 3368 DisableIntegrityCheck(); | 3377 DisableIntegrityCheck(); |
| 3369 } | 3378 } |
| 3370 | 3379 |
| 3371 // Tests that old entries are evicted while new entries remain in the index. | 3380 // Tests that old entries are evicted while new entries remain in the index. |
| 3372 // This test relies on non-mandatory properties of the simple Cache Backend: | 3381 // This test relies on non-mandatory properties of the simple Cache Backend: |
| 3373 // LRU eviction, specific values of high-watermark and low-watermark etc. | 3382 // LRU eviction, specific values of high-watermark and low-watermark etc. |
| 3374 // When changing the eviction algorithm, the test will have to be re-engineered. | 3383 // When changing the eviction algorithm, the test will have to be re-engineered. |
| 3375 TEST_F(DiskCacheEntryTest, SimpleCacheEvictOldEntries) { | 3384 TEST_F(DiskCacheEntryTest, SimpleCacheEvictOldEntries) { |
| 3376 const int kMaxSize = 200 * 1024; | 3385 const int kMaxSize = 200 * 1024; |
| 3377 const int kWriteSize = kMaxSize / 10; | 3386 const int kWriteSize = kMaxSize / 10; |
| 3378 const int kNumExtraEntries = 12; | 3387 const int kNumExtraEntries = 12; |
| 3379 SetSimpleCacheMode(); | 3388 SetSimpleCacheMode(); |
| 3380 SetMaxSize(kMaxSize); | 3389 SetMaxSize(kMaxSize); |
| 3381 InitCache(); | 3390 InitCache(); |
| 3382 | 3391 |
| 3383 std::string key1("the first key"); | 3392 std::string key1("the first key"); |
| 3384 disk_cache::Entry* entry; | 3393 disk_cache::Entry* entry; |
| 3385 ASSERT_EQ(net::OK, CreateEntry(key1, &entry)); | 3394 ASSERT_THAT(CreateEntry(key1, &entry), IsOk()); |
| 3386 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kWriteSize)); | 3395 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kWriteSize)); |
| 3387 CacheTestFillBuffer(buffer->data(), kWriteSize, false); | 3396 CacheTestFillBuffer(buffer->data(), kWriteSize, false); |
| 3388 EXPECT_EQ(kWriteSize, | 3397 EXPECT_EQ(kWriteSize, |
| 3389 WriteData(entry, 1, 0, buffer.get(), kWriteSize, false)); | 3398 WriteData(entry, 1, 0, buffer.get(), kWriteSize, false)); |
| 3390 entry->Close(); | 3399 entry->Close(); |
| 3391 AddDelay(); | 3400 AddDelay(); |
| 3392 | 3401 |
| 3393 std::string key2("the key prefix"); | 3402 std::string key2("the key prefix"); |
| 3394 for (int i = 0; i < kNumExtraEntries; i++) { | 3403 for (int i = 0; i < kNumExtraEntries; i++) { |
| 3395 if (i == kNumExtraEntries - 2) { | 3404 if (i == kNumExtraEntries - 2) { |
| 3396 // Create a distinct timestamp for the last two entries. These entries | 3405 // Create a distinct timestamp for the last two entries. These entries |
| 3397 // will be checked for outliving the eviction. | 3406 // will be checked for outliving the eviction. |
| 3398 AddDelay(); | 3407 AddDelay(); |
| 3399 } | 3408 } |
| 3400 ASSERT_EQ(net::OK, CreateEntry(key2 + base::IntToString(i), &entry)); | 3409 ASSERT_THAT(CreateEntry(key2 + base::IntToString(i), &entry), IsOk()); |
| 3401 ScopedEntryPtr entry_closer(entry); | 3410 ScopedEntryPtr entry_closer(entry); |
| 3402 EXPECT_EQ(kWriteSize, | 3411 EXPECT_EQ(kWriteSize, |
| 3403 WriteData(entry, 1, 0, buffer.get(), kWriteSize, false)); | 3412 WriteData(entry, 1, 0, buffer.get(), kWriteSize, false)); |
| 3404 } | 3413 } |
| 3405 | 3414 |
| 3406 // TODO(pasko): Find a way to wait for the eviction task(s) to finish by using | 3415 // TODO(pasko): Find a way to wait for the eviction task(s) to finish by using |
| 3407 // the internal knowledge about |SimpleBackendImpl|. | 3416 // the internal knowledge about |SimpleBackendImpl|. |
| 3408 ASSERT_NE(net::OK, OpenEntry(key1, &entry)) | 3417 ASSERT_NE(net::OK, OpenEntry(key1, &entry)) |
| 3409 << "Should have evicted the old entry"; | 3418 << "Should have evicted the old entry"; |
| 3410 for (int i = 0; i < 2; i++) { | 3419 for (int i = 0; i < 2; i++) { |
| (...skipping 14 matching lines...) Expand all Loading... |
| 3425 SetSimpleCacheMode(); | 3434 SetSimpleCacheMode(); |
| 3426 InitCache(); | 3435 InitCache(); |
| 3427 | 3436 |
| 3428 const char key[] = "the first key"; | 3437 const char key[] = "the first key"; |
| 3429 | 3438 |
| 3430 const int kBufferSize = 1024; | 3439 const int kBufferSize = 1024; |
| 3431 scoped_refptr<net::IOBuffer> write_buffer(new net::IOBuffer(kBufferSize)); | 3440 scoped_refptr<net::IOBuffer> write_buffer(new net::IOBuffer(kBufferSize)); |
| 3432 CacheTestFillBuffer(write_buffer->data(), kBufferSize, false); | 3441 CacheTestFillBuffer(write_buffer->data(), kBufferSize, false); |
| 3433 | 3442 |
| 3434 disk_cache::Entry* entry = NULL; | 3443 disk_cache::Entry* entry = NULL; |
| 3435 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 3444 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 3436 | 3445 |
| 3437 EXPECT_EQ(kBufferSize, | 3446 EXPECT_EQ(kBufferSize, |
| 3438 WriteData(entry, 1, 0, write_buffer.get(), kBufferSize, false)); | 3447 WriteData(entry, 1, 0, write_buffer.get(), kBufferSize, false)); |
| 3439 entry->Close(); | 3448 entry->Close(); |
| 3440 entry = NULL; | 3449 entry = NULL; |
| 3441 | 3450 |
| 3442 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 3451 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 3443 ScopedEntryPtr entry_closer(entry); | 3452 ScopedEntryPtr entry_closer(entry); |
| 3444 | 3453 |
| 3445 MessageLoopHelper helper; | 3454 MessageLoopHelper helper; |
| 3446 int expected = 0; | 3455 int expected = 0; |
| 3447 | 3456 |
| 3448 // Make a short read. | 3457 // Make a short read. |
| 3449 const int kReadBufferSize = 512; | 3458 const int kReadBufferSize = 512; |
| 3450 scoped_refptr<net::IOBuffer> read_buffer(new net::IOBuffer(kReadBufferSize)); | 3459 scoped_refptr<net::IOBuffer> read_buffer(new net::IOBuffer(kReadBufferSize)); |
| 3451 CallbackTest read_callback(&helper, false); | 3460 CallbackTest read_callback(&helper, false); |
| 3452 EXPECT_EQ(net::ERR_IO_PENDING, | 3461 EXPECT_EQ(net::ERR_IO_PENDING, |
| (...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 3538 | 3547 |
| 3539 // Assume the index is not initialized, which is likely, since we are blocking | 3548 // Assume the index is not initialized, which is likely, since we are blocking |
| 3540 // the IO thread from executing the index finalization step. | 3549 // the IO thread from executing the index finalization step. |
| 3541 disk_cache::Entry* entry1; | 3550 disk_cache::Entry* entry1; |
| 3542 net::TestCompletionCallback cb1; | 3551 net::TestCompletionCallback cb1; |
| 3543 disk_cache::Entry* entry2; | 3552 disk_cache::Entry* entry2; |
| 3544 net::TestCompletionCallback cb2; | 3553 net::TestCompletionCallback cb2; |
| 3545 int rv1 = cache_->OpenEntry("key", &entry1, cb1.callback()); | 3554 int rv1 = cache_->OpenEntry("key", &entry1, cb1.callback()); |
| 3546 int rv2 = cache_->CreateEntry("key", &entry2, cb2.callback()); | 3555 int rv2 = cache_->CreateEntry("key", &entry2, cb2.callback()); |
| 3547 | 3556 |
| 3548 EXPECT_EQ(net::ERR_FAILED, cb1.GetResult(rv1)); | 3557 EXPECT_THAT(cb1.GetResult(rv1), IsError(net::ERR_FAILED)); |
| 3549 ASSERT_EQ(net::OK, cb2.GetResult(rv2)); | 3558 ASSERT_THAT(cb2.GetResult(rv2), IsOk()); |
| 3550 entry2->Close(); | 3559 entry2->Close(); |
| 3551 } | 3560 } |
| 3552 | 3561 |
| 3553 // Checking one more scenario of overlapped reading of a bad entry. | 3562 // Checking one more scenario of overlapped reading of a bad entry. |
| 3554 // Differs from the |SimpleCacheMultipleReadersCheckCRC| only by the order of | 3563 // Differs from the |SimpleCacheMultipleReadersCheckCRC| only by the order of |
| 3555 // last two reads. | 3564 // last two reads. |
| 3556 TEST_F(DiskCacheEntryTest, SimpleCacheMultipleReadersCheckCRC2) { | 3565 TEST_F(DiskCacheEntryTest, SimpleCacheMultipleReadersCheckCRC2) { |
| 3557 SetSimpleCacheMode(); | 3566 SetSimpleCacheMode(); |
| 3558 InitCache(); | 3567 InitCache(); |
| 3559 | 3568 |
| 3560 const char key[] = "key"; | 3569 const char key[] = "key"; |
| 3561 int size; | 3570 int size; |
| 3562 ASSERT_TRUE(SimpleCacheMakeBadChecksumEntry(key, &size)); | 3571 ASSERT_TRUE(SimpleCacheMakeBadChecksumEntry(key, &size)); |
| 3563 | 3572 |
| 3564 scoped_refptr<net::IOBuffer> read_buffer1(new net::IOBuffer(size)); | 3573 scoped_refptr<net::IOBuffer> read_buffer1(new net::IOBuffer(size)); |
| 3565 scoped_refptr<net::IOBuffer> read_buffer2(new net::IOBuffer(size)); | 3574 scoped_refptr<net::IOBuffer> read_buffer2(new net::IOBuffer(size)); |
| 3566 | 3575 |
| 3567 // Advance the first reader a little. | 3576 // Advance the first reader a little. |
| 3568 disk_cache::Entry* entry = NULL; | 3577 disk_cache::Entry* entry = NULL; |
| 3569 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 3578 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 3570 ScopedEntryPtr entry_closer(entry); | 3579 ScopedEntryPtr entry_closer(entry); |
| 3571 EXPECT_EQ(1, ReadData(entry, 1, 0, read_buffer1.get(), 1)); | 3580 EXPECT_EQ(1, ReadData(entry, 1, 0, read_buffer1.get(), 1)); |
| 3572 | 3581 |
| 3573 // Advance the 2nd reader by the same amount. | 3582 // Advance the 2nd reader by the same amount. |
| 3574 disk_cache::Entry* entry2 = NULL; | 3583 disk_cache::Entry* entry2 = NULL; |
| 3575 EXPECT_EQ(net::OK, OpenEntry(key, &entry2)); | 3584 EXPECT_THAT(OpenEntry(key, &entry2), IsOk()); |
| 3576 ScopedEntryPtr entry2_closer(entry2); | 3585 ScopedEntryPtr entry2_closer(entry2); |
| 3577 EXPECT_EQ(1, ReadData(entry2, 1, 0, read_buffer2.get(), 1)); | 3586 EXPECT_EQ(1, ReadData(entry2, 1, 0, read_buffer2.get(), 1)); |
| 3578 | 3587 |
| 3579 // Continue reading 1st. | 3588 // Continue reading 1st. |
| 3580 EXPECT_GT(0, ReadData(entry, 1, 1, read_buffer1.get(), size)); | 3589 EXPECT_GT(0, ReadData(entry, 1, 1, read_buffer1.get(), size)); |
| 3581 | 3590 |
| 3582 // This read should fail as well because we have previous read failures. | 3591 // This read should fail as well because we have previous read failures. |
| 3583 EXPECT_GT(0, ReadData(entry2, 1, 1, read_buffer2.get(), 1)); | 3592 EXPECT_GT(0, ReadData(entry2, 1, 1, read_buffer2.get(), 1)); |
| 3584 DisableIntegrityCheck(); | 3593 DisableIntegrityCheck(); |
| 3585 } | 3594 } |
| 3586 | 3595 |
| 3587 // Test if we can sequentially read each subset of the data until all the data | 3596 // Test if we can sequentially read each subset of the data until all the data |
| 3588 // is read, then the CRC is calculated correctly and the reads are successful. | 3597 // is read, then the CRC is calculated correctly and the reads are successful. |
| 3589 TEST_F(DiskCacheEntryTest, SimpleCacheReadCombineCRC) { | 3598 TEST_F(DiskCacheEntryTest, SimpleCacheReadCombineCRC) { |
| 3590 // Test sequence: | 3599 // Test sequence: |
| 3591 // Create, Write, Read (first half of data), Read (second half of data), | 3600 // Create, Write, Read (first half of data), Read (second half of data), |
| 3592 // Close. | 3601 // Close. |
| 3593 SetSimpleCacheMode(); | 3602 SetSimpleCacheMode(); |
| 3594 InitCache(); | 3603 InitCache(); |
| 3595 disk_cache::Entry* null = NULL; | 3604 disk_cache::Entry* null = NULL; |
| 3596 const char key[] = "the first key"; | 3605 const char key[] = "the first key"; |
| 3597 | 3606 |
| 3598 const int kHalfSize = 200; | 3607 const int kHalfSize = 200; |
| 3599 const int kSize = 2 * kHalfSize; | 3608 const int kSize = 2 * kHalfSize; |
| 3600 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize)); | 3609 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize)); |
| 3601 CacheTestFillBuffer(buffer1->data(), kSize, false); | 3610 CacheTestFillBuffer(buffer1->data(), kSize, false); |
| 3602 disk_cache::Entry* entry = NULL; | 3611 disk_cache::Entry* entry = NULL; |
| 3603 | 3612 |
| 3604 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 3613 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 3605 EXPECT_NE(null, entry); | 3614 EXPECT_NE(null, entry); |
| 3606 | 3615 |
| 3607 EXPECT_EQ(kSize, WriteData(entry, 1, 0, buffer1.get(), kSize, false)); | 3616 EXPECT_EQ(kSize, WriteData(entry, 1, 0, buffer1.get(), kSize, false)); |
| 3608 entry->Close(); | 3617 entry->Close(); |
| 3609 | 3618 |
| 3610 disk_cache::Entry* entry2 = NULL; | 3619 disk_cache::Entry* entry2 = NULL; |
| 3611 ASSERT_EQ(net::OK, OpenEntry(key, &entry2)); | 3620 ASSERT_THAT(OpenEntry(key, &entry2), IsOk()); |
| 3612 EXPECT_EQ(entry, entry2); | 3621 EXPECT_EQ(entry, entry2); |
| 3613 | 3622 |
| 3614 // Read the first half of the data. | 3623 // Read the first half of the data. |
| 3615 int offset = 0; | 3624 int offset = 0; |
| 3616 int buf_len = kHalfSize; | 3625 int buf_len = kHalfSize; |
| 3617 scoped_refptr<net::IOBuffer> buffer1_read1(new net::IOBuffer(buf_len)); | 3626 scoped_refptr<net::IOBuffer> buffer1_read1(new net::IOBuffer(buf_len)); |
| 3618 EXPECT_EQ(buf_len, ReadData(entry2, 1, offset, buffer1_read1.get(), buf_len)); | 3627 EXPECT_EQ(buf_len, ReadData(entry2, 1, offset, buffer1_read1.get(), buf_len)); |
| 3619 EXPECT_EQ(0, memcmp(buffer1->data(), buffer1_read1->data(), buf_len)); | 3628 EXPECT_EQ(0, memcmp(buffer1->data(), buffer1_read1->data(), buf_len)); |
| 3620 | 3629 |
| 3621 // Read the second half of the data. | 3630 // Read the second half of the data. |
| (...skipping 25 matching lines...) Expand all Loading... |
| 3647 | 3656 |
| 3648 const int kHalfSize = 200; | 3657 const int kHalfSize = 200; |
| 3649 const int kSize = 2 * kHalfSize; | 3658 const int kSize = 2 * kHalfSize; |
| 3650 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize)); | 3659 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize)); |
| 3651 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize)); | 3660 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize)); |
| 3652 CacheTestFillBuffer(buffer1->data(), kSize, false); | 3661 CacheTestFillBuffer(buffer1->data(), kSize, false); |
| 3653 char* buffer1_data = buffer1->data() + kHalfSize; | 3662 char* buffer1_data = buffer1->data() + kHalfSize; |
| 3654 memcpy(buffer2->data(), buffer1_data, kHalfSize); | 3663 memcpy(buffer2->data(), buffer1_data, kHalfSize); |
| 3655 | 3664 |
| 3656 disk_cache::Entry* entry = NULL; | 3665 disk_cache::Entry* entry = NULL; |
| 3657 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 3666 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 3658 entry->Close(); | 3667 entry->Close(); |
| 3659 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { | 3668 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { |
| 3660 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 3669 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 3661 EXPECT_NE(null, entry); | 3670 EXPECT_NE(null, entry); |
| 3662 | 3671 |
| 3663 int offset = kHalfSize; | 3672 int offset = kHalfSize; |
| 3664 int buf_len = kHalfSize; | 3673 int buf_len = kHalfSize; |
| 3665 | 3674 |
| 3666 EXPECT_EQ(buf_len, | 3675 EXPECT_EQ(buf_len, |
| 3667 WriteData(entry, i, offset, buffer2.get(), buf_len, false)); | 3676 WriteData(entry, i, offset, buffer2.get(), buf_len, false)); |
| 3668 offset = 0; | 3677 offset = 0; |
| 3669 buf_len = kHalfSize; | 3678 buf_len = kHalfSize; |
| 3670 EXPECT_EQ(buf_len, | 3679 EXPECT_EQ(buf_len, |
| 3671 WriteData(entry, i, offset, buffer1.get(), buf_len, false)); | 3680 WriteData(entry, i, offset, buffer1.get(), buf_len, false)); |
| 3672 entry->Close(); | 3681 entry->Close(); |
| 3673 | 3682 |
| 3674 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 3683 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 3675 | 3684 |
| 3676 scoped_refptr<net::IOBuffer> buffer1_read1(new net::IOBuffer(kSize)); | 3685 scoped_refptr<net::IOBuffer> buffer1_read1(new net::IOBuffer(kSize)); |
| 3677 EXPECT_EQ(kSize, ReadData(entry, i, 0, buffer1_read1.get(), kSize)); | 3686 EXPECT_EQ(kSize, ReadData(entry, i, 0, buffer1_read1.get(), kSize)); |
| 3678 EXPECT_EQ(0, memcmp(buffer1->data(), buffer1_read1->data(), kSize)); | 3687 EXPECT_EQ(0, memcmp(buffer1->data(), buffer1_read1->data(), kSize)); |
| 3679 // Check that we are not leaking. | 3688 // Check that we are not leaking. |
| 3680 ASSERT_NE(entry, null); | 3689 ASSERT_NE(entry, null); |
| 3681 EXPECT_TRUE(static_cast<disk_cache::SimpleEntryImpl*>(entry)->HasOneRef()); | 3690 EXPECT_TRUE(static_cast<disk_cache::SimpleEntryImpl*>(entry)->HasOneRef()); |
| 3682 entry->Close(); | 3691 entry->Close(); |
| 3683 } | 3692 } |
| 3684 } | 3693 } |
| 3685 | 3694 |
| 3686 // Test that changing stream1 size does not affect stream0 (stream0 and stream1 | 3695 // Test that changing stream1 size does not affect stream0 (stream0 and stream1 |
| 3687 // are stored in the same file in Simple Cache). | 3696 // are stored in the same file in Simple Cache). |
| 3688 TEST_F(DiskCacheEntryTest, SimpleCacheStream1SizeChanges) { | 3697 TEST_F(DiskCacheEntryTest, SimpleCacheStream1SizeChanges) { |
| 3689 SetSimpleCacheMode(); | 3698 SetSimpleCacheMode(); |
| 3690 InitCache(); | 3699 InitCache(); |
| 3691 disk_cache::Entry* entry = NULL; | 3700 disk_cache::Entry* entry = NULL; |
| 3692 const std::string key("the key"); | 3701 const std::string key("the key"); |
| 3693 const int kSize = 100; | 3702 const int kSize = 100; |
| 3694 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize)); | 3703 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize)); |
| 3695 scoped_refptr<net::IOBuffer> buffer_read(new net::IOBuffer(kSize)); | 3704 scoped_refptr<net::IOBuffer> buffer_read(new net::IOBuffer(kSize)); |
| 3696 CacheTestFillBuffer(buffer->data(), kSize, false); | 3705 CacheTestFillBuffer(buffer->data(), kSize, false); |
| 3697 | 3706 |
| 3698 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 3707 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 3699 EXPECT_TRUE(entry); | 3708 EXPECT_TRUE(entry); |
| 3700 | 3709 |
| 3701 // Write something into stream0. | 3710 // Write something into stream0. |
| 3702 EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer.get(), kSize, false)); | 3711 EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer.get(), kSize, false)); |
| 3703 EXPECT_EQ(kSize, ReadData(entry, 0, 0, buffer_read.get(), kSize)); | 3712 EXPECT_EQ(kSize, ReadData(entry, 0, 0, buffer_read.get(), kSize)); |
| 3704 EXPECT_EQ(0, memcmp(buffer->data(), buffer_read->data(), kSize)); | 3713 EXPECT_EQ(0, memcmp(buffer->data(), buffer_read->data(), kSize)); |
| 3705 entry->Close(); | 3714 entry->Close(); |
| 3706 | 3715 |
| 3707 // Extend stream1. | 3716 // Extend stream1. |
| 3708 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 3717 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 3709 int stream1_size = 100; | 3718 int stream1_size = 100; |
| 3710 EXPECT_EQ(0, WriteData(entry, 1, stream1_size, buffer.get(), 0, false)); | 3719 EXPECT_EQ(0, WriteData(entry, 1, stream1_size, buffer.get(), 0, false)); |
| 3711 EXPECT_EQ(stream1_size, entry->GetDataSize(1)); | 3720 EXPECT_EQ(stream1_size, entry->GetDataSize(1)); |
| 3712 entry->Close(); | 3721 entry->Close(); |
| 3713 | 3722 |
| 3714 // Check that stream0 data has not been modified and that the EOF record for | 3723 // Check that stream0 data has not been modified and that the EOF record for |
| 3715 // stream 0 contains a crc. | 3724 // stream 0 contains a crc. |
| 3716 // The entry needs to be reopened before checking the crc: Open will perform | 3725 // The entry needs to be reopened before checking the crc: Open will perform |
| 3717 // the synchronization with the previous Close. This ensures the EOF records | 3726 // the synchronization with the previous Close. This ensures the EOF records |
| 3718 // have been written to disk before we attempt to read them independently. | 3727 // have been written to disk before we attempt to read them independently. |
| 3719 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 3728 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 3720 base::FilePath entry_file0_path = cache_path_.AppendASCII( | 3729 base::FilePath entry_file0_path = cache_path_.AppendASCII( |
| 3721 disk_cache::simple_util::GetFilenameFromKeyAndFileIndex(key, 0)); | 3730 disk_cache::simple_util::GetFilenameFromKeyAndFileIndex(key, 0)); |
| 3722 base::File entry_file0(entry_file0_path, | 3731 base::File entry_file0(entry_file0_path, |
| 3723 base::File::FLAG_READ | base::File::FLAG_OPEN); | 3732 base::File::FLAG_READ | base::File::FLAG_OPEN); |
| 3724 ASSERT_TRUE(entry_file0.IsValid()); | 3733 ASSERT_TRUE(entry_file0.IsValid()); |
| 3725 | 3734 |
| 3726 int data_size[disk_cache::kSimpleEntryStreamCount] = {kSize, stream1_size, 0}; | 3735 int data_size[disk_cache::kSimpleEntryStreamCount] = {kSize, stream1_size, 0}; |
| 3727 int sparse_data_size = 0; | 3736 int sparse_data_size = 0; |
| 3728 disk_cache::SimpleEntryStat entry_stat( | 3737 disk_cache::SimpleEntryStat entry_stat( |
| 3729 base::Time::Now(), base::Time::Now(), data_size, sparse_data_size); | 3738 base::Time::Now(), base::Time::Now(), data_size, sparse_data_size); |
| (...skipping 11 matching lines...) Expand all Loading... |
| 3741 EXPECT_EQ(0, memcmp(buffer->data(), buffer_read->data(), kSize)); | 3750 EXPECT_EQ(0, memcmp(buffer->data(), buffer_read->data(), kSize)); |
| 3742 | 3751 |
| 3743 // Shrink stream1. | 3752 // Shrink stream1. |
| 3744 stream1_size = 50; | 3753 stream1_size = 50; |
| 3745 EXPECT_EQ(0, WriteData(entry, 1, stream1_size, buffer.get(), 0, true)); | 3754 EXPECT_EQ(0, WriteData(entry, 1, stream1_size, buffer.get(), 0, true)); |
| 3746 EXPECT_EQ(stream1_size, entry->GetDataSize(1)); | 3755 EXPECT_EQ(stream1_size, entry->GetDataSize(1)); |
| 3747 entry->Close(); | 3756 entry->Close(); |
| 3748 | 3757 |
| 3749 // Check that stream0 data has not been modified. | 3758 // Check that stream0 data has not been modified. |
| 3750 buffer_read = new net::IOBuffer(kSize); | 3759 buffer_read = new net::IOBuffer(kSize); |
| 3751 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 3760 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 3752 EXPECT_EQ(kSize, ReadData(entry, 0, 0, buffer_read.get(), kSize)); | 3761 EXPECT_EQ(kSize, ReadData(entry, 0, 0, buffer_read.get(), kSize)); |
| 3753 EXPECT_EQ(0, memcmp(buffer->data(), buffer_read->data(), kSize)); | 3762 EXPECT_EQ(0, memcmp(buffer->data(), buffer_read->data(), kSize)); |
| 3754 entry->Close(); | 3763 entry->Close(); |
| 3755 entry = NULL; | 3764 entry = NULL; |
| 3756 } | 3765 } |
| 3757 | 3766 |
| 3758 // Test that writing within the range for which the crc has already been | 3767 // Test that writing within the range for which the crc has already been |
| 3759 // computed will properly invalidate the computed crc. | 3768 // computed will properly invalidate the computed crc. |
| 3760 TEST_F(DiskCacheEntryTest, SimpleCacheCRCRewrite) { | 3769 TEST_F(DiskCacheEntryTest, SimpleCacheCRCRewrite) { |
| 3761 // Test sequence: | 3770 // Test sequence: |
| 3762 // Create, Write (big data), Write (small data in the middle), Close. | 3771 // Create, Write (big data), Write (small data in the middle), Close. |
| 3763 // Open, Read (all), Close. | 3772 // Open, Read (all), Close. |
| 3764 SetSimpleCacheMode(); | 3773 SetSimpleCacheMode(); |
| 3765 InitCache(); | 3774 InitCache(); |
| 3766 disk_cache::Entry* null = NULL; | 3775 disk_cache::Entry* null = NULL; |
| 3767 const char key[] = "the first key"; | 3776 const char key[] = "the first key"; |
| 3768 | 3777 |
| 3769 const int kHalfSize = 200; | 3778 const int kHalfSize = 200; |
| 3770 const int kSize = 2 * kHalfSize; | 3779 const int kSize = 2 * kHalfSize; |
| 3771 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize)); | 3780 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize)); |
| 3772 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kHalfSize)); | 3781 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kHalfSize)); |
| 3773 CacheTestFillBuffer(buffer1->data(), kSize, false); | 3782 CacheTestFillBuffer(buffer1->data(), kSize, false); |
| 3774 CacheTestFillBuffer(buffer2->data(), kHalfSize, false); | 3783 CacheTestFillBuffer(buffer2->data(), kHalfSize, false); |
| 3775 | 3784 |
| 3776 disk_cache::Entry* entry = NULL; | 3785 disk_cache::Entry* entry = NULL; |
| 3777 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 3786 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 3778 EXPECT_NE(null, entry); | 3787 EXPECT_NE(null, entry); |
| 3779 entry->Close(); | 3788 entry->Close(); |
| 3780 | 3789 |
| 3781 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { | 3790 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { |
| 3782 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 3791 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 3783 int offset = 0; | 3792 int offset = 0; |
| 3784 int buf_len = kSize; | 3793 int buf_len = kSize; |
| 3785 | 3794 |
| 3786 EXPECT_EQ(buf_len, | 3795 EXPECT_EQ(buf_len, |
| 3787 WriteData(entry, i, offset, buffer1.get(), buf_len, false)); | 3796 WriteData(entry, i, offset, buffer1.get(), buf_len, false)); |
| 3788 offset = kHalfSize; | 3797 offset = kHalfSize; |
| 3789 buf_len = kHalfSize; | 3798 buf_len = kHalfSize; |
| 3790 EXPECT_EQ(buf_len, | 3799 EXPECT_EQ(buf_len, |
| 3791 WriteData(entry, i, offset, buffer2.get(), buf_len, false)); | 3800 WriteData(entry, i, offset, buffer2.get(), buf_len, false)); |
| 3792 entry->Close(); | 3801 entry->Close(); |
| 3793 | 3802 |
| 3794 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 3803 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 3795 | 3804 |
| 3796 scoped_refptr<net::IOBuffer> buffer1_read1(new net::IOBuffer(kSize)); | 3805 scoped_refptr<net::IOBuffer> buffer1_read1(new net::IOBuffer(kSize)); |
| 3797 EXPECT_EQ(kSize, ReadData(entry, i, 0, buffer1_read1.get(), kSize)); | 3806 EXPECT_EQ(kSize, ReadData(entry, i, 0, buffer1_read1.get(), kSize)); |
| 3798 EXPECT_EQ(0, memcmp(buffer1->data(), buffer1_read1->data(), kHalfSize)); | 3807 EXPECT_EQ(0, memcmp(buffer1->data(), buffer1_read1->data(), kHalfSize)); |
| 3799 EXPECT_EQ( | 3808 EXPECT_EQ( |
| 3800 0, | 3809 0, |
| 3801 memcmp(buffer2->data(), buffer1_read1->data() + kHalfSize, kHalfSize)); | 3810 memcmp(buffer2->data(), buffer1_read1->data() + kHalfSize, kHalfSize)); |
| 3802 | 3811 |
| 3803 entry->Close(); | 3812 entry->Close(); |
| 3804 } | 3813 } |
| (...skipping 19 matching lines...) Expand all Loading... |
| 3824 TEST_F(DiskCacheEntryTest, SimpleCacheOmittedThirdStream1) { | 3833 TEST_F(DiskCacheEntryTest, SimpleCacheOmittedThirdStream1) { |
| 3825 SetSimpleCacheMode(); | 3834 SetSimpleCacheMode(); |
| 3826 InitCache(); | 3835 InitCache(); |
| 3827 | 3836 |
| 3828 const char key[] = "key"; | 3837 const char key[] = "key"; |
| 3829 | 3838 |
| 3830 disk_cache::Entry* entry; | 3839 disk_cache::Entry* entry; |
| 3831 | 3840 |
| 3832 // Create entry and close without writing: third stream file should be | 3841 // Create entry and close without writing: third stream file should be |
| 3833 // omitted, since the stream is empty. | 3842 // omitted, since the stream is empty. |
| 3834 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 3843 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 3835 entry->Close(); | 3844 entry->Close(); |
| 3836 EXPECT_FALSE(SimpleCacheThirdStreamFileExists(key)); | 3845 EXPECT_FALSE(SimpleCacheThirdStreamFileExists(key)); |
| 3837 | 3846 |
| 3838 SyncDoomEntry(key); | 3847 SyncDoomEntry(key); |
| 3839 EXPECT_FALSE(SimpleCacheThirdStreamFileExists(key)); | 3848 EXPECT_FALSE(SimpleCacheThirdStreamFileExists(key)); |
| 3840 } | 3849 } |
| 3841 | 3850 |
| 3842 // Check that a newly-created entry with only a single zero-offset, zero-length | 3851 // Check that a newly-created entry with only a single zero-offset, zero-length |
| 3843 // write omits the third stream file. | 3852 // write omits the third stream file. |
| 3844 TEST_F(DiskCacheEntryTest, SimpleCacheOmittedThirdStream2) { | 3853 TEST_F(DiskCacheEntryTest, SimpleCacheOmittedThirdStream2) { |
| 3845 SetSimpleCacheMode(); | 3854 SetSimpleCacheMode(); |
| 3846 InitCache(); | 3855 InitCache(); |
| 3847 | 3856 |
| 3848 const int kHalfSize = 8; | 3857 const int kHalfSize = 8; |
| 3849 const int kSize = kHalfSize * 2; | 3858 const int kSize = kHalfSize * 2; |
| 3850 const char key[] = "key"; | 3859 const char key[] = "key"; |
| 3851 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize)); | 3860 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize)); |
| 3852 CacheTestFillBuffer(buffer->data(), kHalfSize, false); | 3861 CacheTestFillBuffer(buffer->data(), kHalfSize, false); |
| 3853 | 3862 |
| 3854 disk_cache::Entry* entry; | 3863 disk_cache::Entry* entry; |
| 3855 | 3864 |
| 3856 // Create entry, write empty buffer to third stream, and close: third stream | 3865 // Create entry, write empty buffer to third stream, and close: third stream |
| 3857 // should still be omitted, since the entry ignores writes that don't modify | 3866 // should still be omitted, since the entry ignores writes that don't modify |
| 3858 // data or change the length. | 3867 // data or change the length. |
| 3859 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 3868 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 3860 EXPECT_EQ(0, WriteData(entry, 2, 0, buffer.get(), 0, true)); | 3869 EXPECT_EQ(0, WriteData(entry, 2, 0, buffer.get(), 0, true)); |
| 3861 entry->Close(); | 3870 entry->Close(); |
| 3862 EXPECT_FALSE(SimpleCacheThirdStreamFileExists(key)); | 3871 EXPECT_FALSE(SimpleCacheThirdStreamFileExists(key)); |
| 3863 | 3872 |
| 3864 SyncDoomEntry(key); | 3873 SyncDoomEntry(key); |
| 3865 EXPECT_FALSE(SimpleCacheThirdStreamFileExists(key)); | 3874 EXPECT_FALSE(SimpleCacheThirdStreamFileExists(key)); |
| 3866 } | 3875 } |
| 3867 | 3876 |
| 3868 // Check that we can read back data written to the third stream. | 3877 // Check that we can read back data written to the third stream. |
| 3869 TEST_F(DiskCacheEntryTest, SimpleCacheOmittedThirdStream3) { | 3878 TEST_F(DiskCacheEntryTest, SimpleCacheOmittedThirdStream3) { |
| 3870 SetSimpleCacheMode(); | 3879 SetSimpleCacheMode(); |
| 3871 InitCache(); | 3880 InitCache(); |
| 3872 | 3881 |
| 3873 const int kHalfSize = 8; | 3882 const int kHalfSize = 8; |
| 3874 const int kSize = kHalfSize * 2; | 3883 const int kSize = kHalfSize * 2; |
| 3875 const char key[] = "key"; | 3884 const char key[] = "key"; |
| 3876 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize)); | 3885 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize)); |
| 3877 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize)); | 3886 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize)); |
| 3878 CacheTestFillBuffer(buffer1->data(), kHalfSize, false); | 3887 CacheTestFillBuffer(buffer1->data(), kHalfSize, false); |
| 3879 | 3888 |
| 3880 disk_cache::Entry* entry; | 3889 disk_cache::Entry* entry; |
| 3881 | 3890 |
| 3882 // Create entry, write data to third stream, and close: third stream should | 3891 // Create entry, write data to third stream, and close: third stream should |
| 3883 // not be omitted, since it contains data. Re-open entry and ensure there | 3892 // not be omitted, since it contains data. Re-open entry and ensure there |
| 3884 // are that many bytes in the third stream. | 3893 // are that many bytes in the third stream. |
| 3885 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 3894 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 3886 EXPECT_EQ(kHalfSize, WriteData(entry, 2, 0, buffer1.get(), kHalfSize, true)); | 3895 EXPECT_EQ(kHalfSize, WriteData(entry, 2, 0, buffer1.get(), kHalfSize, true)); |
| 3887 entry->Close(); | 3896 entry->Close(); |
| 3888 EXPECT_TRUE(SimpleCacheThirdStreamFileExists(key)); | 3897 EXPECT_TRUE(SimpleCacheThirdStreamFileExists(key)); |
| 3889 | 3898 |
| 3890 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 3899 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 3891 EXPECT_EQ(kHalfSize, ReadData(entry, 2, 0, buffer2.get(), kSize)); | 3900 EXPECT_EQ(kHalfSize, ReadData(entry, 2, 0, buffer2.get(), kSize)); |
| 3892 EXPECT_EQ(0, memcmp(buffer1->data(), buffer2->data(), kHalfSize)); | 3901 EXPECT_EQ(0, memcmp(buffer1->data(), buffer2->data(), kHalfSize)); |
| 3893 entry->Close(); | 3902 entry->Close(); |
| 3894 EXPECT_TRUE(SimpleCacheThirdStreamFileExists(key)); | 3903 EXPECT_TRUE(SimpleCacheThirdStreamFileExists(key)); |
| 3895 | 3904 |
| 3896 SyncDoomEntry(key); | 3905 SyncDoomEntry(key); |
| 3897 EXPECT_FALSE(SimpleCacheThirdStreamFileExists(key)); | 3906 EXPECT_FALSE(SimpleCacheThirdStreamFileExists(key)); |
| 3898 } | 3907 } |
| 3899 | 3908 |
| 3900 // Check that we remove the third stream file upon opening an entry and finding | 3909 // Check that we remove the third stream file upon opening an entry and finding |
| (...skipping 10 matching lines...) Expand all Loading... |
| 3911 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize)); | 3920 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize)); |
| 3912 CacheTestFillBuffer(buffer1->data(), kHalfSize, false); | 3921 CacheTestFillBuffer(buffer1->data(), kHalfSize, false); |
| 3913 | 3922 |
| 3914 disk_cache::Entry* entry; | 3923 disk_cache::Entry* entry; |
| 3915 | 3924 |
| 3916 // Create entry, write data to third stream, truncate third stream back to | 3925 // Create entry, write data to third stream, truncate third stream back to |
| 3917 // empty, and close: third stream will not initially be omitted, since entry | 3926 // empty, and close: third stream will not initially be omitted, since entry |
| 3918 // creates the file when the first significant write comes in, and only | 3927 // creates the file when the first significant write comes in, and only |
| 3919 // removes it on open if it is empty. Reopen, ensure that the file is | 3928 // removes it on open if it is empty. Reopen, ensure that the file is |
| 3920 // deleted, and that there's no data in the third stream. | 3929 // deleted, and that there's no data in the third stream. |
| 3921 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 3930 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 3922 EXPECT_EQ(kHalfSize, WriteData(entry, 2, 0, buffer1.get(), kHalfSize, true)); | 3931 EXPECT_EQ(kHalfSize, WriteData(entry, 2, 0, buffer1.get(), kHalfSize, true)); |
| 3923 EXPECT_EQ(0, WriteData(entry, 2, 0, buffer1.get(), 0, true)); | 3932 EXPECT_EQ(0, WriteData(entry, 2, 0, buffer1.get(), 0, true)); |
| 3924 entry->Close(); | 3933 entry->Close(); |
| 3925 EXPECT_TRUE(SimpleCacheThirdStreamFileExists(key)); | 3934 EXPECT_TRUE(SimpleCacheThirdStreamFileExists(key)); |
| 3926 | 3935 |
| 3927 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 3936 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 3928 EXPECT_FALSE(SimpleCacheThirdStreamFileExists(key)); | 3937 EXPECT_FALSE(SimpleCacheThirdStreamFileExists(key)); |
| 3929 EXPECT_EQ(0, ReadData(entry, 2, 0, buffer2.get(), kSize)); | 3938 EXPECT_EQ(0, ReadData(entry, 2, 0, buffer2.get(), kSize)); |
| 3930 entry->Close(); | 3939 entry->Close(); |
| 3931 EXPECT_FALSE(SimpleCacheThirdStreamFileExists(key)); | 3940 EXPECT_FALSE(SimpleCacheThirdStreamFileExists(key)); |
| 3932 | 3941 |
| 3933 SyncDoomEntry(key); | 3942 SyncDoomEntry(key); |
| 3934 EXPECT_FALSE(SimpleCacheThirdStreamFileExists(key)); | 3943 EXPECT_FALSE(SimpleCacheThirdStreamFileExists(key)); |
| 3935 } | 3944 } |
| 3936 | 3945 |
| 3937 // Check that we don't accidentally create the third stream file once the entry | 3946 // Check that we don't accidentally create the third stream file once the entry |
| 3938 // has been doomed. | 3947 // has been doomed. |
| 3939 TEST_F(DiskCacheEntryTest, SimpleCacheOmittedThirdStream5) { | 3948 TEST_F(DiskCacheEntryTest, SimpleCacheOmittedThirdStream5) { |
| 3940 SetSimpleCacheMode(); | 3949 SetSimpleCacheMode(); |
| 3941 InitCache(); | 3950 InitCache(); |
| 3942 | 3951 |
| 3943 const int kHalfSize = 8; | 3952 const int kHalfSize = 8; |
| 3944 const int kSize = kHalfSize * 2; | 3953 const int kSize = kHalfSize * 2; |
| 3945 const char key[] = "key"; | 3954 const char key[] = "key"; |
| 3946 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize)); | 3955 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize)); |
| 3947 CacheTestFillBuffer(buffer->data(), kHalfSize, false); | 3956 CacheTestFillBuffer(buffer->data(), kHalfSize, false); |
| 3948 | 3957 |
| 3949 disk_cache::Entry* entry; | 3958 disk_cache::Entry* entry; |
| 3950 | 3959 |
| 3951 // Create entry, doom entry, write data to third stream, and close: third | 3960 // Create entry, doom entry, write data to third stream, and close: third |
| 3952 // stream should not exist. (Note: We don't care if the write fails, just | 3961 // stream should not exist. (Note: We don't care if the write fails, just |
| 3953 // that it doesn't cause the file to be created on disk.) | 3962 // that it doesn't cause the file to be created on disk.) |
| 3954 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 3963 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 3955 entry->Doom(); | 3964 entry->Doom(); |
| 3956 WriteData(entry, 2, 0, buffer.get(), kHalfSize, true); | 3965 WriteData(entry, 2, 0, buffer.get(), kHalfSize, true); |
| 3957 entry->Close(); | 3966 entry->Close(); |
| 3958 EXPECT_FALSE(SimpleCacheThirdStreamFileExists(key)); | 3967 EXPECT_FALSE(SimpleCacheThirdStreamFileExists(key)); |
| 3959 } | 3968 } |
| 3960 | 3969 |
| 3961 // There could be a race between Doom and an optimistic write. | 3970 // There could be a race between Doom and an optimistic write. |
| 3962 TEST_F(DiskCacheEntryTest, SimpleCacheDoomOptimisticWritesRace) { | 3971 TEST_F(DiskCacheEntryTest, SimpleCacheDoomOptimisticWritesRace) { |
| 3963 // Test sequence: | 3972 // Test sequence: |
| 3964 // Create, first Write, second Write, Close. | 3973 // Create, first Write, second Write, Close. |
| 3965 // Open, Close. | 3974 // Open, Close. |
| 3966 SetSimpleCacheMode(); | 3975 SetSimpleCacheMode(); |
| 3967 InitCache(); | 3976 InitCache(); |
| 3968 disk_cache::Entry* null = NULL; | 3977 disk_cache::Entry* null = NULL; |
| 3969 const char key[] = "the first key"; | 3978 const char key[] = "the first key"; |
| 3970 | 3979 |
| 3971 const int kSize = 200; | 3980 const int kSize = 200; |
| 3972 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize)); | 3981 scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize)); |
| 3973 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize)); | 3982 scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize)); |
| 3974 CacheTestFillBuffer(buffer1->data(), kSize, false); | 3983 CacheTestFillBuffer(buffer1->data(), kSize, false); |
| 3975 CacheTestFillBuffer(buffer2->data(), kSize, false); | 3984 CacheTestFillBuffer(buffer2->data(), kSize, false); |
| 3976 | 3985 |
| 3977 // The race only happens on stream 1 and stream 2. | 3986 // The race only happens on stream 1 and stream 2. |
| 3978 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { | 3987 for (int i = 0; i < disk_cache::kSimpleEntryStreamCount; ++i) { |
| 3979 ASSERT_EQ(net::OK, DoomAllEntries()); | 3988 ASSERT_THAT(DoomAllEntries(), IsOk()); |
| 3980 disk_cache::Entry* entry = NULL; | 3989 disk_cache::Entry* entry = NULL; |
| 3981 | 3990 |
| 3982 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 3991 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 3983 EXPECT_NE(null, entry); | 3992 EXPECT_NE(null, entry); |
| 3984 entry->Close(); | 3993 entry->Close(); |
| 3985 entry = NULL; | 3994 entry = NULL; |
| 3986 | 3995 |
| 3987 ASSERT_EQ(net::OK, DoomAllEntries()); | 3996 ASSERT_THAT(DoomAllEntries(), IsOk()); |
| 3988 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 3997 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 3989 EXPECT_NE(null, entry); | 3998 EXPECT_NE(null, entry); |
| 3990 | 3999 |
| 3991 int offset = 0; | 4000 int offset = 0; |
| 3992 int buf_len = kSize; | 4001 int buf_len = kSize; |
| 3993 // This write should not be optimistic (since create is). | 4002 // This write should not be optimistic (since create is). |
| 3994 EXPECT_EQ(buf_len, | 4003 EXPECT_EQ(buf_len, |
| 3995 WriteData(entry, i, offset, buffer1.get(), buf_len, false)); | 4004 WriteData(entry, i, offset, buffer1.get(), buf_len, false)); |
| 3996 | 4005 |
| 3997 offset = kSize; | 4006 offset = kSize; |
| 3998 // This write should be optimistic. | 4007 // This write should be optimistic. |
| 3999 EXPECT_EQ(buf_len, | 4008 EXPECT_EQ(buf_len, |
| 4000 WriteData(entry, i, offset, buffer2.get(), buf_len, false)); | 4009 WriteData(entry, i, offset, buffer2.get(), buf_len, false)); |
| 4001 entry->Close(); | 4010 entry->Close(); |
| 4002 | 4011 |
| 4003 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 4012 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 4004 EXPECT_NE(null, entry); | 4013 EXPECT_NE(null, entry); |
| 4005 | 4014 |
| 4006 entry->Close(); | 4015 entry->Close(); |
| 4007 entry = NULL; | 4016 entry = NULL; |
| 4008 } | 4017 } |
| 4009 } | 4018 } |
| 4010 | 4019 |
| 4011 // Tests for a regression in crbug.com/317138 , in which deleting an already | 4020 // Tests for a regression in crbug.com/317138 , in which deleting an already |
| 4012 // doomed entry was removing the active entry from the index. | 4021 // doomed entry was removing the active entry from the index. |
| 4013 TEST_F(DiskCacheEntryTest, SimpleCachePreserveActiveEntries) { | 4022 TEST_F(DiskCacheEntryTest, SimpleCachePreserveActiveEntries) { |
| 4014 SetSimpleCacheMode(); | 4023 SetSimpleCacheMode(); |
| 4015 InitCache(); | 4024 InitCache(); |
| 4016 | 4025 |
| 4017 disk_cache::Entry* null = NULL; | 4026 disk_cache::Entry* null = NULL; |
| 4018 | 4027 |
| 4019 const char key[] = "this is a key"; | 4028 const char key[] = "this is a key"; |
| 4020 | 4029 |
| 4021 disk_cache::Entry* entry1 = NULL; | 4030 disk_cache::Entry* entry1 = NULL; |
| 4022 ASSERT_EQ(net::OK, CreateEntry(key, &entry1)); | 4031 ASSERT_THAT(CreateEntry(key, &entry1), IsOk()); |
| 4023 ScopedEntryPtr entry1_closer(entry1); | 4032 ScopedEntryPtr entry1_closer(entry1); |
| 4024 EXPECT_NE(null, entry1); | 4033 EXPECT_NE(null, entry1); |
| 4025 entry1->Doom(); | 4034 entry1->Doom(); |
| 4026 | 4035 |
| 4027 disk_cache::Entry* entry2 = NULL; | 4036 disk_cache::Entry* entry2 = NULL; |
| 4028 ASSERT_EQ(net::OK, CreateEntry(key, &entry2)); | 4037 ASSERT_THAT(CreateEntry(key, &entry2), IsOk()); |
| 4029 ScopedEntryPtr entry2_closer(entry2); | 4038 ScopedEntryPtr entry2_closer(entry2); |
| 4030 EXPECT_NE(null, entry2); | 4039 EXPECT_NE(null, entry2); |
| 4031 entry2_closer.reset(); | 4040 entry2_closer.reset(); |
| 4032 | 4041 |
| 4033 // Closing then reopening entry2 insures that entry2 is serialized, and so | 4042 // Closing then reopening entry2 insures that entry2 is serialized, and so |
| 4034 // it can be opened from files without error. | 4043 // it can be opened from files without error. |
| 4035 entry2 = NULL; | 4044 entry2 = NULL; |
| 4036 ASSERT_EQ(net::OK, OpenEntry(key, &entry2)); | 4045 ASSERT_THAT(OpenEntry(key, &entry2), IsOk()); |
| 4037 EXPECT_NE(null, entry2); | 4046 EXPECT_NE(null, entry2); |
| 4038 entry2_closer.reset(entry2); | 4047 entry2_closer.reset(entry2); |
| 4039 | 4048 |
| 4040 scoped_refptr<disk_cache::SimpleEntryImpl> | 4049 scoped_refptr<disk_cache::SimpleEntryImpl> |
| 4041 entry1_refptr = static_cast<disk_cache::SimpleEntryImpl*>(entry1); | 4050 entry1_refptr = static_cast<disk_cache::SimpleEntryImpl*>(entry1); |
| 4042 | 4051 |
| 4043 // If crbug.com/317138 has regressed, this will remove |entry2| from | 4052 // If crbug.com/317138 has regressed, this will remove |entry2| from |
| 4044 // the backend's |active_entries_| while |entry2| is still alive and its | 4053 // the backend's |active_entries_| while |entry2| is still alive and its |
| 4045 // files are still on disk. | 4054 // files are still on disk. |
| 4046 entry1_closer.reset(); | 4055 entry1_closer.reset(); |
| 4047 entry1 = NULL; | 4056 entry1 = NULL; |
| 4048 | 4057 |
| 4049 // Close does not have a callback. However, we need to be sure the close is | 4058 // Close does not have a callback. However, we need to be sure the close is |
| 4050 // finished before we continue the test. We can take advantage of how the ref | 4059 // finished before we continue the test. We can take advantage of how the ref |
| 4051 // counting of a SimpleEntryImpl works to fake out a callback: When the | 4060 // counting of a SimpleEntryImpl works to fake out a callback: When the |
| 4052 // last Close() call is made to an entry, an IO operation is sent to the | 4061 // last Close() call is made to an entry, an IO operation is sent to the |
| 4053 // synchronous entry to close the platform files. This IO operation holds a | 4062 // synchronous entry to close the platform files. This IO operation holds a |
| 4054 // ref pointer to the entry, which expires when the operation is done. So, | 4063 // ref pointer to the entry, which expires when the operation is done. So, |
| 4055 // we take a refpointer, and watch the SimpleEntry object until it has only | 4064 // we take a refpointer, and watch the SimpleEntry object until it has only |
| 4056 // one ref; this indicates the IO operation is complete. | 4065 // one ref; this indicates the IO operation is complete. |
| 4057 while (!entry1_refptr->HasOneRef()) { | 4066 while (!entry1_refptr->HasOneRef()) { |
| 4058 base::PlatformThread::YieldCurrentThread(); | 4067 base::PlatformThread::YieldCurrentThread(); |
| 4059 base::RunLoop().RunUntilIdle(); | 4068 base::RunLoop().RunUntilIdle(); |
| 4060 } | 4069 } |
| 4061 entry1_refptr = NULL; | 4070 entry1_refptr = NULL; |
| 4062 | 4071 |
| 4063 // In the bug case, this new entry ends up being a duplicate object pointing | 4072 // In the bug case, this new entry ends up being a duplicate object pointing |
| 4064 // at the same underlying files. | 4073 // at the same underlying files. |
| 4065 disk_cache::Entry* entry3 = NULL; | 4074 disk_cache::Entry* entry3 = NULL; |
| 4066 EXPECT_EQ(net::OK, OpenEntry(key, &entry3)); | 4075 EXPECT_THAT(OpenEntry(key, &entry3), IsOk()); |
| 4067 ScopedEntryPtr entry3_closer(entry3); | 4076 ScopedEntryPtr entry3_closer(entry3); |
| 4068 EXPECT_NE(null, entry3); | 4077 EXPECT_NE(null, entry3); |
| 4069 | 4078 |
| 4070 // The test passes if these two dooms do not crash. | 4079 // The test passes if these two dooms do not crash. |
| 4071 entry2->Doom(); | 4080 entry2->Doom(); |
| 4072 entry3->Doom(); | 4081 entry3->Doom(); |
| 4073 } | 4082 } |
| 4074 | 4083 |
| 4075 TEST_F(DiskCacheEntryTest, SimpleCacheBasicSparseIO) { | 4084 TEST_F(DiskCacheEntryTest, SimpleCacheBasicSparseIO) { |
| 4076 SetSimpleCacheMode(); | 4085 SetSimpleCacheMode(); |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 4113 | 4122 |
| 4114 SetSimpleCacheMode(); | 4123 SetSimpleCacheMode(); |
| 4115 // An entry is allowed sparse data 1/10 the size of the cache, so this size | 4124 // An entry is allowed sparse data 1/10 the size of the cache, so this size |
| 4116 // allows for one |kSize|-sized range plus overhead, but not two ranges. | 4125 // allows for one |kSize|-sized range plus overhead, but not two ranges. |
| 4117 SetMaxSize(kSize * 15); | 4126 SetMaxSize(kSize * 15); |
| 4118 InitCache(); | 4127 InitCache(); |
| 4119 | 4128 |
| 4120 const char key[] = "key"; | 4129 const char key[] = "key"; |
| 4121 disk_cache::Entry* null = NULL; | 4130 disk_cache::Entry* null = NULL; |
| 4122 disk_cache::Entry* entry; | 4131 disk_cache::Entry* entry; |
| 4123 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 4132 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 4124 EXPECT_NE(null, entry); | 4133 EXPECT_NE(null, entry); |
| 4125 | 4134 |
| 4126 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize)); | 4135 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize)); |
| 4127 CacheTestFillBuffer(buffer->data(), kSize, false); | 4136 CacheTestFillBuffer(buffer->data(), kSize, false); |
| 4128 net::TestCompletionCallback callback; | 4137 net::TestCompletionCallback callback; |
| 4129 int ret; | 4138 int ret; |
| 4130 | 4139 |
| 4131 // Verify initial conditions. | 4140 // Verify initial conditions. |
| 4132 ret = entry->ReadSparseData(0, buffer.get(), kSize, callback.callback()); | 4141 ret = entry->ReadSparseData(0, buffer.get(), kSize, callback.callback()); |
| 4133 EXPECT_EQ(0, callback.GetResult(ret)); | 4142 EXPECT_EQ(0, callback.GetResult(ret)); |
| (...skipping 15 matching lines...) Expand all Loading... |
| 4149 ret = entry->ReadSparseData(kSize, buffer.get(), kSize, callback.callback()); | 4158 ret = entry->ReadSparseData(kSize, buffer.get(), kSize, callback.callback()); |
| 4150 EXPECT_EQ(kSize, callback.GetResult(ret)); | 4159 EXPECT_EQ(kSize, callback.GetResult(ret)); |
| 4151 | 4160 |
| 4152 // Make sure the first range was removed when the second was written. | 4161 // Make sure the first range was removed when the second was written. |
| 4153 ret = entry->ReadSparseData(0, buffer.get(), kSize, callback.callback()); | 4162 ret = entry->ReadSparseData(0, buffer.get(), kSize, callback.callback()); |
| 4154 EXPECT_EQ(0, callback.GetResult(ret)); | 4163 EXPECT_EQ(0, callback.GetResult(ret)); |
| 4155 | 4164 |
| 4156 // Close and reopen the entry and make sure the first entry is still absent | 4165 // Close and reopen the entry and make sure the first entry is still absent |
| 4157 // and the second entry is still present. | 4166 // and the second entry is still present. |
| 4158 entry->Close(); | 4167 entry->Close(); |
| 4159 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 4168 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 4160 | 4169 |
| 4161 ret = entry->ReadSparseData(0, buffer.get(), kSize, callback.callback()); | 4170 ret = entry->ReadSparseData(0, buffer.get(), kSize, callback.callback()); |
| 4162 EXPECT_EQ(0, callback.GetResult(ret)); | 4171 EXPECT_EQ(0, callback.GetResult(ret)); |
| 4163 | 4172 |
| 4164 ret = entry->ReadSparseData(kSize, buffer.get(), kSize, callback.callback()); | 4173 ret = entry->ReadSparseData(kSize, buffer.get(), kSize, callback.callback()); |
| 4165 EXPECT_EQ(kSize, callback.GetResult(ret)); | 4174 EXPECT_EQ(kSize, callback.GetResult(ret)); |
| 4166 | 4175 |
| 4167 entry->Close(); | 4176 entry->Close(); |
| 4168 } | 4177 } |
| 4169 | 4178 |
| 4170 TEST_F(DiskCacheEntryTest, SimpleCacheReadWithoutKeySHA256) { | 4179 TEST_F(DiskCacheEntryTest, SimpleCacheReadWithoutKeySHA256) { |
| 4171 // This test runs as APP_CACHE to make operations more synchronous. | 4180 // This test runs as APP_CACHE to make operations more synchronous. |
| 4172 SetCacheType(net::APP_CACHE); | 4181 SetCacheType(net::APP_CACHE); |
| 4173 SetSimpleCacheMode(); | 4182 SetSimpleCacheMode(); |
| 4174 InitCache(); | 4183 InitCache(); |
| 4175 disk_cache::Entry* entry; | 4184 disk_cache::Entry* entry; |
| 4176 std::string key("a key"); | 4185 std::string key("a key"); |
| 4177 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 4186 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 4178 | 4187 |
| 4179 const std::string stream_0_data = "data for stream zero"; | 4188 const std::string stream_0_data = "data for stream zero"; |
| 4180 scoped_refptr<net::IOBuffer> stream_0_iobuffer( | 4189 scoped_refptr<net::IOBuffer> stream_0_iobuffer( |
| 4181 new net::StringIOBuffer(stream_0_data)); | 4190 new net::StringIOBuffer(stream_0_data)); |
| 4182 EXPECT_EQ(static_cast<int>(stream_0_data.size()), | 4191 EXPECT_EQ(static_cast<int>(stream_0_data.size()), |
| 4183 WriteData(entry, 0, 0, stream_0_iobuffer.get(), | 4192 WriteData(entry, 0, 0, stream_0_iobuffer.get(), |
| 4184 stream_0_data.size(), false)); | 4193 stream_0_data.size(), false)); |
| 4185 const std::string stream_1_data = "FOR STREAM ONE, QUITE DIFFERENT THINGS"; | 4194 const std::string stream_1_data = "FOR STREAM ONE, QUITE DIFFERENT THINGS"; |
| 4186 scoped_refptr<net::IOBuffer> stream_1_iobuffer( | 4195 scoped_refptr<net::IOBuffer> stream_1_iobuffer( |
| 4187 new net::StringIOBuffer(stream_1_data)); | 4196 new net::StringIOBuffer(stream_1_data)); |
| 4188 EXPECT_EQ(static_cast<int>(stream_1_data.size()), | 4197 EXPECT_EQ(static_cast<int>(stream_1_data.size()), |
| 4189 WriteData(entry, 1, 0, stream_1_iobuffer.get(), | 4198 WriteData(entry, 1, 0, stream_1_iobuffer.get(), |
| 4190 stream_1_data.size(), false)); | 4199 stream_1_data.size(), false)); |
| 4191 entry->Close(); | 4200 entry->Close(); |
| 4192 | 4201 |
| 4193 base::RunLoop().RunUntilIdle(); | 4202 base::RunLoop().RunUntilIdle(); |
| 4194 disk_cache::SimpleBackendImpl::FlushWorkerPoolForTesting(); | 4203 disk_cache::SimpleBackendImpl::FlushWorkerPoolForTesting(); |
| 4195 base::RunLoop().RunUntilIdle(); | 4204 base::RunLoop().RunUntilIdle(); |
| 4196 | 4205 |
| 4197 EXPECT_TRUE( | 4206 EXPECT_TRUE( |
| 4198 disk_cache::simple_util::RemoveKeySHA256FromEntry(key, cache_path_)); | 4207 disk_cache::simple_util::RemoveKeySHA256FromEntry(key, cache_path_)); |
| 4199 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 4208 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 4200 ScopedEntryPtr entry_closer(entry); | 4209 ScopedEntryPtr entry_closer(entry); |
| 4201 | 4210 |
| 4202 EXPECT_EQ(static_cast<int>(stream_0_data.size()), entry->GetDataSize(0)); | 4211 EXPECT_EQ(static_cast<int>(stream_0_data.size()), entry->GetDataSize(0)); |
| 4203 scoped_refptr<net::IOBuffer> check_stream_0_data( | 4212 scoped_refptr<net::IOBuffer> check_stream_0_data( |
| 4204 new net::IOBuffer(stream_0_data.size())); | 4213 new net::IOBuffer(stream_0_data.size())); |
| 4205 EXPECT_EQ( | 4214 EXPECT_EQ( |
| 4206 static_cast<int>(stream_0_data.size()), | 4215 static_cast<int>(stream_0_data.size()), |
| 4207 ReadData(entry, 0, 0, check_stream_0_data.get(), stream_0_data.size())); | 4216 ReadData(entry, 0, 0, check_stream_0_data.get(), stream_0_data.size())); |
| 4208 EXPECT_EQ(0, stream_0_data.compare(0, std::string::npos, | 4217 EXPECT_EQ(0, stream_0_data.compare(0, std::string::npos, |
| 4209 check_stream_0_data->data(), | 4218 check_stream_0_data->data(), |
| (...skipping 10 matching lines...) Expand all Loading... |
| 4220 stream_1_data.size())); | 4229 stream_1_data.size())); |
| 4221 } | 4230 } |
| 4222 | 4231 |
| 4223 TEST_F(DiskCacheEntryTest, SimpleCacheDoubleOpenWithoutKeySHA256) { | 4232 TEST_F(DiskCacheEntryTest, SimpleCacheDoubleOpenWithoutKeySHA256) { |
| 4224 // This test runs as APP_CACHE to make operations more synchronous. | 4233 // This test runs as APP_CACHE to make operations more synchronous. |
| 4225 SetCacheType(net::APP_CACHE); | 4234 SetCacheType(net::APP_CACHE); |
| 4226 SetSimpleCacheMode(); | 4235 SetSimpleCacheMode(); |
| 4227 InitCache(); | 4236 InitCache(); |
| 4228 disk_cache::Entry* entry; | 4237 disk_cache::Entry* entry; |
| 4229 std::string key("a key"); | 4238 std::string key("a key"); |
| 4230 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 4239 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 4231 entry->Close(); | 4240 entry->Close(); |
| 4232 | 4241 |
| 4233 base::RunLoop().RunUntilIdle(); | 4242 base::RunLoop().RunUntilIdle(); |
| 4234 disk_cache::SimpleBackendImpl::FlushWorkerPoolForTesting(); | 4243 disk_cache::SimpleBackendImpl::FlushWorkerPoolForTesting(); |
| 4235 base::RunLoop().RunUntilIdle(); | 4244 base::RunLoop().RunUntilIdle(); |
| 4236 | 4245 |
| 4237 EXPECT_TRUE( | 4246 EXPECT_TRUE( |
| 4238 disk_cache::simple_util::RemoveKeySHA256FromEntry(key, cache_path_)); | 4247 disk_cache::simple_util::RemoveKeySHA256FromEntry(key, cache_path_)); |
| 4239 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 4248 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 4240 entry->Close(); | 4249 entry->Close(); |
| 4241 | 4250 |
| 4242 base::RunLoop().RunUntilIdle(); | 4251 base::RunLoop().RunUntilIdle(); |
| 4243 disk_cache::SimpleBackendImpl::FlushWorkerPoolForTesting(); | 4252 disk_cache::SimpleBackendImpl::FlushWorkerPoolForTesting(); |
| 4244 base::RunLoop().RunUntilIdle(); | 4253 base::RunLoop().RunUntilIdle(); |
| 4245 | 4254 |
| 4246 ASSERT_EQ(net::OK, OpenEntry(key, &entry)); | 4255 ASSERT_THAT(OpenEntry(key, &entry), IsOk()); |
| 4247 entry->Close(); | 4256 entry->Close(); |
| 4248 } | 4257 } |
| 4249 | 4258 |
| 4250 TEST_F(DiskCacheEntryTest, SimpleCacheReadCorruptKeySHA256) { | 4259 TEST_F(DiskCacheEntryTest, SimpleCacheReadCorruptKeySHA256) { |
| 4251 // This test runs as APP_CACHE to make operations more synchronous. | 4260 // This test runs as APP_CACHE to make operations more synchronous. |
| 4252 SetCacheType(net::APP_CACHE); | 4261 SetCacheType(net::APP_CACHE); |
| 4253 SetSimpleCacheMode(); | 4262 SetSimpleCacheMode(); |
| 4254 InitCache(); | 4263 InitCache(); |
| 4255 disk_cache::Entry* entry; | 4264 disk_cache::Entry* entry; |
| 4256 std::string key("a key"); | 4265 std::string key("a key"); |
| 4257 ASSERT_EQ(net::OK, CreateEntry(key, &entry)); | 4266 ASSERT_THAT(CreateEntry(key, &entry), IsOk()); |
| 4258 entry->Close(); | 4267 entry->Close(); |
| 4259 | 4268 |
| 4260 base::RunLoop().RunUntilIdle(); | 4269 base::RunLoop().RunUntilIdle(); |
| 4261 disk_cache::SimpleBackendImpl::FlushWorkerPoolForTesting(); | 4270 disk_cache::SimpleBackendImpl::FlushWorkerPoolForTesting(); |
| 4262 base::RunLoop().RunUntilIdle(); | 4271 base::RunLoop().RunUntilIdle(); |
| 4263 | 4272 |
| 4264 EXPECT_TRUE( | 4273 EXPECT_TRUE( |
| 4265 disk_cache::simple_util::CorruptKeySHA256FromEntry(key, cache_path_)); | 4274 disk_cache::simple_util::CorruptKeySHA256FromEntry(key, cache_path_)); |
| 4266 EXPECT_NE(net::OK, OpenEntry(key, &entry)); | 4275 EXPECT_NE(net::OK, OpenEntry(key, &entry)); |
| 4267 } | 4276 } |
| OLD | NEW |