dart::KernelIsolate Class Reference

#include <kernel_isolate.h>

Inheritance diagram for dart::KernelIsolate:

Static Public Member Functions
static void	InitializeState ()
static bool	Start ()
static void	Shutdown ()
static bool	Exists ()
static bool	IsRunning ()
static Dart_Port	WaitForKernelPort ()
static Dart_Port	KernelPort ()
static Dart_KernelCompilationResult	CompileToKernel (const char *script_uri, const uint8_t *platform_kernel, intptr_t platform_kernel_size, int source_files_count=0, Dart_SourceFile source_files[]=nullptr, bool incremental_compile=true, bool for_snapshot=false, bool embed_sources=true, const char *package_config=nullptr, const char *multiroot_filepaths=nullptr, const char *multiroot_scheme=nullptr, Dart_KernelCompilationVerbosityLevel verbosity=Dart_KernelCompilationVerbosityLevel_All)
static Dart_KernelCompilationResult	AcceptCompilation ()
static Dart_KernelCompilationResult	RejectCompilation ()
static Dart_KernelCompilationResult	UpdateInMemorySources (int source_files_count, Dart_SourceFile source_files[])
static Dart_KernelCompilationResult	CompileExpressionToKernel (const uint8_t *platform_kernel, intptr_t platform_kernel_size, const char *expression, const Array &definitions, const Array &definition_types, const Array &type_definitions, const Array &type_bounds, const Array &type_defaults, const char *library_url, const char *klass, const char *method, TokenPosition token_pos, char const *script_uri, bool is_static)
static Dart_KernelCompilationResult	ListDependencies ()
static void	NotifyAboutIsolateGroupShutdown (const IsolateGroup *isolate_group)
static void	AddExperimentalFlag (const char *value)
static bool	GetExperimentalFlag (ExperimentalFeature feature)

Static Public Attributes
static const char *	kName = DART_KERNEL_ISOLATE_NAME
static constexpr int	kCompileTag = 0
static constexpr int	kUpdateSourcesTag = 1
static constexpr int	kAcceptTag = 2
static constexpr int	kTrainTag = 3
static constexpr int	kCompileExpressionTag = 4
static constexpr int	kListDependenciesTag = 5
static constexpr int	kNotifyIsolateShutdown = 6
static constexpr int	kRejectTag = 7

Protected Types
enum	State {   kNotStarted , kStopped , kStarting , kStarted ,   kStopping }

Static Protected Member Functions
static void	InitCallback (Isolate *I)
static void	SetKernelIsolate (Isolate *isolate)
static void	SetLoadPort (Dart_Port port)
static void	FinishedExiting ()
static void	FinishedInitializing ()
static void	InitializingFailed ()
static Dart_IsolateGroupCreateCallback	create_group_callback ()

Static Protected Attributes
static Dart_IsolateGroupCreateCallback	create_group_callback_ = nullptr
static Monitor *	monitor_ = new Monitor()
static State	state_ = KernelIsolate::kNotStarted
static Isolate *	isolate_ = nullptr
static Dart_Port	kernel_port_ = ILLEGAL_PORT
static MallocGrowableArray< char * > *	experimental_flags_

Friends
class	Dart
class	Isolate
class	RunKernelTask

Detailed Description

Definition at line 22 of file kernel_isolate.h.

Member Enumeration Documentation

State

enum dart::KernelIsolate::State

protected

Enumerator
kNotStarted
kStopped
kStarting
kStarted
kStopping

Definition at line 115 of file kernel_isolate.h.

            {
      kNotStarted, kStopped, kStarting, kStarted, kStopping,
  };

Member Function Documentation

AcceptCompilation()

Dart_KernelCompilationResult dart::KernelIsolate::AcceptCompilation ( )

static

Definition at line 1139 of file kernel_isolate.cc.

                                                              {
  // This must be the main script to be loaded. Wait for Kernel isolate
  // to finish initialization.
  Dart_Port kernel_port = WaitForKernelPort();
  if (kernel_port == ILLEGAL_PORT) {
    Dart_KernelCompilationResult result = {};
    result.status = Dart_KernelCompilationStatus_MsgFailed;
    result.error = Utils::StrDup("Error while initializing Kernel isolate");
    return result;
  }
 
  KernelCompilationRequest request;
  return request.SendAndWaitForResponse(
      kAcceptTag, kernel_port, nullptr, nullptr, 0, 0, nullptr, true, false,
      false, nullptr, nullptr, nullptr, experimental_flags_,
      Dart_KernelCompilationVerbosityLevel_Error);
}

AddExperimentalFlag()

void dart::KernelIsolate::AddExperimentalFlag ( const char *  value )

static

Definition at line 371 of file kernel_isolate.cc.

                                                         {
  char* save_ptr;  // Needed for strtok_r.
  char* temp = Utils::StrDup(value);
  char* token = strtok_r(temp, ",", &save_ptr);
  while (token != nullptr) {
    experimental_flags_->Add(Utils::StrDup(token));
    token = strtok_r(nullptr, ",", &save_ptr);
  }
  free(temp);
}

CompileExpressionToKernel()

Dart_KernelCompilationResult dart::KernelIsolate::CompileExpressionToKernel ( const uint8_t *  platform_kernel, intptr_t  platform_kernel_size, const char *  expression, const Array &  definitions, const Array &  definition_types, const Array &  type_definitions, const Array &  type_bounds, const Array &  type_defaults, const char *  library_url, const char *  klass, const char *  method, TokenPosition  token_pos, char const *  script_uri, bool  is_static  )

static

Definition at line 1175 of file kernel_isolate.cc.

                    {
  Dart_Port kernel_port = WaitForKernelPort();
  if (kernel_port == ILLEGAL_PORT) {
    Dart_KernelCompilationResult result = {};
    result.status = Dart_KernelCompilationStatus_MsgFailed;
    result.error = Utils::StrDup("Error while initializing Kernel isolate");
    return result;
  }
 
  intptr_t token_pos_int = -1;
  if (token_pos.IsReal()) {
    token_pos_int = token_pos.Pos();
  }
 
  TransitionVMToNative transition(Thread::Current());
  KernelCompilationRequest request;
  ASSERT(is_static || (klass != nullptr));
  return request.SendAndWaitForResponse(
      kernel_port, platform_kernel, platform_kernel_size, expression,
      definitions, definition_types, type_definitions, type_bounds,
      type_defaults, library_url, klass, method, token_pos_int, script_uri,
      is_static, experimental_flags_);
}

CompileToKernel()

Dart_KernelCompilationResult dart::KernelIsolate::CompileToKernel ( const char *  script_uri, const uint8_t *  platform_kernel, intptr_t  platform_kernel_size, int  source_files_count = 0, Dart_SourceFile  source_files[] = nullptr, bool  incremental_compile = true, bool  for_snapshot = false, bool  embed_sources = true, const char *  package_config = nullptr, const char *  multiroot_filepaths = nullptr, const char *  multiroot_scheme = nullptr, Dart_KernelCompilationVerbosityLevel  verbosity = Dart_KernelCompilationVerbosityLevel_All  )

static

Definition at line 1084 of file kernel_isolate.cc.

                                                    {
  // Start the kernel Isolate if it is not already running.
  if (!Start()) {
    Dart_KernelCompilationResult result = {};
    result.status = Dart_KernelCompilationStatus_Unknown;
    result.error = Utils::StrDup("Error while starting Kernel isolate task");
    return result;
  }
 
  // This must be the main script to be loaded. Wait for Kernel isolate
  // to finish initialization.
  Dart_Port kernel_port = WaitForKernelPort();
  if (kernel_port == ILLEGAL_PORT) {
    Dart_KernelCompilationResult result = {};
    result.status = Dart_KernelCompilationStatus_MsgFailed;
    result.error = Utils::StrDup("Error while initializing Kernel isolate");
    return result;
  }
 
  KernelCompilationRequest request;
  return request.SendAndWaitForResponse(
      kCompileTag, kernel_port, script_uri, platform_kernel,
      platform_kernel_size, source_file_count, source_files,
      incremental_compile, for_snapshot, embed_sources, package_config,
      multiroot_filepaths, multiroot_scheme, experimental_flags_, verbosity);
}

create_group_callback()

static Dart_IsolateGroupCreateCallback dart::KernelIsolate::create_group_callback ( )

inlinestaticprotected

Definition at line 109 of file kernel_isolate.h.

                                                                 {
    return create_group_callback_;
  }

Exists()

bool dart::KernelIsolate::Exists ( )

static

Definition at line 282 of file kernel_isolate.cc.

                           {
  MonitorLocker ml(monitor_);
  return isolate_ != nullptr;
}

FinishedExiting()

void dart::KernelIsolate::FinishedExiting ( )

staticprotected

Definition at line 300 of file kernel_isolate.cc.

                                    {
  MonitorLocker ml(monitor_);
  ASSERT(state_ == kStarted || state_ == kStopping);
  state_ = kStopped;
  ml.NotifyAll();
}

FinishedInitializing()

void dart::KernelIsolate::FinishedInitializing ( )

staticprotected

Definition at line 307 of file kernel_isolate.cc.

                                         {
  MonitorLocker ml(monitor_);
  ASSERT(state_ == kStarting);
  state_ = kStarted;
  ml.NotifyAll();
}

GetExperimentalFlag()

bool dart::KernelIsolate::GetExperimentalFlag ( ExperimentalFeature  feature )

static

Definition at line 382 of file kernel_isolate.cc.

                                                                   {
  const char* value = GetExperimentalFeatureName(feature);
  for (const char* str : *experimental_flags_) {
    if (strcmp(str, value) == 0) {
      return true;
    } else if (strstr(str, "no-") == str && strcmp(str + 3, value) == 0) {
      return false;
    }
  }
  return GetExperimentalFeatureDefault(feature);
}

InitCallback()

void dart::KernelIsolate::InitCallback ( Isolate *  I )

staticprotected

Definition at line 261 of file kernel_isolate.cc.

                                           {
  Thread* T = Thread::Current();
  ASSERT(I == T->isolate());
  ASSERT(I != nullptr);
  if (!I->is_kernel_isolate()) {
    // Not kernel isolate.
    return;
  }
  ASSERT(!Exists());
  if (FLAG_trace_kernel) {
    OS::PrintErr(DART_KERNEL_ISOLATE_NAME ": InitCallback for %s.\n",
                 I->name());
  }
  SetKernelIsolate(I);
}

InitializeState()

void dart::KernelIsolate::InitializeState ( )

static

Definition at line 202 of file kernel_isolate.cc.

                                    {
  // Grab the isolate create callback here to avoid race conditions with tests
  // that change this after Dart_Initialize returns.
  if (FLAG_trace_kernel) {
    OS::PrintErr(DART_KERNEL_ISOLATE_NAME ": InitializeState\n");
  }
  create_group_callback_ = Isolate::CreateGroupCallback();
  if (create_group_callback_ == nullptr) {
    KernelIsolate::InitializingFailed();
    return;
  }
}

InitializingFailed()

void dart::KernelIsolate::InitializingFailed ( )

staticprotected

Definition at line 314 of file kernel_isolate.cc.

                                       {
  MonitorLocker ml(monitor_);
  ASSERT(state_ == kStarting);
  state_ = kStopped;
  ml.NotifyAll();
}

IsRunning()

bool dart::KernelIsolate::IsRunning ( )

static

Definition at line 277 of file kernel_isolate.cc.

                              {
  MonitorLocker ml(monitor_);
  return (kernel_port_ != ILLEGAL_PORT) && (isolate_ != nullptr);
}

KernelPort()

static Dart_Port dart::KernelIsolate::KernelPort ( )

inlinestatic

Definition at line 55 of file kernel_isolate.h.

{ return kernel_port_; }

ListDependencies()

Dart_KernelCompilationResult dart::KernelIsolate::ListDependencies ( )

static

Definition at line 1123 of file kernel_isolate.cc.

                                                             {
  Dart_Port kernel_port = WaitForKernelPort();
  if (kernel_port == ILLEGAL_PORT) {
    Dart_KernelCompilationResult result = {};
    result.status = Dart_KernelCompilationStatus_MsgFailed;
    result.error = Utils::StrDup("Error while initializing Kernel isolate");
    return result;
  }
 
  KernelCompilationRequest request;
  return request.SendAndWaitForResponse(
      kListDependenciesTag, kernel_port, nullptr, nullptr, 0, 0, nullptr, false,
      false, false, nullptr, nullptr, nullptr, experimental_flags_,
      Dart_KernelCompilationVerbosityLevel_Error);
}

NotifyAboutIsolateGroupShutdown()

void dart::KernelIsolate::NotifyAboutIsolateGroupShutdown ( const IsolateGroup *  isolate_group )

static

Definition at line 1233 of file kernel_isolate.cc.

                                       {
  if (!KernelIsolate::IsRunning()) {
    return;
  }
  Dart_Port kernel_port = WaitForKernelPort();
  if (kernel_port == ILLEGAL_PORT) {
    return;
  }
 
  Dart_CObject tag;
  tag.type = Dart_CObject_kInt32;
  tag.value.as_int32 = KernelIsolate::kNotifyIsolateShutdown;
 
  Dart_CObject isolate_id;
  isolate_id.type = Dart_CObject_kInt64;
  isolate_id.value.as_int64 = static_cast<int64_t>(isolate_group->id());
 
  Dart_CObject message;
  message.type = Dart_CObject_kArray;
  Dart_CObject* message_arr[] = {&tag, &isolate_id};
  message.value.as_array.values = message_arr;
  message.value.as_array.length = ARRAY_SIZE(message_arr);
  // Send the message.
  Dart_PostCObject(kernel_port, &message);
}

RejectCompilation()

Dart_KernelCompilationResult dart::KernelIsolate::RejectCompilation ( )

static

Definition at line 1157 of file kernel_isolate.cc.

                                                              {
  // This must be the main script to be loaded. Wait for Kernel isolate
  // to finish initialization.
  Dart_Port kernel_port = WaitForKernelPort();
  if (kernel_port == ILLEGAL_PORT) {
    Dart_KernelCompilationResult result = {};
    result.status = Dart_KernelCompilationStatus_MsgFailed;
    result.error = Utils::StrDup("Error while initializing Kernel isolate");
    return result;
  }
 
  KernelCompilationRequest request;
  return request.SendAndWaitForResponse(
      kRejectTag, kernel_port, nullptr, nullptr, 0, 0, nullptr, true, false,
      false, nullptr, nullptr, nullptr, experimental_flags_,
      Dart_KernelCompilationVerbosityLevel_Error);
}

SetKernelIsolate()

void dart::KernelIsolate::SetKernelIsolate ( Isolate *  isolate )

staticprotected

Definition at line 287 of file kernel_isolate.cc.

                                                     {
  MonitorLocker ml(monitor_);
  ASSERT(isolate == nullptr || isolate->is_kernel_isolate());
  isolate_ = isolate;
  ml.NotifyAll();
}

SetLoadPort()

void dart::KernelIsolate::SetLoadPort ( Dart_Port  port )

staticprotected

Definition at line 294 of file kernel_isolate.cc.

                                              {
  MonitorLocker ml(monitor_);
  kernel_port_ = port;
  ml.NotifyAll();
}

Shutdown()

void dart::KernelIsolate::Shutdown ( )

static

Definition at line 244 of file kernel_isolate.cc.

                             {
  MonitorLocker ml(monitor_);
  while (state_ == kStarting) {
    ml.Wait();
  }
  if (state_ == kStopped || state_ == kNotStarted) {
    return;
  }
  ASSERT(state_ == kStarted);
  state_ = kStopping;
  ml.NotifyAll();
  Isolate::KillIfExists(isolate_, Isolate::kInternalKillMsg);
  while (state_ != kStopped) {
    ml.Wait();
  }
}

Start()

bool dart::KernelIsolate::Start ( )

static

Definition at line 215 of file kernel_isolate.cc.

                          {
  if (create_group_callback_ == nullptr) {
    if (FLAG_trace_kernel) {
      OS::PrintErr(DART_KERNEL_ISOLATE_NAME
                   ": Attempted to start kernel isolate without setting "
                   "Dart_InitializeParams property 'start_kernel_isolate' "
                   "to true\n");
    }
    return false;
  }
  bool start_task = false;
  {
    MonitorLocker ml(monitor_);
    if (state_ == kNotStarted) {
      if (FLAG_trace_kernel) {
        OS::PrintErr(DART_KERNEL_ISOLATE_NAME ": Start\n");
      }
      start_task = true;
      state_ = kStarting;
      ml.NotifyAll();
    }
  }
  bool task_started = true;
  if (start_task) {
    task_started = Dart::thread_pool()->Run<RunKernelTask>();
  }
  return task_started;
}

UpdateInMemorySources()

Dart_KernelCompilationResult dart::KernelIsolate::UpdateInMemorySources ( int  source_files_count, Dart_SourceFile  source_files[]  )

static

Definition at line 1213 of file kernel_isolate.cc.

                                    {
  // This must be the main script to be loaded. Wait for Kernel isolate
  // to finish initialization.
  Dart_Port kernel_port = WaitForKernelPort();
  if (kernel_port == ILLEGAL_PORT) {
    Dart_KernelCompilationResult result = {};
    result.status = Dart_KernelCompilationStatus_MsgFailed;
    result.error = Utils::StrDup("Error while initializing Kernel isolate");
    return result;
  }
 
  KernelCompilationRequest request;
  return request.SendAndWaitForResponse(
      kUpdateSourcesTag, kernel_port, nullptr, nullptr, 0, source_files_count,
      source_files, true, false, false, nullptr, nullptr, nullptr,
      experimental_flags_, Dart_KernelCompilationVerbosityLevel_Error);
}

WaitForKernelPort()

Dart_Port dart::KernelIsolate::WaitForKernelPort ( )

static

Definition at line 321 of file kernel_isolate.cc.

                                           {
  VMTagScope tagScope(Thread::Current(), VMTag::kLoadWaitTagId);
  MonitorLocker ml(monitor_);
  while (state_ == kStarting && (kernel_port_ == ILLEGAL_PORT)) {
    ml.Wait();
  }
  return kernel_port_;
}

Friends And Related Symbol Documentation

Dart

friend class Dart

friend

Definition at line 137 of file kernel_isolate.h.

Isolate

friend class Isolate

friend

Definition at line 138 of file kernel_isolate.h.

RunKernelTask

friend class RunKernelTask

friend

Definition at line 139 of file kernel_isolate.h.

Member Data Documentation

create_group_callback_

Dart_IsolateGroupCreateCallback dart::KernelIsolate::create_group_callback_ = nullptr

staticprotected

Definition at line 113 of file kernel_isolate.h.

experimental_flags_

MallocGrowableArray< char * > * dart::KernelIsolate::experimental_flags_

staticprotected

Initial value:

=
    new MallocGrowableArray<char*>()

Definition at line 122 of file kernel_isolate.h.

isolate_

Isolate * dart::KernelIsolate::isolate_ = nullptr

staticprotected

Definition at line 119 of file kernel_isolate.h.

kAcceptTag

constexpr int dart::KernelIsolate::kAcceptTag = 2

staticconstexpr

Definition at line 41 of file kernel_isolate.h.

kCompileExpressionTag

constexpr int dart::KernelIsolate::kCompileExpressionTag = 4

staticconstexpr

Definition at line 43 of file kernel_isolate.h.

kCompileTag

constexpr int dart::KernelIsolate::kCompileTag = 0

staticconstexpr

Definition at line 39 of file kernel_isolate.h.

kernel_port_

Dart_Port dart::KernelIsolate::kernel_port_ = ILLEGAL_PORT

staticprotected

Definition at line 120 of file kernel_isolate.h.

kListDependenciesTag

constexpr int dart::KernelIsolate::kListDependenciesTag = 5

staticconstexpr

Definition at line 44 of file kernel_isolate.h.

kName

const char * dart::KernelIsolate::kName = DART_KERNEL_ISOLATE_NAME

static

Definition at line 26 of file kernel_isolate.h.

kNotifyIsolateShutdown

constexpr int dart::KernelIsolate::kNotifyIsolateShutdown = 6

staticconstexpr

Definition at line 45 of file kernel_isolate.h.

kRejectTag

constexpr int dart::KernelIsolate::kRejectTag = 7

staticconstexpr

Definition at line 46 of file kernel_isolate.h.

kTrainTag

constexpr int dart::KernelIsolate::kTrainTag = 3

staticconstexpr

Definition at line 42 of file kernel_isolate.h.

kUpdateSourcesTag

constexpr int dart::KernelIsolate::kUpdateSourcesTag = 1

staticconstexpr

Definition at line 40 of file kernel_isolate.h.

monitor_

Monitor * dart::KernelIsolate::monitor_ = new Monitor()

staticprotected

Definition at line 114 of file kernel_isolate.h.

state_

KernelIsolate::State dart::KernelIsolate::state_ = KernelIsolate::kNotStarted

staticprotected

Definition at line 118 of file kernel_isolate.h.

---

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

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