#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.

55{ 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 Function Documentation

◆ Dart

friend class Dart

friend

Definition at line 141 of file kernel_isolate.h.

◆ Isolate

friend class Isolate

friend

Definition at line 142 of file kernel_isolate.h.

◆ RunKernelTask

friend class RunKernelTask

friend

Definition at line 143 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 126 of file kernel_isolate.h.

◆ isolate_

Isolate * dart::KernelIsolate::isolate_ = nullptr

staticprotected

Definition at line 123 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 124 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 122 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

Static Public Member Functions

Static Public Attributes

Protected Types

Static Protected Member Functions

Static Protected Attributes

Friends

Detailed Description

Member Enumeration Documentation

◆ State

Member Function Documentation

◆ AcceptCompilation()

◆ AddExperimentalFlag()

◆ CompileExpressionToKernel()

◆ CompileToKernel()

◆ create_group_callback()

◆ Exists()

◆ FinishedExiting()

◆ FinishedInitializing()

◆ GetExperimentalFlag()

◆ InitCallback()

◆ InitializeState()

◆ InitializingFailed()

◆ IsRunning()

◆ KernelPort()

◆ ListDependencies()

◆ NotifyAboutIsolateGroupShutdown()

◆ RejectCompilation()

◆ SetKernelIsolate()

◆ SetLoadPort()

◆ Shutdown()

◆ Start()

◆ UpdateInMemorySources()

◆ WaitForKernelPort()

Friends And Related Function Documentation

◆ Dart

◆ Isolate

◆ RunKernelTask

Member Data Documentation

◆ create_group_callback_

◆ experimental_flags_

◆ isolate_

◆ kAcceptTag

◆ kCompileExpressionTag

◆ kCompileTag

◆ kernel_port_

◆ kListDependenciesTag

◆ kName

◆ kNotifyIsolateShutdown

◆ kRejectTag

◆ kTrainTag

◆ kUpdateSourcesTag

◆ monitor_

◆ state_