dart::PrologueTask Class Reference

Inheritance diagram for dart::PrologueTask:

Public Member Functions
	PrologueTask (ThreadBarrier *barrier, IsolateGroup *isolate_group, PageSpace *old_space, PrologueState *state)
void	Run ()
void	RunEnteredIsolateGroup ()
void	MarkEvacuationCandidates ()
void	PruneFreeLists ()
Public Member Functions inherited from dart::ThreadPool::Task
virtual	~Task ()
virtual void	Run ()=0
Public Member Functions inherited from dart::IntrusiveDListEntry< Task >
	IntrusiveDListEntry ()
	~IntrusiveDListEntry ()

Additional Inherited Members
Protected Member Functions inherited from dart::ThreadPool::Task
	Task ()

Detailed Description

Definition at line 102 of file incremental_compactor.cc.

Constructor & Destructor Documentation

PrologueTask()

dart::PrologueTask::PrologueTask ( ThreadBarrier *  barrier, IsolateGroup *  isolate_group, PageSpace *  old_space, PrologueState *  state  )

inline

Definition at line 104 of file incremental_compactor.cc.

      : barrier_(barrier),
        isolate_group_(isolate_group),
        old_space_(old_space),
        state_(state) {}

Member Function Documentation

MarkEvacuationCandidates()

void dart::PrologueTask::MarkEvacuationCandidates ( )

inline

Definition at line 137 of file incremental_compactor.cc.

                                  {
    TIMELINE_FUNCTION_GC_DURATION(Thread::Current(),
                                  "MarkEvacuationCandidates");
    for (;;) {
      intptr_t page_index = state_->page_cursor.fetch_add(1);
      if (page_index >= state_->page_limit) break;
      Page* page = state_->pages[page_index].page;
 
      // Already set, otherwise a barrier would be needed before moving onto
      // freelists.
      ASSERT(page->is_evacuation_candidate());
 
      uword start = page->object_start();
      uword end = page->object_end();
      uword current = start;
      while (current < end) {
        ObjectPtr obj = UntaggedObject::FromAddr(current);
        intptr_t cid = obj->untag()->GetClassId();
        if (cid != kFreeListElement && cid != kForwardingCorpse) {
          obj->untag()->SetIsEvacuationCandidateUnsynchronized();
        }
        current += obj->untag()->HeapSize();
      }
    }
  }

PruneFreeLists()

void dart::PrologueTask::PruneFreeLists ( )

inline

Definition at line 163 of file incremental_compactor.cc.

                        {
    TIMELINE_FUNCTION_GC_DURATION(Thread::Current(), "PruneFreeLists");
    for (;;) {
      intptr_t chunk = state_->freelist_cursor.fetch_add(1);
      if (chunk >= state_->freelist_limit) break;
      intptr_t list_index = chunk / (FreeList::kNumLists + 1);
      intptr_t size_class_index = chunk % (FreeList::kNumLists + 1);
      FreeList* freelist = &old_space_->freelists_[list_index];
 
      // Empty bump-region, no need to prune this.
      ASSERT(freelist->top_ == freelist->end_);
 
      FreeListElement* current = freelist->free_lists_[size_class_index];
      freelist->free_lists_[size_class_index] = nullptr;
      while (current != nullptr) {
        FreeListElement* next = current->next();
        if (!Page::Of(current)->is_evacuation_candidate()) {
          current->set_next(freelist->free_lists_[size_class_index]);
          freelist->free_lists_[size_class_index] = current;
        }
        current = next;
      }
    }
  }

Run()

void dart::PrologueTask::Run ( )

inlinevirtual

Implements dart::ThreadPool::Task.

Definition at line 113 of file incremental_compactor.cc.

             {
    if (!barrier_->TryEnter()) {
      barrier_->Release();
      return;
    }
 
    bool result = Thread::EnterIsolateGroupAsHelper(
        isolate_group_, Thread::kIncrementalCompactorTask,
        /*bypass_safepoint=*/true);
    ASSERT(result);
 
    RunEnteredIsolateGroup();
 
    Thread::ExitIsolateGroupAsHelper(/*bypass_safepoint=*/true);
 
    barrier_->Sync();
    barrier_->Release();
  }

RunEnteredIsolateGroup()

void dart::PrologueTask::RunEnteredIsolateGroup ( )

inline

Definition at line 132 of file incremental_compactor.cc.

                                {
    MarkEvacuationCandidates();
    PruneFreeLists();
  }

---

The documentation for this class was generated from the following file:

• third_party/dart-lang/sdk/runtime/vm/heap/incremental_compactor.cc