OLD | NEW |
1 /* | 1 /* |
2 Copyright (C) 1998 Lars Knoll (knoll@mpi-hd.mpg.de) | 2 Copyright (C) 1998 Lars Knoll (knoll@mpi-hd.mpg.de) |
3 Copyright (C) 2001 Dirk Mueller (mueller@kde.org) | 3 Copyright (C) 2001 Dirk Mueller (mueller@kde.org) |
4 Copyright (C) 2002 Waldo Bastian (bastian@kde.org) | 4 Copyright (C) 2002 Waldo Bastian (bastian@kde.org) |
5 Copyright (C) 2004, 2005, 2006, 2007, 2008 Apple Inc. All rights reserved. | 5 Copyright (C) 2004, 2005, 2006, 2007, 2008 Apple Inc. All rights reserved. |
6 | 6 |
7 This library is free software; you can redistribute it and/or | 7 This library is free software; you can redistribute it and/or |
8 modify it under the terms of the GNU Library General Public | 8 modify it under the terms of the GNU Library General Public |
9 License as published by the Free Software Foundation; either | 9 License as published by the Free Software Foundation; either |
10 version 2 of the License, or (at your option) any later version. | 10 version 2 of the License, or (at your option) any later version. |
11 | 11 |
12 This library is distributed in the hope that it will be useful, | 12 This library is distributed in the hope that it will be useful, |
13 but WITHOUT ANY WARRANTY; without even the implied warranty of | 13 but WITHOUT ANY WARRANTY; without even the implied warranty of |
14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU | 14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU |
15 Library General Public License for more details. | 15 Library General Public License for more details. |
16 | 16 |
17 You should have received a copy of the GNU Library General Public License | 17 You should have received a copy of the GNU Library General Public License |
18 along with this library; see the file COPYING.LIB. If not, write to | 18 along with this library; see the file COPYING.LIB. If not, write to |
19 the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, | 19 the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, |
20 Boston, MA 02110-1301, USA. | 20 Boston, MA 02110-1301, USA. |
21 */ | 21 */ |
22 | 22 |
23 #include "config.h" | 23 #include "config.h" |
24 #include "core/loader/cache/MemoryCache.h" | 24 #include "core/loader/cache/MemoryCache.h" |
25 | 25 |
26 #include <stdio.h> | 26 #include <stdio.h> |
27 #include "core/dom/CrossThreadTask.h" | 27 #include "core/dom/CrossThreadTask.h" |
28 #include "core/dom/Document.h" | 28 #include "core/dom/Document.h" |
29 #include "core/loader/cache/CachedResource.h" | |
30 #include "core/loader/cache/CachedResourceHandle.h" | 29 #include "core/loader/cache/CachedResourceHandle.h" |
31 #include "core/page/FrameView.h" | 30 #include "core/page/FrameView.h" |
32 #include "core/platform/Logging.h" | 31 #include "core/platform/Logging.h" |
33 #include "core/workers/WorkerGlobalScope.h" | 32 #include "core/workers/WorkerGlobalScope.h" |
34 #include "core/workers/WorkerLoaderProxy.h" | 33 #include "core/workers/WorkerLoaderProxy.h" |
35 #include "core/workers/WorkerThread.h" | 34 #include "core/workers/WorkerThread.h" |
36 #include "weborigin/SecurityOrigin.h" | 35 #include "weborigin/SecurityOrigin.h" |
37 #include "weborigin/SecurityOriginHash.h" | 36 #include "weborigin/SecurityOriginHash.h" |
38 #include "wtf/Assertions.h" | 37 #include "wtf/Assertions.h" |
39 #include "wtf/CurrentTime.h" | 38 #include "wtf/CurrentTime.h" |
(...skipping 24 matching lines...) Expand all Loading... |
64 gMemoryCache = memoryCache; | 63 gMemoryCache = memoryCache; |
65 } | 64 } |
66 | 65 |
67 MemoryCache::MemoryCache() | 66 MemoryCache::MemoryCache() |
68 : m_inPruneResources(false) | 67 : m_inPruneResources(false) |
69 , m_capacity(cDefaultCacheCapacity) | 68 , m_capacity(cDefaultCacheCapacity) |
70 , m_minDeadCapacity(0) | 69 , m_minDeadCapacity(0) |
71 , m_maxDeadCapacity(cDefaultCacheCapacity) | 70 , m_maxDeadCapacity(cDefaultCacheCapacity) |
72 , m_liveSize(0) | 71 , m_liveSize(0) |
73 , m_deadSize(0) | 72 , m_deadSize(0) |
| 73 , m_delayBeforeLiveDecodedPrune(cMinDelayBeforeLiveDecodedPrune) |
74 #ifdef MEMORY_CACHE_STATS | 74 #ifdef MEMORY_CACHE_STATS |
75 , m_statsTimer(this, &MemoryCache::dumpStats) | 75 , m_statsTimer(this, &MemoryCache::dumpStats) |
76 #endif | 76 #endif |
77 { | 77 { |
78 #ifdef MEMORY_CACHE_STATS | 78 #ifdef MEMORY_CACHE_STATS |
79 const double statsIntervalInSeconds = 15; | 79 const double statsIntervalInSeconds = 15; |
80 m_statsTimer.startRepeating(statsIntervalInSeconds); | 80 m_statsTimer.startRepeating(statsIntervalInSeconds); |
81 #endif | 81 #endif |
82 } | 82 } |
83 | 83 |
(...skipping 69 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
153 if (capacity && m_liveSize <= capacity) | 153 if (capacity && m_liveSize <= capacity) |
154 return; | 154 return; |
155 | 155 |
156 unsigned targetSize = static_cast<unsigned>(capacity * cTargetPrunePercentag
e); // Cut by a percentage to avoid immediately pruning again. | 156 unsigned targetSize = static_cast<unsigned>(capacity * cTargetPrunePercentag
e); // Cut by a percentage to avoid immediately pruning again. |
157 | 157 |
158 double currentTime = FrameView::currentPaintTimeStamp(); | 158 double currentTime = FrameView::currentPaintTimeStamp(); |
159 if (!currentTime) // In case prune is called directly, outside of a Frame pa
int. | 159 if (!currentTime) // In case prune is called directly, outside of a Frame pa
int. |
160 currentTime = WTF::currentTime(); | 160 currentTime = WTF::currentTime(); |
161 | 161 |
162 // Destroy any decoded data in live objects that we can. | 162 // Destroy any decoded data in live objects that we can. |
163 // Start from the tail, since this is the least recently accessed of the obj
ects. | 163 // Start from the tail, since this is the lowest priority |
| 164 // and least recently accessed of the objects. |
164 | 165 |
165 // The list might not be sorted by the m_lastDecodedAccessTime. The impact | 166 // The list might not be sorted by the m_lastDecodedAccessTime. The impact |
166 // of this weaker invariant is minor as the below if statement to check the | 167 // of this weaker invariant is minor as the below if statement to check the |
167 // elapsedTime will evaluate to false as the currentTime will be a lot | 168 // elapsedTime will evaluate to false as the currentTime will be a lot |
168 // greater than the current->m_lastDecodedAccessTime. | 169 // greater than the current->m_lastDecodedAccessTime. |
169 // For more details see: https://bugs.webkit.org/show_bug.cgi?id=30209 | 170 // For more details see: https://bugs.webkit.org/show_bug.cgi?id=30209 |
170 CachedResource* current = m_liveDecodedResources.m_tail; | |
171 while (current) { | |
172 CachedResource* prev = current->m_prevInLiveResourcesList; | |
173 ASSERT(current->hasClients()); | |
174 if (current->isLoaded() && current->decodedSize()) { | |
175 // Check to see if the remaining resources are too new to prune. | |
176 double elapsedTime = currentTime - current->m_lastDecodedAccessTime; | |
177 if (elapsedTime < cMinDelayBeforeLiveDecodedPrune) | |
178 return; | |
179 | 171 |
180 // Destroy our decoded data. This will remove us from | 172 // Start pruning from the lowest priority list. |
181 // m_liveDecodedResources, and possibly move us to a different LRU | 173 for (int priority = CachedResource::CacheLiveResourcePriorityLow; priority <
= CachedResource::CacheLiveResourcePriorityHigh; ++priority) { |
182 // list in m_allResources. | 174 CachedResource* current = m_liveDecodedResources[priority].m_tail; |
183 current->destroyDecodedData(); | 175 while (current) { |
| 176 CachedResource* prev = current->m_prevInLiveResourcesList; |
| 177 ASSERT(current->hasClients()); |
| 178 if (current->isLoaded() && current->decodedSize()) { |
| 179 // Check to see if the remaining resources are too new to prune. |
| 180 double elapsedTime = currentTime - current->m_lastDecodedAccessT
ime; |
| 181 if (elapsedTime < m_delayBeforeLiveDecodedPrune) |
| 182 return; |
184 | 183 |
185 if (targetSize && m_liveSize <= targetSize) | 184 // Destroy our decoded data. This will remove us from |
186 return; | 185 // m_liveDecodedResources, and possibly move us to a different L
RU |
| 186 // list in m_allResources. |
| 187 current->destroyDecodedData(); |
| 188 |
| 189 if (targetSize && m_liveSize <= targetSize) |
| 190 return; |
| 191 } |
| 192 current = prev; |
187 } | 193 } |
188 current = prev; | |
189 } | 194 } |
190 } | 195 } |
191 | 196 |
192 void MemoryCache::pruneDeadResources() | 197 void MemoryCache::pruneDeadResources() |
193 { | 198 { |
194 unsigned capacity = deadCapacity(); | 199 unsigned capacity = deadCapacity(); |
195 if (capacity && m_deadSize <= capacity) | 200 if (capacity && m_deadSize <= capacity) |
196 return; | 201 return; |
197 | 202 |
198 unsigned targetSize = static_cast<unsigned>(capacity * cTargetPrunePercentag
e); // Cut by a percentage to avoid immediately pruning again. | 203 unsigned targetSize = static_cast<unsigned>(capacity * cTargetPrunePercentag
e); // Cut by a percentage to avoid immediately pruning again. |
(...skipping 188 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
387 | 392 |
388 } | 393 } |
389 | 394 |
390 void MemoryCache::removeFromLiveDecodedResourcesList(CachedResource* resource) | 395 void MemoryCache::removeFromLiveDecodedResourcesList(CachedResource* resource) |
391 { | 396 { |
392 // If we've never been accessed, then we're brand new and not in any list. | 397 // If we've never been accessed, then we're brand new and not in any list. |
393 if (!resource->m_inLiveDecodedResourcesList) | 398 if (!resource->m_inLiveDecodedResourcesList) |
394 return; | 399 return; |
395 resource->m_inLiveDecodedResourcesList = false; | 400 resource->m_inLiveDecodedResourcesList = false; |
396 | 401 |
| 402 LRUList* list = &m_liveDecodedResources[resource->cacheLiveResourcePriority(
)]; |
| 403 |
397 #if !ASSERT_DISABLED | 404 #if !ASSERT_DISABLED |
398 // Verify that we are in fact in this list. | 405 // Verify that we are in fact in this list. |
399 bool found = false; | 406 bool found = false; |
400 for (CachedResource* current = m_liveDecodedResources.m_head; current; curre
nt = current->m_nextInLiveResourcesList) { | 407 for (CachedResource* current = list->m_head; current; current = current->m_n
extInLiveResourcesList) { |
401 if (current == resource) { | 408 if (current == resource) { |
402 found = true; | 409 found = true; |
403 break; | 410 break; |
404 } | 411 } |
405 } | 412 } |
406 ASSERT(found); | 413 ASSERT(found); |
407 #endif | 414 #endif |
408 | 415 |
409 CachedResource* next = resource->m_nextInLiveResourcesList; | 416 CachedResource* next = resource->m_nextInLiveResourcesList; |
410 CachedResource* prev = resource->m_prevInLiveResourcesList; | 417 CachedResource* prev = resource->m_prevInLiveResourcesList; |
411 | 418 |
412 if (next == 0 && prev == 0 && m_liveDecodedResources.m_head != resource) | 419 if (!next && !prev && list->m_head != resource) |
413 return; | 420 return; |
414 | 421 |
415 resource->m_nextInLiveResourcesList = 0; | 422 resource->m_nextInLiveResourcesList = 0; |
416 resource->m_prevInLiveResourcesList = 0; | 423 resource->m_prevInLiveResourcesList = 0; |
417 | 424 |
418 if (next) | 425 if (next) |
419 next->m_prevInLiveResourcesList = prev; | 426 next->m_prevInLiveResourcesList = prev; |
420 else if (m_liveDecodedResources.m_tail == resource) | 427 else if (list->m_tail == resource) |
421 m_liveDecodedResources.m_tail = prev; | 428 list->m_tail = prev; |
422 | 429 |
423 if (prev) | 430 if (prev) |
424 prev->m_nextInLiveResourcesList = next; | 431 prev->m_nextInLiveResourcesList = next; |
425 else if (m_liveDecodedResources.m_head == resource) | 432 else if (list->m_head == resource) |
426 m_liveDecodedResources.m_head = next; | 433 list->m_head = next; |
427 } | 434 } |
428 | 435 |
429 void MemoryCache::insertInLiveDecodedResourcesList(CachedResource* resource) | 436 void MemoryCache::insertInLiveDecodedResourcesList(CachedResource* resource) |
430 { | 437 { |
431 // Make sure we aren't in the list already. | 438 // Make sure we aren't in the list already. |
432 ASSERT(!resource->m_nextInLiveResourcesList && !resource->m_prevInLiveResour
cesList && !resource->m_inLiveDecodedResourcesList); | 439 ASSERT(!resource->m_nextInLiveResourcesList && !resource->m_prevInLiveResour
cesList && !resource->m_inLiveDecodedResourcesList); |
433 resource->m_inLiveDecodedResourcesList = true; | 440 resource->m_inLiveDecodedResourcesList = true; |
434 | 441 |
435 resource->m_nextInLiveResourcesList = m_liveDecodedResources.m_head; | 442 LRUList* list = &m_liveDecodedResources[resource->cacheLiveResourcePriority(
)]; |
436 if (m_liveDecodedResources.m_head) | 443 resource->m_nextInLiveResourcesList = list->m_head; |
437 m_liveDecodedResources.m_head->m_prevInLiveResourcesList = resource; | 444 if (list->m_head) |
438 m_liveDecodedResources.m_head = resource; | 445 list->m_head->m_prevInLiveResourcesList = resource; |
439 | 446 list->m_head = resource; |
| 447 |
440 if (!resource->m_nextInLiveResourcesList) | 448 if (!resource->m_nextInLiveResourcesList) |
441 m_liveDecodedResources.m_tail = resource; | 449 list->m_tail = resource; |
442 | 450 |
443 #if !ASSERT_DISABLED | 451 #if !ASSERT_DISABLED |
444 // Verify that we are in now in the list like we should be. | 452 // Verify that we are in now in the list like we should be. |
445 bool found = false; | 453 bool found = false; |
446 for (CachedResource* current = m_liveDecodedResources.m_head; current; curre
nt = current->m_nextInLiveResourcesList) { | 454 for (CachedResource* current = list->m_head; current; current = current->m_n
extInLiveResourcesList) { |
447 if (current == resource) { | 455 if (current == resource) { |
448 found = true; | 456 found = true; |
449 break; | 457 break; |
450 } | 458 } |
451 } | 459 } |
452 ASSERT(found); | 460 ASSERT(found); |
453 #endif | 461 #endif |
454 | 462 |
455 } | 463 } |
456 | 464 |
(...skipping 142 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
599 printf("(%.1fK, %.1fK, %uA, %dR, %d, %d); ", current->decodedSiz
e() / 1024.0f, (current->encodedSize() + current->overheadSize()) / 1024.0f, cur
rent->accessCount(), current->hasClients(), current->isPurgeable(), current->was
Purged()); | 607 printf("(%.1fK, %.1fK, %uA, %dR, %d, %d); ", current->decodedSiz
e() / 1024.0f, (current->encodedSize() + current->overheadSize()) / 1024.0f, cur
rent->accessCount(), current->hasClients(), current->isPurgeable(), current->was
Purged()); |
600 | 608 |
601 current = prev; | 609 current = prev; |
602 } | 610 } |
603 } | 611 } |
604 } | 612 } |
605 | 613 |
606 #endif // MEMORY_CACHE_STATS | 614 #endif // MEMORY_CACHE_STATS |
607 | 615 |
608 } // namespace WebCore | 616 } // namespace WebCore |
OLD | NEW |