Home
last modified time | relevance | path

Searched refs:pair (Results 1 – 20 of 20) sorted by relevance

/libevent-2.1.12/test/
H A Dregress_et.c83 evutil_socket_t *pair = data->pair; in test_edgetriggered() local
97 tt_int_op(send(pair[0], test, (int)strlen(test)+1, 0), >, 0); in test_edgetriggered()
98 tt_int_op(shutdown(pair[0], EVUTIL_SHUT_WR), ==, 0); in test_edgetriggered()
106 ev = event_new(base, pair[1], EV_READ|EV_ET|EV_PERSIST, read_cb, &ev); in test_edgetriggered()
155 ev_lt = event_new(base, data->pair[0], EV_READ, read_cb, ev_lt); in test_edgetriggered_mix_error()
212 evutil_socket_t *pair = data->pair; in test_edge_triggered_multiple_events() local
225 tt_int_op(send(pair[0], &c, 1, 0), >, 0); in test_edge_triggered_multiple_events()
227 read_ev = event_new(base, pair[1], EV_READ|EV_ET|EV_PERSIST, in test_edge_triggered_multiple_events()
229 write_ev = event_new(base, pair[1], EV_WRITE|EV_ET|EV_PERSIST, in test_edge_triggered_multiple_events()
246 close(pair[0]); in test_edge_triggered_multiple_events()
[all …]
H A Dregress_main.c316 data->pair[0] = spair[0]; in basic_test_setup()
317 data->pair[1] = spair[1]; in basic_test_setup()
331 if (data->pair[0] != -1) in basic_test_cleanup()
332 evutil_closesocket(data->pair[0]); in basic_test_cleanup()
333 if (data->pair[1] != -1) in basic_test_cleanup()
334 evutil_closesocket(data->pair[1]); in basic_test_cleanup()
372 pair[0] = data->pair[0]; in legacy_test_setup()
373 pair[1] = data->pair[1]; in legacy_test_setup()
407 pair[0] = pair[1] = -1; in legacy_test_cleanup()
H A Dregress_bufferevent.c147 struct bufferevent *pair[2]; in test_bufferevent_impl() local
149 bev1 = pair[0]; in test_bufferevent_impl()
150 bev2 = pair[1]; in test_bufferevent_impl()
351 bufferevent_free(pair[0]); in test_bufferevent_pair_release_lock()
417 bev1 = pair[0]; in test_bufferevent_watermarks_impl()
418 bev2 = pair[1]; in test_bufferevent_watermarks_impl()
562 bev1 = pair[0]; in test_bufferevent_filters_impl()
563 bev2 = pair[1]; in test_bufferevent_filters_impl()
1237 bev1 = pair[0]; in test_bufferevent_pair_flush()
1238 bev2 = pair[1]; in test_bufferevent_pair_flush()
[all …]
H A Dregress_zlib.c283 evutil_socket_t pair[2] = {-1, -1}; in test_bufferevent_zlib() local
289 if (evutil_socketpair(AF_UNIX, SOCK_STREAM, 0, pair) == -1) { in test_bufferevent_zlib()
293 evutil_make_socket_nonblocking(pair[0]); in test_bufferevent_zlib()
294 evutil_make_socket_nonblocking(pair[1]); in test_bufferevent_zlib()
296 bev1 = bufferevent_socket_new(NULL, pair[0], 0); in test_bufferevent_zlib()
297 bev2 = bufferevent_socket_new(NULL, pair[1], 0); in test_bufferevent_zlib()
344 if (pair[0] >= 0) in test_bufferevent_zlib()
345 evutil_closesocket(pair[0]); in test_bufferevent_zlib()
346 if (pair[1] >= 0) in test_bufferevent_zlib()
347 evutil_closesocket(pair[1]); in test_bufferevent_zlib()
H A Dtest-closed.c78 evutil_socket_t pair[2]; in main() local
93 if (evutil_socketpair(AF_UNIX, SOCK_STREAM, 0, pair) == -1) in main()
97 if (send(pair[0], test, (int)strlen(test)+1, 0) < 0) in main()
99 shutdown(pair[0], EVUTIL_SHUT_WR); in main()
102 ev = event_new(base, pair[1], EV_CLOSED | EV_TIMEOUT, closed_cb, event_self_cbarg()); in main()
H A Dtest-eof.c86 evutil_socket_t pair[2]; in main() local
97 if (evutil_socketpair(AF_UNIX, SOCK_STREAM, 0, pair) == -1) in main()
101 if (send(pair[0], test, (int)strlen(test)+1, 0) < 0) in main()
103 shutdown(pair[0], EVUTIL_SHUT_WR); in main()
109 event_set(&ev, pair[1], EV_READ | EV_TIMEOUT, read_cb, &ev); in main()
H A Dtest-weof.c55 evutil_socket_t pair[2]; variable
73 evutil_closesocket(pair[0]); in write_cb()
99 if (evutil_socketpair(AF_UNIX, SOCK_STREAM, 0, pair) == -1) in main()
106 event_set(&ev, pair[1], EV_WRITE, write_cb, &ev); in main()
H A Dregress.c78 evutil_socket_t pair[2]; variable
307 shutdown(pair[0], EVUTIL_SHUT_WR); in test_simpleread()
352 shutdown(pair[0], EVUTIL_SHUT_WR); in test_simpleread_multiple()
477 evutil_socket_t *pair = data->pair; in test_simpleclose() local
498 tt_assert(!evutil_closesocket(pair[1])); in test_simpleclose()
500 pair[1] = -1; in test_simpleclose()
1009 shutdown(pair[0], EVUTIL_SHUT_WR); in test_fork()
2019 event_assign(&ev1, base, data->pair[1], in test_event_base_new()
2936 close(data->pair[0]); in test_event_closed_fd_poll()
2965 fd = data->pair[1]; in test_dup_fd()
[all …]
H A Dregress_iocp.c253 rbuf = evbuffer_overlapped_new_(data->pair[0]); in test_iocp_evbuffer()
254 wbuf = evbuffer_overlapped_new_(data->pair[1]); in test_iocp_evbuffer()
263 tt_assert(!event_iocp_port_associate_(port, data->pair[0], 100)); in test_iocp_evbuffer()
264 tt_assert(!event_iocp_port_associate_(port, data->pair[1], 100)); in test_iocp_evbuffer()
317 bea1 = bufferevent_async_new_(data->base, data->pair[0], in test_iocp_bufferevent_async()
319 bea2 = bufferevent_async_new_(data->base, data->pair[1], in test_iocp_bufferevent_async()
H A Dregress_listener.c169 tt_int_op(send(data->pair[1], "hello", 5, 0), >, 0); in regress_listener_error()
174 data->pair[0]); in regress_listener_error()
282 tt_int_op(send(data->pair[1], "hello", 5, 0), >, 0); in regress_listener_error_unlock()
285 listener = evconnlistener_new(base, acceptcb, NULL, flags, 0, data->pair[0]); in regress_listener_error_unlock()
291 rl.rlim_cur = rl.rlim_max = data->pair[1]; in regress_listener_error_unlock()
H A Dtest-changelist.c168 evutil_socket_t pair[2]; in main() local
182 if (evutil_socketpair(AF_UNIX, SOCK_STREAM, 0, pair) == -1) in main()
192 ev = event_new(base,pair[1],EV_WRITE | EV_PERSIST, write_cb, &ev); in main()
H A Dregress.h65 extern evutil_socket_t pair[2];
75 evutil_socket_t pair[2]; member
H A Dregress_buffer.c1135 evutil_socket_t pair[2] = {-1, -1}; in test_evbuffer_add_file() local
1299 if (pair[0] >= 0) in test_evbuffer_add_file()
1300 evutil_closesocket(pair[0]); in test_evbuffer_add_file()
1301 if (pair[1] >= 0) in test_evbuffer_add_file()
1302 evutil_closesocket(pair[1]); in test_evbuffer_add_file()
2528 evutil_socket_t *pair = testdata->pair; in test_evbuffer_freeze() local
2599 evbuffer_write(tmp_buf, pair[0]); in test_evbuffer_freeze()
2600 r = evbuffer_read(buf, pair[1], -1); in test_evbuffer_freeze()
2630 r = evbuffer_write(buf, pair[0]); in test_evbuffer_freeze()
2631 evbuffer_read(tmp_buf, pair[1], -1); in test_evbuffer_freeze()
[all …]
H A Dregress_ssl.c492 fd_pair = data->pair; in regress_bufferevent_openssl()
494 bev_ll[0] = bufferevent_socket_new(data->base, data->pair[0], in regress_bufferevent_openssl()
496 bev_ll[1] = bufferevent_socket_new(data->base, data->pair[1], in regress_bufferevent_openssl()
504 tt_fd_op(bufferevent_getfd(bev1), ==, data->pair[0]); in regress_bufferevent_openssl()
/libevent-2.1.12/
H A Dbufferevent_pair.c116 struct bufferevent *pair[2]) in bufferevent_pair_new()
146 pair[0] = downcast(bufev1); in bufferevent_pair_new()
147 pair[1] = downcast(bufev2); in bufferevent_pair_new()
H A DChangeLog-1.447 o Fix another pair of fencepost bugs in epoll.c. [Patch from Adam Langley.]
H A Dwhatsnew-2.1.txt421 There are a new pair of functions: evhttp_set_bevcb() and
H A DChangeLog-2.0585 o Close th_notify_fds and open a new pair on reinit (495ed66)
642 o Add a function to retrieve the other side of a bufferevent pair (17a8e2d)
H A DChangeLog503 o test: replace sleeping with syncing pair in main/fork (16d220c Azat Khuzhin)
567 o test/regress_be: basic coverage bufferevent_flush() for pair/sock layers (ad52602 Azat Khuzhin)
/libevent-2.1.12/include/event2/
H A Dbufferevent.h742 struct bufferevent *pair[2]);