dart::ThreadInterrupter Class Reference

#include <thread_interrupter.h>

Inheritance diagram for dart::ThreadInterrupter:

Static Public Member Functions
static void	Init ()
static void	Startup ()
static void	Cleanup ()
static void	SetInterruptPeriod (intptr_t period)
static void	WakeUp ()
static void	InterruptThread (OSThread *thread)
static void *	PrepareCurrentThread ()
static void	CleanupCurrentThreadState (void *state)

Friends
class	ThreadInterrupterVisitIsolates

Detailed Description

Definition at line 23 of file thread_interrupter.h.

Member Function Documentation

Cleanup()

void dart::ThreadInterrupter::Cleanup ( )

static

Definition at line 83 of file thread_interrupter.cc.

                                {
  {
    MonitorLocker shutdown_ml(monitor_);
    if (shutdown_) {
      // Already shutdown.
      return;
    }
    shutdown_ = true;
    // Notify.
    shutdown_ml.Notify();
    ASSERT(initialized_);
    if (FLAG_trace_thread_interrupter) {
      OS::PrintErr("ThreadInterrupter shutting down.\n");
    }
  }
 
  // Join the thread.
  ASSERT(interrupter_thread_id_ != OSThread::kInvalidThreadJoinId);
  OSThread::Join(interrupter_thread_id_);
  interrupter_thread_id_ = OSThread::kInvalidThreadJoinId;
  initialized_ = false;
 
  if (FLAG_trace_thread_interrupter) {
    OS::PrintErr("ThreadInterrupter shut down.\n");
  }
}

CleanupCurrentThreadState()

void dart::ThreadInterrupter::CleanupCurrentThreadState ( void *  state )

static

Definition at line 238 of file thread_interrupter.cc.

{}

Init()

void dart::ThreadInterrupter::Init ( )

static

Definition at line 54 of file thread_interrupter.cc.

                             {
  ASSERT(!initialized_);
  if (monitor_ == nullptr) {
    monitor_ = new Monitor();
  }
  ASSERT(monitor_ != nullptr);
  initialized_ = true;
  shutdown_ = false;
}

InterruptThread()

static void dart::ThreadInterrupter::InterruptThread ( OSThread *  thread )

static

PrepareCurrentThread()

void * dart::ThreadInterrupter::PrepareCurrentThread ( )

static

Definition at line 234 of file thread_interrupter.cc.

                                              {
  return nullptr;
}

SetInterruptPeriod()

void dart::ThreadInterrupter::SetInterruptPeriod ( intptr_t  period )

static

Definition at line 111 of file thread_interrupter.cc.

                                                          {
  if (!initialized_) {
    // Profiler may not be enabled.
    return;
  }
  MonitorLocker ml(monitor_);
  if (shutdown_) {
    return;
  }
  ASSERT(initialized_);
  ASSERT(period > 0);
  interrupt_period_ = period;
}

Startup()

void dart::ThreadInterrupter::Startup ( )

static

Definition at line 64 of file thread_interrupter.cc.

                                {
  ASSERT(initialized_);
  if (FLAG_trace_thread_interrupter) {
    OS::PrintErr("ThreadInterrupter starting up.\n");
  }
  ASSERT(interrupter_thread_id_ == OSThread::kInvalidThreadJoinId);
  {
    MonitorLocker startup_ml(monitor_);
    OSThread::Start("Dart Profiler ThreadInterrupter", ThreadMain, 0);
    while (!thread_running_) {
      startup_ml.Wait();
    }
  }
  ASSERT(interrupter_thread_id_ != OSThread::kInvalidThreadJoinId);
  if (FLAG_trace_thread_interrupter) {
    OS::PrintErr("ThreadInterrupter running.\n");
  }
}

WakeUp()

void dart::ThreadInterrupter::WakeUp ( )

static

Definition at line 125 of file thread_interrupter.cc.

                               {
  if (monitor_ == nullptr) {
    // Early call.
    return;
  }
  {
    MonitorLocker ml(monitor_);
    if (shutdown_) {
      // Late call
      return;
    }
    if (!initialized_) {
      // Early call.
      return;
    }
    woken_up_ = true;
    if (!InDeepSleep()) {
      // No need to notify, regularly waking up.
      return;
    }
    // Notify the interrupter to wake it from its deep sleep.
    ml.Notify();
  }
}

Friends And Related Function Documentation

ThreadInterrupterVisitIsolates

friend class ThreadInterrupterVisitIsolates

friend

Definition at line 67 of file thread_interrupter.h.

---

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

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