isc/tests/socket_test.c

42 completion_init(completion_t *completion) {
43 	completion->done = ISC_FALSE;
49 	completion_t *completion = event->ev_arg;
54 	completion->result = dev->result;
55 	completion->done = ISC_TRUE;
60 waitfor(completion_t *completion) {
62 	while (!completion->done && i++ < 5000) {
69 	if (completion->done)
90 	completion_t completion;
123 	completion_init(&completion);
124 	result = isc_socket_sendto(s1, &r, task, event_done, &completion,
127 	waitfor(&completion);
128 	ATF_CHECK(completion.done);
129 	ATF_CHECK_EQ(completion.result, ISC_R_SUCCESS);
133 	completion_init(&completion);
134 	result = isc_socket_recv(s2, &r, 1, task, event_done, &completion);
136 	waitfor(&completion);
137 	ATF_CHECK(completion.done);
138 	ATF_CHECK_EQ(completion.result, ISC_R_SUCCESS);
161 	completion_t completion;
197 	completion_init(&completion);
198 	result = isc_socket_sendto(s1, &r, task, event_done, &completion,
201 	waitfor(&completion);
202 	ATF_CHECK(completion.done);
203 	ATF_CHECK_EQ(completion.result, ISC_R_SUCCESS);
209 	completion_init(&completion);
210 	result = isc_socket_sendto(s1, &r, task, event_done, &completion,
213 	waitfor(&completion);
214 	ATF_CHECK(completion.done);
215 	ATF_CHECK_EQ(completion.result, ISC_R_SUCCESS);
219 	completion_init(&completion);
220 	result = isc_socket_recv(s2, &r, 1, task, event_done, &completion);
222 	waitfor(&completion);
223 	ATF_CHECK(completion.done);
224 	ATF_CHECK_EQ(completion.result, ISC_R_SUCCESS);
229 	completion_init(&completion);
230 	result = isc_socket_recv(s3, &r, 1, task, event_done, &completion);
232 	waitfor(&completion);
233 	ATF_CHECK(completion.done);
234 	ATF_CHECK_EQ(completion.result, ISC_R_SUCCESS);