78 evutil_socket_t pair[2];  variable
303 	if (write(pair[0], TEST1, strlen(TEST1)+1) < 0) {  in test_simpleread()
307 	shutdown(pair[0], EVUTIL_SHUT_WR);  in test_simpleread()
309 	event_set(&ev, pair[1], EV_READ, simple_read_cb, &ev);  in test_simpleread()
325 	event_set(&ev, pair[0], EV_WRITE, simple_write_cb, &ev);  in test_simplewrite()
348 	if (write(pair[0], TEST1, strlen(TEST1)+1) < 0) {  in test_simpleread_multiple()
352 	shutdown(pair[0], EVUTIL_SHUT_WR);  in test_simpleread_multiple()
354 	event_set(&one, pair[1], EV_READ, simpleread_multiple_cb, NULL);  in test_simpleread_multiple()
357 	event_set(&two, pair[1], EV_READ, simpleread_multiple_cb, NULL);  in test_simpleread_multiple()
477 	evutil_socket_t *pair        = data->pair;  in test_simpleclose()  local
492 	ev = event_new(base, pair[0], events, record_event_cb, &got_event);  in test_simpleclose()
498 		tt_assert(!evutil_closesocket(pair[1]));  in test_simpleclose()
500 		pair[1] = -1;  in test_simpleclose()
502 		tt_assert(!shutdown(pair[1], EVUTIL_SHUT_WR));  in test_simpleclose()
538 	event_set(&ev, pair[0], EV_WRITE, multiple_write_cb, &ev);  in test_multiple()
541 	event_set(&ev2, pair[1], EV_READ, multiple_read_cb, &ev2);  in test_multiple()
567 	event_set(&ev, pair[0], EV_WRITE|EV_PERSIST, multiple_write_cb, &ev);  in test_persistent()
570 	event_set(&ev2, pair[1], EV_READ|EV_PERSIST, multiple_read_cb, &ev2);  in test_persistent()
595 	event_set(&r1.ev, pair[0], EV_READ, combined_read_cb, &r1);  in test_combined()
596 	event_set(&w1.ev, pair[0], EV_WRITE, combined_write_cb, &w1);  in test_combined()
597 	event_set(&r2.ev, pair[1], EV_READ, combined_read_cb, &r2);  in test_combined()
598 	event_set(&w2.ev, pair[1], EV_WRITE, combined_write_cb, &w2);  in test_combined()
947 	if (write(pair[0], TEST1, strlen(TEST1)+1) < 0) {  in test_fork()
951 	event_set(&ev, pair[1], EV_READ, simple_child_read_cb, &ev);  in test_fork()
998 	if (write(pair[0], TEST1, strlen(TEST1)+1) < 0) {  in test_fork()
1005 	if (write(pair[0], TEST1, strlen(TEST1)+1) < 0) {  in test_fork()
1009 	shutdown(pair[0], EVUTIL_SHUT_WR);  in test_fork()
1061 	event_set(&ev, pair[1], EV_READ|EV_PERSIST, del_wait_cb, &ev);  in test_del_wait()
1066 	if (write(pair[0], TEST1, strlen(TEST1)+1) < 0) {  in test_del_wait()
1441 	event_assign(&ev1, base1, data->pair[1], EV_READ, dummy_read_cb, NULL);  in test_free_active_base()
1447 	event_assign(&ev1, base1, data->pair[0], 0, dummy_read_cb, NULL);  in test_free_active_base()
1864 	ev1 = event_new(data->base, data->pair[0], EV_READ|EV_PERSIST, read_and_drain_cb, NULL);  in test_active_later()
1865 	ev2 = event_new(data->base, data->pair[1], EV_WRITE|EV_PERSIST, write_a_byte_cb, NULL);  in test_active_later()
1964 	ev[0] = event_new(base, data->pair[0], EV_READ|EV_PERSIST,  in test_event_remove_timeout()
1968 	ev[3] = evtimer_new(base, send_a_byte_cb, &data->pair[1]);  in test_event_remove_timeout()
1969 	ev[4] = evtimer_new(base, send_a_byte_cb, &data->pair[1]);  in test_event_remove_timeout()
2001 	int len = write(data->pair[0], TEST1, towrite);  in test_event_base_new()
2009 	if (shutdown(data->pair[0], EVUTIL_SHUT_WR))  in test_event_base_new()
2019 	event_assign(&ev1, base, data->pair[1],  in test_event_base_new()
2170 	tt_assert(!event_assign(&ev1, data->base, data->pair[0], EV_READ, re_add_read_cb, &ev2));  in test_nonpersist_readd()
2171 	tt_assert(!event_assign(&ev2, data->base, data->pair[1], EV_READ, re_add_read_cb, &ev1));  in test_nonpersist_readd()
2173 	tt_int_op(write(data->pair[0], "Hello", 5), ==, 5);  in test_nonpersist_readd()
2174 	tt_int_op(write(data->pair[1], "Hello", 5), ==, 5);  in test_nonpersist_readd()
2351    event_set(&e1, pair[0], EV_READ, test_multiple_cb, NULL);  in test_multiple_events_for_same_fd()
2353    event_set(&e2, pair[0], EV_WRITE, test_multiple_cb, NULL);  in test_multiple_events_for_same_fd()
2358    if (write(pair[1], TEST1, strlen(TEST1)+1) < 0) {  in test_multiple_events_for_same_fd()
2388 		if (write(pair[0], TEST1, strlen(TEST1)+1) < 0) {  in read_once_cb()
2408 	if (write(pair[0], TEST1, strlen(TEST1)+1) < 0) {  in test_want_only_once()
2417 	event_set(&ev, pair[1], EV_READ, read_once_cb, &ev);  in test_want_only_once()
2805 	r = event_base_once(data->base, data->pair[0], EV_READ,  in test_event_once()
2822 	if (write(data->pair[1], TEST1, strlen(TEST1)+1) < 0) {  in test_event_once()
2826 	shutdown(data->pair[1], EVUTIL_SHUT_WR);  in test_event_once()
2869 	r = event_new(data->base, data->pair[0], EV_READ, simple_read_cb,  in test_event_pending()
2871 	w = event_new(data->base, data->pair[1], EV_WRITE, simple_write_cb,  in test_event_pending()
2929 	e = event_new(data->base, data->pair[0], EV_READ, dfd_cb, &i);  in test_event_closed_fd_poll()
2936 	close(data->pair[0]);  in test_event_closed_fd_poll()
2937 	data->pair[0] = -1; /** avoids double-close */  in test_event_closed_fd_poll()
2963 	tt_int_op(write(data->pair[0], "Hello world",  in test_dup_fd()
2965 	fd = data->pair[1];  in test_dup_fd()
3165 	ev1 = event_new(base, data->pair[1], EV_READ, dummy_read_cb, (void*)str);  in test_get_assignment()
3169 	tt_fd_op(s, ==, data->pair[1]);  in test_get_assignment()
3420 	ev1 = event_new(base, data->pair[0], EV_READ, tabf_cb, &e1);  in test_active_by_fd()
3421 	ev2 = event_new(base, data->pair[0], EV_WRITE, tabf_cb, &e2);  in test_active_by_fd()
3422 	ev3 = event_new(base, data->pair[1], EV_READ, tabf_cb, &e3);  in test_active_by_fd()
3423 	ev4 = event_new(base, data->pair[1], EV_READ, tabf_cb, &e4);  in test_active_by_fd()
3443 	event_base_active_by_fd(base, data->pair[0], EV_WRITE);  in test_active_by_fd()
3444 	event_base_active_by_fd(base, data->pair[1], EV_READ);  in test_active_by_fd()
3445 	event_base_active_by_fd(base, data->pair[1], EV_TIMEOUT);  in test_active_by_fd()