#include <isolate.h>

Inheritance diagram for dart::Isolate:

Public Types
enum	LibMsgId { kPauseMsg = 1 , kResumeMsg = 2 , kPingMsg = 3 , kKillMsg = 4 , kAddExitMsg = 5 , kDelExitMsg = 6 , kAddErrorMsg = 7 , kDelErrorMsg = 8 , kErrorFatalMsg = 9 , kInterruptMsg = 10 , kInternalKillMsg = 11 , kDrainServiceExtensionsMsg = 12 , kCheckForReload = 13 }

enum	LibMsgPriority { kImmediateAction = 0 , kBeforeNextEventAction = 1 , kAsEventAction = 2 }

Public Member Functions
	~Isolate ()

bool	IsScheduled ()

Thread *	scheduled_mutator_thread () const

ThreadRegistry *	thread_registry () const

SafepointHandler *	safepoint_handler () const

FieldTable *	field_table () const

void	set_field_table (Thread T, FieldTable field_table)

IsolateObjectStore *	isolate_object_store () const

Dart_MessageNotifyCallback	message_notify_callback () const

void	set_message_notify_callback (Dart_MessageNotifyCallback value)

void	set_on_shutdown_callback (Dart_IsolateShutdownCallback value)

Dart_IsolateShutdownCallback	on_shutdown_callback ()

void	set_on_cleanup_callback (Dart_IsolateCleanupCallback value)

Dart_IsolateCleanupCallback	on_cleanup_callback ()

void	bequeath (std::unique_ptr< Bequest > bequest)

IsolateGroupSource *	source () const

IsolateGroup *	group () const

bool	HasPendingMessages ()

Thread *	mutator_thread () const

const char *	name () const

void	set_name (const char *name)

int64_t	UptimeMicros () const

Dart_Port	main_port () const

void	set_main_port (Dart_Port port)

Dart_Port	origin_id ()

void	set_origin_id (Dart_Port id)

void	set_pause_capability (uint64_t value)

uint64_t	pause_capability () const

void	set_terminate_capability (uint64_t value)

uint64_t	terminate_capability () const

void	SendInternalLibMessage (LibMsgId msg_id, uint64_t capability)

void	set_init_callback_data (void *value)

void *	init_callback_data () const

void	set_finalizers (const GrowableObjectArray &value)

Dart_EnvironmentCallback	environment_callback () const

void	set_environment_callback (Dart_EnvironmentCallback value)

bool	HasDeferredLoadHandler () const

ObjectPtr	CallDeferredLoadHandler (intptr_t id)

void	ScheduleInterrupts (uword interrupt_bits)

const char *	MakeRunnable ()

void	MakeRunnableLocked ()

void	Run ()

MessageHandler *	message_handler () const

bool	is_runnable () const

void	set_is_runnable (bool value)

Mutex *	mutex ()

Debugger *	debugger () const

SampleBlock *	current_sample_block () const

void	set_current_sample_block (SampleBlock *block)

void	ProcessFreeSampleBlocks (Thread *thread)

SampleBlock *	current_allocation_sample_block () const

void	set_current_allocation_sample_block (SampleBlock *block)

bool	TakeHasCompletedBlocks ()

bool	TrySetHasCompletedBlocks ()

void	set_single_step (bool value)

bool	single_step () const

void	set_has_resumption_breakpoints (bool value)

bool	has_resumption_breakpoints () const

bool	ResumeRequest () const

void	SetResumeRequest ()

void	set_last_resume_timestamp ()

int64_t	last_resume_timestamp () const

bool	GetAndClearResumeRequest ()

bool	VerifyPauseCapability (const Object &capability) const

bool	VerifyTerminateCapability (const Object &capability) const

bool	AddResumeCapability (const Capability &capability)

bool	RemoveResumeCapability (const Capability &capability)

void	AddExitListener (const SendPort &listener, const Instance &response)

void	RemoveExitListener (const SendPort &listener)

void	NotifyExitListeners ()

void	AddErrorListener (const SendPort &listener)

void	RemoveErrorListener (const SendPort &listener)

bool	NotifyErrorListeners (const char msg, const char stacktrace)

bool	ErrorsFatal () const

void	SetErrorsFatal (bool value)

Random *	random ()

Simulator *	simulator () const

void	set_simulator (Simulator *value)

void	IncrementSpawnCount ()

void	DecrementSpawnCount ()

void	WaitForOutstandingSpawns ()

ObjectIdRing *	object_id_ring () const

ObjectIdRing *	EnsureObjectIdRing ()

bool	IsDeoptimizing () const

DeoptContext *	deopt_context () const

void	set_deopt_context (DeoptContext *value)

FfiCallbackMetadata::Trampoline	CreateAsyncFfiCallback (Zone *zone, const Function &send_function, Dart_Port send_port)

FfiCallbackMetadata::Trampoline	CreateIsolateLocalFfiCallback (Zone *zone, const Function &trampoline, const Closure &target, bool keep_isolate_alive)

void	DeleteFfiCallback (FfiCallbackMetadata::Trampoline callback)

void	UpdateNativeCallableKeepIsolateAliveCounter (intptr_t delta)

bool	HasOpenNativeCallables ()

bool	HasLivePorts ()

ReceivePortPtr	CreateReceivePort (const String &debug_name)

void	SetReceivePortKeepAliveState (const ReceivePort &receive_port, bool keep_isolate_alive)

void	CloseReceivePort (const ReceivePort &receive_port)

FfiCallbackMetadata::Metadata *	ffi_callback_list_head ()

intptr_t	BlockClassFinalization ()

intptr_t	UnblockClassFinalization ()

bool	AllowClassFinalization ()

void	PrintJSON (JSONStream *stream, bool ref=true)

void	PrintMemoryUsageJSON (JSONStream *stream)

void	PrintPauseEventJSON (JSONStream *stream)

VMTagCounters *	vm_tag_counters ()

bool	IsPaused () const

bool	should_pause_post_service_request () const

void	set_should_pause_post_service_request (bool value)

ErrorPtr	PausePostRequest ()

uword	user_tag () const

	ISOLATE_METRIC_LIST (ISOLATE_METRIC_ACCESSOR)

GrowableObjectArrayPtr	tag_table () const

void	set_tag_table (const GrowableObjectArray &value)

UserTagPtr	current_tag () const

void	set_current_tag (const UserTag &tag)

UserTagPtr	default_tag () const

void	set_default_tag (const UserTag &tag)

void	SetStickyError (ErrorPtr sticky_error)

ErrorPtr	sticky_error () const

DART_WARN_UNUSED_RESULT ErrorPtr	StealStickyError ()

ErrorPtr	InvokePendingServiceExtensionCalls ()

void	AppendServiceExtensionCall (const Instance &closure, const String &method_name, const Array &parameter_keys, const Array &parameter_values, const Instance &reply_port, const Instance &id)

void	RegisterServiceExtensionHandler (const String &name, const Instance &closure)

InstancePtr	LookupServiceExtensionHandler (const String &name)

void	PauseEventHandler ()

bool	is_vm_isolate () const

void	set_is_vm_isolate (bool value)

bool	is_service_registered () const

void	set_is_service_registered (bool value)

void	FlagsCopyTo (Dart_IsolateFlags *api_flags) const

void	FlagsCopyFrom (const Dart_IsolateFlags &api_flags)

bool	has_attempted_stepping () const

void	set_has_attempted_stepping (bool value)

HandlerInfoCache *	handler_info_cache ()

CatchEntryMovesCache *	catch_entry_moves_cache ()

WeakTable *	forward_table_new ()

void	set_forward_table_new (WeakTable *table)

WeakTable *	forward_table_old ()

void	set_forward_table_old (WeakTable *table)

void	RememberLiveTemporaries ()

void	DeferredMarkLiveTemporaries ()

std::unique_ptr< VirtualMemory >	TakeRegexpBacktrackStack ()

void	CacheRegexpBacktrackStack (std::unique_ptr< VirtualMemory > stack)

void	init_loaded_prefixes_set_storage ()

bool	IsPrefixLoaded (const LibraryPrefix &prefix) const

void	SetPrefixIsLoaded (const LibraryPrefix &prefix)

MallocGrowableArray< ObjectPtr > *	pointers_to_verify_at_exit ()

Public Member Functions inherited from dart::IntrusiveDListEntry< Isolate >
	IntrusiveDListEntry ()

	~IntrusiveDListEntry ()

Static Public Member Functions
static Isolate *	Current ()

static bool	SendInternalLibMessage (Dart_Port main_port, LibMsgId msg_id, uint64_t capability)

static intptr_t	finalizers_offset ()

static intptr_t	single_step_offset ()

static intptr_t	has_resumption_breakpoints_offset ()

static void	SetCreateGroupCallback (Dart_IsolateGroupCreateCallback cb)

static Dart_IsolateGroupCreateCallback	CreateGroupCallback ()

static void	SetInitializeCallback_ (Dart_InitializeIsolateCallback cb)

static Dart_InitializeIsolateCallback	InitializeCallback ()

static void	SetShutdownCallback (Dart_IsolateShutdownCallback cb)

static Dart_IsolateShutdownCallback	ShutdownCallback ()

static void	SetCleanupCallback (Dart_IsolateCleanupCallback cb)

static Dart_IsolateCleanupCallback	CleanupCallback ()

static void	SetGroupCleanupCallback (Dart_IsolateGroupCleanupCallback cb)

static Dart_IsolateGroupCleanupCallback	GroupCleanupCallback ()

static void	SetRegisterKernelBlobCallback (Dart_RegisterKernelBlobCallback cb)

static Dart_RegisterKernelBlobCallback	RegisterKernelBlobCallback ()

static void	SetUnregisterKernelBlobCallback (Dart_UnregisterKernelBlobCallback cb)

static Dart_UnregisterKernelBlobCallback	UnregisterKernelBlobCallback ()

static intptr_t	user_tag_offset ()

static intptr_t	current_tag_offset ()

static intptr_t	default_tag_offset ()

static intptr_t	IsolateListLength ()

static void	VisitIsolates (IsolateVisitor *visitor)

static void	FlagsInitialize (Dart_IsolateFlags *api_flags)

static void	KillAllIsolates (LibMsgId msg_id)

static void	KillAllSystemIsolates (LibMsgId msg_id)

static void	KillIfExists (Isolate *isolate, LibMsgId msg_id)

static Isolate *	LookupIsolateByPort (Dart_Port port)

static std::unique_ptr< char[]>	LookupIsolateNameByPort (Dart_Port port)

static void	DisableIsolateCreation ()

static void	EnableIsolateCreation ()

static bool	IsolateCreationEnabled ()

static bool	IsSystemIsolate (const Isolate *isolate)

static bool	IsVMInternalIsolate (const Isolate *isolate)

Friends
class	Dart

class	IsolateKillerVisitor

class	Become

class	GCCompactor

class	GCMarker

class	SafepointHandler

class	ObjectGraph

class	HeapSnapshotWriter

class	Scavenger

class	HeapIterationScope

class	ServiceIsolate

class	Thread

class	Timeline

class	IsolateGroup

Isolate *	CreateWithinExistingIsolateGroup (IsolateGroup g, const char n, char **e)

Additional Inherited Members
Protected Member Functions inherited from dart::BaseIsolate
	BaseIsolate ()

	~BaseIsolate ()

Protected Attributes inherited from dart::BaseIsolate
Thread *	scheduled_mutator_thread_ = nullptr

Thread *	mutator_thread_ = nullptr

Detailed Description

Definition at line 956 of file isolate.h.

Member Enumeration Documentation

◆ LibMsgId

enum dart::Isolate::LibMsgId

Enumerator
kPauseMsg
kResumeMsg
kPingMsg
kKillMsg
kAddExitMsg
kDelExitMsg
kAddErrorMsg
kDelErrorMsg
kErrorFatalMsg
kInterruptMsg
kInternalKillMsg
kDrainServiceExtensionsMsg
kCheckForReload

Definition at line 960 of file isolate.h.

                {
    kPauseMsg = 1,
    kResumeMsg = 2,
    kPingMsg = 3,
    kKillMsg = 4,
    kAddExitMsg = 5,
    kDelExitMsg = 6,
    kAddErrorMsg = 7,
    kDelErrorMsg = 8,
    kErrorFatalMsg = 9,
 
    // Internal message ids.
    kInterruptMsg = 10,     // Break in the debugger.
    kInternalKillMsg = 11,  // Like kill, but does not run exit listeners, etc.
    kDrainServiceExtensionsMsg = 12,  // Invoke pending service extensions
    kCheckForReload = 13,  // Participate in other isolate group reload.
  };

◆ LibMsgPriority

enum dart::Isolate::LibMsgPriority

Enumerator
kImmediateAction
kBeforeNextEventAction
kAsEventAction

Definition at line 978 of file isolate.h.

                      {
    kImmediateAction = 0,
    kBeforeNextEventAction = 1,
    kAsEventAction = 2
  };

Constructor & Destructor Documentation

◆ ~Isolate()

dart::Isolate::~Isolate ( )

Definition at line 1780 of file isolate.cc.

                  {
#if !defined(PRODUCT) && !defined(DART_PRECOMPILED_RUNTIME)
  // TODO(32796): Re-enable assertion.
  // RELEASE_ASSERT(program_reload_context_ == nullptr);
#endif  // !defined(PRODUCT) && !defined(DART_PRECOMPILED_RUNTIME)
 
#if !defined(PRODUCT)
  delete debugger_;
  debugger_ = nullptr;
  delete object_id_ring_;
  object_id_ring_ = nullptr;
  delete pause_loop_monitor_;
  pause_loop_monitor_ = nullptr;
#endif  // !defined(PRODUCT)
 
  free(name_);
  delete field_table_;
#if defined(USING_SIMULATOR)
  delete simulator_;
#endif
  delete message_handler_;
  message_handler_ =
      nullptr;  // Fail fast if we send messages to a dead isolate.
  ASSERT(deopt_context_ ==
         nullptr);  // No deopt in progress when isolate deleted.
  ASSERT(spawn_count_ == 0);
 
  // The [Thread] object should've been released on the last
  // `Thread::ExitIsolate()` call.
  ASSERT(scheduled_mutator_thread_ == nullptr);
  ASSERT(mutator_thread_ == nullptr);
}

Member Function Documentation

◆ AddErrorListener()

void dart::Isolate::AddErrorListener ( const SendPort & listener )

Definition at line 2316 of file isolate.cc.

                                                       {
  // Ensure a limit for the number of listeners remembered.
  const intptr_t kMaxListeners = compiler::target::kSmiMax / (6 * kWordSize);
 
  const GrowableObjectArray& listeners = GrowableObjectArray::Handle(
      current_zone(), isolate_object_store()->error_listeners());
  SendPort& current = SendPort::Handle(current_zone());
  intptr_t insertion_index = -1;
  for (intptr_t i = 0; i < listeners.Length(); i++) {
    current ^= listeners.At(i);
    if (current.IsNull()) {
      if (insertion_index < 0) {
        insertion_index = i;
      }
    } else if (current.Id() == listener.Id()) {
      return;
    }
  }
  if (insertion_index < 0) {
    if (listeners.Length() >= kMaxListeners) {
      // Cannot grow the array of listeners beyond its max. Additional
      // listeners are ignored. In practice will never happen as we will
      // run out of memory beforehand.
      return;
    }
    listeners.Add(listener);
  } else {
    listeners.SetAt(insertion_index, listener);
  }
}

◆ AddExitListener()

void dart::Isolate::AddExitListener	(	const SendPort &	listener,
		const Instance &	response
	)

Definition at line 2248 of file isolate.cc.

                                                        {
  // Ensure a limit for the number of listeners remembered.
  const intptr_t kMaxListeners = compiler::target::kSmiMax / (12 * kWordSize);
 
  const GrowableObjectArray& listeners = GrowableObjectArray::Handle(
      current_zone(), isolate_object_store()->exit_listeners());
  SendPort& current = SendPort::Handle(current_zone());
  intptr_t insertion_index = -1;
  for (intptr_t i = 0; i < listeners.Length(); i += 2) {
    current ^= listeners.At(i);
    if (current.IsNull()) {
      if (insertion_index < 0) {
        insertion_index = i;
      }
    } else if (current.Id() == listener.Id()) {
      listeners.SetAt(i + 1, response);
      return;
    }
  }
  if (insertion_index < 0) {
    if (listeners.Length() >= kMaxListeners) {
      // Cannot grow the array of listeners beyond its max. Additional
      // listeners are ignored. In practice will never happen as we will
      // run out of memory beforehand.
      return;
    }
    listeners.Add(listener);
    listeners.Add(response);
  } else {
    listeners.SetAt(insertion_index, listener);
    listeners.SetAt(insertion_index + 1, response);
  }
}

◆ AddResumeCapability()

bool dart::Isolate::AddResumeCapability ( const Capability & capability )

Definition at line 2197 of file isolate.cc.

                                                              {
  // Ensure a limit for the number of resume capabilities remembered.
  const intptr_t kMaxResumeCapabilities =
      compiler::target::kSmiMax / (6 * kWordSize);
 
  const GrowableObjectArray& caps = GrowableObjectArray::Handle(
      current_zone(), isolate_object_store()->resume_capabilities());
  Capability& current = Capability::Handle(current_zone());
  intptr_t insertion_index = -1;
  for (intptr_t i = 0; i < caps.Length(); i++) {
    current ^= caps.At(i);
    if (current.IsNull()) {
      if (insertion_index < 0) {
        insertion_index = i;
      }
    } else if (current.Id() == capability.Id()) {
      return false;
    }
  }
  if (insertion_index < 0) {
    if (caps.Length() >= kMaxResumeCapabilities) {
      // Cannot grow the array of resume capabilities beyond its max. Additional
      // pause requests are ignored. In practice will never happen as we will
      // run out of memory beforehand.
      return false;
    }
    caps.Add(capability);
  } else {
    caps.SetAt(insertion_index, capability);
  }
  return true;
}

◆ AllowClassFinalization()

bool dart::Isolate::AllowClassFinalization ( )

inline

Definition at line 1295 of file isolate.h.

                                {
    ASSERT(defer_finalization_count_ >= 0);
    return defer_finalization_count_ == 0;
  }

◆ AppendServiceExtensionCall()

void dart::Isolate::AppendServiceExtensionCall	(	const Instance &	closure,
		const String &	method_name,
		const Array &	parameter_keys,
		const Array &	parameter_values,
		const Instance &	reply_port,
		const Instance &	id
	)

Definition at line 3332 of file isolate.cc.

                                                             {
  if (FLAG_trace_service) {
    OS::PrintErr("[+%" Pd64
                 "ms] Isolate %s ENQUEUING request for extension %s\n",
                 Dart::UptimeMillis(), name(), method_name.ToCString());
  }
  GrowableObjectArray& calls =
      GrowableObjectArray::Handle(pending_service_extension_calls());
  bool schedule_drain = false;
  if (calls.IsNull()) {
    calls = GrowableObjectArray::New();
    ASSERT(!calls.IsNull());
    set_pending_service_extension_calls(calls);
    schedule_drain = true;
  }
  ASSERT(kPendingHandlerIndex == 0);
  calls.Add(closure);
  ASSERT(kPendingMethodNameIndex == 1);
  calls.Add(method_name);
  ASSERT(kPendingKeysIndex == 2);
  calls.Add(parameter_keys);
  ASSERT(kPendingValuesIndex == 3);
  calls.Add(parameter_values);
  ASSERT(kPendingReplyPortIndex == 4);
  calls.Add(reply_port);
  ASSERT(kPendingIdIndex == 5);
  calls.Add(id);
 
  if (schedule_drain) {
    const Array& msg = Array::Handle(Array::New(3));
    Object& element = Object::Handle();
    element = Smi::New(Message::kIsolateLibOOBMsg);
    msg.SetAt(0, element);
    element = Smi::New(Isolate::kDrainServiceExtensionsMsg);
    msg.SetAt(1, element);
    element = Smi::New(Isolate::kBeforeNextEventAction);
    msg.SetAt(2, element);
    std::unique_ptr<Message> message = WriteMessage(
        /* same_group */ false, msg, main_port(), Message::kOOBPriority);
    bool posted = PortMap::PostMessage(std::move(message));
    ASSERT(posted);
  }
}

◆ bequeath()

void dart::Isolate::bequeath ( std::unique_ptr< Bequest > bequest )

inline

Definition at line 1032 of file isolate.h.

                                                {
    bequest_ = std::move(bequest);
  }

◆ BlockClassFinalization()

intptr_t dart::Isolate::BlockClassFinalization ( )

inline

Definition at line 1285 of file isolate.h.

                                    {
    ASSERT(defer_finalization_count_ >= 0);
    return defer_finalization_count_++;
  }

◆ CacheRegexpBacktrackStack()

void dart::Isolate::CacheRegexpBacktrackStack ( std::unique_ptr< VirtualMemory > stack )

inline

Definition at line 1471 of file isolate.h.

                                                                     {
    regexp_backtracking_stack_cache_ = std::move(stack);
  }

◆ CallDeferredLoadHandler()

ObjectPtr dart::Isolate::CallDeferredLoadHandler ( intptr_t id )

Definition at line 1941 of file isolate.cc.

                                                      {
  Thread* thread = Thread::Current();
  Api::Scope api_scope(thread);
  Dart_Handle api_result;
  {
    TransitionVMToNative transition(thread);
    RELEASE_ASSERT(HasDeferredLoadHandler());
    api_result = group()->deferred_load_handler()(id);
  }
  return Api::UnwrapHandle(api_result);
}

◆ catch_entry_moves_cache()

CatchEntryMovesCache * dart::Isolate::catch_entry_moves_cache ( )

inline

Definition at line 1452 of file isolate.h.

                                                  {
    return &catch_entry_moves_cache_;
  }

◆ CleanupCallback()

static Dart_IsolateCleanupCallback dart::Isolate::CleanupCallback ( )

inlinestatic

Definition at line 1224 of file isolate.h.

                                                       {
    return cleanup_callback_;
  }

◆ CloseReceivePort()

void dart::Isolate::CloseReceivePort ( const ReceivePort & receive_port )

Definition at line 3785 of file isolate.cc.

                                                              {
  // Closing an already closed port is a NOP.
  if (!receive_port.is_open()) return;
 
  ASSERT(open_ports_ > 0);
  const bool ok = PortMap::ClosePort(receive_port.Id());
  RELEASE_ASSERT(ok);
 
  if (receive_port.keep_isolate_alive()) {
    --open_ports_keepalive_;
    receive_port.set_keep_isolate_alive(false);
  }
  --open_ports_;
  receive_port.set_is_open(false);
}

◆ CreateAsyncFfiCallback()

FfiCallbackMetadata::Trampoline dart::Isolate::CreateAsyncFfiCallback	(	Zone *	zone,
		const Function &	send_function,
		Dart_Port	send_port
	)

Definition at line 3732 of file isolate.cc.

                         {
  return FfiCallbackMetadata::Instance()->CreateAsyncFfiCallback(
      this, zone, send_function, send_port, &ffi_callback_list_head_);
}

◆ CreateGroupCallback()

static Dart_IsolateGroupCreateCallback dart::Isolate::CreateGroupCallback ( )

inlinestatic

Definition at line 1203 of file isolate.h.

                                                               {
    return create_group_callback_;
  }

◆ CreateIsolateLocalFfiCallback()

FfiCallbackMetadata::Trampoline dart::Isolate::CreateIsolateLocalFfiCallback	(	Zone *	zone,
		const Function &	trampoline,
		const Closure &	target,
		bool	keep_isolate_alive
	)

Definition at line 3740 of file isolate.cc.

                             {
  if (keep_isolate_alive) {
    UpdateNativeCallableKeepIsolateAliveCounter(1);
  }
  return FfiCallbackMetadata::Instance()->CreateIsolateLocalFfiCallback(
      this, zone, trampoline, target, &ffi_callback_list_head_);
}

◆ CreateReceivePort()

ReceivePortPtr dart::Isolate::CreateReceivePort ( const String & debug_name )

Definition at line 3758 of file isolate.cc.

                                                                  {
  Dart_Port port_id = PortMap::CreatePort(message_handler());
  ++open_ports_;
  ++open_ports_keepalive_;
  return ReceivePort::New(port_id, debug_name);
}

◆ Current()

static Isolate * dart::Isolate::Current ( )

inlinestatic

Definition at line 986 of file isolate.h.

                                   {
    Thread* thread = Thread::Current();
    return thread == nullptr ? nullptr : thread->isolate();
  }

◆ current_allocation_sample_block()

SampleBlock * dart::Isolate::current_allocation_sample_block ( ) const

inline

Definition at line 1118 of file isolate.h.

                                                       {
    return current_allocation_sample_block_;
  }

◆ current_sample_block()

SampleBlock * dart::Isolate::current_sample_block ( ) const

inline

Definition at line 1111 of file isolate.h.

1111{ return current_sample_block_; }

◆ current_tag()

UserTagPtr dart::Isolate::current_tag ( ) const

inline

Definition at line 1348 of file isolate.h.

1348{ return current_tag_; }

◆ current_tag_offset()

static intptr_t dart::Isolate::current_tag_offset ( )

inlinestatic

Definition at line 1329 of file isolate.h.

                                       {
    return OFFSET_OF(Isolate, current_tag_);
  }

◆ debugger()

Debugger * dart::Isolate::debugger ( ) const

inline

Definition at line 1108 of file isolate.h.

1108{ return debugger_; }

◆ DecrementSpawnCount()

void dart::Isolate::DecrementSpawnCount ( )

Definition at line 3716 of file isolate.cc.

                                  {
  MonitorLocker ml(&spawn_count_monitor_);
  ASSERT(spawn_count_ > 0);
  spawn_count_--;
  ml.Notify();
}

◆ default_tag()

UserTagPtr dart::Isolate::default_tag ( ) const

inline

Definition at line 1351 of file isolate.h.

1351{ return default_tag_; }

◆ default_tag_offset()

static intptr_t dart::Isolate::default_tag_offset ( )

inlinestatic

Definition at line 1332 of file isolate.h.

                                       {
    return OFFSET_OF(Isolate, default_tag_);
  }

◆ DeferredMarkLiveTemporaries()

void dart::Isolate::DeferredMarkLiveTemporaries ( )

Definition at line 2790 of file isolate.cc.

                                          {
  if (mutator_thread_ != nullptr) {
    mutator_thread_->DeferredMarkLiveTemporaries();
  }
}

◆ DeleteFfiCallback()

void dart::Isolate::DeleteFfiCallback ( FfiCallbackMetadata::Trampoline callback )

Definition at line 3801 of file isolate.cc.

                                                                      {
  FfiCallbackMetadata::Instance()->DeleteCallback(callback,
                                                  &ffi_callback_list_head_);
}

◆ deopt_context()

DeoptContext * dart::Isolate::deopt_context ( ) const

inline

Definition at line 1255 of file isolate.h.

1255{ return deopt_context_; }

◆ DisableIsolateCreation()

void dart::Isolate::DisableIsolateCreation ( )

static

Definition at line 3590 of file isolate.cc.

                                     {
  MonitorLocker ml(isolate_creation_monitor_);
  creation_enabled_ = false;
}

◆ EnableIsolateCreation()

void dart::Isolate::EnableIsolateCreation ( )

static

Definition at line 3595 of file isolate.cc.

                                    {
  MonitorLocker ml(isolate_creation_monitor_);
  creation_enabled_ = true;
}

◆ EnsureObjectIdRing()

ObjectIdRing * dart::Isolate::EnsureObjectIdRing ( )

Definition at line 3014 of file isolate.cc.

                                          {
  if (object_id_ring_ == nullptr) {
    object_id_ring_ = new ObjectIdRing();
  }
  return object_id_ring_;
}

◆ environment_callback()

Dart_EnvironmentCallback dart::Isolate::environment_callback ( ) const

inline

Definition at line 1075 of file isolate.h.

                                                        {
    return environment_callback_;
  }

◆ ErrorsFatal()

bool dart::Isolate::ErrorsFatal ( ) const

inline

Definition at line 1186 of file isolate.h.

1186{ return LoadIsolateFlagsBit<ErrorsFatalBit>(); }

◆ ffi_callback_list_head()

FfiCallbackMetadata::Metadata * dart::Isolate::ffi_callback_list_head ( )

inline

Definition at line 1281 of file isolate.h.

                                                        {
    return ffi_callback_list_head_;
  }

◆ field_table()

FieldTable * dart::Isolate::field_table ( ) const

inline

Definition at line 1000 of file isolate.h.

1000{ return field_table_; }

◆ finalizers_offset()

static intptr_t dart::Isolate::finalizers_offset ( )

inlinestatic

Definition at line 1071 of file isolate.h.

                                      {
    return OFFSET_OF(Isolate, finalizers_);
  }

◆ FlagsCopyFrom()

void dart::Isolate::FlagsCopyFrom ( const Dart_IsolateFlags & api_flags )

Definition at line 1674 of file isolate.cc.

                                                              {
#if defined(DART_PRECOMPILER)
#define FLAG_FOR_PRECOMPILER(action) action
#else
#define FLAG_FOR_PRECOMPILER(action)
#endif
 
#if !defined(PRODUCT)
#define FLAG_FOR_NONPRODUCT(action) action
#else
#define FLAG_FOR_NONPRODUCT(action)
#endif
 
#define FLAG_FOR_PRODUCT(action) action
 
#define SET_FROM_FLAG(when, name, bitname, isolate_flag, flag)                 \
  FLAG_FOR_##when(isolate_flags_ = bitname##Bit::update(                       \
                      api_flags.isolate_flag, isolate_flags_));
 
  BOOL_ISOLATE_FLAG_LIST(SET_FROM_FLAG)
#undef FLAG_FOR_NONPRODUCT
#undef FLAG_FOR_PRECOMPILER
#undef FLAG_FOR_PRODUCT
#undef SET_FROM_FLAG
}

◆ FlagsCopyTo()

void dart::Isolate::FlagsCopyTo ( Dart_IsolateFlags * api_flags ) const

Definition at line 1661 of file isolate.cc.

                                                            {
  group()->FlagsCopyTo(api_flags);
 
  api_flags->version = DART_FLAGS_CURRENT_VERSION;
#define INIT_FROM_FIELD(when, name, bitname, isolate_flag, flag)               \
  api_flags->isolate_flag = name();
  BOOL_ISOLATE_FLAG_LIST(INIT_FROM_FIELD)
#undef INIT_FROM_FIELD
  api_flags->is_service_isolate = false;
  api_flags->is_kernel_isolate = false;
  api_flags->null_safety = true;
}

◆ FlagsInitialize()

void dart::Isolate::FlagsInitialize ( Dart_IsolateFlags * api_flags )

static

Definition at line 1648 of file isolate.cc.

                                                          {
  IsolateGroup::FlagsInitialize(api_flags);
 
  api_flags->version = DART_FLAGS_CURRENT_VERSION;
#define INIT_FROM_FLAG(when, name, bitname, isolate_flag, flag)                \
  api_flags->isolate_flag = flag;
  BOOL_ISOLATE_FLAG_LIST(INIT_FROM_FLAG)
#undef INIT_FROM_FLAG
  api_flags->is_service_isolate = false;
  api_flags->is_kernel_isolate = false;
  api_flags->null_safety = true;
}

◆ forward_table_new()

WeakTable * dart::Isolate::forward_table_new ( )

inline

Definition at line 1458 of file isolate.h.

1458{ return forward_table_new_.get(); }

◆ forward_table_old()

WeakTable * dart::Isolate::forward_table_old ( )

inline

Definition at line 1461 of file isolate.h.

1461{ return forward_table_old_.get(); }

◆ GetAndClearResumeRequest()

bool dart::Isolate::GetAndClearResumeRequest ( )

inline

Definition at line 1163 of file isolate.h.

                                  {
    return UpdateIsolateFlagsBit<ResumeRequestBit>(false);
  }

◆ group()

IsolateGroup * dart::Isolate::group ( ) const

inline

Definition at line 1037 of file isolate.h.

1037{ return isolate_group_; }

◆ GroupCleanupCallback()

static Dart_IsolateGroupCleanupCallback dart::Isolate::GroupCleanupCallback ( )

inlinestatic

Definition at line 1231 of file isolate.h.

                                                                 {
    return cleanup_group_callback_;
  }

◆ handler_info_cache()

HandlerInfoCache * dart::Isolate::handler_info_cache ( )

inline

Definition at line 1450 of file isolate.h.

1450{ return &handler_info_cache_; }

◆ has_attempted_stepping()

bool dart::Isolate::has_attempted_stepping ( ) const

inline

Definition at line 1421 of file isolate.h.

                                      {
    return LoadIsolateFlagsBit<HasAttemptedSteppingBit>();
  }

◆ has_resumption_breakpoints()

bool dart::Isolate::has_resumption_breakpoints ( ) const

inline

Definition at line 1141 of file isolate.h.

                                          {
    return has_resumption_breakpoints_;
  }

◆ has_resumption_breakpoints_offset()

static intptr_t dart::Isolate::has_resumption_breakpoints_offset ( )

inlinestatic

Definition at line 1144 of file isolate.h.

                                                      {
    return OFFSET_OF(Isolate, has_resumption_breakpoints_);
  }

◆ HasDeferredLoadHandler()

bool dart::Isolate::HasDeferredLoadHandler ( ) const

inline

Definition at line 1082 of file isolate.h.

                                      {
    return group()->deferred_load_handler() != nullptr;
  }

◆ HasLivePorts()

bool dart::Isolate::HasLivePorts ( )

Definition at line 3752 of file isolate.cc.

                           {
  ASSERT(0 <= open_ports_ && 0 <= open_ports_keepalive_ &&
         open_ports_keepalive_ <= open_ports_);
  return open_ports_keepalive_ > 0;
}

◆ HasOpenNativeCallables()

bool dart::Isolate::HasOpenNativeCallables ( )

Definition at line 3811 of file isolate.cc.

                                     {
  ASSERT(ffi_callback_keep_alive_counter_ >= 0);
  return ffi_callback_keep_alive_counter_ > 0;
}

◆ HasPendingMessages()

bool dart::Isolate::HasPendingMessages ( )

Definition at line 1356 of file isolate.cc.

                                 {
  return message_handler_->HasMessages() || message_handler_->HasOOBMessages();
}

◆ IncrementSpawnCount()

void dart::Isolate::IncrementSpawnCount ( )

Definition at line 3711 of file isolate.cc.

                                  {
  MonitorLocker ml(&spawn_count_monitor_);
  spawn_count_++;
}

◆ init_callback_data()

void * dart::Isolate::init_callback_data ( ) const

inline

Definition at line 1068 of file isolate.h.

1068{ return init_callback_data_; }

◆ init_loaded_prefixes_set_storage()

void dart::Isolate::init_loaded_prefixes_set_storage ( )

Definition at line 2796 of file isolate.cc.

                                               {
  ASSERT(loaded_prefixes_set_storage_ == nullptr);
  loaded_prefixes_set_storage_ =
      HashTables::New<UnorderedHashSet<LibraryPrefixMapTraits> >(4);
}

◆ InitializeCallback()

static Dart_InitializeIsolateCallback dart::Isolate::InitializeCallback ( )

inlinestatic

Definition at line 1210 of file isolate.h.

                                                             {
    return initialize_callback_;
  }

◆ InvokePendingServiceExtensionCalls()

ErrorPtr dart::Isolate::InvokePendingServiceExtensionCalls ( )

Definition at line 3253 of file isolate.cc.

                                                     {
  GrowableObjectArray& calls =
      GrowableObjectArray::Handle(GetAndClearPendingServiceExtensionCalls());
  if (calls.IsNull()) {
    return Error::null();
  }
  // Grab run function.
  const Library& developer_lib = Library::Handle(Library::DeveloperLibrary());
  ASSERT(!developer_lib.IsNull());
  const Function& run_extension = Function::Handle(
      developer_lib.LookupFunctionAllowPrivate(Symbols::_runExtension()));
  ASSERT(!run_extension.IsNull());
 
  const Array& arguments =
      Array::Handle(Array::New(kPendingEntrySize + 1, Heap::kNew));
  Object& result = Object::Handle();
  String& method_name = String::Handle();
  Instance& closure = Instance::Handle();
  Array& parameter_keys = Array::Handle();
  Array& parameter_values = Array::Handle();
  Instance& reply_port = Instance::Handle();
  Instance& id = Instance::Handle();
  for (intptr_t i = 0; i < calls.Length(); i += kPendingEntrySize) {
    // Grab arguments for call.
    closure ^= calls.At(i + kPendingHandlerIndex);
    ASSERT(!closure.IsNull());
    arguments.SetAt(kPendingHandlerIndex, closure);
    method_name ^= calls.At(i + kPendingMethodNameIndex);
    ASSERT(!method_name.IsNull());
    arguments.SetAt(kPendingMethodNameIndex, method_name);
    parameter_keys ^= calls.At(i + kPendingKeysIndex);
    ASSERT(!parameter_keys.IsNull());
    arguments.SetAt(kPendingKeysIndex, parameter_keys);
    parameter_values ^= calls.At(i + kPendingValuesIndex);
    ASSERT(!parameter_values.IsNull());
    arguments.SetAt(kPendingValuesIndex, parameter_values);
    reply_port ^= calls.At(i + kPendingReplyPortIndex);
    ASSERT(!reply_port.IsNull());
    arguments.SetAt(kPendingReplyPortIndex, reply_port);
    id ^= calls.At(i + kPendingIdIndex);
    arguments.SetAt(kPendingIdIndex, id);
    arguments.SetAt(kPendingEntrySize, Bool::Get(FLAG_trace_service));
 
    if (FLAG_trace_service) {
      OS::PrintErr("[+%" Pd64 "ms] Isolate %s invoking _runExtension for %s\n",
                   Dart::UptimeMillis(), name(), method_name.ToCString());
    }
    result = DartEntry::InvokeFunction(run_extension, arguments);
    if (FLAG_trace_service) {
      OS::PrintErr("[+%" Pd64 "ms] Isolate %s _runExtension complete for %s\n",
                   Dart::UptimeMillis(), name(), method_name.ToCString());
    }
    // Propagate the error.
    if (result.IsError()) {
      // Remaining service extension calls are dropped.
      if (!result.IsUnwindError()) {
        // Send error back over the protocol.
        Service::PostError(method_name, parameter_keys, parameter_values,
                           reply_port, id, Error::Cast(result));
      }
      return Error::Cast(result).ptr();
    }
    // Drain the microtask queue.
    result = DartLibraryCalls::DrainMicrotaskQueue();
    // Propagate the error.
    if (result.IsError()) {
      // Remaining service extension calls are dropped.
      return Error::Cast(result).ptr();
    }
  }
  return Error::null();
}

◆ is_runnable()

bool dart::Isolate::is_runnable ( ) const

inline

Definition at line 1095 of file isolate.h.

1095{ return LoadIsolateFlagsBit<IsRunnableBit>(); }

◆ is_service_registered()

bool dart::Isolate::is_service_registered ( ) const

inline

Definition at line 1385 of file isolate.h.

                                     {
    return LoadIsolateFlagsBit<IsServiceRegisteredBit>();
  }

◆ is_vm_isolate()

bool dart::Isolate::is_vm_isolate ( ) const

inline

Definition at line 1380 of file isolate.h.

1380{ return LoadIsolateFlagsBit<IsVMIsolateBit>(); }

◆ IsDeoptimizing()

bool dart::Isolate::IsDeoptimizing ( ) const

inline

Definition at line 1254 of file isolate.h.

1254{ return deopt_context_ != nullptr; }

◆ ISOLATE_METRIC_LIST()

dart::Isolate::ISOLATE_METRIC_LIST ( ISOLATE_METRIC_ACCESSOR )

◆ isolate_object_store()

IsolateObjectStore * dart::Isolate::isolate_object_store ( ) const

inline

Definition at line 1007 of file isolate.h.

                                                   {
    return isolate_object_store_.get();
  }

◆ IsolateCreationEnabled()

bool dart::Isolate::IsolateCreationEnabled ( )

static

Definition at line 3600 of file isolate.cc.

                                     {
  MonitorLocker ml(isolate_creation_monitor_);
  return creation_enabled_;
}

◆ IsolateListLength()

intptr_t dart::Isolate::IsolateListLength ( )

static

Definition at line 3541 of file isolate.cc.

                                    {
  intptr_t count = 0;
  IsolateGroup::ForEach([&](IsolateGroup* group) {
    group->ForEachIsolate([&](Isolate* isolate) { count++; });
  });
  return count;
}

◆ IsPaused()

bool dart::Isolate::IsPaused ( ) const

Definition at line 2005 of file isolate.cc.

                             {
#if defined(PRODUCT)
  return false;
#else
  return (debugger_ != nullptr) && (debugger_->PauseEvent() != nullptr);
#endif  // !defined(PRODUCT)
}

◆ IsPrefixLoaded()

bool dart::Isolate::IsPrefixLoaded ( const LibraryPrefix & prefix ) const

Definition at line 2802 of file isolate.cc.

                                                              {
  UnorderedHashSet<LibraryPrefixMapTraits> loaded_prefixes_set(
      loaded_prefixes_set_storage_);
  bool result = loaded_prefixes_set.GetOrNull(prefix) != Object::null();
  loaded_prefixes_set.Release();
  return result;
}

◆ IsScheduled()

bool dart::Isolate::IsScheduled ( )

inline

Definition at line 991 of file isolate.h.

991{ return scheduled_mutator_thread() != nullptr; }

dart::Isolate::scheduled_mutator_thread

Thread * scheduled_mutator_thread() const

Definition: isolate.h:992

◆ IsSystemIsolate()

static bool dart::Isolate::IsSystemIsolate ( const Isolate * isolate )

inlinestatic

Definition at line 1445 of file isolate.h.

                                                      {
    return IsolateGroup::IsSystemIsolateGroup(isolate->group());
  }

◆ IsVMInternalIsolate()

bool dart::Isolate::IsVMInternalIsolate ( const Isolate * isolate )

static

Definition at line 3609 of file isolate.cc.

                                                        {
  return isolate->is_kernel_isolate() || isolate->is_service_isolate() ||
         isolate->is_vm_isolate();
}

◆ KillAllIsolates()

void dart::Isolate::KillAllIsolates ( LibMsgId msg_id )

static

Definition at line 3696 of file isolate.cc.

                                             {
  IsolateKillerVisitor visitor(msg_id);
  VisitIsolates(&visitor);
}

◆ KillAllSystemIsolates()

void dart::Isolate::KillAllSystemIsolates ( LibMsgId msg_id )

static

Definition at line 3701 of file isolate.cc.

                                                   {
  IsolateKillerVisitor visitor(msg_id, /*kill_system_isolates=*/true);
  VisitIsolates(&visitor);
}

◆ KillIfExists()

void dart::Isolate::KillIfExists	(	Isolate *	isolate,
		LibMsgId	msg_id
	)

static

Definition at line 3706 of file isolate.cc.

                                                            {
  IsolateKillerVisitor visitor(isolate, msg_id);
  VisitIsolates(&visitor);
}

◆ last_resume_timestamp()

int64_t dart::Isolate::last_resume_timestamp ( ) const

inline

Definition at line 1159 of file isolate.h.

1159{ return last_resume_timestamp_; }

◆ LookupIsolateByPort()

Isolate * dart::Isolate::LookupIsolateByPort ( Dart_Port port )

static

Definition at line 3549 of file isolate.cc.

                                                    {
  Isolate* match = nullptr;
  IsolateGroup::ForEach([&](IsolateGroup* group) {
    group->ForEachIsolate([&](Isolate* isolate) {
      if (isolate->main_port() == port) {
        match = isolate;
      }
    });
  });
  return match;
}

◆ LookupIsolateNameByPort()

std::unique_ptr< char[]> dart::Isolate::LookupIsolateNameByPort ( Dart_Port port )

static

Definition at line 3561 of file isolate.cc.

                                                                     {
  MonitorLocker ml(isolate_creation_monitor_);
  std::unique_ptr<char[]> result;
  IsolateGroup::ForEach([&](IsolateGroup* group) {
    group->ForEachIsolate([&](Isolate* isolate) {
      if (isolate->main_port() == port) {
        const size_t len = strlen(isolate->name()) + 1;
        result = std::unique_ptr<char[]>(new char[len]);
        strncpy(result.get(), isolate->name(), len);
      }
    });
  });
  return result;
}

◆ LookupServiceExtensionHandler()

InstancePtr dart::Isolate::LookupServiceExtensionHandler ( const String & name )

Definition at line 3421 of file isolate.cc.

                                                                     {
  const GrowableObjectArray& handlers =
      GrowableObjectArray::Handle(registered_service_extension_handlers());
  if (handlers.IsNull()) {
    return Instance::null();
  }
  String& handler_name = String::Handle();
  for (intptr_t i = 0; i < handlers.Length(); i += kRegisteredEntrySize) {
    handler_name ^= handlers.At(i + kRegisteredNameIndex);
    ASSERT(!handler_name.IsNull());
    if (handler_name.Equals(name)) {
      return Instance::RawCast(handlers.At(i + kRegisteredHandlerIndex));
    }
  }
  return Instance::null();
}

◆ main_port()

Dart_Port dart::Isolate::main_port ( ) const

inline

Definition at line 1048 of file isolate.h.

1048{ return main_port_; }

◆ MakeRunnable()

const char * dart::Isolate::MakeRunnable ( )

Definition at line 2140 of file isolate.cc.

                                  {
  MutexLocker ml(&mutex_);
  // Check if we are in a valid state to make the isolate runnable.
  if (is_runnable() == true) {
    return "Isolate is already runnable";
  }
  if (group()->object_store()->root_library() == Library::null()) {
    return "The embedder has to ensure there is a root library (e.g. by "
           "calling Dart_LoadScriptFromKernel ).";
  }
  MakeRunnableLocked();
  return nullptr;
}

◆ MakeRunnableLocked()

void dart::Isolate::MakeRunnableLocked ( )

Definition at line 2154 of file isolate.cc.

                                 {
  ASSERT(mutex_.IsOwnedByCurrentThread());
  ASSERT(!is_runnable());
  ASSERT(group()->object_store()->root_library() != Library::null());
 
  // Set the isolate as runnable and if we are being spawned schedule
  // isolate on thread pool for execution.
  set_is_runnable(true);
#ifndef PRODUCT
  if (!Isolate::IsSystemIsolate(this)) {
    if (FLAG_pause_isolates_on_unhandled_exceptions) {
      debugger()->SetExceptionPauseInfo(kPauseOnUnhandledExceptions);
    }
  }
#endif  // !PRODUCT
#if defined(SUPPORT_TIMELINE)
  TimelineStream* stream = Timeline::GetIsolateStream();
  ASSERT(stream != nullptr);
  TimelineEvent* event = stream->StartEvent();
  if (event != nullptr) {
    event->Instant("Runnable");
    event->Complete();
  }
#endif
#ifndef PRODUCT
  if (!Isolate::IsSystemIsolate(this) && Service::isolate_stream.enabled()) {
    ServiceEvent runnableEvent(this, ServiceEvent::kIsolateRunnable);
    Service::HandleEvent(&runnableEvent, /* enter_safepoint */ false);
  }
  GetRunnableLatencyMetric()->set_value(UptimeMicros());
#endif  // !PRODUCT
}

◆ message_handler()

MessageHandler * dart::Isolate::message_handler ( ) const

Definition at line 2416 of file isolate.cc.

                                               {
  return message_handler_;
}

◆ message_notify_callback()

Dart_MessageNotifyCallback dart::Isolate::message_notify_callback ( ) const

inline

Definition at line 1011 of file isolate.h.

                                                             {
    return message_notify_callback_.load(std::memory_order_relaxed);
  }

◆ mutator_thread()

Thread * dart::Isolate::mutator_thread ( ) const

Definition at line 1920 of file isolate.cc.

                                      {
  ASSERT(thread_registry() != nullptr);
  return mutator_thread_;
}

◆ mutex()

Mutex * dart::Isolate::mutex ( )

inline

Definition at line 1105 of file isolate.h.

1105{ return &mutex_; }

◆ name()

const char * dart::Isolate::name ( ) const

inline

Definition at line 1043 of file isolate.h.

1043{ return name_; }

◆ NotifyErrorListeners()

bool dart::Isolate::NotifyErrorListeners	(	const char *	msg,
		const char *	stacktrace
	)

Definition at line 2362 of file isolate.cc.

                                                           {
  const GrowableObjectArray& listeners = GrowableObjectArray::Handle(
      current_zone(), isolate_object_store()->error_listeners());
  if (listeners.IsNull()) return false;
 
  Dart_CObject arr;
  Dart_CObject* arr_values[2];
  arr.type = Dart_CObject_kArray;
  arr.value.as_array.length = 2;
  arr.value.as_array.values = arr_values;
  Dart_CObject msg;
  msg.type = Dart_CObject_kString;
  msg.value.as_string = const_cast<char*>(message);
  arr_values[0] = &msg;
  Dart_CObject stack;
  if (stacktrace == nullptr) {
    stack.type = Dart_CObject_kNull;
  } else {
    stack.type = Dart_CObject_kString;
    stack.value.as_string = const_cast<char*>(stacktrace);
  }
  arr_values[1] = &stack;
 
  SendPort& listener = SendPort::Handle(current_zone());
  bool was_somebody_notified = false;
  for (intptr_t i = 0; i < listeners.Length(); i++) {
    listener ^= listeners.At(i);
    if (!listener.IsNull()) {
      Dart_Port port_id = listener.Id();
      PortMap::PostMessage(SerializeMessage(current_zone(), port_id, &arr));
      was_somebody_notified = true;
    }
  }
  return was_somebody_notified;
}

◆ NotifyExitListeners()

void dart::Isolate::NotifyExitListeners ( )

Definition at line 2299 of file isolate.cc.

                                  {
  const GrowableObjectArray& listeners = GrowableObjectArray::Handle(
      current_zone(), isolate_object_store()->exit_listeners());
  if (listeners.IsNull()) return;
 
  SendPort& listener = SendPort::Handle(current_zone());
  Instance& response = Instance::Handle(current_zone());
  for (intptr_t i = 0; i < listeners.Length(); i += 2) {
    listener ^= listeners.At(i);
    if (!listener.IsNull()) {
      Dart_Port port_id = listener.Id();
      response ^= listeners.At(i + 1);
      PortMap::PostMessage(SerializeMessage(port_id, response));
    }
  }
}

◆ object_id_ring()

ObjectIdRing * dart::Isolate::object_id_ring ( ) const

inline

Definition at line 1250 of file isolate.h.

1250{ return object_id_ring_; }

◆ on_cleanup_callback()

Dart_IsolateCleanupCallback dart::Isolate::on_cleanup_callback ( )

inline

Definition at line 1028 of file isolate.h.

                                                    {
    return on_cleanup_callback_;
  }

◆ on_shutdown_callback()

Dart_IsolateShutdownCallback dart::Isolate::on_shutdown_callback ( )

inline

Definition at line 1022 of file isolate.h.

                                                      {
    return on_shutdown_callback_;
  }

◆ origin_id()

Dart_Port dart::Isolate::origin_id ( )

Definition at line 1990 of file isolate.cc.

                             {
  MutexLocker ml(&origin_id_mutex_);
  return origin_id_;
}

◆ pause_capability()

uint64_t dart::Isolate::pause_capability ( ) const

inline

Definition at line 1056 of file isolate.h.

1056{ return pause_capability_; }

◆ PauseEventHandler()

void dart::Isolate::PauseEventHandler ( )

Definition at line 3458 of file isolate.cc.

                                {
  // We are stealing a pause event (like a breakpoint) from the
  // embedder.  We don't know what kind of thread we are on -- it
  // could be from our thread pool or it could be a thread from the
  // embedder.  Sit on the current thread handling service events
  // until we are told to resume.
  if (pause_loop_monitor_ == nullptr) {
    pause_loop_monitor_ = new Monitor();
  }
  Dart_EnterScope();
  MonitorLocker ml(pause_loop_monitor_, false);
 
  Dart_MessageNotifyCallback saved_notify_callback = message_notify_callback();
  ASSERT(wake_pause_event_handler_count_ == 0);
  set_message_notify_callback(Isolate::WakePauseEventHandler);
 
#if !defined(DART_PRECOMPILED_RUNTIME)
  const bool had_program_reload_context =
      group()->program_reload_context() != nullptr;
  const int64_t start_time_micros = !had_program_reload_context
                                        ? 0
                                        : group()
                                              ->program_reload_context()
                                              ->group_reload_context()
                                              ->start_time_micros();
#endif  // !defined(DART_PRECOMPILED_RUNTIME)
  bool resume = false;
  while (true) {
    // Handle all available vm service messages, up to a resume
    // request.
    while (!resume && Dart_HasServiceMessages()) {
      ml.Exit();
      resume = Dart_HandleServiceMessages();
      ml.Enter();
    }
    if (resume) {
      break;
    }
 
#if !defined(DART_PRECOMPILED_RUNTIME)
    if (had_program_reload_context &&
        (group()->program_reload_context() == nullptr)) {
      if (FLAG_trace_reload) {
        const int64_t reload_time_micros =
            OS::GetCurrentMonotonicMicros() - start_time_micros;
        double reload_millis = MicrosecondsToMilliseconds(reload_time_micros);
        OS::PrintErr("Reloading has finished! (%.2f ms)\n", reload_millis);
      }
      break;
    }
#endif  // !defined(DART_PRECOMPILED_RUNTIME)
 
    // Wait for more service messages.
    Monitor::WaitResult res = ml.Wait();
    ASSERT(res == Monitor::kNotified);
  }
  // If any non-service messages came in, we need to notify the registered
  // message notify callback to check for unhandled messages. Otherwise, events
  // may be left unhandled until the next event comes in. See
  // https://github.com/dart-lang/sdk/issues/37312.
  if (saved_notify_callback != nullptr) {
    while (wake_pause_event_handler_count_ > 0) {
      saved_notify_callback(Api::CastIsolate(this));
      --wake_pause_event_handler_count_;
    }
  } else {
    wake_pause_event_handler_count_ = 0;
  }
  set_message_notify_callback(saved_notify_callback);
  Dart_ExitScope();
}

◆ PausePostRequest()

ErrorPtr dart::Isolate::PausePostRequest ( )

Definition at line 2013 of file isolate.cc.

                                   {
#if !defined(PRODUCT)
  if (debugger_ == nullptr) {
    return Error::null();
  }
  ASSERT(!IsPaused());
  const Error& error = Error::Handle(debugger_->PausePostRequest());
  if (!error.IsNull()) {
    if (Thread::Current()->top_exit_frame_info() == 0) {
      return error.ptr();
    } else {
      Exceptions::PropagateError(error);
      UNREACHABLE();
    }
  }
#endif
  return Error::null();
}

◆ pointers_to_verify_at_exit()

MallocGrowableArray< ObjectPtr > * dart::Isolate::pointers_to_verify_at_exit ( )

inline

Definition at line 1479 of file isolate.h.

                                                               {
    return &pointers_to_verify_at_exit_;
  }

◆ PrintJSON()

void dart::Isolate::PrintJSON	(	JSONStream *	stream,
		bool	ref = `true`
	)

Definition at line 3084 of file isolate.cc.

                                                    {
  JSONObject jsobj(stream);
  jsobj.AddProperty("type", (ref ? "@Isolate" : "Isolate"));
  jsobj.AddServiceId(ISOLATE_SERVICE_ID_FORMAT_STRING,
                     static_cast<int64_t>(main_port()));
 
  jsobj.AddProperty("name", name());
  jsobj.AddPropertyF("number", "%" Pd64 "", static_cast<int64_t>(main_port()));
  jsobj.AddProperty("isSystemIsolate", is_system_isolate());
  jsobj.AddPropertyF("isolateGroupId", ISOLATE_GROUP_SERVICE_ID_FORMAT_STRING,
                     group()->id());
  if (ref) {
    return;
  }
  jsobj.AddPropertyF("_originNumber", "%" Pd64 "",
                     static_cast<int64_t>(origin_id()));
  int64_t uptime_millis = UptimeMicros() / kMicrosecondsPerMillisecond;
  int64_t start_time = OS::GetCurrentTimeMillis() - uptime_millis;
  jsobj.AddPropertyTimeMillis("startTime", start_time);
  {
    JSONObject jsheap(&jsobj, "_heaps");
    group()->heap()->PrintToJSONObject(Heap::kNew, &jsheap);
    group()->heap()->PrintToJSONObject(Heap::kOld, &jsheap);
  }
 
  {
// Stringification macros
// See https://gcc.gnu.org/onlinedocs/gcc-4.8.5/cpp/Stringification.html
#define TO_STRING(s) STR(s)
#define STR(s) #s
 
#define ADD_ISOLATE_FLAGS(when, name, bitname, isolate_flag_name, flag_name)   \
  {                                                                            \
    JSONObject jsflag(&jsflags);                                               \
    jsflag.AddProperty("name", TO_STRING(name));                               \
    jsflag.AddProperty("valueAsString", name() ? "true" : "false");            \
  }
    JSONArray jsflags(&jsobj, "isolateFlags");
    BOOL_ISOLATE_FLAG_LIST(ADD_ISOLATE_FLAGS)
#undef ADD_ISOLATE_FLAGS
#undef TO_STRING
#undef STR
  }
 
  jsobj.AddProperty("runnable", is_runnable());
  jsobj.AddProperty("livePorts", open_ports_keepalive_);
  jsobj.AddProperty("pauseOnExit", message_handler()->should_pause_on_exit());
#if !defined(DART_PRECOMPILED_RUNTIME)
  jsobj.AddProperty("_isReloading", group()->IsReloading());
#endif  // !defined(DART_PRECOMPILED_RUNTIME)
 
  ServiceEvent pause_event = IsolatePauseEvent(this);
  jsobj.AddProperty("pauseEvent", &pause_event);
 
  const Library& lib = Library::Handle(group()->object_store()->root_library());
  if (!lib.IsNull()) {
    jsobj.AddProperty("rootLib", lib);
  }
 
  if (FLAG_profiler) {
    JSONObject tagCounters(&jsobj, "_tagCounters");
    vm_tag_counters()->PrintToJSONObject(&tagCounters);
  }
  if (Thread::Current()->sticky_error() != Object::null()) {
    Error& error = Error::Handle(Thread::Current()->sticky_error());
    ASSERT(!error.IsNull());
    jsobj.AddProperty("error", error, false);
  } else if (sticky_error() != Object::null()) {
    Error& error = Error::Handle(sticky_error());
    ASSERT(!error.IsNull());
    jsobj.AddProperty("error", error, false);
  }
 
  {
    const GrowableObjectArray& libs =
        GrowableObjectArray::Handle(group()->object_store()->libraries());
    intptr_t num_libs = libs.Length();
    Library& lib = Library::Handle();
 
    JSONArray lib_array(&jsobj, "libraries");
    for (intptr_t i = 0; i < num_libs; i++) {
      lib ^= libs.At(i);
      ASSERT(!lib.IsNull());
      lib_array.AddValue(lib);
    }
  }
 
  {
    JSONArray breakpoints(&jsobj, "breakpoints");
    if (debugger() != nullptr) {
      debugger()->PrintBreakpointsToJSONArray(&breakpoints);
    }
  }
 
  Dart_ExceptionPauseInfo pause_info = (debugger() != nullptr)
                                           ? debugger()->GetExceptionPauseInfo()
                                           : kNoPauseOnExceptions;
  jsobj.AddProperty("exceptionPauseMode",
                    ExceptionPauseInfoToServiceEnum(pause_info));
 
  if (debugger() != nullptr) {
    JSONObject settings(&jsobj, "_debuggerSettings");
    debugger()->PrintSettingsToJSONObject(&settings);
  }
 
  {
    GrowableObjectArray& handlers =
        GrowableObjectArray::Handle(registered_service_extension_handlers());
    if (!handlers.IsNull()) {
      JSONArray extensions(&jsobj, "extensionRPCs");
      String& handler_name = String::Handle();
      for (intptr_t i = 0; i < handlers.Length(); i += kRegisteredEntrySize) {
        handler_name ^= handlers.At(i + kRegisteredNameIndex);
        extensions.AddValue(handler_name.ToCString());
      }
    }
  }
 
  {
    JSONObject isolate_group(&jsobj, "isolate_group");
    group()->PrintToJSONObject(&isolate_group, /*ref=*/true);
  }
}

◆ PrintMemoryUsageJSON()

void dart::Isolate::PrintMemoryUsageJSON ( JSONStream * stream )

Definition at line 3208 of file isolate.cc.

                                                     {
  group()->heap()->PrintMemoryUsageJSON(stream);
}

◆ PrintPauseEventJSON()

void dart::Isolate::PrintPauseEventJSON ( JSONStream * stream )

Definition at line 3212 of file isolate.cc.

                                                    {
  IsolatePauseEvent(this).PrintJSON(stream);
}

◆ ProcessFreeSampleBlocks()

void dart::Isolate::ProcessFreeSampleBlocks ( Thread * thread )

◆ random()

Random * dart::Isolate::random ( )

inline

Definition at line 1191 of file isolate.h.

1191{ return &random_; }

◆ RegisterKernelBlobCallback()

static Dart_RegisterKernelBlobCallback dart::Isolate::RegisterKernelBlobCallback ( )

inlinestatic

Definition at line 1238 of file isolate.h.

                                                                      {
    return register_kernel_blob_callback_;
  }

◆ RegisterServiceExtensionHandler()

void dart::Isolate::RegisterServiceExtensionHandler	(	const String &	name,
		const Instance &	closure
	)

Definition at line 3385 of file isolate.cc.

                                                                       {
  // Don't allow for service extensions to be registered for internal isolates.
  if (Isolate::IsVMInternalIsolate(this)) {
    return;
  }
  GrowableObjectArray& handlers =
      GrowableObjectArray::Handle(registered_service_extension_handlers());
  if (handlers.IsNull()) {
    handlers = GrowableObjectArray::New(Heap::kOld);
    set_registered_service_extension_handlers(handlers);
  }
#if defined(DEBUG)
  {
    // Sanity check.
    const Instance& existing_handler =
        Instance::Handle(LookupServiceExtensionHandler(name));
    ASSERT(existing_handler.IsNull());
  }
#endif
  ASSERT(kRegisteredNameIndex == 0);
  handlers.Add(name, Heap::kOld);
  ASSERT(kRegisteredHandlerIndex == 1);
  handlers.Add(closure, Heap::kOld);
  {
    // Fire off an event.
    ServiceEvent event(this, ServiceEvent::kServiceExtensionAdded);
    event.set_extension_rpc(&name);
    Service::HandleEvent(&event);
  }
}

◆ RememberLiveTemporaries()

void dart::Isolate::RememberLiveTemporaries ( )

Definition at line 2784 of file isolate.cc.

                                      {
  if (mutator_thread_ != nullptr) {
    mutator_thread_->RememberLiveTemporaries();
  }
}

◆ RemoveErrorListener()

void dart::Isolate::RemoveErrorListener ( const SendPort & listener )

Definition at line 2347 of file isolate.cc.

                                                          {
  const GrowableObjectArray& listeners = GrowableObjectArray::Handle(
      current_zone(), isolate_object_store()->error_listeners());
  SendPort& current = SendPort::Handle(current_zone());
  for (intptr_t i = 0; i < listeners.Length(); i++) {
    current ^= listeners.At(i);
    if (!current.IsNull() && (current.Id() == listener.Id())) {
      // Remove the matching listener from the list.
      current = SendPort::null();
      listeners.SetAt(i, current);
      return;
    }
  }
}

◆ RemoveExitListener()

void dart::Isolate::RemoveExitListener ( const SendPort & listener )

Definition at line 2283 of file isolate.cc.

                                                         {
  const GrowableObjectArray& listeners = GrowableObjectArray::Handle(
      current_zone(), isolate_object_store()->exit_listeners());
  SendPort& current = SendPort::Handle(current_zone());
  for (intptr_t i = 0; i < listeners.Length(); i += 2) {
    current ^= listeners.At(i);
    if (!current.IsNull() && (current.Id() == listener.Id())) {
      // Remove the matching listener from the list.
      current = SendPort::null();
      listeners.SetAt(i, current);
      listeners.SetAt(i + 1, Object::null_instance());
      return;
    }
  }
}

◆ RemoveResumeCapability()

bool dart::Isolate::RemoveResumeCapability ( const Capability & capability )

Definition at line 2230 of file isolate.cc.

                                                                 {
  const GrowableObjectArray& caps = GrowableObjectArray::Handle(
      current_zone(), isolate_object_store()->resume_capabilities());
  Capability& current = Capability::Handle(current_zone());
  for (intptr_t i = 0; i < caps.Length(); i++) {
    current ^= caps.At(i);
    if (!current.IsNull() && (current.Id() == capability.Id())) {
      // Remove the matching capability from the list.
      current = Capability::null();
      caps.SetAt(i, current);
      return true;
    }
  }
  return false;
}

◆ ResumeRequest()

bool dart::Isolate::ResumeRequest ( ) const

inline

Definition at line 1148 of file isolate.h.

1148{ return LoadIsolateFlagsBit<ResumeRequestBit>(); }

◆ Run()

void dart::Isolate::Run ( )

Definition at line 2411 of file isolate.cc.

                  {
  message_handler()->Run(group()->thread_pool(), nullptr, ShutdownIsolate,
                         reinterpret_cast<uword>(this));
}

◆ safepoint_handler()

SafepointHandler * dart::Isolate::safepoint_handler ( ) const

inline

Definition at line 996 of file isolate.h.

                                              {
    return group()->safepoint_handler();
  }

◆ scheduled_mutator_thread()

Thread * dart::Isolate::scheduled_mutator_thread ( ) const

inline

Definition at line 992 of file isolate.h.

992{ return scheduled_mutator_thread_; }

◆ ScheduleInterrupts()

void dart::Isolate::ScheduleInterrupts ( uword interrupt_bits )

Definition at line 1967 of file isolate.cc.

                                                     {
  // We take the threads lock here to ensure that the mutator thread does not
  // exit the isolate while we are trying to schedule interrupts on it.
  MonitorLocker ml(group()->thread_registry()->threads_lock());
  Thread* mthread = mutator_thread();
  if (mthread != nullptr) {
    mthread->ScheduleInterrupts(interrupt_bits);
  }
}

◆ SendInternalLibMessage() [1/2]

bool dart::Isolate::SendInternalLibMessage	(	Dart_Port	main_port,
		LibMsgId	msg_id,
		uint64_t	capability
	)

static

Definition at line 1038 of file isolate.cc.

                                                          {
  Dart_CObject array_entry_msg_kind;
  array_entry_msg_kind.type = Dart_CObject_kInt64;
  array_entry_msg_kind.value.as_int64 = Message::kIsolateLibOOBMsg;
 
  Dart_CObject array_entry_msg_id;
  array_entry_msg_id.type = Dart_CObject_kInt64;
  array_entry_msg_id.value.as_int64 = msg_id;
 
  Dart_CObject array_entry_capability;
  array_entry_capability.type = Dart_CObject_kCapability;
  array_entry_capability.value.as_capability.id = capability;
 
  Dart_CObject* array_entries[3] = {
      &array_entry_msg_kind,
      &array_entry_msg_id,
      &array_entry_capability,
  };
 
  Dart_CObject message;
  message.type = Dart_CObject_kArray;
  message.value.as_array.values = array_entries;
  message.value.as_array.length = ARRAY_SIZE(array_entries);
 
  AllocOnlyStackZone zone;
  std::unique_ptr<Message> msg = WriteApiMessage(
      zone.GetZone(), &message, main_port, Message::kOOBPriority);
  if (msg == nullptr) UNREACHABLE();
 
  return PortMap::PostMessage(std::move(msg));
}

◆ SendInternalLibMessage() [2/2]

void dart::Isolate::SendInternalLibMessage	(	LibMsgId	msg_id,
		uint64_t	capability
	)

Definition at line 1033 of file isolate.cc.

                                                                         {
  const bool ok = SendInternalLibMessage(main_port(), msg_id, capability);
  if (!ok) UNREACHABLE();
}

◆ set_current_allocation_sample_block()

void dart::Isolate::set_current_allocation_sample_block ( SampleBlock * block )

inline

Definition at line 1121 of file isolate.h.

                                                               {
    current_allocation_sample_block_ = block;
  }

◆ set_current_sample_block()

void dart::Isolate::set_current_sample_block ( SampleBlock * block )

inline

Definition at line 1112 of file isolate.h.

                                                    {
    current_sample_block_ = block;
  }

◆ set_current_tag()

void dart::Isolate::set_current_tag ( const UserTag & tag )

Definition at line 3222 of file isolate.cc.

                                                {
  uword user_tag = tag.tag();
  ASSERT(user_tag < kUwordMax);
  set_user_tag(user_tag);
  current_tag_ = tag.ptr();
}

◆ set_default_tag()

void dart::Isolate::set_default_tag ( const UserTag & tag )

Definition at line 3229 of file isolate.cc.

                                                {
  default_tag_ = tag.ptr();
}

◆ set_deopt_context()

void dart::Isolate::set_deopt_context ( DeoptContext * value )

inline

Definition at line 1256 of file isolate.h.

                                              {
    ASSERT(value == nullptr || deopt_context_ == nullptr);
    deopt_context_ = value;
  }

◆ set_environment_callback()

void dart::Isolate::set_environment_callback ( Dart_EnvironmentCallback value )

inline

Definition at line 1078 of file isolate.h.

                                                                {
    environment_callback_ = value;
  }

◆ set_field_table()

void dart::Isolate::set_field_table	(	Thread *	T,
		FieldTable *	field_table
	)

inline

Definition at line 1001 of file isolate.h.

                                                           {
    delete field_table_;
    field_table_ = field_table;
    T->field_table_values_ = field_table->table();
  }

◆ set_finalizers()

void dart::Isolate::set_finalizers ( const GrowableObjectArray & value )

Definition at line 2001 of file isolate.cc.

                                                             {
  finalizers_ = value.ptr();
}

◆ set_forward_table_new()

void dart::Isolate::set_forward_table_new ( WeakTable * table )

Definition at line 2548 of file isolate.cc.

                                                    {
  std::unique_ptr<WeakTable> value(table);
  forward_table_new_ = std::move(value);
}

◆ set_forward_table_old()

void dart::Isolate::set_forward_table_old ( WeakTable * table )

Definition at line 2552 of file isolate.cc.

                                                    {
  std::unique_ptr<WeakTable> value(table);
  forward_table_old_ = std::move(value);
}

◆ set_has_attempted_stepping()

void dart::Isolate::set_has_attempted_stepping ( bool value )

inline

Definition at line 1424 of file isolate.h.

                                              {
    UpdateIsolateFlagsBit<HasAttemptedSteppingBit>(value);
  }

◆ set_has_resumption_breakpoints()

void dart::Isolate::set_has_resumption_breakpoints ( bool value )

inline

Definition at line 1138 of file isolate.h.

                                                  {
    has_resumption_breakpoints_ = value;
  }

◆ set_init_callback_data()

void dart::Isolate::set_init_callback_data ( void * value )

inline

Definition at line 1067 of file isolate.h.

1067{ init_callback_data_ = value; }

◆ set_is_runnable()

void dart::Isolate::set_is_runnable ( bool value )

inline

Definition at line 1096 of file isolate.h.

                                   {
    UpdateIsolateFlagsBit<IsRunnableBit>(value);
#if !defined(PRODUCT)
    if (is_runnable()) {
      set_last_resume_timestamp();
    }
#endif
  }

◆ set_is_service_registered()

void dart::Isolate::set_is_service_registered ( bool value )

inline

Definition at line 1388 of file isolate.h.

                                             {
    UpdateIsolateFlagsBit<IsServiceRegisteredBit>(value);
  }

◆ set_is_vm_isolate()

void dart::Isolate::set_is_vm_isolate ( bool value )

inline

Definition at line 1381 of file isolate.h.

                                     {
    UpdateIsolateFlagsBit<IsVMIsolateBit>(value);
  }

◆ set_last_resume_timestamp()

void dart::Isolate::set_last_resume_timestamp ( )

inline

Definition at line 1155 of file isolate.h.

                                   {
    last_resume_timestamp_ = OS::GetCurrentTimeMillis();
  }

◆ set_main_port()

void dart::Isolate::set_main_port ( Dart_Port port )

inline

Definition at line 1049 of file isolate.h.

                                     {
    ASSERT(main_port_ == 0);  // Only set main port once.
    main_port_ = port;
  }

◆ set_message_notify_callback()

void dart::Isolate::set_message_notify_callback ( Dart_MessageNotifyCallback value )

inline

Definition at line 1015 of file isolate.h.

                                                                     {
    message_notify_callback_.store(value, std::memory_order_release);
  }

◆ set_name()

void dart::Isolate::set_name ( const char * name )

Definition at line 1977 of file isolate.cc.

                                       {
  free(name_);
  name_ = Utils::StrDup(name);
}

◆ set_on_cleanup_callback()

void dart::Isolate::set_on_cleanup_callback ( Dart_IsolateCleanupCallback value )

inline

Definition at line 1025 of file isolate.h.

                                                                  {
    on_cleanup_callback_ = value;
  }

◆ set_on_shutdown_callback()

void dart::Isolate::set_on_shutdown_callback ( Dart_IsolateShutdownCallback value )

inline

Definition at line 1019 of file isolate.h.

                                                                    {
    on_shutdown_callback_ = value;
  }

◆ set_origin_id()

void dart::Isolate::set_origin_id ( Dart_Port id )

Definition at line 1995 of file isolate.cc.

                                        {
  MutexLocker ml(&origin_id_mutex_);
  ASSERT((id == main_port_ && origin_id_ == 0) || (origin_id_ == main_port_));
  origin_id_ = id;
}

◆ set_pause_capability()

void dart::Isolate::set_pause_capability ( uint64_t value )

inline

Definition at line 1055 of file isolate.h.

1055{ pause_capability_ = value; }

◆ set_should_pause_post_service_request()

void dart::Isolate::set_should_pause_post_service_request ( bool value )

inline

Definition at line 1320 of file isolate.h.

                                                         {
    UpdateIsolateFlagsBit<ShouldPausePostServiceRequestBit>(value);
  }

◆ set_simulator()

void dart::Isolate::set_simulator ( Simulator * value )

inline

Definition at line 1194 of file isolate.h.

1194{ simulator_ = value; }

◆ set_single_step()

void dart::Isolate::set_single_step ( bool value )

inline

Definition at line 1132 of file isolate.h.

1132{ single_step_ = value; }

◆ set_tag_table()

void dart::Isolate::set_tag_table ( const GrowableObjectArray & value )

Definition at line 3218 of file isolate.cc.

                                                            {
  tag_table_ = value.ptr();
}

◆ set_terminate_capability()

void dart::Isolate::set_terminate_capability ( uint64_t value )

inline

Definition at line 1057 of file isolate.h.

                                                {
    terminate_capability_ = value;
  }

◆ SetCleanupCallback()

static void dart::Isolate::SetCleanupCallback ( Dart_IsolateCleanupCallback cb )

inlinestatic

Definition at line 1221 of file isolate.h.

                                                                 {
    cleanup_callback_ = cb;
  }

◆ SetCreateGroupCallback()

static void dart::Isolate::SetCreateGroupCallback ( Dart_IsolateGroupCreateCallback cb )

inlinestatic

Definition at line 1200 of file isolate.h.

                                                                         {
    create_group_callback_ = cb;
  }

◆ SetErrorsFatal()

void dart::Isolate::SetErrorsFatal ( bool value )

inline

Definition at line 1187 of file isolate.h.

                                  {
    UpdateIsolateFlagsBit<ErrorsFatalBit>(value);
  }

◆ SetGroupCleanupCallback()

static void dart::Isolate::SetGroupCleanupCallback ( Dart_IsolateGroupCleanupCallback cb )

inlinestatic

Definition at line 1228 of file isolate.h.

                                                                           {
    cleanup_group_callback_ = cb;
  }

◆ SetInitializeCallback_()

static void dart::Isolate::SetInitializeCallback_ ( Dart_InitializeIsolateCallback cb )

inlinestatic

Definition at line 1207 of file isolate.h.

                                                                        {
    initialize_callback_ = cb;
  }

◆ SetPrefixIsLoaded()

void dart::Isolate::SetPrefixIsLoaded ( const LibraryPrefix & prefix )

Definition at line 2810 of file isolate.cc.

                                                           {
  UnorderedHashSet<LibraryPrefixMapTraits> loaded_prefixes_set(
      loaded_prefixes_set_storage_);
  loaded_prefixes_set.InsertOrGet(prefix);
  loaded_prefixes_set_storage_ = loaded_prefixes_set.Release().ptr();
}

◆ SetReceivePortKeepAliveState()

void dart::Isolate::SetReceivePortKeepAliveState	(	const ReceivePort &	receive_port,
		bool	keep_isolate_alive
	)

Definition at line 3765 of file isolate.cc.

                                                                    {
  // Changing keep-isolate-alive state of a closed port is a NOP.
  if (!receive_port.is_open()) return;
 
  ASSERT(0 < open_ports_);
 
  // If the state doesn't change it's a NOP.
  if (receive_port.keep_isolate_alive() == keep_isolate_alive) return;
 
  if (keep_isolate_alive) {
    ASSERT(open_ports_keepalive_ < open_ports_);
    ++open_ports_keepalive_;
  } else {
    ASSERT(0 < open_ports_keepalive_);
    --open_ports_keepalive_;
  }
  receive_port.set_keep_isolate_alive(keep_isolate_alive);
}

◆ SetRegisterKernelBlobCallback()

static void dart::Isolate::SetRegisterKernelBlobCallback ( Dart_RegisterKernelBlobCallback cb )

inlinestatic

Definition at line 1234 of file isolate.h.

                                          {
    register_kernel_blob_callback_ = cb;
  }

◆ SetResumeRequest()

void dart::Isolate::SetResumeRequest ( )

inline

Definition at line 1150 of file isolate.h.

                          {
    UpdateIsolateFlagsBit<ResumeRequestBit>(true);
    set_last_resume_timestamp();
  }

◆ SetShutdownCallback()

static void dart::Isolate::SetShutdownCallback ( Dart_IsolateShutdownCallback cb )

inlinestatic

Definition at line 1214 of file isolate.h.

                                                                   {
    shutdown_callback_ = cb;
  }

◆ SetStickyError()

void dart::Isolate::SetStickyError ( ErrorPtr sticky_error )

Definition at line 2404 of file isolate.cc.

                                                  {
  ASSERT(
      ((sticky_error_ == Error::null()) || (sticky_error == Error::null())) &&
      (sticky_error != sticky_error_));
  sticky_error_ = sticky_error;
}

◆ SetUnregisterKernelBlobCallback()

static void dart::Isolate::SetUnregisterKernelBlobCallback ( Dart_UnregisterKernelBlobCallback cb )

inlinestatic

Definition at line 1241 of file isolate.h.

                                            {
    unregister_kernel_blob_callback_ = cb;
  }

◆ should_pause_post_service_request()

bool dart::Isolate::should_pause_post_service_request ( ) const

inline

Definition at line 1317 of file isolate.h.

                                                 {
    return LoadIsolateFlagsBit<ShouldPausePostServiceRequestBit>();
  }

◆ ShutdownCallback()

static Dart_IsolateShutdownCallback dart::Isolate::ShutdownCallback ( )

inlinestatic

Definition at line 1217 of file isolate.h.

                                                         {
    return shutdown_callback_;
  }

◆ simulator()

Simulator * dart::Isolate::simulator ( ) const

inline

Definition at line 1193 of file isolate.h.

1193{ return simulator_; }

◆ single_step()

bool dart::Isolate::single_step ( ) const

inline

Definition at line 1133 of file isolate.h.

1133{ return single_step_; }

◆ single_step_offset()

static intptr_t dart::Isolate::single_step_offset ( )

inlinestatic

Definition at line 1134 of file isolate.h.

                                       {
    return OFFSET_OF(Isolate, single_step_);
  }

◆ source()

IsolateGroupSource * dart::Isolate::source ( ) const

inline

Definition at line 1036 of file isolate.h.

1036{ return isolate_group_->source(); }

dart::IsolateGroup::source

IsolateGroupSource * source() const

Definition: isolate.h:286

◆ StealStickyError()

ErrorPtr dart::Isolate::StealStickyError ( )

Definition at line 3233 of file isolate.cc.

                                   {
  NoSafepointScope no_safepoint;
  ErrorPtr return_value = sticky_error_;
  sticky_error_ = Error::null();
  return return_value;
}

◆ sticky_error()

ErrorPtr dart::Isolate::sticky_error ( ) const

inline

Definition at line 1357 of file isolate.h.

1357{ return sticky_error_; }

◆ tag_table()

GrowableObjectArrayPtr dart::Isolate::tag_table ( ) const

inline

Definition at line 1345 of file isolate.h.

1345{ return tag_table_; }

◆ TakeHasCompletedBlocks()

bool dart::Isolate::TakeHasCompletedBlocks ( )

inline

Definition at line 1125 of file isolate.h.

                                {
    return has_completed_blocks_.exchange(0) != 0;
  }

◆ TakeRegexpBacktrackStack()

std::unique_ptr< VirtualMemory > dart::Isolate::TakeRegexpBacktrackStack ( )

inline

Definition at line 1467 of file isolate.h.

                                                          {
    return std::move(regexp_backtracking_stack_cache_);
  }

◆ terminate_capability()

uint64_t dart::Isolate::terminate_capability ( ) const

inline

Definition at line 1060 of file isolate.h.

1060{ return terminate_capability_; }

◆ thread_registry()

ThreadRegistry * dart::Isolate::thread_registry ( ) const

inline

Definition at line 994 of file isolate.h.

994{ return group()->thread_registry(); }

dart::IsolateGroup::thread_registry

ThreadRegistry * thread_registry() const

Definition: isolate.h:333

◆ TrySetHasCompletedBlocks()

bool dart::Isolate::TrySetHasCompletedBlocks ( )

inline

Definition at line 1128 of file isolate.h.

                                  {
    return has_completed_blocks_.exchange(1) == 0;
  }

◆ UnblockClassFinalization()

intptr_t dart::Isolate::UnblockClassFinalization ( )

inline

Definition at line 1290 of file isolate.h.

                                      {
    ASSERT(defer_finalization_count_ > 0);
    return defer_finalization_count_--;
  }

◆ UnregisterKernelBlobCallback()

static Dart_UnregisterKernelBlobCallback dart::Isolate::UnregisterKernelBlobCallback ( )

inlinestatic

Definition at line 1245 of file isolate.h.

                                                                          {
    return unregister_kernel_blob_callback_;
  }

◆ UpdateNativeCallableKeepIsolateAliveCounter()

void dart::Isolate::UpdateNativeCallableKeepIsolateAliveCounter ( intptr_t delta )

Definition at line 3806 of file isolate.cc.

                                                                        {
  ffi_callback_keep_alive_counter_ += delta;
  ASSERT(ffi_callback_keep_alive_counter_ >= 0);
}

◆ UptimeMicros()

int64_t dart::Isolate::UptimeMicros ( ) const

Definition at line 1986 of file isolate.cc.

                                    {
  return OS::GetCurrentMonotonicMicros() - start_time_micros_;
}

◆ user_tag()

uword dart::Isolate::user_tag ( ) const

inline

Definition at line 1327 of file isolate.h.

1327{ return user_tag_; }

◆ user_tag_offset()

static intptr_t dart::Isolate::user_tag_offset ( )

inlinestatic

Definition at line 1328 of file isolate.h.

1328{ return OFFSET_OF(Isolate, user_tag_); }

◆ VerifyPauseCapability()

bool dart::Isolate::VerifyPauseCapability ( const Object & capability ) const

Definition at line 2187 of file isolate.cc.

                                                                  {
  return !capability.IsNull() && capability.IsCapability() &&
         (pause_capability() == Capability::Cast(capability).Id());
}

◆ VerifyTerminateCapability()

bool dart::Isolate::VerifyTerminateCapability ( const Object & capability ) const

Definition at line 2192 of file isolate.cc.

                                                                      {
  return !capability.IsNull() && capability.IsCapability() &&
         (terminate_capability() == Capability::Cast(capability).Id());
}

◆ VisitIsolates()

void dart::Isolate::VisitIsolates ( IsolateVisitor * visitor )

static

Definition at line 3531 of file isolate.cc.

                                                   {
  if (visitor == nullptr) {
    return;
  }
  IsolateGroup::ForEach([&](IsolateGroup* group) {
    group->ForEachIsolate(
        [&](Isolate* isolate) { visitor->VisitIsolate(isolate); });
  });
}

◆ vm_tag_counters()

VMTagCounters * dart::Isolate::vm_tag_counters ( )

inline

Definition at line 1311 of file isolate.h.

1311{ return &vm_tag_counters_; }

◆ WaitForOutstandingSpawns()

void dart::Isolate::WaitForOutstandingSpawns ( )

Definition at line 3723 of file isolate.cc.

                                       {
  Thread* thread = Thread::Current();
  ASSERT(thread != nullptr);
  MonitorLocker ml(&spawn_count_monitor_);
  while (spawn_count_ > 0) {
    ml.WaitWithSafepointCheck(thread);
  }
}

Friends And Related Function Documentation

◆ Become

friend class Become

friend

Definition at line 1748 of file isolate.h.

◆ CreateWithinExistingIsolateGroup

Isolate * CreateWithinExistingIsolateGroup	(	IsolateGroup *	g,
		const char *	n,
		char **	e
	)

friend

Definition at line 1301 of file dart_api_impl.cc.

                                                        {
  API_TIMELINE_DURATION(Thread::Current());
  CHECK_NO_ISOLATE(Isolate::Current());
 
  auto spawning_group = group;
 
  Isolate* isolate = reinterpret_cast<Isolate*>(
      CreateIsolate(spawning_group, /*is_new_group=*/false, name,
                    /*isolate_data=*/nullptr, error));
  if (isolate == nullptr) return nullptr;
 
  auto source = spawning_group->source();
  ASSERT(isolate->source() == source);
 
  return isolate;
}

◆ Dart

friend class Dart

friend

Definition at line 1484 of file isolate.h.

◆ GCCompactor

friend class GCCompactor

friend

Definition at line 1749 of file isolate.h.

◆ GCMarker

friend class GCMarker

friend

Definition at line 1750 of file isolate.h.

◆ HeapIterationScope

friend class HeapIterationScope

friend

Definition at line 1755 of file isolate.h.

◆ HeapSnapshotWriter

friend class HeapSnapshotWriter

friend

Definition at line 1753 of file isolate.h.

◆ IsolateGroup

friend class IsolateGroup

friend

Definition at line 1759 of file isolate.h.

◆ IsolateKillerVisitor

friend class IsolateKillerVisitor

friend

Definition at line 1485 of file isolate.h.

◆ ObjectGraph

friend class ObjectGraph

friend

Definition at line 1752 of file isolate.h.

◆ SafepointHandler

friend class SafepointHandler

friend

Definition at line 1751 of file isolate.h.

◆ Scavenger

friend class Scavenger

friend

Definition at line 1754 of file isolate.h.

◆ ServiceIsolate

friend class ServiceIsolate

friend

Definition at line 1756 of file isolate.h.

◆ Thread

friend class Thread

friend

Definition at line 1757 of file isolate.h.

◆ Timeline

friend class Timeline

friend

Definition at line 1758 of file isolate.h.

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

third_party/dart-lang/sdk/runtime/vm/isolate.h
third_party/dart-lang/sdk/runtime/vm/isolate.cc

Public Types

Public Member Functions

Static Public Member Functions

Friends

Additional Inherited Members

Detailed Description

Member Enumeration Documentation

◆ LibMsgId

◆ LibMsgPriority

Constructor & Destructor Documentation

◆ ~Isolate()

Member Function Documentation

◆ AddErrorListener()

◆ AddExitListener()

◆ AddResumeCapability()

◆ AllowClassFinalization()

◆ AppendServiceExtensionCall()

◆ bequeath()

◆ BlockClassFinalization()

◆ CacheRegexpBacktrackStack()

◆ CallDeferredLoadHandler()

◆ catch_entry_moves_cache()

◆ CleanupCallback()

◆ CloseReceivePort()

◆ CreateAsyncFfiCallback()

◆ CreateGroupCallback()

◆ CreateIsolateLocalFfiCallback()

◆ CreateReceivePort()

◆ Current()

◆ current_allocation_sample_block()

◆ current_sample_block()

◆ current_tag()

◆ current_tag_offset()

◆ debugger()

◆ DecrementSpawnCount()

◆ default_tag()

◆ default_tag_offset()

◆ DeferredMarkLiveTemporaries()

◆ DeleteFfiCallback()

◆ deopt_context()

◆ DisableIsolateCreation()

◆ EnableIsolateCreation()

◆ EnsureObjectIdRing()

◆ environment_callback()

◆ ErrorsFatal()

◆ ffi_callback_list_head()

◆ field_table()

◆ finalizers_offset()

◆ FlagsCopyFrom()

◆ FlagsCopyTo()

◆ FlagsInitialize()

◆ forward_table_new()

◆ forward_table_old()

◆ GetAndClearResumeRequest()

◆ group()

◆ GroupCleanupCallback()

◆ handler_info_cache()

◆ has_attempted_stepping()

◆ has_resumption_breakpoints()

◆ has_resumption_breakpoints_offset()

◆ HasDeferredLoadHandler()

◆ HasLivePorts()

◆ HasOpenNativeCallables()

◆ HasPendingMessages()

◆ IncrementSpawnCount()

◆ init_callback_data()

◆ init_loaded_prefixes_set_storage()

◆ InitializeCallback()

◆ InvokePendingServiceExtensionCalls()

◆ is_runnable()

◆ is_service_registered()

◆ is_vm_isolate()

◆ IsDeoptimizing()

◆ ISOLATE_METRIC_LIST()

◆ isolate_object_store()

◆ IsolateCreationEnabled()

◆ IsolateListLength()

◆ IsPaused()

◆ IsPrefixLoaded()

◆ IsScheduled()