Lines Matching refs:env
27 #include "env-inl.h"
153 channel->env()->CloseHandle(&task->poll_watcher, ares_poll_close_cb);
161 Local<Array> HostentToNames(Environment* env, struct hostent* host) {
162 EscapableHandleScope scope(env->isolate());
167 names.emplace_back(OneByteString(env->isolate(), host->h_aliases[i]));
169 Local<Array> ret = Array::New(env->isolate(), names.data(), names.size());
174 Local<Array> HostentToNames(Environment* env,
181 env->context(),
183 OneByteString(env->isolate(), host->h_aliases[i])).Check();
191 Environment* env,
196 ttls[i] = Integer::NewFromUnsigned(env->isolate(), addrttls[i].ttl);
198 return Array::New(env->isolate(), ttls.out(), naddrttls);
202 Environment* env,
209 HandleScope handle_scope(env->isolate());
254 ret->Set(env->context(),
256 OneByteString(env->isolate(), ptr->h_name)).Check();
264 HostentToNames(env, ptr.get(), ret);
268 auto alias = OneByteString(env->isolate(), ptr->h_aliases[i]);
269 ret->Set(env->context(), i + offset, alias).Check();
276 auto address = OneByteString(env->isolate(), ip);
277 ret->Set(env->context(), i + offset, address).Check();
285 Environment* env,
290 HandleScope handle_scope(env->isolate());
300 Local<Object> mx_record = Object::New(env->isolate());
301 mx_record->Set(env->context(),
302 env->exchange_string(),
303 OneByteString(env->isolate(), current->host)).Check();
304 mx_record->Set(env->context(),
305 env->priority_string(),
306 Integer::New(env->isolate(), current->priority)).Check();
308 mx_record->Set(env->context(),
309 env->type_string(),
310 env->dns_mx_string()).Check();
312 ret->Set(env->context(), i + offset, mx_record).Check();
320 Environment* env,
325 HandleScope handle_scope(env->isolate());
335 Local<Object> caa_record = Object::New(env->isolate());
337 caa_record->Set(env->context(),
338 env->dns_critical_string(),
339 Integer::New(env->isolate(), current->critical)).Check();
340 caa_record->Set(env->context(),
341 OneByteString(env->isolate(), current->property),
342 OneByteString(env->isolate(), current->value)).Check();
344 caa_record->Set(env->context(),
345 env->type_string(),
346 env->dns_caa_string()).Check();
348 ret->Set(env->context(), i + offset, caa_record).Check();
356 Environment* env,
361 HandleScope handle_scope(env->isolate());
376 OneByteString(env->isolate(), current->txt, current->length);
382 Local<Object> elem = Object::New(env->isolate());
383 elem->Set(env->context(), env->entries_string(), txt_chunk).Check();
384 elem->Set(env->context(),
385 env->type_string(),
386 env->dns_txt_string()).Check();
387 ret->Set(env->context(), offset + i++, elem).Check();
389 ret->Set(env->context(), offset + i++, txt_chunk).Check();
393 txt_chunk = Array::New(env->isolate());
397 txt_chunk->Set(env->context(), j++, txt).Check();
403 Local<Object> elem = Object::New(env->isolate());
404 elem->Set(env->context(), env->entries_string(), txt_chunk).Check();
405 elem->Set(env->context(),
406 env->type_string(),
407 env->dns_txt_string()).Check();
408 ret->Set(env->context(), offset + i, elem).Check();
410 ret->Set(env->context(), offset + i, txt_chunk).Check();
420 Environment* env,
425 HandleScope handle_scope(env->isolate());
435 Local<Object> srv_record = Object::New(env->isolate());
436 srv_record->Set(env->context(),
437 env->name_string(),
438 OneByteString(env->isolate(), current->host)).Check();
439 srv_record->Set(env->context(),
440 env->port_string(),
441 Integer::New(env->isolate(), current->port)).Check();
442 srv_record->Set(env->context(),
443 env->priority_string(),
444 Integer::New(env->isolate(), current->priority)).Check();
445 srv_record->Set(env->context(),
446 env->weight_string(),
447 Integer::New(env->isolate(), current->weight)).Check();
449 srv_record->Set(env->context(),
450 env->type_string(),
451 env->dns_srv_string()).Check();
453 ret->Set(env->context(), i + offset, srv_record).Check();
462 Environment* env,
467 HandleScope handle_scope(env->isolate());
478 Local<Object> naptr_record = Object::New(env->isolate());
479 naptr_record->Set(env->context(),
480 env->flags_string(),
481 OneByteString(env->isolate(), current->flags)).Check();
482 naptr_record->Set(env->context(),
483 env->service_string(),
484 OneByteString(env->isolate(),
486 naptr_record->Set(env->context(),
487 env->regexp_string(),
488 OneByteString(env->isolate(),
490 naptr_record->Set(env->context(),
491 env->replacement_string(),
492 OneByteString(env->isolate(),
494 naptr_record->Set(env->context(),
495 env->order_string(),
496 Integer::New(env->isolate(), current->order)).Check();
497 naptr_record->Set(env->context(),
498 env->preference_string(),
499 Integer::New(env->isolate(),
502 naptr_record->Set(env->context(),
503 env->type_string(),
504 env->dns_naptr_string()).Check();
506 ret->Set(env->context(), i + offset, naptr_record).Check();
515 Environment* env,
519 EscapableHandleScope handle_scope(env->isolate());
599 Local<Object> soa_record = Object::New(env->isolate());
600 soa_record->Set(env->context(),
601 env->nsname_string(),
602 OneByteString(env->isolate(), nsname.get())).Check();
603 soa_record->Set(env->context(),
604 env->hostmaster_string(),
605 OneByteString(env->isolate(),
607 soa_record->Set(env->context(),
608 env->serial_string(),
609 Integer::NewFromUnsigned(env->isolate(), serial)).Check();
610 soa_record->Set(env->context(),
611 env->refresh_string(),
612 Integer::New(env->isolate(), refresh)).Check();
613 soa_record->Set(env->context(),
614 env->retry_string(),
615 Integer::New(env->isolate(), retry)).Check();
616 soa_record->Set(env->context(),
617 env->expire_string(),
618 Integer::New(env->isolate(), expire)).Check();
619 soa_record->Set(env->context(),
620 env->minttl_string(),
621 Integer::NewFromUnsigned(env->isolate(), minttl)).Check();
622 soa_record->Set(env->context(),
623 env->type_string(),
624 env->dns_soa_string()).Check();
639 Environment* env,
643 : AsyncWrap(env, object, PROVIDER_DNSCHANNEL),
664 Environment* env = Environment::GetCurrent(args);
665 new ChannelWrap(env, args.This(), timeout, tries);
669 Environment* env,
672 : ReqWrap(env, req_wrap_obj, AsyncWrap::PROVIDER_GETADDRINFOREQWRAP),
676 Environment* env,
678 : ReqWrap(env, req_wrap_obj, AsyncWrap::PROVIDER_GETNAMEINFOREQWRAP) {}
701 if (uv_poll_init_socket(channel->env()->event_loop(),
727 return env()->ThrowError(ToErrorCodeString(r));
739 return env()->ThrowError(ToErrorCodeString(r));
749 uv_timer_init(env()->event_loop(), timer_handle_);
763 env()->CloseHandle(timer_handle_, [](uv_timer_t* handle) { delete handle; });
900 Environment* env = wrap->env();
901 HandleScope handle_scope(env->isolate());
902 Context::Scope context_scope(env->context());
904 Local<Array> ret = Array::New(env->isolate());
912 status = ParseGeneralReply(env,
926 Local<Object> obj = Object::New(env->isolate());
927 obj->Set(env->context(),
928 env->address_string(),
929 ret->Get(env->context(), i).ToLocalChecked()).Check();
930 obj->Set(env->context(),
931 env->ttl_string(),
933 env->isolate(), addrttls[i].ttl)).Check();
934 obj->Set(env->context(),
935 env->type_string(),
936 env->dns_a_string()).Check();
937 ret->Set(env->context(), i, obj).Check();
941 Local<Object> obj = Object::New(env->isolate());
942 obj->Set(env->context(),
943 env->value_string(),
944 ret->Get(env->context(), i).ToLocalChecked()).Check();
945 obj->Set(env->context(),
946 env->type_string(),
947 env->dns_cname_string()).Check();
948 ret->Set(env->context(), i, obj).Check();
957 status = ParseGeneralReply(env,
971 Local<Object> obj = Object::New(env->isolate());
972 obj->Set(env->context(),
973 env->address_string(),
974 ret->Get(env->context(), i).ToLocalChecked()).Check();
975 obj->Set(env->context(),
976 env->ttl_string(),
978 env->isolate(), addr6ttls[i - a_count].ttl)).Check();
979 obj->Set(env->context(),
980 env->type_string(),
981 env->dns_aaaa_string()).Check();
982 ret->Set(env->context(), i, obj).Check();
986 status = ParseMxReply(env, buf, len, ret, true);
993 status = ParseGeneralReply(env, buf, len, &type, ret);
998 Local<Object> obj = Object::New(env->isolate());
999 obj->Set(env->context(),
1000 env->value_string(),
1001 ret->Get(env->context(), i).ToLocalChecked()).Check();
1002 obj->Set(env->context(),
1003 env->type_string(),
1004 env->dns_ns_string()).Check();
1005 ret->Set(env->context(), i, obj).Check();
1009 status = ParseTxtReply(env, buf, len, ret, true);
1014 status = ParseSrvReply(env, buf, len, ret, true);
1021 status = ParseGeneralReply(env, buf, len, &type, ret);
1025 Local<Object> obj = Object::New(env->isolate());
1026 obj->Set(env->context(),
1027 env->value_string(),
1028 ret->Get(env->context(), i).ToLocalChecked()).Check();
1029 obj->Set(env->context(),
1030 env->type_string(),
1031 env->dns_ptr_string()).Check();
1032 ret->Set(env->context(), i, obj).Check();
1036 status = ParseNaptrReply(env, buf, len, ret, true);
1042 status = ParseSoaReply(env, buf, len, &soa_record);
1047 ret->Set(env->context(), ret->Length(), soa_record).Check();
1050 status = ParseCaaReply(env, buf, len, ret, true);
1067 Environment* env = wrap->env();
1068 HandleScope handle_scope(env->isolate());
1069 Context::Scope context_scope(env->context());
1073 Local<Array> ret = Array::New(env->isolate());
1076 status = ParseGeneralReply(env,
1086 Local<Array> ttls = AddrTTLToArray<ares_addrttl>(env, addrttls, naddrttls);
1101 Environment* env = wrap->env();
1102 HandleScope handle_scope(env->isolate());
1103 Context::Scope context_scope(env->context());
1107 Local<Array> ret = Array::New(env->isolate());
1110 status = ParseGeneralReply(env,
1120 Local<Array> ttls = AddrTTLToArray<ares_addr6ttl>(env, addrttls, naddrttls);
1135 Environment* env = wrap->env();
1136 HandleScope handle_scope(env->isolate());
1137 Context::Scope context_scope(env->context());
1139 Local<Array> ret = Array::New(env->isolate());
1140 int status = ParseCaaReply(env, buf, len, ret);
1157 Environment* env = wrap->env();
1158 HandleScope handle_scope(env->isolate());
1159 Context::Scope context_scope(env->context());
1161 Local<Array> ret = Array::New(env->isolate());
1163 int status = ParseGeneralReply(env, buf, len, &type, ret);
1180 Environment* env = wrap->env();
1181 HandleScope handle_scope(env->isolate());
1182 Context::Scope context_scope(env->context());
1184 Local<Array> mx_records = Array::New(env->isolate());
1185 int status = ParseMxReply(env, buf, len, mx_records);
1203 Environment* env = wrap->env();
1204 HandleScope handle_scope(env->isolate());
1205 Context::Scope context_scope(env->context());
1208 Local<Array> names = Array::New(env->isolate());
1209 int status = ParseGeneralReply(env, buf, len, &type, names);
1226 Environment* env = wrap->env();
1227 HandleScope handle_scope(env->isolate());
1228 Context::Scope context_scope(env->context());
1230 Local<Array> txt_records = Array::New(env->isolate());
1231 int status = ParseTxtReply(env, buf, len, txt_records);
1248 Environment* env = wrap->env();
1249 HandleScope handle_scope(env->isolate());
1250 Context::Scope context_scope(env->context());
1252 Local<Array> srv_records = Array::New(env->isolate());
1253 int status = ParseSrvReply(env, buf, len, srv_records);
1270 Environment* env = wrap->env();
1271 HandleScope handle_scope(env->isolate());
1272 Context::Scope context_scope(env->context());
1275 Local<Array> aliases = Array::New(env->isolate());
1277 int status = ParseGeneralReply(env, buf, len, &type, aliases);
1294 Environment* env = wrap->env();
1295 HandleScope handle_scope(env->isolate());
1296 Context::Scope context_scope(env->context());
1298 Local<Array> naptr_records = Array::New(env->isolate());
1299 int status = ParseNaptrReply(env, buf, len, naptr_records);
1316 Environment* env = wrap->env();
1317 HandleScope handle_scope(env->isolate());
1318 Context::Scope context_scope(env->context());
1326 Local<Object> soa_record = Object::New(env->isolate());
1328 soa_record->Set(env->context(),
1329 env->nsname_string(),
1330 OneByteString(env->isolate(), soa_out->nsname)).Check();
1331 soa_record->Set(env->context(),
1332 env->hostmaster_string(),
1333 OneByteString(env->isolate(), soa_out->hostmaster)).Check();
1334 soa_record->Set(env->context(),
1335 env->serial_string(),
1337 env->isolate(), soa_out->serial)).Check();
1338 soa_record->Set(env->context(),
1339 env->refresh_string(),
1340 Integer::New(env->isolate(), soa_out->refresh)).Check();
1341 soa_record->Set(env->context(),
1342 env->retry_string(),
1343 Integer::New(env->isolate(), soa_out->retry)).Check();
1344 soa_record->Set(env->context(),
1345 env->expire_string(),
1346 Integer::New(env->isolate(), soa_out->expire)).Check();
1347 soa_record->Set(env->context(),
1348 env->minttl_string(),
1350 env->isolate(), soa_out->minttl)).Check();
1395 Environment* env = wrap->env();
1396 HandleScope handle_scope(env->isolate());
1397 Context::Scope context_scope(env->context());
1398 wrap->CallOnComplete(HostentToNames(env, host));
1405 Environment* env = Environment::GetCurrent(args);
1417 node::Utf8Value utf8name(env->isolate(), string);
1437 Environment* env = req_wrap->env();
1439 HandleScope handle_scope(env->isolate());
1440 Context::Scope context_scope(env->context());
1443 Integer::New(env->isolate(), status),
1444 Null(env->isolate())
1451 Local<Array> results = Array::New(env->isolate());
1472 Local<String> s = OneByteString(env->isolate(), ip);
1473 if (results->Set(env->context(), n, s).IsNothing())
1489 argv[0] = Integer::New(env->isolate(), UV_EAI_NODATA);
1500 req_wrap->MakeCallback(env->oncomplete_string(), arraysize(argv), argv);
1510 Environment* env = req_wrap->env();
1512 HandleScope handle_scope(env->isolate());
1513 Context::Scope context_scope(env->context());
1516 Integer::New(env->isolate(), status),
1517 Null(env->isolate()),
1518 Null(env->isolate())
1523 Local<String> js_hostname = OneByteString(env->isolate(), hostname);
1524 Local<String> js_service = OneByteString(env->isolate(), service);
1535 req_wrap->MakeCallback(env->oncomplete_string(), arraysize(argv), argv);
1556 Environment* env = Environment::GetCurrent(args);
1563 node::Utf8Value hostname(env->isolate(), args[1]);
1587 auto req_wrap = std::make_unique<GetAddrInfoReqWrap>(env,
1618 Environment* env = Environment::GetCurrent(args);
1624 node::Utf8Value ip(env->isolate(), args[1]);
1625 const unsigned port = args[2]->Uint32Value(env->context()).FromJust();
1631 auto req_wrap = std::make_unique<GetNameInfoReqWrap>(env, req_wrap_obj);
1650 Environment* env = Environment::GetCurrent(args);
1654 Local<Array> server_array = Array::New(env->isolate());
1672 OneByteString(env->isolate(), ip),
1673 Integer::New(env->isolate(), cur->udp_port)
1676 if (server_array->Set(env->context(), i,
1677 Array::New(env->isolate(), ret, arraysize(ret)))
1688 Environment* env = Environment::GetCurrent(args);
1713 CHECK(arr->Get(env->context(), i).ToLocalChecked()->IsArray());
1715 Local<Array> elm = arr->Get(env->context(), i).ToLocalChecked().As<Array>();
1717 CHECK(elm->Get(env->context(),
1718 0).ToLocalChecked()->Int32Value(env->context()).FromJust());
1719 CHECK(elm->Get(env->context(), 1).ToLocalChecked()->IsString());
1720 CHECK(elm->Get(env->context(),
1721 2).ToLocalChecked()->Int32Value(env->context()).FromJust());
1723 int fam = elm->Get(env->context(), 0)
1724 .ToLocalChecked()->Int32Value(env->context()).FromJust();
1725 node::Utf8Value ip(env->isolate(),
1726 elm->Get(env->context(), 1).ToLocalChecked());
1727 int port = elm->Get(env->context(), 2)
1728 .ToLocalChecked()->Int32Value(env->context()).FromJust();
1769 Environment* env = Environment::GetCurrent(args);
1795 THROW_ERR_INVALID_ARG_VALUE(env, "Invalid IP address.");
1805 THROW_ERR_INVALID_ARG_VALUE(env, "Cannot specify two IPv4 addresses.");
1812 THROW_ERR_INVALID_ARG_VALUE(env, "Cannot specify two IPv6 addresses.");
1818 THROW_ERR_INVALID_ARG_VALUE(env, "Invalid IP address.");
1844 Environment* env = Environment::GetCurrent(args);
1845 int code = args[0]->Int32Value(env->context()).FromJust();
1849 args.GetReturnValue().Set(OneByteString(env->isolate(), errmsg));
1883 Environment* env = Environment::GetCurrent(context);
1884 Isolate* isolate = env->isolate();
1892 target->Set(env->context(), FIXED_ONE_BYTE_STRING(env->isolate(), "AF_INET"),
1893 Integer::New(env->isolate(), AF_INET)).Check();
1894 target->Set(env->context(), FIXED_ONE_BYTE_STRING(env->isolate(), "AF_INET6"),
1895 Integer::New(env->isolate(), AF_INET6)).Check();
1896 target->Set(env->context(), FIXED_ONE_BYTE_STRING(env->isolate(),
1898 Integer::New(env->isolate(), AF_UNSPEC)).Check();
1899 target->Set(env->context(), FIXED_ONE_BYTE_STRING(env->isolate(),
1901 Integer::New(env->isolate(), AI_ADDRCONFIG)).Check();
1902 target->Set(env->context(), FIXED_ONE_BYTE_STRING(env->isolate(),
1904 Integer::New(env->isolate(), AI_ALL)).Check();
1905 target->Set(env->context(), FIXED_ONE_BYTE_STRING(env->isolate(),
1907 Integer::New(env->isolate(), AI_V4MAPPED)).Check();
1910 BaseObject::MakeLazilyInitializedJSTemplate(env);
1911 aiw->Inherit(AsyncWrap::GetConstructorTemplate(env));
1915 BaseObject::MakeLazilyInitializedJSTemplate(env);
1916 niw->Inherit(AsyncWrap::GetConstructorTemplate(env));
1920 BaseObject::MakeLazilyInitializedJSTemplate(env);
1921 qrw->Inherit(AsyncWrap::GetConstructorTemplate(env));
1928 channel_wrap->Inherit(AsyncWrap::GetConstructorTemplate(env));