Lines Matching refs:server_index
589 typedef void (*thread_callback) (struct resolv_test *, int server_index);
597 int server_index; /* Index of the implemented server. */ member
606 closure->callback (closure->obj, closure->server_index); in thread_callback_wrapper()
614 start_server_thread (struct resolv_test *obj, int server_index, in start_server_thread() argument
622 .server_index = server_index, in start_server_thread()
630 server_thread_udp_process_one (struct resolv_test *obj, int server_index) in server_thread_udp_process_one() argument
635 size_t length = xrecvfrom (obj->servers[server_index].socket_udp, in server_thread_udp_process_one()
656 server_index, length, qinfo.qname, qinfo.qclass, qinfo.qtype, in server_thread_udp_process_one()
661 server_index, length, qinfo.qname, qinfo.qclass, qinfo.qtype); in server_thread_udp_process_one()
671 .server_index = server_index, in server_thread_udp_process_one()
684 server_index, qinfo.qname, qinfo.qclass, qinfo.qtype); in server_thread_udp_process_one()
693 ctx.server_index, b->offset, b->buffer[3] & 0x0f, in server_thread_udp_process_one()
698 server_index, b->offset, in server_thread_udp_process_one()
722 if (sendto (ctx->test->servers[ctx->server_index].socket_udp, in resolv_response_send_udp()
731 server_thread_udp (struct resolv_test *obj, int server_index) in server_thread_udp() argument
733 while (server_thread_udp_process_one (obj, server_index)) in server_thread_udp()
745 for (int server_index = 0; server_index < resolv_max_test_servers; in server_thread_udp_single() local
746 ++server_index) in server_thread_udp_single()
747 if (obj->config.servers[server_index].disable_udp) in server_thread_udp_single()
748 fds[server_index] = (struct pollfd) {.fd = -1}; in server_thread_udp_single()
751 fds[server_index] = (struct pollfd) in server_thread_udp_single()
753 .fd = obj->servers[server_index].socket_udp, in server_thread_udp_single()
758 int flags = fcntl (obj->servers[server_index].socket_udp, F_GETFL, 0); in server_thread_udp_single()
762 if (fcntl (obj->servers[server_index].socket_udp, F_SETFL, flags) < 0) in server_thread_udp_single()
769 for (int server_index = 0; server_index < resolv_max_test_servers; in server_thread_udp_single() local
770 ++server_index) in server_thread_udp_single()
771 if (fds[server_index].revents != 0) in server_thread_udp_single()
773 if (!server_thread_udp_process_one (obj, server_index)) in server_thread_udp_single()
775 fds[server_index].revents = 0; in server_thread_udp_single()
796 int server_index; member
902 closure->server_index, query_length, in server_thread_tcp_client()
908 closure->server_index, query_length, in server_thread_tcp_client()
917 .server_index = closure->server_index, in server_thread_tcp_client()
930 closure->server_index, in server_thread_tcp_client()
938 closure->server_index, b->offset, in server_thread_tcp_client()
968 server_thread_tcp (struct resolv_test *obj, int server_index) in server_thread_tcp() argument
974 (obj->servers[server_index].socket_tcp, NULL, NULL); in server_thread_tcp()
991 .server_index = server_index, in server_thread_tcp()
1139 for (int server_index = 0; server_index < config.nscount; ++server_index) in resolv_test_start() local
1142 (obj->servers + server_index, in resolv_test_start()
1143 config.server_address_overrides[server_index]); in resolv_test_start()
1145 make_server_sockets (obj->servers + server_index); in resolv_test_start()
1149 for (int server_index = 0; server_index < config.nscount; ++server_index) in resolv_test_start() local
1151 struct resolv_test_server *server = obj->servers + server_index; in resolv_test_start()
1152 if (config.servers[server_index].disable_udp) in resolv_test_start()
1158 server->thread_udp = start_server_thread (obj, server_index, in resolv_test_start()
1160 if (config.servers[server_index].disable_tcp) in resolv_test_start()
1166 server->thread_tcp = start_server_thread (obj, server_index, in resolv_test_start()
1207 for (int server_index = 0; server_index < config.nscount; ++server_index) in resolv_test_start() local
1209 TEST_VERIFY_EXIT (obj->servers[server_index].address.sin_port != 0); in resolv_test_start()
1210 _res.nsaddr_list[server_index] = obj->servers[server_index].address; in resolv_test_start()
1215 (inet_ntop (AF_INET, &obj->servers[server_index].address.sin_addr, in resolv_test_start()
1218 server_index, buf, in resolv_test_start()
1219 htons (obj->servers[server_index].address.sin_port)); in resolv_test_start()
1238 for (int server_index = 0; server_index < obj->config.nscount; in resolv_test_end() local
1239 ++server_index) in resolv_test_end()
1241 if (!obj->config.servers[server_index].disable_udp) in resolv_test_end()
1245 (struct sockaddr *) &obj->servers[server_index].address, in resolv_test_end()
1246 sizeof (obj->servers[server_index].address)); in resolv_test_end()
1249 if (!obj->config.servers[server_index].disable_tcp) in resolv_test_end()
1253 (struct sockaddr *) &obj->servers[server_index].address, in resolv_test_end()
1254 sizeof (obj->servers[server_index].address)); in resolv_test_end()
1263 for (int server_index = 0; server_index < obj->config.nscount; in resolv_test_end() local
1264 ++server_index) in resolv_test_end()
1266 if (!obj->config.servers[server_index].disable_udp) in resolv_test_end()
1269 xpthread_join (obj->servers[server_index].thread_udp); in resolv_test_end()
1270 xclose (obj->servers[server_index].socket_udp); in resolv_test_end()
1272 if (!obj->config.servers[server_index].disable_tcp) in resolv_test_end()
1274 xpthread_join (obj->servers[server_index].thread_tcp); in resolv_test_end()
1275 xclose (obj->servers[server_index].socket_tcp); in resolv_test_end()