Lines Matching refs:closure
605 struct thread_closure *closure = arg; in thread_callback_wrapper() local
606 closure->callback (closure->obj, closure->server_index); in thread_callback_wrapper()
607 free (closure); in thread_callback_wrapper()
617 struct thread_closure *closure = xmalloc (sizeof (*closure)); in start_server_thread() local
618 *closure = (struct thread_closure) in start_server_thread()
624 return xpthread_create (NULL, thread_callback_wrapper, closure); in start_server_thread()
740 server_thread_udp_single (void *closure) in server_thread_udp_single() argument
742 struct resolv_test *obj = closure; in server_thread_udp_single()
880 struct tcp_thread_closure *closure = arg; in server_thread_tcp_client() local
886 if (!read_fully (closure->client_socket, in server_thread_tcp_client()
893 read_fully (closure->client_socket, query_buffer, query_length, false); in server_thread_tcp_client()
902 closure->server_index, query_length, in server_thread_tcp_client()
908 closure->server_index, query_length, in server_thread_tcp_client()
914 .test = closure->obj, in server_thread_tcp_client()
917 .server_index = closure->server_index, in server_thread_tcp_client()
923 closure->obj->config.response_callback 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()
951 writev_fully (closure->client_socket, buffers, 2); in server_thread_tcp_client()
960 xclose (closure->client_socket); in server_thread_tcp_client()
961 free (closure); in server_thread_tcp_client()
987 struct tcp_thread_closure *closure = xmalloc (sizeof (*closure)); in server_thread_tcp() local
988 *closure = (struct tcp_thread_closure) in server_thread_tcp()
996 = xpthread_create (NULL, server_thread_tcp_client, closure); in server_thread_tcp()