| Index: net/disk_cache/backend_unittest.cc
|
| diff --git a/net/disk_cache/backend_unittest.cc b/net/disk_cache/backend_unittest.cc
|
| index ecec7b7442f8a7ab37defa7575dc184824f6b35c..3779b227d85b1b0afe3283fe3725ceedf0794065 100644
|
| --- a/net/disk_cache/backend_unittest.cc
|
| +++ b/net/disk_cache/backend_unittest.cc
|
| @@ -295,7 +295,7 @@ TEST_F(DiskCacheBackendTest, ExternalFiles) {
|
| // Now let's create a file with the cache.
|
| disk_cache::Entry* entry;
|
| ASSERT_EQ(net::OK, CreateEntry("key", &entry));
|
| - ASSERT_EQ(0, WriteData(entry, 0, 20000, buffer1, 0, false));
|
| + ASSERT_EQ(0, WriteData(entry, 0, 20000, buffer1.get(), 0, false));
|
| entry->Close();
|
|
|
| // And verify that the first file is still there.
|
| @@ -336,7 +336,8 @@ void DiskCacheBackendTest::BackendShutdownWithPendingFileIO(bool fast) {
|
| // We are using the current thread as the cache thread because we want to
|
| // be able to call directly this method to make sure that the OS (instead
|
| // of us switching thread) is returning IO pending.
|
| - rv = entry->WriteDataImpl(0, i, buffer, kSize, cb.callback(), false);
|
| + rv =
|
| + entry->WriteDataImpl(0, i, buffer.get(), kSize, cb.callback(), false);
|
| if (rv == net::ERR_IO_PENDING)
|
| break;
|
| EXPECT_EQ(kSize, rv);
|
| @@ -496,21 +497,23 @@ void DiskCacheBackendTest::BackendSetSize() {
|
|
|
| scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(cache_size));
|
| memset(buffer->data(), 0, cache_size);
|
| - EXPECT_EQ(cache_size / 10, WriteData(entry, 0, 0, buffer, cache_size / 10,
|
| - false)) << "normal file";
|
| + EXPECT_EQ(cache_size / 10,
|
| + WriteData(entry, 0, 0, buffer.get(), cache_size / 10, false))
|
| + << "normal file";
|
|
|
| - EXPECT_EQ(net::ERR_FAILED, WriteData(entry, 1, 0, buffer, cache_size / 5,
|
| - false)) << "file size above the limit";
|
| + EXPECT_EQ(net::ERR_FAILED,
|
| + WriteData(entry, 1, 0, buffer.get(), cache_size / 5, false))
|
| + << "file size above the limit";
|
|
|
| // By doubling the total size, we make this file cacheable.
|
| SetMaxSize(cache_size * 2);
|
| - EXPECT_EQ(cache_size / 5, WriteData(entry, 1, 0, buffer, cache_size / 5,
|
| - false));
|
| + EXPECT_EQ(cache_size / 5,
|
| + WriteData(entry, 1, 0, buffer.get(), cache_size / 5, false));
|
|
|
| // Let's fill up the cache!.
|
| SetMaxSize(cache_size * 10);
|
| - EXPECT_EQ(cache_size * 3 / 4, WriteData(entry, 0, 0, buffer,
|
| - cache_size * 3 / 4, false));
|
| + EXPECT_EQ(cache_size * 3 / 4,
|
| + WriteData(entry, 0, 0, buffer.get(), cache_size * 3 / 4, false));
|
| entry->Close();
|
| FlushQueueForTest();
|
|
|
| @@ -519,13 +522,13 @@ void DiskCacheBackendTest::BackendSetSize() {
|
| // The cache is 95% full.
|
|
|
| ASSERT_EQ(net::OK, CreateEntry(second, &entry));
|
| - EXPECT_EQ(cache_size / 10, WriteData(entry, 0, 0, buffer, cache_size / 10,
|
| - false));
|
| + EXPECT_EQ(cache_size / 10,
|
| + WriteData(entry, 0, 0, buffer.get(), cache_size / 10, false));
|
|
|
| disk_cache::Entry* entry2;
|
| ASSERT_EQ(net::OK, CreateEntry("an extra key", &entry2));
|
| - EXPECT_EQ(cache_size / 10, WriteData(entry2, 0, 0, buffer, cache_size / 10,
|
| - false));
|
| + EXPECT_EQ(cache_size / 10,
|
| + WriteData(entry2, 0, 0, buffer.get(), cache_size / 10, false));
|
| entry2->Close(); // This will trigger the cache trim.
|
|
|
| EXPECT_NE(net::OK, OpenEntry(first, &entry2));
|
| @@ -696,7 +699,7 @@ void DiskCacheBackendTest::BackendValidEntry() {
|
| scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize));
|
| memset(buffer1->data(), 0, kSize);
|
| base::strlcpy(buffer1->data(), "And the data to save", kSize);
|
| - EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer1, kSize, false));
|
| + EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer1.get(), kSize, false));
|
| entry->Close();
|
| SimulateCrash();
|
|
|
| @@ -704,7 +707,7 @@ void DiskCacheBackendTest::BackendValidEntry() {
|
|
|
| scoped_refptr<net::IOBuffer> buffer2(new net::IOBuffer(kSize));
|
| memset(buffer2->data(), 0, kSize);
|
| - EXPECT_EQ(kSize, ReadData(entry, 0, 0, buffer2, kSize));
|
| + EXPECT_EQ(kSize, ReadData(entry, 0, 0, buffer2.get(), kSize));
|
| entry->Close();
|
| EXPECT_STREQ(buffer1->data(), buffer2->data());
|
| }
|
| @@ -732,7 +735,7 @@ void DiskCacheBackendTest::BackendInvalidEntry() {
|
| scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize));
|
| memset(buffer->data(), 0, kSize);
|
| base::strlcpy(buffer->data(), "And the data to save", kSize);
|
| - EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer, kSize, false));
|
| + EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer.get(), kSize, false));
|
| SimulateCrash();
|
|
|
| EXPECT_NE(net::OK, OpenEntry(key, &entry));
|
| @@ -779,10 +782,10 @@ void DiskCacheBackendTest::BackendInvalidEntryRead() {
|
| scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize));
|
| memset(buffer->data(), 0, kSize);
|
| base::strlcpy(buffer->data(), "And the data to save", kSize);
|
| - EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer, kSize, false));
|
| + EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer.get(), kSize, false));
|
| entry->Close();
|
| ASSERT_EQ(net::OK, OpenEntry(key, &entry));
|
| - EXPECT_EQ(kSize, ReadData(entry, 0, 0, buffer, kSize));
|
| + EXPECT_EQ(kSize, ReadData(entry, 0, 0, buffer.get(), kSize));
|
|
|
| SimulateCrash();
|
|
|
| @@ -905,13 +908,13 @@ void DiskCacheBackendTest::BackendTrimInvalidEntry() {
|
|
|
| scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize));
|
| memset(buffer->data(), 0, kSize);
|
| - EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer, kSize, false));
|
| + EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer.get(), kSize, false));
|
|
|
| // Simulate a crash.
|
| SimulateCrash();
|
|
|
| ASSERT_EQ(net::OK, CreateEntry(second, &entry));
|
| - EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer, kSize, false));
|
| + EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer.get(), kSize, false));
|
|
|
| EXPECT_EQ(2, cache_->GetEntryCount());
|
| SetMaxSize(kSize);
|
| @@ -960,7 +963,7 @@ void DiskCacheBackendTest::BackendTrimInvalidEntry2() {
|
| for (int i = 0; i < 32; i++) {
|
| std::string key(base::StringPrintf("some key %d", i));
|
| ASSERT_EQ(net::OK, CreateEntry(key, &entry));
|
| - EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer, kSize, false));
|
| + EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer.get(), kSize, false));
|
| entry->Close();
|
| ASSERT_EQ(net::OK, OpenEntry(key, &entry));
|
| // Note that we are not closing the entries.
|
| @@ -970,7 +973,7 @@ void DiskCacheBackendTest::BackendTrimInvalidEntry2() {
|
| SimulateCrash();
|
|
|
| ASSERT_EQ(net::OK, CreateEntry("Something else", &entry));
|
| - EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer, kSize, false));
|
| + EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer.get(), kSize, false));
|
|
|
| FlushQueueForTest();
|
| EXPECT_EQ(33, cache_->GetEntryCount());
|
| @@ -1163,7 +1166,7 @@ TEST_F(DiskCacheBackendTest, ShaderCacheEnumerationReadData) {
|
| ASSERT_EQ(net::OK, CreateEntry(first, &entry1));
|
| memset(buffer1->data(), 0, kSize);
|
| base::strlcpy(buffer1->data(), "And the data to save", kSize);
|
| - EXPECT_EQ(kSize, WriteData(entry1, 0, 0, buffer1, kSize, false));
|
| + EXPECT_EQ(kSize, WriteData(entry1, 0, 0, buffer1.get(), kSize, false));
|
|
|
| ASSERT_EQ(net::OK, CreateEntry(second, &entry2));
|
| entry2->Close();
|
| @@ -1174,7 +1177,7 @@ TEST_F(DiskCacheBackendTest, ShaderCacheEnumerationReadData) {
|
| AddDelay();
|
|
|
| // Read from the last item in the LRU.
|
| - EXPECT_EQ(kSize, ReadData(entry1, 0, 0, buffer1, kSize));
|
| + EXPECT_EQ(kSize, ReadData(entry1, 0, 0, buffer1.get(), kSize));
|
| entry1->Close();
|
|
|
| void* iter = NULL;
|
| @@ -1197,10 +1200,10 @@ void DiskCacheBackendTest::BackendInvalidEntryEnumeration() {
|
| scoped_refptr<net::IOBuffer> buffer1(new net::IOBuffer(kSize));
|
| memset(buffer1->data(), 0, kSize);
|
| base::strlcpy(buffer1->data(), "And the data to save", kSize);
|
| - EXPECT_EQ(kSize, WriteData(entry1, 0, 0, buffer1, kSize, false));
|
| + EXPECT_EQ(kSize, WriteData(entry1, 0, 0, buffer1.get(), kSize, false));
|
| entry1->Close();
|
| ASSERT_EQ(net::OK, OpenEntry(key, &entry1));
|
| - EXPECT_EQ(kSize, ReadData(entry1, 0, 0, buffer1, kSize));
|
| + EXPECT_EQ(kSize, ReadData(entry1, 0, 0, buffer1.get(), kSize));
|
|
|
| std::string key2("Another key");
|
| ASSERT_EQ(net::OK, CreateEntry(key2, &entry2));
|
| @@ -2401,8 +2404,8 @@ void DiskCacheBackendTest::BackendDisable4() {
|
| const int kBufSize = 20000;
|
| scoped_refptr<net::IOBuffer> buf(new net::IOBuffer(kBufSize));
|
| memset(buf->data(), 0, kBufSize);
|
| - EXPECT_EQ(100, WriteData(entry2, 0, 0, buf, 100, false));
|
| - EXPECT_EQ(kBufSize, WriteData(entry3, 0, 0, buf, kBufSize, false));
|
| + EXPECT_EQ(100, WriteData(entry2, 0, 0, buf.get(), 100, false));
|
| + EXPECT_EQ(kBufSize, WriteData(entry3, 0, 0, buf.get(), kBufSize, false));
|
|
|
| // This line should disable the cache but not delete it.
|
| EXPECT_NE(net::OK, OpenNextEntry(&iter, &entry4));
|
| @@ -2410,13 +2413,13 @@ void DiskCacheBackendTest::BackendDisable4() {
|
|
|
| EXPECT_NE(net::OK, CreateEntry("cache is disabled", &entry4));
|
|
|
| - EXPECT_EQ(100, ReadData(entry2, 0, 0, buf, 100));
|
| - EXPECT_EQ(100, WriteData(entry2, 0, 0, buf, 100, false));
|
| - EXPECT_EQ(100, WriteData(entry2, 1, 0, buf, 100, false));
|
| + EXPECT_EQ(100, ReadData(entry2, 0, 0, buf.get(), 100));
|
| + EXPECT_EQ(100, WriteData(entry2, 0, 0, buf.get(), 100, false));
|
| + EXPECT_EQ(100, WriteData(entry2, 1, 0, buf.get(), 100, false));
|
|
|
| - EXPECT_EQ(kBufSize, ReadData(entry3, 0, 0, buf, kBufSize));
|
| - EXPECT_EQ(kBufSize, WriteData(entry3, 0, 0, buf, kBufSize, false));
|
| - EXPECT_EQ(kBufSize, WriteData(entry3, 1, 0, buf, kBufSize, false));
|
| + EXPECT_EQ(kBufSize, ReadData(entry3, 0, 0, buf.get(), kBufSize));
|
| + EXPECT_EQ(kBufSize, WriteData(entry3, 0, 0, buf.get(), kBufSize, false));
|
| + EXPECT_EQ(kBufSize, WriteData(entry3, 1, 0, buf.get(), kBufSize, false));
|
|
|
| std::string key = entry2->GetKey();
|
| EXPECT_EQ(sizeof(key2) - 1, key.size());
|
| @@ -2675,14 +2678,16 @@ TEST_F(DiskCacheBackendTest, TotalBuffersSize1) {
|
| for (int i = 0; i < 10; i++) {
|
| SCOPED_TRACE(i);
|
| // Allocate 2MB for this entry.
|
| - EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer, kSize, true));
|
| - EXPECT_EQ(kSize, WriteData(entry, 1, 0, buffer, kSize, true));
|
| - EXPECT_EQ(kSize, WriteData(entry, 0, 1024 * 1024, buffer, kSize, false));
|
| - EXPECT_EQ(kSize, WriteData(entry, 1, 1024 * 1024, buffer, kSize, false));
|
| + EXPECT_EQ(kSize, WriteData(entry, 0, 0, buffer.get(), kSize, true));
|
| + EXPECT_EQ(kSize, WriteData(entry, 1, 0, buffer.get(), kSize, true));
|
| + EXPECT_EQ(kSize,
|
| + WriteData(entry, 0, 1024 * 1024, buffer.get(), kSize, false));
|
| + EXPECT_EQ(kSize,
|
| + WriteData(entry, 1, 1024 * 1024, buffer.get(), kSize, false));
|
|
|
| // Delete one of the buffers and truncate the other.
|
| - EXPECT_EQ(0, WriteData(entry, 0, 0, buffer, 0, true));
|
| - EXPECT_EQ(0, WriteData(entry, 1, 10, buffer, 0, true));
|
| + EXPECT_EQ(0, WriteData(entry, 0, 0, buffer.get(), 0, true));
|
| + EXPECT_EQ(0, WriteData(entry, 1, 10, buffer.get(), 0, true));
|
|
|
| // Delete the second buffer, writing 10 bytes to disk.
|
| entry->Close();
|
| @@ -2974,7 +2979,7 @@ TEST_F(DiskCacheBackendTest, SimpleCacheOverBlockfileCache) {
|
| scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize));
|
| CacheTestFillBuffer(buffer->data(), kSize, false);
|
| ASSERT_EQ(net::OK, CreateEntry("key", &entry));
|
| - ASSERT_EQ(0, WriteData(entry, 0, 0, buffer, 0, false));
|
| + ASSERT_EQ(0, WriteData(entry, 0, 0, buffer.get(), 0, false));
|
| entry->Close();
|
| delete cache_;
|
| cache_ = NULL;
|
| @@ -3005,7 +3010,7 @@ TEST_F(DiskCacheBackendTest, BlockfileCacheOverSimpleCache) {
|
| scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize));
|
| CacheTestFillBuffer(buffer->data(), kSize, false);
|
| ASSERT_EQ(net::OK, CreateEntry("key", &entry));
|
| - ASSERT_EQ(0, WriteData(entry, 0, 0, buffer, 0, false));
|
| + ASSERT_EQ(0, WriteData(entry, 0, 0, buffer.get(), 0, false));
|
| entry->Close();
|
| delete cache_;
|
| cache_ = NULL;
|
|
|