| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 "base/basictypes.h" | 5 #include "base/basictypes.h" |
| 6 #include "base/file_util.h" | 6 #include "base/file_util.h" |
| 7 #include "base/string_util.h" | 7 #include "base/string_util.h" |
| 8 #include "base/stringprintf.h" | 8 #include "base/stringprintf.h" |
| 9 #include "base/third_party/dynamic_annotations/dynamic_annotations.h" | 9 #include "base/third_party/dynamic_annotations/dynamic_annotations.h" |
| 10 #include "base/threading/platform_thread.h" | 10 #include "base/threading/platform_thread.h" |
| (...skipping 248 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 259 { | 259 { |
| 260 FilePath path = GetCacheFilePath(); | 260 FilePath path = GetCacheFilePath(); |
| 261 ASSERT_TRUE(DeleteCache(path)); | 261 ASSERT_TRUE(DeleteCache(path)); |
| 262 base::Thread cache_thread("CacheThread"); | 262 base::Thread cache_thread("CacheThread"); |
| 263 ASSERT_TRUE(cache_thread.StartWithOptions( | 263 ASSERT_TRUE(cache_thread.StartWithOptions( |
| 264 base::Thread::Options(MessageLoop::TYPE_IO, 0))); | 264 base::Thread::Options(MessageLoop::TYPE_IO, 0))); |
| 265 | 265 |
| 266 disk_cache::Backend* cache; | 266 disk_cache::Backend* cache; |
| 267 int rv = disk_cache::BackendImpl::CreateBackend( | 267 int rv = disk_cache::BackendImpl::CreateBackend( |
| 268 path, false, 0, net::DISK_CACHE, disk_cache::kNoRandom, | 268 path, false, 0, net::DISK_CACHE, disk_cache::kNoRandom, |
| 269 base::MessageLoopProxy::CreateForCurrentThread(), NULL, | 269 base::MessageLoopProxy::current(), NULL, |
| 270 &cache, &cb); | 270 &cache, &cb); |
| 271 ASSERT_EQ(net::OK, cb.GetResult(rv)); | 271 ASSERT_EQ(net::OK, cb.GetResult(rv)); |
| 272 | 272 |
| 273 disk_cache::EntryImpl* entry; | 273 disk_cache::EntryImpl* entry; |
| 274 rv = cache->CreateEntry("some key", | 274 rv = cache->CreateEntry("some key", |
| 275 reinterpret_cast<disk_cache::Entry**>(&entry), &cb); | 275 reinterpret_cast<disk_cache::Entry**>(&entry), &cb); |
| 276 ASSERT_EQ(net::OK, cb.GetResult(rv)); | 276 ASSERT_EQ(net::OK, cb.GetResult(rv)); |
| 277 | 277 |
| 278 const int kSize = 25000; | 278 const int kSize = 25000; |
| 279 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize)); | 279 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer(kSize)); |
| (...skipping 1531 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1811 BackendDisable4(); | 1811 BackendDisable4(); |
| 1812 } | 1812 } |
| 1813 | 1813 |
| 1814 TEST_F(DiskCacheTest, Backend_UsageStats) { | 1814 TEST_F(DiskCacheTest, Backend_UsageStats) { |
| 1815 MessageLoopHelper helper; | 1815 MessageLoopHelper helper; |
| 1816 | 1816 |
| 1817 FilePath path = GetCacheFilePath(); | 1817 FilePath path = GetCacheFilePath(); |
| 1818 ASSERT_TRUE(DeleteCache(path)); | 1818 ASSERT_TRUE(DeleteCache(path)); |
| 1819 scoped_ptr<disk_cache::BackendImpl> cache; | 1819 scoped_ptr<disk_cache::BackendImpl> cache; |
| 1820 cache.reset(new disk_cache::BackendImpl( | 1820 cache.reset(new disk_cache::BackendImpl( |
| 1821 path, base::MessageLoopProxy::CreateForCurrentThread(), | 1821 path, base::MessageLoopProxy::current(), |
| 1822 NULL)); | 1822 NULL)); |
| 1823 ASSERT_TRUE(NULL != cache.get()); | 1823 ASSERT_TRUE(NULL != cache.get()); |
| 1824 cache->SetUnitTestMode(); | 1824 cache->SetUnitTestMode(); |
| 1825 ASSERT_EQ(net::OK, cache->SyncInit()); | 1825 ASSERT_EQ(net::OK, cache->SyncInit()); |
| 1826 | 1826 |
| 1827 // Wait for a callback that never comes... about 2 secs :). The message loop | 1827 // Wait for a callback that never comes... about 2 secs :). The message loop |
| 1828 // has to run to allow invocation of the usage timer. | 1828 // has to run to allow invocation of the usage timer. |
| 1829 helper.WaitUntilCacheIoFinished(1); | 1829 helper.WaitUntilCacheIoFinished(1); |
| 1830 } | 1830 } |
| 1831 | 1831 |
| (...skipping 302 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2134 // Ping the oldest entry. | 2134 // Ping the oldest entry. |
| 2135 cache_->OnExternalCacheHit("key0"); | 2135 cache_->OnExternalCacheHit("key0"); |
| 2136 | 2136 |
| 2137 TrimForTest(false); | 2137 TrimForTest(false); |
| 2138 | 2138 |
| 2139 // Make sure the older key remains. | 2139 // Make sure the older key remains. |
| 2140 EXPECT_EQ(1, cache_->GetEntryCount()); | 2140 EXPECT_EQ(1, cache_->GetEntryCount()); |
| 2141 ASSERT_EQ(net::OK, OpenEntry("key0", &entry)); | 2141 ASSERT_EQ(net::OK, OpenEntry("key0", &entry)); |
| 2142 entry->Close(); | 2142 entry->Close(); |
| 2143 } | 2143 } |
| OLD | NEW |