Lines Matching defs:channel
87 ChannelWrap* channel = task->channel;
90 uv_timer_again(channel->timer_handle());
95 ares_process_fd(channel->cares_channel(), task->sock, task->sock);
100 ares_process_fd(channel->cares_channel(),
114 ChannelWrap* channel = static_cast<ChannelWrap*>(data);
119 auto it = channel->task_list()->find(&lookup_task);
121 task = (it == channel->task_list()->end()) ? nullptr : *it;
126 channel->StartTimer();
128 task = NodeAresTask::Create(channel, sock);
136 channel->task_list()->insert(task);
152 channel->task_list()->erase(it);
153 channel->env()->CloseHandle(&task->poll_watcher, ares_poll_close_cb);
155 if (channel->task_list()->empty()) {
156 channel->CloseTimer();
683 ChannelWrap* channel = static_cast<ChannelWrap*>(handle->data);
684 CHECK_EQ(channel->timer_handle(), handle);
685 CHECK_EQ(false, channel->task_list()->empty());
686 ares_process_fd(channel->cares_channel(), ARES_SOCKET_BAD, ARES_SOCKET_BAD);
691 tracker->TrackField("channel", channel);
695 NodeAresTask* NodeAresTask::Create(ChannelWrap* channel, ares_socket_t sock) {
698 task->channel = channel;
701 if (uv_poll_init_socket(channel->env()->event_loop(),
824 /* destroy channel and reset channel */
1378 wrap->channel()->cares_channel(),
1406 ChannelWrap* channel;
1407 ASSIGN_OR_RETURN_UNWRAP(&channel, args.Holder());
1415 auto wrap = std::make_unique<Wrap>(channel, req_wrap_obj);
1420 channel->ModifyActivityQueryCount(1);
1423 channel->ModifyActivityQueryCount(-1);
1651 ChannelWrap* channel;
1652 ASSIGN_OR_RETURN_UNWRAP(&channel, args.Holder());
1658 int r = ares_get_servers_ports(channel->cares_channel(), &servers);
1689 ChannelWrap* channel;
1690 ASSIGN_OR_RETURN_UNWRAP(&channel, args.Holder());
1692 if (channel->active_query_count()) {
1703 int rv = ares_set_servers(channel->cares_channel(), nullptr);
1758 err = ares_set_servers_ports(channel->cares_channel(), servers.data());
1763 channel->set_is_servers_default(false);
1770 ChannelWrap* channel;
1771 ASSIGN_OR_RETURN_UNWRAP(&channel, args.Holder());
1789 ares_set_local_ip4(channel->cares_channel(), ReadUint32BE(addr0));
1792 ares_set_local_ip6(channel->cares_channel(), addr0);
1808 ares_set_local_ip4(channel->cares_channel(), ReadUint32BE(addr1));
1815 ares_set_local_ip6(channel->cares_channel(), addr1);
1825 ares_set_local_ip6(channel->cares_channel(), addr1);
1827 ares_set_local_ip4(channel->cares_channel(), 0);
1833 ChannelWrap* channel;
1834 ASSIGN_OR_RETURN_UNWRAP(&channel, args.Holder());
1839 ares_cancel(channel->cares_channel());