Lines Matching defs:env
48 Worker::Worker(Environment* env,
56 : AsyncWrap(env, wrap, AsyncWrap::PROVIDER_WORKER),
59 platform_(env->isolate_data()->platform()),
68 MessagePort* parent_port = MessagePort::New(env, env->context());
78 ->Set(env->context(), env->message_port_string(), parent_port->object())
81 object()->Set(env->context(),
82 env->thread_id_string(),
83 Number::New(env->isolate(), static_cast<double>(thread_id_.id)))
87 GetInspectorParentHandle(env, thread_id_, url.c_str(), name.c_str());
89 argv_ = std::vector<std::string>{env->argv()[0]};
247 Environment* env = worker->env();
248 if (env != nullptr) {
249 DCHECK(!env->is_in_heapsnapshot_heap_limit_callback());
250 Debug(env,
379 bool Worker::CreateEnvMessagePort(Environment* env) {
388 MessagePort* child_port = MessagePort::New(env,
389 env->context(),
394 env->set_message_port(child_port->object(isolate_));
405 env()->remove_sub_worker_context(this);
408 HandleScope handle_scope(env()->isolate());
409 Context::Scope context_scope(env()->context());
412 object()->Set(env()->context(),
413 env()->message_port_string(),
414 Undefined(env()->isolate())).Check();
417 Integer::New(env()->isolate(), exit_code_),
419 ? OneByteString(env()->isolate(), custom_error_).As<Value>()
420 : Null(env()->isolate()).As<Value>(),
422 ? OneByteString(env()->isolate(), custom_error_str_.c_str())
424 : Null(env()->isolate()).As<Value>(),
427 MakeCallback(env()->onexit_string(), arraysize(args), args);
447 Environment* env = Environment::GetCurrent(args);
454 if (env->isolate_data()->platform() == nullptr) {
455 THROW_ERR_MISSING_PLATFORM_FOR_WORKER(env);
469 isolate, args[0]->ToString(env->context()).FromMaybe(Local<String>()));
475 isolate, args[6]->ToString(env->context()).FromMaybe(Local<String>()));
480 // Means worker.env = { ...process.env }.
481 env_vars = env->env_vars()->Clone(isolate);
483 // User provided env.
489 env_vars = env->env_vars();
518 // Only fail for explicitly provided env, this protects from failures
519 // when NODE_OPTIONS from parent's env is used (which is the default).
521 if (!ToV8Value(env->context(), errors).ToLocal(&error)) return;
523 FIXED_ONE_BYTE_STRING(env->isolate(), "invalidNodeOptions");
526 USE(args.This()->Set(env->context(), key, error));
541 if (!array->Get(env->context(), i).ToLocal(&arg)) {
545 if (!arg->ToString(env->context()).ToLocal(&arg_v8)) {
568 if (!ToV8Value(env->context(),
574 FIXED_ONE_BYTE_STRING(env->isolate(), "invalidExecArgv");
577 USE(args.This()->Set(env->context(), key, error));
581 exec_argv_out = env->exec_argv();
588 Worker* worker = new Worker(env,
604 if (args[4]->IsTrue() || env->tracks_unmanaged_fds())
606 if (env->hide_console_windows())
608 if (env->no_native_addons())
610 if (env->no_global_search_paths())
612 if (env->no_browser_globals())
654 w->env()->SetImmediateThreadsafe(
655 [w = std::unique_ptr<Worker>(w)](Environment* env) {
657 env->add_refs(-1);
669 w->env()->add_refs(1);
671 w->env()->add_sub_worker_context(w);
679 Isolate* isolate = w->env()->isolate();
699 w->env()->add_refs(1);
714 w->env()->add_refs(-1);
757 WorkerHeapSnapshotTaker(Environment* env, Local<Object> obj)
758 : AsyncWrap(env, obj, AsyncWrap::PROVIDER_WORKERHEAPSNAPSHOT) {}
771 Environment* env = w->env();
774 if (!env->worker_heap_snapshot_taker_template()
775 ->NewInstance(env->context()).ToLocal(&wrap)) {
783 MakeDetachedBaseObject<WorkerHeapSnapshotTaker>(env, wrap));
788 env](Environment* worker_env) mutable {
796 env->SetImmediateThreadsafe(
798 snapshot = std::move(snapshot)](Environment* env) mutable {
799 HandleScope handle_scope(env->isolate());
800 Context::Scope context_scope(env->context());
804 heap::CreateHeapSnapshotStream(env, std::move(snapshot));
807 env->ondone_string(), arraysize(args), args);
861 Environment* env = Environment::GetCurrent(args);
862 Local<Object> port = env->message_port();
863 CHECK_IMPLIES(!env->is_main_thread(), !port.IsEmpty());
875 Environment* env = Environment::GetCurrent(context);
876 Isolate* isolate = env->isolate();
883 w->Inherit(AsyncWrap::GetConstructorTemplate(env));
903 wst->Inherit(AsyncWrap::GetConstructorTemplate(env));
908 env->set_worker_heap_snapshot_taker_template(wst->InstanceTemplate());
914 ->Set(env->context(),
915 env->thread_id_string(),
916 Number::New(isolate, static_cast<double>(env->thread_id())))
920 ->Set(env->context(),
922 Boolean::New(isolate, env->is_main_thread()))
926 ->Set(env->context(),
928 Boolean::New(isolate, env->owns_process_state()))
931 if (!env->is_main_thread()) {
933 ->Set(env->context(),
935 env->worker_context()->GetResourceLimits(isolate))