Local<Function> before,

Local<Function> after,

Local<Function> resolve) {

js_promise_hooks_[0].Reset(env()->isolate(), init);

js_promise_hooks_[1].Reset(env()->isolate(), before);

js_promise_hooks_[2].Reset(env()->isolate(), after);

js_promise_hooks_[3].Reset(env()->isolate(), resolve);

Local<Function> before,

Local<Function> after,

Local<Function> resolve) {

async_hooks()->ResetPromiseHooks(init, before, after, resolve);

for (auto it = contexts_.begin(); it != contexts_.end(); it++) {

if (it->IsEmpty()) {

contexts_.erase(it--);

continue;

}

PersistentToLocal::Weak(isolate_, *it)

->SetPromiseHooks(init, before, after, resolve);

}

double trigger_async_id,

Local<Object> resource) {

// Since async_hooks is experimental, do only perform the check

// when async_hooks is enabled.

if (fields_[kCheck] > 0) {

CHECK_GE(async_id, -1);

CHECK_GE(trigger_async_id, -1);

}

uint32_t offset = fields_[kStackLength];

if (offset * 2 >= async_ids_stack_.Length()) grow_async_ids_stack();

async_ids_stack_[2 * offset] = async_id_fields_[kExecutionAsyncId];

async_ids_stack_[2 * offset + 1] = async_id_fields_[kTriggerAsyncId];

fields_[kStackLength] += 1;

async_id_fields_[kExecutionAsyncId] = async_id;

async_id_fields_[kTriggerAsyncId] = trigger_async_id;

#ifdef DEBUG

for (uint32_t i = offset; i < native_execution_async_resources_.size(); i++)

CHECK(native_execution_async_resources_[i].IsEmpty());

#endif

// When this call comes from JS (as a way of increasing the stack size),

// `resource` will be empty, because JS caches these values anyway.

if (!resource.IsEmpty()) {

native_execution_async_resources_.resize(offset + 1);

// Caveat: This is a v8::Local<> assignment, we do not keep a v8::Global<>!

native_execution_async_resources_[offset] = resource;

}

// In case of an exception then this may have already been reset, if the

// stack was multiple MakeCallback()'s deep.

if (UNLIKELY(fields_[kStackLength] == 0)) return false;

// Ask for the async_id to be restored as a check that the stack

// hasn't been corrupted.

if (UNLIKELY(fields_[kCheck] > 0 &&

async_id_fields_[kExecutionAsyncId] != async_id)) {

FailWithCorruptedAsyncStack(async_id);

}

uint32_t offset = fields_[kStackLength] - 1;

async_id_fields_[kExecutionAsyncId] = async_ids_stack_[2 * offset];

async_id_fields_[kTriggerAsyncId] = async_ids_stack_[2 * offset + 1];

fields_[kStackLength] = offset;

if (LIKELY(offset < native_execution_async_resources_.size() &&

!native_execution_async_resources_[offset].IsEmpty())) {

#ifdef DEBUG

for (uint32_t i = offset + 1; i < native_execution_async_resources_.size();

i++) {

CHECK(native_execution_async_resources_[i].IsEmpty());

}

#endif

native_execution_async_resources_.resize(offset);

if (native_execution_async_resources_.size() <

native_execution_async_resources_.capacity() / 2 &&

native_execution_async_resources_.size() > 16) {

native_execution_async_resources_.shrink_to_fit();

}

}

if (UNLIKELY(js_execution_async_resources()->Length() > offset)) {

HandleScope handle_scope(env()->isolate());

USE(js_execution_async_resources()->Set(

env()->context(),

env()->length_string(),

Integer::NewFromUnsigned(env()->isolate(), offset)));

}

return fields_[kStackLength] > 0;

if (env()->can_call_into_js()) {

Isolate* isolate = env()->isolate();

HandleScope handle_scope(isolate);

if (!js_execution_async_resources_.IsEmpty()) {

USE(PersistentToLocal::Strong(js_execution_async_resources_)

->Set(env()->context(),

env()->length_string(),

Integer::NewFromUnsigned(isolate, 0)));

}

}

native_execution_async_resources_.clear();

native_execution_async_resources_.shrink_to_fit();

async_id_fields_[kExecutionAsyncId] = 0;

async_id_fields_[kTriggerAsyncId] = 0;

fields_[kStackLength] = 0;

ctx->SetPromiseHooks(js_promise_hooks_[0].IsEmpty()

? Local<Function>()

: PersistentToLocal::Strong(js_promise_hooks_[0]),

js_promise_hooks_[1].IsEmpty()

? Local<Function>()

: PersistentToLocal::Strong(js_promise_hooks_[1]),

js_promise_hooks_[2].IsEmpty()

? Local<Function>()

: PersistentToLocal::Strong(js_promise_hooks_[2]),

js_promise_hooks_[3].IsEmpty()

? Local<Function>()

: PersistentToLocal::Strong(js_promise_hooks_[3]));

size_t id = contexts_.size();

contexts_.resize(id + 1);

contexts_[id].Reset(isolate_, context);

contexts_[id].SetWeak();

HandleScope handle_scope(isolate_);

contexts_.erase(std::remove_if(contexts_.begin(),

contexts_.end(),

[&](auto&& el) { return el.IsEmpty(); }),

contexts_.end());

for (auto it = contexts_.begin(); it != contexts_.end(); it++) {

Local<Context> saved_context = PersistentToLocal::Weak(isolate_, *it);

if (saved_context == context) {

it->Reset();

contexts_.erase(it);

break;

}

}

Isolate* isolate = creator->GetIsolate();

IsolateDataSerializeInfo info;

HandleScope handle_scope(isolate);

// XXX(joyeecheung): technically speaking, the indexes here should be

// consecutive and we could just return a range instead of an array,

// but that's not part of the V8 API contract so we use an array

// just to be safe.

#define VP(PropertyName, StringValue) V(Private, PropertyName)

#define VY(PropertyName, StringValue) V(Symbol, PropertyName)

#define VS(PropertyName, StringValue) V(String, PropertyName)

#define VR(PropertyName, TypeName) V(Private, per_realm_##PropertyName)

#define V(TypeName, PropertyName) \

info.primitive_values.push_back( \

creator->AddData(PropertyName##_.Get(isolate)));

PER_ISOLATE_PRIVATE_SYMBOL_PROPERTIES(VP)

PER_ISOLATE_SYMBOL_PROPERTIES(VY)

PER_ISOLATE_STRING_PROPERTIES(VS)

PER_REALM_STRONG_PERSISTENT_VALUES(VR)

#undef V

#undef VR

#undef VY

#undef VS

#undef VP

for (size_t i = 0; i < AsyncWrap::PROVIDERS_LENGTH; i++)

info.primitive_values.push_back(creator->AddData(async_wrap_provider(i)));

uint32_t id = 0;

#define VM(PropertyName) V(PropertyName##_binding, FunctionTemplate)

#define V(PropertyName, TypeName) \

do { \

Local<TypeName> field = PropertyName(); \

if (!field.IsEmpty()) { \

size_t index = creator->AddData(field); \

info.template_values.push_back({#PropertyName, id, index}); \

} \

id++; \

} while (0);

PER_ISOLATE_TEMPLATE_PROPERTIES(V)

NODE_BINDINGS_WITH_PER_ISOLATE_INIT(VM)

#undef V

return info;

size_t i = 0;

HandleScope handle_scope(isolate_);

#define VP(PropertyName, StringValue) V(Private, PropertyName)

#define VY(PropertyName, StringValue) V(Symbol, PropertyName)

#define VS(PropertyName, StringValue) V(String, PropertyName)

#define VR(PropertyName, TypeName) V(Private, per_realm_##PropertyName)

#define V(TypeName, PropertyName) \

do { \

MaybeLocal<TypeName> maybe_field = \

isolate_->GetDataFromSnapshotOnce<TypeName>( \

info->primitive_values[i++]); \

Local<TypeName> field; \

if (!maybe_field.ToLocal(&field)) { \

fprintf(stderr, "Failed to deserialize " #PropertyName "\n"); \

} \

PropertyName##_.Set(isolate_, field); \

} while (0);

PER_ISOLATE_PRIVATE_SYMBOL_PROPERTIES(VP)

PER_ISOLATE_SYMBOL_PROPERTIES(VY)

PER_ISOLATE_STRING_PROPERTIES(VS)

PER_REALM_STRONG_PERSISTENT_VALUES(VR)

#undef V

#undef VR

#undef VY

#undef VS

#undef VP

for (size_t j = 0; j < AsyncWrap::PROVIDERS_LENGTH; j++) {

MaybeLocal<String> maybe_field =

isolate_->GetDataFromSnapshotOnce<String>(info->primitive_values[i++]);

Local<String> field;

if (!maybe_field.ToLocal(&field)) {

fprintf(stderr, "Failed to deserialize AsyncWrap provider %zu\n", j);

}

async_wrap_providers_[j].Set(isolate_, field);

}

const std::vector<PropInfo>& values = info->template_values;

i = 0; // index to the array

uint32_t id = 0;

#define VM(PropertyName) V(PropertyName##_binding, FunctionTemplate)

#define V(PropertyName, TypeName) \

do { \

if (values.size() > i && id == values[i].id) { \

const PropInfo& d = values[i]; \

DCHECK_EQ(d.name, #PropertyName); \

MaybeLocal<TypeName> maybe_field = \

isolate_->GetDataFromSnapshotOnce<TypeName>(d.index); \

Local<TypeName> field; \

if (!maybe_field.ToLocal(&field)) { \

fprintf(stderr, \

"Failed to deserialize isolate data template " #PropertyName \

"\n"); \

} \

set_##PropertyName(field); \

i++; \

} \

id++; \

} while (0);

PER_ISOLATE_TEMPLATE_PROPERTIES(V);

NODE_BINDINGS_WITH_PER_ISOLATE_INIT(VM);

#undef V

// Create string and private symbol properties as internalized one byte

// strings after the platform is properly initialized.

//

// Internalized because it makes property lookups a little faster and

// because the string is created in the old space straight away. It's going

// to end up in the old space sooner or later anyway but now it doesn't go

// through v8::Eternal's new space handling first.

//

// One byte because our strings are ASCII and we can safely skip V8's UTF-8

// decoding step.

HandleScope handle_scope(isolate_);

#define V(PropertyName, StringValue) \

PropertyName##_.Set( \

isolate_, \

Private::New(isolate_, \

String::NewFromOneByte( \

isolate_, \

reinterpret_cast<const uint8_t*>(StringValue), \

NewStringType::kInternalized, \

sizeof(StringValue) - 1) \

.ToLocalChecked()));

PER_ISOLATE_PRIVATE_SYMBOL_PROPERTIES(V)

#undef V

#define V(PropertyName, TypeName) \

per_realm_##PropertyName##_.Set( \

isolate_, \

Private::New( \

isolate_, \

String::NewFromOneByte( \

isolate_, \

reinterpret_cast<const uint8_t*>("per_realm_" #PropertyName), \

NewStringType::kInternalized, \

sizeof("per_realm_" #PropertyName) - 1) \

.ToLocalChecked()));

PER_REALM_STRONG_PERSISTENT_VALUES(V)

#undef V

#define V(PropertyName, StringValue) \

PropertyName##_.Set( \

isolate_, \

Symbol::New(isolate_, \

String::NewFromOneByte( \

isolate_, \

reinterpret_cast<const uint8_t*>(StringValue), \

NewStringType::kInternalized, \

sizeof(StringValue) - 1) \

.ToLocalChecked()));

PER_ISOLATE_SYMBOL_PROPERTIES(V)

#undef V

#define V(PropertyName, StringValue) \

PropertyName##_.Set( \

isolate_, \

String::NewFromOneByte(isolate_, \

reinterpret_cast<const uint8_t*>(StringValue), \

NewStringType::kInternalized, \

sizeof(StringValue) - 1) \

.ToLocalChecked());

PER_ISOLATE_STRING_PROPERTIES(V)

#undef V

// Create all the provider strings that will be passed to JS. Place them in

// an array so the array index matches the PROVIDER id offset. This way the

// strings can be retrieved quickly.

#define V(Provider) \

async_wrap_providers_[AsyncWrap::PROVIDER_ ## Provider].Set( \

isolate_, \

String::NewFromOneByte( \

isolate_, \

reinterpret_cast<const uint8_t*>(#Provider), \

NewStringType::kInternalized, \

sizeof(#Provider) - 1).ToLocalChecked());

NODE_ASYNC_PROVIDER_TYPES(V)

#undef V

Local<FunctionTemplate> templ = FunctionTemplate::New(isolate());

templ->InstanceTemplate()->SetInternalFieldCount(

BaseObject::kInternalFieldCount);

templ->Inherit(BaseObject::GetConstructorTemplate(this));

set_binding_data_ctor_template(templ);

binding::CreateInternalBindingTemplates(this);

contextify::ContextifyContext::InitializeGlobalTemplates(this);

uv_loop_t* event_loop,

MultiIsolatePlatform* platform,

ArrayBufferAllocator* node_allocator,

const SnapshotData* snapshot_data)

: isolate_(isolate),

event_loop_(event_loop),

node_allocator_(node_allocator == nullptr ? nullptr

: node_allocator->GetImpl()),

platform_(platform),

snapshot_data_(snapshot_data) {

options_.reset(

new PerIsolateOptions(*(per_process::cli_options->per_isolate)));

if (snapshot_data == nullptr) {

CreateProperties();

} else {

DeserializeProperties(&snapshot_data->isolate_data_info);

}

#define V(PropertyName, StringValue) \

tracker->TrackField(#PropertyName, PropertyName());

PER_ISOLATE_SYMBOL_PROPERTIES(V)

PER_ISOLATE_STRING_PROPERTIES(V)

#undef V

tracker->TrackField("async_wrap_providers", async_wrap_providers_);

if (node_allocator_ != nullptr) {

tracker->TrackFieldWithSize(

"node_allocator", sizeof(*node_allocator_), "NodeArrayBufferAllocator");

}

tracker->TrackFieldWithSize(

"platform", sizeof(*platform_), "MultiIsolatePlatform");

// TODO(joyeecheung): implement MemoryRetainer in the option classes.

if (!env_->owns_process_state() || !env_->can_call_into_js()) {

// Ideally, we’d have a consistent story that treats all threads/Environment

// instances equally here. However, tracing is essentially global, and this

// callback is called from whichever thread calls `StartTracing()` or

// `StopTracing()`. The only way to do this in a threadsafe fashion

// seems to be only tracking this from the main thread, and only allowing

// these state modifications from the main thread.

return;

}

if (env_->principal_realm() == nullptr) {

return;

}

bool async_hooks_enabled = (*(TRACE_EVENT_API_GET_CATEGORY_GROUP_ENABLED(

TRACING_CATEGORY_NODE1(async_hooks)))) != 0;

Isolate* isolate = env_->isolate();

HandleScope handle_scope(isolate);

Local<Function> cb = env_->trace_category_state_function();

if (cb.IsEmpty())

return;

TryCatchScope try_catch(env_);

try_catch.SetVerbose(true);

Local<Value> args[] = {Boolean::New(isolate, async_hooks_enabled)};

USE(cb->Call(env_->context(), Undefined(isolate), arraysize(args), args));

Realm* realm,

const ContextInfo& info) {

context->SetAlignedPointerInEmbedderData(ContextEmbedderIndex::kEnvironment,

this);

context->SetAlignedPointerInEmbedderData(ContextEmbedderIndex::kRealm, realm);

// Used to retrieve bindings

context->SetAlignedPointerInEmbedderData(

ContextEmbedderIndex::kBindingDataStoreIndex,

realm->binding_data_store());

// ContextifyContexts will update this to a pointer to the native object.

context->SetAlignedPointerInEmbedderData(

ContextEmbedderIndex::kContextifyContext, nullptr);

// This must not be done before other context fields are initialized.

ContextEmbedderTag::TagNodeContext(context);

#if HAVE_INSPECTOR

inspector_agent()->ContextCreated(context, info);

#endif // HAVE_INSPECTOR

this->async_hooks()->InstallPromiseHooks(context);

TrackContext(context);

const char* filename,

int flags,

const std::function<bool(binding::DLib*)>& was_loaded) {

loaded_addons_.emplace_back(filename, flags);

if (!was_loaded(&loaded_addons_.back())) {

loaded_addons_.pop_back();

}

char cwd[PATH_MAX_BYTES];

size_t size = PATH_MAX_BYTES;

const int err = uv_cwd(cwd, &size);

if (err == 0) {

CHECK_GT(size, 0);

return cwd;

}

// This can fail if the cwd is deleted. In that case, fall back to

// exec_path.

const std::string& exec_path = exec_path_;

return exec_path.substr(0, exec_path.find_last_of(kPathSeparator));

task_queues_async_refs_ += diff;

CHECK_GE(task_queues_async_refs_, 0);

if (task_queues_async_refs_ == 0)

uv_unref(reinterpret_cast<uv_handle_t*>(&task_queues_async_));

else

uv_ref(reinterpret_cast<uv_handle_t*>(&task_queues_async_));

NoArrayBufferZeroFillScope no_zero_fill_scope(isolate_data());

std::unique_ptr<v8::BackingStore> bs =

v8::ArrayBuffer::NewBackingStore(isolate(), suggested_size);

uv_buf_t buf = uv_buf_init(static_cast<char*>(bs->Data()), bs->ByteLength());

released_allocated_buffers_.emplace(buf.base, std::move(bs));

return buf;

const uv_buf_t& buf) {

std::unique_ptr<v8::BackingStore> bs;

if (buf.base != nullptr) {

auto it = released_allocated_buffers_.find(buf.base);

CHECK_NE(it, released_allocated_buffers_.end());

bs = std::move(it->second);

released_allocated_buffers_.erase(it);

}

return bs;

char exec_path_buf[2 * PATH_MAX];

size_t exec_path_len = sizeof(exec_path_buf);

std::string exec_path;

if (uv_exepath(exec_path_buf, &exec_path_len) == 0) {

exec_path = std::string(exec_path_buf, exec_path_len);

} else if (argv.size() > 0) {

exec_path = argv[0];

}

// On OpenBSD process.execPath will be relative unless we

// get the full path before process.execPath is used.

#if defined(__OpenBSD__)

uv_fs_t req;

req.ptr = nullptr;

if (0 ==

uv_fs_realpath(nullptr, &req, exec_path.c_str(), nullptr)) {

CHECK_NOT_NULL(req.ptr);

exec_path = std::string(static_cast<char*>(req.ptr));

}

uv_fs_req_cleanup(&req);

#endif

return exec_path;

Isolate* isolate,

const std::vector<std::string>& args,

const std::vector<std::string>& exec_args,

const EnvSerializeInfo* env_info,

EnvironmentFlags::Flags flags,

ThreadId thread_id)

: isolate_(isolate),

isolate_data_(isolate_data),

async_hooks_(isolate, MAYBE_FIELD_PTR(env_info, async_hooks)),

immediate_info_(isolate, MAYBE_FIELD_PTR(env_info, immediate_info)),

timeout_info_(isolate_, 1, MAYBE_FIELD_PTR(env_info, timeout_info)),

tick_info_(isolate, MAYBE_FIELD_PTR(env_info, tick_info)),

timer_base_(uv_now(isolate_data->event_loop())),

exec_argv_(exec_args),

argv_(args),

exec_path_(GetExecPath(args)),

exit_info_(

isolate_, kExitInfoFieldCount, MAYBE_FIELD_PTR(env_info, exit_info)),

should_abort_on_uncaught_toggle_(

isolate_,

1,

MAYBE_FIELD_PTR(env_info, should_abort_on_uncaught_toggle)),

stream_base_state_(isolate_,

StreamBase::kNumStreamBaseStateFields,

MAYBE_FIELD_PTR(env_info, stream_base_state)),

time_origin_(performance::performance_process_start),

time_origin_timestamp_(performance::performance_process_start_timestamp),

environment_start_(PERFORMANCE_NOW()),

flags_(flags),

thread_id_(thread_id.id == static_cast<uint64_t>(-1)

? AllocateEnvironmentThreadId().id

: thread_id.id) {

constexpr bool is_shared_ro_heap =

#ifdef NODE_V8_SHARED_RO_HEAP

true;

#else

false;

#endif

if (is_shared_ro_heap && !is_main_thread()) {

// If this is a Worker thread and we are in shared-readonly-heap mode,

// we can always safely use the parent's Isolate's code cache.

CHECK_NOT_NULL(isolate_data->worker_context());

builtin_loader()->CopySourceAndCodeCacheReferenceFrom(

isolate_data->worker_context()->env()->builtin_loader());

} else if (isolate_data->snapshot_data() != nullptr) {

// ... otherwise, if a snapshot was provided, use its code cache.

builtin_loader()->RefreshCodeCache(

isolate_data->snapshot_data()->code_cache);

}

// We'll be creating new objects so make sure we've entered the context.

HandleScope handle_scope(isolate);

// Set some flags if only kDefaultFlags was passed. This can make API version

// transitions easier for embedders.

if (flags_ & EnvironmentFlags::kDefaultFlags) {

flags_ = flags_ |

EnvironmentFlags::kOwnsProcessState |

EnvironmentFlags::kOwnsInspector;

}

set_env_vars(per_process::system_environment);

enabled_debug_list_.Parse(env_vars(), isolate);

// We create new copies of the per-Environment option sets, so that it is

// easier to modify them after Environment creation. The defaults are

// part of the per-Isolate option set, for which in turn the defaults are

// part of the per-process option set.

options_ = std::make_shared<EnvironmentOptions>(

*isolate_data->options()->per_env);

inspector_host_port_ = std::make_shared<ExclusiveAccess<HostPort>>(

options_->debug_options().host_port);

heap_snapshot_near_heap_limit_ =

static_cast<uint32_t>(options_->heap_snapshot_near_heap_limit);

if (!(flags_ & EnvironmentFlags::kOwnsProcessState)) {

set_abort_on_uncaught_exception(false);

}

#if HAVE_INSPECTOR

// We can only create the inspector agent after having cloned the options.

inspector_agent_ = std::make_unique<inspector::Agent>(this);

#endif

if (tracing::AgentWriterHandle* writer = GetTracingAgentWriter()) {

trace_state_observer_ = std::make_unique<TrackingTraceStateObserver>(this);

if (TracingController* tracing_controller = writer->GetTracingController())

tracing_controller->AddTraceStateObserver(trace_state_observer_.get());

}

destroy_async_id_list_.reserve(512);

performance_state_ = std::make_unique<performance::PerformanceState>(

isolate, MAYBE_FIELD_PTR(env_info, performance_state));

if (*TRACE_EVENT_API_GET_CATEGORY_GROUP_ENABLED(

TRACING_CATEGORY_NODE1(environment)) != 0) {

auto traced_value = tracing::TracedValue::Create();

traced_value->BeginArray("args");

for (const std::string& arg : args) traced_value->AppendString(arg);

traced_value->EndArray();

traced_value->BeginArray("exec_args");

for (const std::string& arg : exec_args) traced_value->AppendString(arg);

traced_value->EndArray();

TRACE_EVENT_NESTABLE_ASYNC_BEGIN1(TRACING_CATEGORY_NODE1(environment),

"Environment",

this,

"args",

std::move(traced_value));

}

if (options_->experimental_permission) {

permission()->EnablePermissions();

// If any permission is set the process shouldn't be able to neither

// spawn/worker nor use addons unless explicitly allowed by the user

if (!options_->allow_fs_read.empty() || !options_->allow_fs_write.empty()) {

options_->allow_native_addons = false;

if (!options_->allow_child_process) {

permission()->Deny(permission::PermissionScope::kChildProcess, {});

}

if (!options_->allow_worker_threads) {

permission()->Deny(permission::PermissionScope::kWorkerThreads, {});

}

}

if (!options_->allow_fs_read.empty()) {

permission()->Apply(options_->allow_fs_read,

permission::PermissionScope::kFileSystemRead);

}

if (!options_->allow_fs_write.empty()) {

permission()->Apply(options_->allow_fs_write,

permission::PermissionScope::kFileSystemWrite);

}

}

const EnvSerializeInfo* env_info) {

principal_realm_ = std::make_unique<PrincipalRealm>(

this, context, MAYBE_FIELD_PTR(env_info, principal_realm));

AssignToContext(context, principal_realm_.get(), ContextInfo(""));

if (env_info != nullptr) {

DeserializeProperties(env_info);

}

if (!options_->force_async_hooks_checks) {

async_hooks_.no_force_checks();

}

// By default, always abort when --abort-on-uncaught-exception was passed.

should_abort_on_uncaught_toggle_[0] = 1;

// The process is not exiting by default.

set_exiting(false);

performance_state_->Mark(performance::NODE_PERFORMANCE_MILESTONE_ENVIRONMENT,

environment_start_);

performance_state_->Mark(performance::NODE_PERFORMANCE_MILESTONE_NODE_START,

per_process::node_start_time);

if (per_process::v8_initialized) {

performance_state_->Mark(performance::NODE_PERFORMANCE_MILESTONE_V8_START,

performance::performance_v8_start);

}

HandleScope handle_scope(isolate());

Context::Scope context_scope(context());

CHECK_EQ(0, uv_timer_init(event_loop(), timer_handle()));

uv_unref(reinterpret_cast<uv_handle_t*>(timer_handle()));

CHECK_EQ(0, uv_check_init(event_loop(), immediate_check_handle()));

uv_unref(reinterpret_cast<uv_handle_t*>(immediate_check_handle()));

CHECK_EQ(0, uv_idle_init(event_loop(), immediate_idle_handle()));

CHECK_EQ(0, uv_check_start(immediate_check_handle(), CheckImmediate));

// Inform V8's CPU profiler when we're idle. The profiler is sampling-based

// but not all samples are created equal; mark the wall clock time spent in

// epoll_wait() and friends so profiling tools can filter it out. The samples

// still end up in v8.log but with state=IDLE rather than state=EXTERNAL.

CHECK_EQ(0, uv_prepare_init(event_loop(), &idle_prepare_handle_));

CHECK_EQ(0, uv_check_init(event_loop(), &idle_check_handle_));

CHECK_EQ(0, uv_async_init(

event_loop(),

&task_queues_async_,

[](uv_async_t* async) {

Environment* env = ContainerOf(

&Environment::task_queues_async_, async);

HandleScope handle_scope(env->isolate());

Context::Scope context_scope(env->context());

env->RunAndClearNativeImmediates();

}));

uv_unref(reinterpret_cast<uv_handle_t*>(&idle_prepare_handle_));

uv_unref(reinterpret_cast<uv_handle_t*>(&idle_check_handle_));

uv_unref(reinterpret_cast<uv_handle_t*>(&task_queues_async_));

{

Mutex::ScopedLock lock(native_immediates_threadsafe_mutex_);

task_queues_async_initialized_ = true;

if (native_immediates_threadsafe_.size() > 0 ||

native_immediates_interrupts_.size() > 0) {

uv_async_send(&task_queues_async_);

}

}

// Register clean-up cb to be called to clean up the handles

// when the environment is freed, note that they are not cleaned in

// the one environment per process setup, but will be called in

// FreeEnvironment.

RegisterHandleCleanups();

StartProfilerIdleNotifier();

// Should not access non-thread-safe methods here.

set_stopping(true);

if ((flags & StopFlags::kDoNotTerminateIsolate) == 0)

isolate_->TerminateExecution();

SetImmediateThreadsafe([](Environment* env) {

env->set_can_call_into_js(false);

uv_stop(env->event_loop());

});

HandleCleanupCb close_and_finish = [](Environment* env, uv_handle_t* handle,

void* arg) {

handle->data = env;

env->CloseHandle(handle, [](uv_handle_t* handle) {

#ifdef DEBUG

memset(handle, 0xab, uv_handle_size(handle->type));

#endif

});

};

auto register_handle = [&](uv_handle_t* handle) {

RegisterHandleCleanup(handle, close_and_finish, nullptr);

};

register_handle(reinterpret_cast<uv_handle_t*>(timer_handle()));

register_handle(reinterpret_cast<uv_handle_t*>(immediate_check_handle()));

register_handle(reinterpret_cast<uv_handle_t*>(immediate_idle_handle()));

register_handle(reinterpret_cast<uv_handle_t*>(&idle_prepare_handle_));

register_handle(reinterpret_cast<uv_handle_t*>(&idle_check_handle_));

register_handle(reinterpret_cast<uv_handle_t*>(&task_queues_async_));

{

Mutex::ScopedLock lock(native_immediates_threadsafe_mutex_);

task_queues_async_initialized_ = false;

}

Isolate::DisallowJavascriptExecutionScope disallow_js(isolate(),