| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "platform/heap/CallbackStack.h" | 5 #include "platform/heap/CallbackStack.h" |
| 6 #include "wtf/PageAllocator.h" | |
| 7 | 6 |
| 8 namespace blink { | 7 namespace blink { |
| 9 | 8 |
| 10 CallbackStack::Block::Block(Block* next) | 9 void CallbackStack::Block::clear() |
| 11 { | 10 { |
| 12 static_assert((blockSize * sizeof(Item)) % WTF::kPageAllocationGranularity =
= 0, "CallbackStack::blockSize * sizeof(Item) must be a multiple of WTF::kPageAl
locationGranularity"); | |
| 13 m_buffer = static_cast<Item*>(WTF::allocPages(nullptr, blockSize * sizeof(It
em), WTF::kPageAllocationGranularity, WTF::PageAccessible)); | |
| 14 RELEASE_ASSERT(m_buffer); | |
| 15 | |
| 16 #if ENABLE(ASSERT) | |
| 17 for (size_t i = 0; i < blockSize; i++) | |
| 18 m_buffer[i] = Item(0, 0); | |
| 19 #endif | |
| 20 | |
| 21 m_limit = &(m_buffer[blockSize]); | |
| 22 m_current = &(m_buffer[0]); | |
| 23 m_next = next; | |
| 24 } | |
| 25 | |
| 26 CallbackStack::Block::~Block() | |
| 27 { | |
| 28 WTF::freePages(m_buffer, blockSize * sizeof(Item)); | |
| 29 m_buffer = nullptr; | |
| 30 m_limit = nullptr; | |
| 31 m_current = nullptr; | |
| 32 m_next = nullptr; | |
| 33 } | |
| 34 | |
| 35 void CallbackStack::Block::decommit() | |
| 36 { | |
| 37 #if ENABLE(ASSERT) | |
| 38 for (size_t i = 0; i < blockSize; i++) | |
| 39 m_buffer[i] = Item(0, 0); | |
| 40 #endif | |
| 41 | |
| 42 WTF::discardSystemPages(m_buffer, blockSize * sizeof(Item)); | |
| 43 | |
| 44 m_current = &m_buffer[0]; | 11 m_current = &m_buffer[0]; |
| 45 m_next = nullptr; | 12 m_next = nullptr; |
| 13 clearUnused(); |
| 46 } | 14 } |
| 47 | 15 |
| 48 void CallbackStack::Block::invokeEphemeronCallbacks(Visitor* visitor) | 16 void CallbackStack::Block::invokeEphemeronCallbacks(Visitor* visitor) |
| 49 { | 17 { |
| 50 // This loop can tolerate entries being added by the callbacks after | 18 // This loop can tolerate entries being added by the callbacks after |
| 51 // iteration starts. | 19 // iteration starts. |
| 52 for (unsigned i = 0; m_buffer + i < m_current; i++) { | 20 for (unsigned i = 0; m_buffer + i < m_current; i++) { |
| 53 Item& item = m_buffer[i]; | 21 Item& item = m_buffer[i]; |
| 54 item.call(visitor); | 22 item.call(visitor); |
| 55 } | 23 } |
| 56 } | 24 } |
| 57 | 25 |
| 58 #if ENABLE(ASSERT) | 26 #if ENABLE(ASSERT) |
| 59 bool CallbackStack::Block::hasCallbackForObject(const void* object) | 27 bool CallbackStack::Block::hasCallbackForObject(const void* object) |
| 60 { | 28 { |
| 61 for (unsigned i = 0; m_buffer + i < m_current; i++) { | 29 for (unsigned i = 0; m_buffer + i < m_current; i++) { |
| 62 Item* item = &m_buffer[i]; | 30 Item* item = &m_buffer[i]; |
| 63 if (item->object() == object) | 31 if (item->object() == object) |
| 64 return true; | 32 return true; |
| 65 } | 33 } |
| 66 return false; | 34 return false; |
| 67 } | 35 } |
| 68 #endif | 36 #endif |
| 69 | 37 |
| 70 CallbackStack::CallbackStack() | 38 void CallbackStack::Block::clearUnused() |
| 71 : m_first(new Block(0)) | 39 { |
| 72 , m_last(m_first) | 40 #if ENABLE(ASSERT) |
| 41 for (size_t i = 0; i < blockSize; i++) |
| 42 m_buffer[i] = Item(0, 0); |
| 43 #endif |
| 44 } |
| 45 |
| 46 CallbackStack::CallbackStack() : m_first(new Block(0)), m_last(m_first) |
| 73 { | 47 { |
| 74 } | 48 } |
| 75 | 49 |
| 76 CallbackStack::~CallbackStack() | 50 CallbackStack::~CallbackStack() |
| 77 { | 51 { |
| 78 RELEASE_ASSERT(isEmpty()); | 52 clear(); |
| 79 delete m_first; | 53 delete m_first; |
| 80 m_first = nullptr; | 54 m_first = nullptr; |
| 81 m_last = nullptr; | 55 m_last = nullptr; |
| 82 } | 56 } |
| 83 | 57 |
| 84 void CallbackStack::decommit() | 58 void CallbackStack::clear() |
| 85 { | 59 { |
| 86 Block* next; | 60 Block* next; |
| 87 for (Block* current = m_first->next(); current; current = next) { | 61 for (Block* current = m_first->next(); current; current = next) { |
| 88 next = current->next(); | 62 next = current->next(); |
| 89 delete current; | 63 delete current; |
| 90 } | 64 } |
| 91 m_first->decommit(); | 65 m_first->clear(); |
| 92 m_last = m_first; | 66 m_last = m_first; |
| 93 } | 67 } |
| 94 | 68 |
| 95 bool CallbackStack::isEmpty() const | 69 bool CallbackStack::isEmpty() const |
| 96 { | 70 { |
| 97 return hasJustOneBlock() && m_first->isEmptyBlock(); | 71 return hasJustOneBlock() && m_first->isEmptyBlock(); |
| 98 } | 72 } |
| 99 | 73 |
| 100 CallbackStack::Item* CallbackStack::allocateEntrySlow() | 74 CallbackStack::Item* CallbackStack::allocateEntrySlow() |
| 101 { | 75 { |
| 102 ASSERT(!m_first->allocateEntry()); | 76 ASSERT(!m_first->allocateEntry()); |
| 103 m_first = new Block(m_first); | 77 m_first = new Block(m_first); |
| 104 return m_first->allocateEntry(); | 78 return m_first->allocateEntry(); |
| 105 } | 79 } |
| 106 | 80 |
| 107 CallbackStack::Item* CallbackStack::popSlow() | 81 CallbackStack::Item* CallbackStack::popSlow() |
| 108 { | 82 { |
| 109 ASSERT(m_first->isEmptyBlock()); | 83 ASSERT(m_first->isEmptyBlock()); |
| 110 | 84 |
| 111 for (;;) { | 85 for (;;) { |
| 112 Block* next = m_first->next(); | 86 Block* next = m_first->next(); |
| 113 if (!next) { | 87 if (!next) { |
| 114 #if ENABLE(ASSERT) | 88 #if ENABLE(ASSERT) |
| 115 m_first->decommit(); | 89 m_first->clear(); |
| 116 #endif | 90 #endif |
| 117 return nullptr; | 91 return nullptr; |
| 118 } | 92 } |
| 119 delete m_first; | 93 delete m_first; |
| 120 m_first = next; | 94 m_first = next; |
| 121 if (Item* item = m_first->pop()) | 95 if (Item* item = m_first->pop()) |
| 122 return item; | 96 return item; |
| 123 } | 97 } |
| 124 } | 98 } |
| 125 | 99 |
| (...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 161 { | 135 { |
| 162 for (Block* current = m_first; current; current = current->next()) { | 136 for (Block* current = m_first; current; current = current->next()) { |
| 163 if (current->hasCallbackForObject(object)) | 137 if (current->hasCallbackForObject(object)) |
| 164 return true; | 138 return true; |
| 165 } | 139 } |
| 166 return false; | 140 return false; |
| 167 } | 141 } |
| 168 #endif | 142 #endif |
| 169 | 143 |
| 170 } // namespace blink | 144 } // namespace blink |
| OLD | NEW |