Lines Matching defs:env
46 // should be treated as a regular JS object. Used to transfer process.env.
92 Environment* env,
141 MaybeLocal<Value> Message::Deserialize(Environment* env,
150 *port_list = Array::New(env->isolate());
153 EscapableHandleScope handle_scope(env->isolate());
169 HandleScope handle_scope(env->isolate());
172 env, context, std::move(transferables_[i]));
182 if (env->message_port_constructor_template()->HasInstance(obj)) {
197 SharedArrayBuffer::New(env->isolate(), shared_array_buffers_[i]);
202 this, env, host_objects, shared_array_buffers, wasm_modules_);
204 env->isolate(),
213 ArrayBuffer::New(env->isolate(), std::move(array_buffers_[i]));
296 SerializerDelegate(Environment* env, Local<Context> context, Message* m)
297 : env_(env), context_(context), msg_(m) {}
309 // Convert process.env to a regular object.
314 // TODO(bnoordhuis) Prototype-less object in case process.env contains
315 // a "__proto__" key? process.env has a prototype with concomitant
434 Maybe<bool> Message::Serialize(Environment* env,
439 HandleScope handle_scope(env->isolate());
445 SerializerDelegate delegate(env, context, this);
446 ValueSerializer serializer(env->isolate(), &delegate);
458 env->untransferable_object_private_symbol())
483 env->isolate(),
493 } else if (env->base_object_ctor_template()->HasInstance(entry)) {
498 FIXED_ONE_BYTE_STRING(env->isolate(),
504 if (env->message_port_constructor_template()->HasInstance(entry) &&
510 env->isolate(),
519 String::Concat(env->isolate(),
521 env->isolate(),
533 THROW_ERR_INVALID_TRANSFER_OBJECT(env);
609 MessagePort::MessagePort(Environment* env,
612 : HandleWrap(env,
623 CHECK_EQ(uv_async_init(env->event_loop(),
631 if (!wrap->Get(context, env->oninit_symbol()).ToLocal(&fn))
643 emit_message_fn_.Reset(env->isolate(), emit_message_fn);
675 Environment* env = Environment::GetCurrent(args);
676 THROW_ERR_CONSTRUCT_CALL_INVALID(env);
680 Environment* env,
685 Local<FunctionTemplate> ctor_templ = GetMessagePortConstructorTemplate(env);
692 MessagePort* port = new MessagePort(env, context, instance);
738 return env()->no_message_symbol();
747 return env()->no_message_symbol();
750 if (!env()->can_call_into_js()) return MaybeLocal<Value>();
752 return received->Deserialize(env(), context, port_list);
757 HandleScope handle_scope(env()->isolate());
759 object(env()->isolate())->GetCreationContext().ToLocalChecked();
787 HandleScope handle_scope(env()->isolate());
792 Local<Value> port_list = Undefined(env()->isolate());
799 TryCatchScope try_catch(env());
806 if (payload == env()->no_message_symbol()) break;
808 if (!env()->can_call_into_js()) {
816 argv[2] = env()->message_string();
822 argv[1] = Undefined(env()->isolate());
823 argv[2] = env()->messageerror_string();
862 Environment* env,
866 env, context,
870 Maybe<bool> MessagePort::PostMessage(Environment* env,
874 Isolate* isolate = env->isolate();
883 msg->Serialize(env, context, message_v, transfer_v, obj);
897 ProcessEmitWarning(env, error.c_str());
913 static Maybe<bool> ReadIterable(Environment* env,
931 Isolate* isolate = env->isolate();
943 if (!iterator.As<Object>()->Get(context, env->next_string()).ToLocal(&next))
948 while (env->can_call_into_js()) {
955 if (!result.As<Object>()->Get(context, env->done_string()).ToLocal(&done))
960 if (!result.As<Object>()->Get(context, env->value_string()).ToLocal(&val))
971 Environment* env = Environment::GetCurrent(args);
976 return THROW_ERR_MISSING_ARGS(env, "Not enough arguments to "
983 return THROW_ERR_INVALID_ARG_TYPE(env,
990 if (!ReadIterable(env, context, transfer_list, args[1]).To(&was_iterable))
994 if (!args[1].As<Object>()->Get(context, env->transfer_string())
997 if (!ReadIterable(env, context, transfer_list, transfer_option)
1000 return THROW_ERR_INVALID_ARG_TYPE(env,
1013 USE(msg.Serialize(env, context, args[0], transfer_list, obj));
1017 Maybe<bool> res = port->PostMessage(env, context, args[0], transfer_list);
1055 Environment* env = Environment::GetCurrent(args);
1057 GetMessagePortConstructorTemplate(env)->HasInstance(args[0]));
1067 Environment* env = Environment::GetCurrent(args);
1069 !env->message_port_constructor_template()->HasInstance(args[0])) {
1070 return THROW_ERR_INVALID_ARG_TYPE(env,
1089 Environment* env = Environment::GetCurrent(args);
1091 !env->message_port_constructor_template()->HasInstance(args[0])) {
1092 return THROW_ERR_INVALID_ARG_TYPE(env,
1097 Isolate* isolate = env->isolate();
1106 env, context_arg.As<Object>())) == nullptr) {
1107 return THROW_ERR_INVALID_ARG_TYPE(env, "Invalid context argument");
1116 MessagePort::New(env, context_wrapper->context(), std::move(data));
1134 Local<FunctionTemplate> GetMessagePortConstructorTemplate(Environment* env) {
1137 Local<FunctionTemplate> templ = env->message_port_constructor_template();
1142 Isolate* isolate = env->isolate();
1144 m->SetClassName(env->message_port_constructor_string());
1147 m->Inherit(HandleWrap::GetConstructorTemplate(env));
1152 env->set_message_port_constructor_template(m);
1155 return GetMessagePortConstructorTemplate(env);
1158 JSTransferable::JSTransferable(Environment* env, Local<Object> obj)
1159 : BaseObject(env, obj) {
1170 HandleScope handle_scope(env()->isolate());
1171 errors::TryCatchScope ignore_exceptions(env());
1174 if (!object()->Has(env()->context(),
1175 env()->messaging_clone_symbol()).To(&has_clone)) {
1196 HandleScope handle_scope(env()->isolate());
1197 Local<Context> context = env()->isolate()->GetCurrentContext();
1199 env()->messaging_clone_symbol() : env()->messaging_transfer_symbol();
1216 if (!result->Get(context, env()->data_string()).ToLocal(&data) ||
1217 !result->Get(context, env()->deserialize_info_string())
1221 Utf8Value deserialize_info_str(env()->isolate(), deserialize_info);
1224 *deserialize_info_str, Global<Value>(env()->isolate(), data));
1237 HandleScope handle_scope(env()->isolate());
1238 Local<Context> context = env()->isolate()->GetCurrentContext();
1239 Local<Symbol> method_name = env()->messaging_transfer_list_symbol();
1260 if (env()->base_object_ctor_template()->HasInstance(value))
1270 HandleScope handle_scope(env()->isolate());
1274 Local<Symbol> method_name = env()->messaging_deserialize_symbol();
1293 Environment* env,
1302 if (context != env->context()) {
1303 THROW_ERR_MESSAGE_TARGET_CONTEXT_UNAVAILABLE(env);
1306 HandleScope handle_scope(env->isolate());
1311 CHECK(!env->messaging_deserialize_create_object().IsEmpty());
1312 if (!env->messaging_deserialize_create_object()->Call(
1313 context, Null(env->isolate()), 1, &info).ToLocal(&ret) ||
1314 !env->base_object_ctor_template()->HasInstance(ret)) {
1435 Environment* env = Environment::GetCurrent(args);
1437 env->set_messaging_deserialize_create_object(args[0].As<Function>());
1441 Environment* env = Environment::GetCurrent(args);
1443 THROW_ERR_CONSTRUCT_CALL_REQUIRED(env);
1450 MessagePort* port1 = MessagePort::New(env, context);
1452 MessagePort* port2 = MessagePort::New(env, context);
1460 args.This()->Set(context, env->port1_string(), port1->object())
1462 args.This()->Set(context, env->port2_string(), port2->object())
1468 Environment* env = Environment::GetCurrent(args);
1469 Context::Scope context_scope(env->context());
1470 Utf8Value name(env->isolate(), args[0]);
1472 MessagePort::New(env, env->context(), {}, SiblingGroup::Get(*name));
1482 Environment* env = Environment::GetCurrent(context);
1483 Isolate* isolate = env->isolate();
1495 t->Inherit(BaseObject::GetConstructorTemplate(env));
1505 env->message_port_constructor_string(),
1506 GetMessagePortConstructorTemplate(env),
1528 FIXED_ONE_BYTE_STRING(env->isolate(), "DOMException"),