| 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 <string> | 5 #include <string> |
| 6 | 6 |
| 7 #include "base/basictypes.h" | 7 #include "base/basictypes.h" |
| 8 #include "base/bind.h" | 8 #include "base/bind.h" |
| 9 #include "base/bind_helpers.h" | 9 #include "base/bind_helpers.h" |
| 10 #include "base/hash.h" | 10 #include "base/hash.h" |
| (...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 60 entry.key = GenerateKey(true); | 60 entry.key = GenerateKey(true); |
| 61 entry.data_len = rand() % kMaxSize; | 61 entry.data_len = rand() % kMaxSize; |
| 62 entries->push_back(entry); | 62 entries->push_back(entry); |
| 63 | 63 |
| 64 disk_cache::Entry* cache_entry; | 64 disk_cache::Entry* cache_entry; |
| 65 net::TestCompletionCallback cb; | 65 net::TestCompletionCallback cb; |
| 66 int rv = cache->CreateEntry(entry.key, &cache_entry, cb.callback()); | 66 int rv = cache->CreateEntry(entry.key, &cache_entry, cb.callback()); |
| 67 if (net::OK != cb.GetResult(rv)) | 67 if (net::OK != cb.GetResult(rv)) |
| 68 break; | 68 break; |
| 69 int ret = cache_entry->WriteData( | 69 int ret = cache_entry->WriteData( |
| 70 0, 0, buffer1, kSize1, | 70 0, |
| 71 base::Bind(&CallbackTest::Run, base::Unretained(&callback)), false); | 71 0, |
| 72 buffer1.get(), |
| 73 kSize1, |
| 74 base::Bind(&CallbackTest::Run, base::Unretained(&callback)), |
| 75 false); |
| 72 if (net::ERR_IO_PENDING == ret) | 76 if (net::ERR_IO_PENDING == ret) |
| 73 expected++; | 77 expected++; |
| 74 else if (kSize1 != ret) | 78 else if (kSize1 != ret) |
| 75 break; | 79 break; |
| 76 | 80 |
| 77 ret = cache_entry->WriteData( | 81 ret = cache_entry->WriteData( |
| 78 1, 0, buffer2, entry.data_len, | 82 1, |
| 79 base::Bind(&CallbackTest::Run, base::Unretained(&callback)), false); | 83 0, |
| 84 buffer2.get(), |
| 85 entry.data_len, |
| 86 base::Bind(&CallbackTest::Run, base::Unretained(&callback)), |
| 87 false); |
| 80 if (net::ERR_IO_PENDING == ret) | 88 if (net::ERR_IO_PENDING == ret) |
| 81 expected++; | 89 expected++; |
| 82 else if (entry.data_len != ret) | 90 else if (entry.data_len != ret) |
| 83 break; | 91 break; |
| 84 cache_entry->Close(); | 92 cache_entry->Close(); |
| 85 } | 93 } |
| 86 | 94 |
| 87 helper.WaitUntilCacheIoFinished(expected); | 95 helper.WaitUntilCacheIoFinished(expected); |
| 88 timer.Done(); | 96 timer.Done(); |
| 89 | 97 |
| (...skipping 19 matching lines...) Expand all Loading... |
| 109 "Read disk cache entries (warm)"; | 117 "Read disk cache entries (warm)"; |
| 110 PerfTimeLogger timer(message); | 118 PerfTimeLogger timer(message); |
| 111 | 119 |
| 112 for (int i = 0; i < num_entries; i++) { | 120 for (int i = 0; i < num_entries; i++) { |
| 113 disk_cache::Entry* cache_entry; | 121 disk_cache::Entry* cache_entry; |
| 114 net::TestCompletionCallback cb; | 122 net::TestCompletionCallback cb; |
| 115 int rv = cache->OpenEntry(entries[i].key, &cache_entry, cb.callback()); | 123 int rv = cache->OpenEntry(entries[i].key, &cache_entry, cb.callback()); |
| 116 if (net::OK != cb.GetResult(rv)) | 124 if (net::OK != cb.GetResult(rv)) |
| 117 break; | 125 break; |
| 118 int ret = cache_entry->ReadData( | 126 int ret = cache_entry->ReadData( |
| 119 0, 0, buffer1, kSize1, | 127 0, |
| 128 0, |
| 129 buffer1.get(), |
| 130 kSize1, |
| 120 base::Bind(&CallbackTest::Run, base::Unretained(&callback))); | 131 base::Bind(&CallbackTest::Run, base::Unretained(&callback))); |
| 121 if (net::ERR_IO_PENDING == ret) | 132 if (net::ERR_IO_PENDING == ret) |
| 122 expected++; | 133 expected++; |
| 123 else if (kSize1 != ret) | 134 else if (kSize1 != ret) |
| 124 break; | 135 break; |
| 125 | 136 |
| 126 ret = cache_entry->ReadData( | 137 ret = cache_entry->ReadData( |
| 127 1, 0, buffer2, entries[i].data_len, | 138 1, |
| 139 0, |
| 140 buffer2.get(), |
| 141 entries[i].data_len, |
| 128 base::Bind(&CallbackTest::Run, base::Unretained(&callback))); | 142 base::Bind(&CallbackTest::Run, base::Unretained(&callback))); |
| 129 if (net::ERR_IO_PENDING == ret) | 143 if (net::ERR_IO_PENDING == ret) |
| 130 expected++; | 144 expected++; |
| 131 else if (entries[i].data_len != ret) | 145 else if (entries[i].data_len != ret) |
| 132 break; | 146 break; |
| 133 cache_entry->Close(); | 147 cache_entry->Close(); |
| 134 } | 148 } |
| 135 | 149 |
| 136 helper.WaitUntilCacheIoFinished(expected); | 150 helper.WaitUntilCacheIoFinished(expected); |
| 137 timer.Done(); | 151 timer.Done(); |
| (...skipping 105 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 243 | 257 |
| 244 files.DeleteBlock(address[entry], false); | 258 files.DeleteBlock(address[entry], false); |
| 245 EXPECT_TRUE(files.CreateBlock(disk_cache::RANKINGS, BlockSize(), | 259 EXPECT_TRUE(files.CreateBlock(disk_cache::RANKINGS, BlockSize(), |
| 246 &address[entry])); | 260 &address[entry])); |
| 247 } | 261 } |
| 248 | 262 |
| 249 timer2.Done(); | 263 timer2.Done(); |
| 250 base::MessageLoop::current()->RunUntilIdle(); | 264 base::MessageLoop::current()->RunUntilIdle(); |
| 251 delete[] address; | 265 delete[] address; |
| 252 } | 266 } |
| OLD | NEW |