Index: src/heap/store-buffer.h |
diff --git a/src/heap/store-buffer.h b/src/heap/store-buffer.h |
index 1c985816413a11bd38f0d8c0b1f18edc0a55728d..1b3fcb0a98b22ea5bb254c596e5cfe1ab7e1dadb 100644 |
--- a/src/heap/store-buffer.h |
+++ b/src/heap/store-buffer.h |
@@ -8,7 +8,6 @@ |
#include "src/allocation.h" |
#include "src/base/logging.h" |
#include "src/base/platform/platform.h" |
-#include "src/cancelable-task.h" |
#include "src/globals.h" |
#include "src/heap/slot-set.h" |
@@ -16,17 +15,11 @@ |
namespace internal { |
// Intermediate buffer that accumulates old-to-new stores from the generated |
-// code. Moreover, it stores invalid old-to-new slots with two entries. |
-// The first is a tagged address of the start of the invalid range, the second |
-// one is the end address of the invalid range or null if there is just one slot |
-// that needs to be removed from the remembered set. On buffer overflow the |
-// slots are moved to the remembered set. |
+// code. On buffer overflow the slots are moved to the remembered set. |
class StoreBuffer { |
public: |
static const int kStoreBufferSize = 1 << (14 + kPointerSizeLog2); |
static const int kStoreBufferMask = kStoreBufferSize - 1; |
- static const int kStoreBuffers = 2; |
- static const intptr_t kDeletionTag = 1; |
static void StoreBufferOverflow(Isolate* isolate); |
@@ -37,92 +30,17 @@ |
// Used to add entries from generated code. |
inline Address* top_address() { return reinterpret_cast<Address*>(&top_); } |
- // Moves entries from a specific store buffer to the remembered set. This |
- // method takes a lock. |
- void MoveEntriesToRememberedSet(int index); |
- |
- // This method ensures that all used store buffer entries are transfered to |
- // the remembered set. |
- void MoveAllEntriesToRememberedSet(); |
- |
- inline bool IsDeletionAddress(Address address) const { |
- return reinterpret_cast<intptr_t>(address) & kDeletionTag; |
- } |
- |
- inline Address MarkDeletionAddress(Address address) { |
- return reinterpret_cast<Address>(reinterpret_cast<intptr_t>(address) | |
- kDeletionTag); |
- } |
- |
- inline Address UnmarkDeletionAddress(Address address) { |
- return reinterpret_cast<Address>(reinterpret_cast<intptr_t>(address) & |
- ~kDeletionTag); |
- } |
- |
- // If we only want to delete a single slot, end should be set to null which |
- // will be written into the second field. When processing the store buffer |
- // the more efficient Remove method will be called in this case. |
- void DeleteEntry(Address start, Address end = nullptr); |
- |
- // Used by the concurrent processing thread to transfer entries from the |
- // store buffer to the remembered set. |
- void ConcurrentlyProcessStoreBuffer(); |
- |
- bool Empty() { |
- for (int i = 0; i < kStoreBuffers; i++) { |
- if (lazy_top_[i]) { |
- return false; |
- } |
- } |
- return top_ == start_[current_]; |
- } |
+ void MoveEntriesToRememberedSet(); |
private: |
- // There are two store buffers. If one store buffer fills up, the main thread |
- // publishes the top pointer of the store buffer that needs processing in its |
- // global lazy_top_ field. After that it start the concurrent processing |
- // thread. The concurrent processing thread uses the pointer in lazy_top_. |
- // It will grab the given mutex and transfer its entries to the remembered |
- // set. If the concurrent thread does not make progress, the main thread will |
- // perform the work. |
- // Important: there is an ordering constrained. The store buffer with the |
- // older entries has to be processed first. |
- class Task : public CancelableTask { |
- public: |
- Task(Isolate* isolate, StoreBuffer* store_buffer) |
- : CancelableTask(isolate), store_buffer_(store_buffer) {} |
- virtual ~Task() {} |
- |
- private: |
- void RunInternal() override { |
- store_buffer_->ConcurrentlyProcessStoreBuffer(); |
- } |
- StoreBuffer* store_buffer_; |
- DISALLOW_COPY_AND_ASSIGN(Task); |
- }; |
- |
- void FlipStoreBuffers(); |
- |
Heap* heap_; |
Address* top_; |
// The start and the limit of the buffer that contains store slots |
- // added from the generated code. We have two chunks of store buffers. |
- // Whenever one fills up, we notify a concurrent processing thread and |
- // use the other empty one in the meantime. |
- Address* start_[kStoreBuffers]; |
- Address* limit_[kStoreBuffers]; |
- |
- // At most one lazy_top_ pointer is set at any time. |
- Address* lazy_top_[kStoreBuffers]; |
- base::Mutex mutex_; |
- |
- // We only want to have at most one concurrent processing tas running. |
- bool task_running_; |
- |
- // Points to the current buffer in use. |
- int current_; |
+ // added from the generated code. |
+ Address* start_; |
+ Address* limit_; |
base::VirtualMemory* virtual_memory_; |
}; |