dart::BlockStack< BlockSize > Class Template Reference

#include <pointer_block.h>

Classes
class	List

Public Types
typedef PointerBlock< BlockSize >	Block

Public Member Functions
	BlockStack ()
	~BlockStack ()
Block *	PopNonFullBlock ()
Block *	PopEmptyBlock ()
Block *	PopNonEmptyBlock ()
Block *	PopAll ()
void	PushAll (Block *blocks)
void	Reset ()
bool	IsEmpty ()
Block *	WaitForWork (RelaxedAtomic< uintptr_t > *num_busy, bool abort)
void	VisitObjectPointers (ObjectPointerVisitor *visitor)

Static Public Member Functions
static void	Init ()
static void	Cleanup ()

Protected Member Functions
bool	IsEmptyLocked ()
void	PushBlockImpl (Block *block)

Static Protected Member Functions
static void	TrimGlobalEmpty ()

Protected Attributes
List	full_
List	partial_
Monitor	monitor_

Static Protected Attributes
static constexpr intptr_t	kMaxGlobalEmpty = 100
static List *	global_empty_
static Mutex *	global_mutex_ = nullptr

Detailed Description

template<int BlockSize>
class dart::BlockStack< BlockSize >

Definition at line 89 of file pointer_block.h.

Member Typedef Documentation

Block

template<int BlockSize>

typedef PointerBlock<BlockSize> dart::BlockStack< BlockSize >::Block

Definition at line 91 of file pointer_block.h.

Constructor & Destructor Documentation

BlockStack()

template<int BlockSize>

dart::BlockStack< BlockSize >::BlockStack

(

)

Definition at line 44 of file pointer_block.cc.

: monitor_() {}

~BlockStack()

template<int BlockSize>

dart::BlockStack< BlockSize >::~BlockStack

(

)

Definition at line 47 of file pointer_block.cc.

                                   {
  Reset();
}

Member Function Documentation

Cleanup()

template<int BlockSize>

void dart::BlockStack< BlockSize >::Cleanup ( )

static

Definition at line 38 of file pointer_block.cc.

                                    {
  delete global_empty_;
  global_empty_ = nullptr;
}

Init()

template<int BlockSize>

void dart::BlockStack< BlockSize >::Init ( )

static

Definition at line 30 of file pointer_block.cc.

                                 {
  global_empty_ = new List();
  if (global_mutex_ == nullptr) {
    global_mutex_ = new Mutex();
  }
}

IsEmpty()

template<int BlockSize>

bool dart::BlockStack< BlockSize >::IsEmpty

(

)

Definition at line 198 of file pointer_block.cc.

                                    {
  MonitorLocker ml(&monitor_);
  return IsEmptyLocked();
}

IsEmptyLocked()

template<int BlockSize>

bool dart::BlockStack< BlockSize >::IsEmptyLocked ( )

protected

Definition at line 204 of file pointer_block.cc.

                                          {
  return full_.IsEmpty() && partial_.IsEmpty();
}

PopAll()

template<int BlockSize>

BlockStack< BlockSize >::Block * dart::BlockStack< BlockSize >::PopAll

(

)

Definition at line 72 of file pointer_block.cc.

                                                                   {
  MonitorLocker ml(&monitor_);
  while (!partial_.IsEmpty()) {
    full_.Push(partial_.Pop());
  }
  return full_.PopAll();
}

PopEmptyBlock()

template<int BlockSize>

BlockStack< BlockSize >::Block * dart::BlockStack< BlockSize >::PopEmptyBlock

(

)

Definition at line 174 of file pointer_block.cc.

                                                                          {
  {
    MutexLocker ml(global_mutex_);
    if (!global_empty_->IsEmpty()) {
      return global_empty_->Pop();
    }
  }
  return new Block();
}

PopNonEmptyBlock()

template<int BlockSize>

BlockStack< BlockSize >::Block * dart::BlockStack< BlockSize >::PopNonEmptyBlock

(

)

Definition at line 186 of file pointer_block.cc.

                                        {
  MonitorLocker ml(&monitor_);
  if (!full_.IsEmpty()) {
    return full_.Pop();
  } else if (!partial_.IsEmpty()) {
    return partial_.Pop();
  } else {
    return nullptr;
  }
}

PopNonFullBlock()

template<int BlockSize>

BlockStack< BlockSize >::Block * dart::BlockStack< BlockSize >::PopNonFullBlock

(

)

Definition at line 163 of file pointer_block.cc.

                                       {
  {
    MonitorLocker ml(&monitor_);
    if (!partial_.IsEmpty()) {
      return partial_.Pop();
    }
  }
  return PopEmptyBlock();
}

PushAll()

template<int BlockSize>

void dart::BlockStack< BlockSize >::PushAll

(

Block *

blocks

)

Definition at line 81 of file pointer_block.cc.

                                                {
  while (block != nullptr) {
    Block* next = block->next();
    block->set_next(nullptr);
    PushBlockImpl(block);
    block = next;
  }
}

PushBlockImpl()

template<int BlockSize>

void dart::BlockStack< BlockSize >::PushBlockImpl ( Block *  block )

protected

Definition at line 91 of file pointer_block.cc.

                                                      {
  ASSERT(block->next() == nullptr);  // Should be just a single block.
  if (block->IsFull()) {
    MonitorLocker ml(&monitor_);
    bool was_empty = IsEmptyLocked();
    full_.Push(block);
    if (was_empty) ml.Notify();
  } else if (block->IsEmpty()) {
    MutexLocker ml(global_mutex_);
    global_empty_->Push(block);
    TrimGlobalEmpty();
  } else {
    MonitorLocker ml(&monitor_);
    bool was_empty = IsEmptyLocked();
    partial_.Push(block);
    if (was_empty) ml.Notify();
  }
}

Reset()

template<int BlockSize>

void dart::BlockStack< BlockSize >::Reset

(

)

Definition at line 52 of file pointer_block.cc.

                                  {
  MonitorLocker local_mutex_locker(&monitor_);
  {
    // Empty all blocks and move them to the global cache.
    MutexLocker global_mutex_locker(global_mutex_);
    while (!full_.IsEmpty()) {
      Block* block = full_.Pop();
      block->Reset();
      global_empty_->Push(block);
    }
    while (!partial_.IsEmpty()) {
      Block* block = partial_.Pop();
      block->Reset();
      global_empty_->Push(block);
    }
    TrimGlobalEmpty();
  }
}

TrimGlobalEmpty()

template<int BlockSize>

void dart::BlockStack< BlockSize >::TrimGlobalEmpty ( )

staticprotected

Definition at line 262 of file pointer_block.cc.

                                            {
  DEBUG_ASSERT(global_mutex_->IsOwnedByCurrentThread());
  while (global_empty_->length() > kMaxGlobalEmpty) {
    delete global_empty_->Pop();
  }
}

VisitObjectPointers()

template<int BlockSize>

void dart::BlockStack< BlockSize >::VisitObjectPointers

(

ObjectPointerVisitor *

visitor

)

Definition at line 251 of file pointer_block.cc.

                                                                             {
  for (Block* block = full_.Peek(); block != nullptr; block = block->next()) {
    block->VisitObjectPointers(visitor);
  }
  for (Block* block = partial_.Peek(); block != nullptr;
       block = block->next()) {
    block->VisitObjectPointers(visitor);
  }
}

WaitForWork()

template<int BlockSize>

BlockStack< BlockSize >::Block * dart::BlockStack< BlockSize >::WaitForWork	(	RelaxedAtomic< uintptr_t > *	num_busy,
		bool	abort
	)

Definition at line 111 of file pointer_block.cc.

                {
  MonitorLocker ml(&monitor_);
  if (num_busy->fetch_sub(1u) == 1 /* 1 is before subtraction */) {
    // This is the last worker, wake the others now that we know no further work
    // will come.
    ml.NotifyAll();
    return nullptr;
  }
  if (abort) {
    return nullptr;
  }
  for (;;) {
    if (!full_.IsEmpty()) {
      num_busy->fetch_add(1u);
      return full_.Pop();
    }
    if (!partial_.IsEmpty()) {
      num_busy->fetch_add(1u);
      return partial_.Pop();
    }
    ml.Wait();
    if (num_busy->load() == 0) {
      return nullptr;
    }
  }
}

Member Data Documentation

full_

template<int BlockSize>

List dart::BlockStack< BlockSize >::full_

protected

Definition at line 144 of file pointer_block.h.

global_empty_

template<int BlockSize>

END_LEAF_RUNTIME_ENTRY BlockStack< BlockSize >::List * dart::BlockStack< BlockSize >::global_empty_

staticprotected

Initial value:

=
    nullptr

Definition at line 150 of file pointer_block.h.

global_mutex_

template<int BlockSize>

Mutex * dart::BlockStack< BlockSize >::global_mutex_ = nullptr

staticprotected

Definition at line 151 of file pointer_block.h.

kMaxGlobalEmpty

template<int BlockSize>

constexpr intptr_t dart::BlockStack< BlockSize >::kMaxGlobalEmpty = 100

staticconstexprprotected

Definition at line 149 of file pointer_block.h.

monitor_

template<int BlockSize>

Monitor dart::BlockStack< BlockSize >::monitor_

protected

Definition at line 146 of file pointer_block.h.

partial_

template<int BlockSize>

List dart::BlockStack< BlockSize >::partial_

protected

Definition at line 145 of file pointer_block.h.

---

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

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