Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(418)

Unified Diff: src/heap/store-buffer.h

Issue 2449853010: Revert of [heap] Concurrent store buffer processing. (Closed)
Patch Set: Created 4 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « src/heap/heap.cc ('k') | src/heap/store-buffer.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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_;
};
« no previous file with comments | « src/heap/heap.cc ('k') | src/heap/store-buffer.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698