#include <dart_microtask_queue.h>

Public Member Functions
	DartMicrotaskQueue ()

	~DartMicrotaskQueue ()

void	ScheduleMicrotask (Dart_Handle callback)

void	RunMicrotasks ()

void	Destroy ()

bool	HasMicrotasks () const

DartErrorHandleType	GetLastError ()

Static Public Member Functions
static void	StartForCurrentThread ()

static DartMicrotaskQueue *	GetForCurrentThread ()

Detailed Description

Definition at line 16 of file dart_microtask_queue.h.

Constructor & Destructor Documentation

◆ DartMicrotaskQueue()

tonic::DartMicrotaskQueue::DartMicrotaskQueue ( )

Definition at line 54 of file dart_microtask_queue.cc.

54: last_error_(kNoError) {}

tonic::kNoError

@ kNoError

Definition dart_error.h:68

◆ ~DartMicrotaskQueue()

tonic::DartMicrotaskQueue::~DartMicrotaskQueue ( )

default

Member Function Documentation

◆ Destroy()

void tonic::DartMicrotaskQueue::Destroy ( )

Definition at line 97 of file dart_microtask_queue.cc.

                                 {
  TONIC_DCHECK(this == GetForCurrentThread());
  SetQueue(nullptr);
  delete this;
}

◆ GetForCurrentThread()

DartMicrotaskQueue * tonic::DartMicrotaskQueue::GetForCurrentThread ( )

static

Definition at line 62 of file dart_microtask_queue.cc.

                                                            {
  return GetQueue();
}

◆ GetLastError()

DartErrorHandleType tonic::DartMicrotaskQueue::GetLastError ( )

Definition at line 103 of file dart_microtask_queue.cc.

                                                     {
  return last_error_;
}

◆ HasMicrotasks()

bool tonic::DartMicrotaskQueue::HasMicrotasks ( ) const

inline

Definition at line 29 of file dart_microtask_queue.h.

29{ return !queue_.empty(); }

◆ RunMicrotasks()

void tonic::DartMicrotaskQueue::RunMicrotasks ( )

Definition at line 70 of file dart_microtask_queue.cc.

                                       {
  while (!queue_.empty()) {
    MicrotaskQueue local;
    std::swap(queue_, local);
    for (const auto& callback : local) {
      if (auto dart_state = callback.dart_state().lock()) {
        DartState::Scope dart_scope(dart_state.get());
        Dart_Handle result = Dart_InvokeClosure(callback.value(), 0, nullptr);
        // If the Dart program has set a return code, then it is intending to
        // shut down by way of a fatal error, and so there is no need to emit a
        // log message.
        if (!dart_state->has_set_return_code() || !Dart_IsError(result) ||
            !Dart_IsFatalError(result)) {
          CheckAndHandleError(result);
        }
        DartErrorHandleType error = GetErrorHandleType(result);
        if (error != kNoError) {
          last_error_ = error;
        }
        dart_state->MessageEpilogue(result);
        if (!Dart_CurrentIsolate())
          return;
      }
    }
  }
}

◆ ScheduleMicrotask()

void tonic::DartMicrotaskQueue::ScheduleMicrotask ( Dart_Handle callback )

Definition at line 66 of file dart_microtask_queue.cc.

                                                               {
  queue_.emplace_back(DartState::Current(), callback);
}

◆ StartForCurrentThread()

void tonic::DartMicrotaskQueue::StartForCurrentThread ( )