| /src/external/bsd/libevent/dist/test/ |
| regress_et.c | 87 evutil_socket_t *xpair = data->pair; local
101 tt_int_op(send(xpair[0], test, (int)strlen(test)+1, 0), >, 0);
102 tt_int_op(shutdown(xpair[0], EVUTIL_SHUT_WR), ==, 0);
110 ev = event_new(base, xpair[1], EV_READ|EV_ET|EV_PERSIST, read_cb, &ev);
115 * will read a single byte from xpair[1] in either case. If we're edge
216 evutil_socket_t *xpair = data->pair; local
228 /* Make xpair[1] readable */
229 tt_int_op(send(xpair[0], &c, 1, 0), >, 0);
231 read_ev = event_new(base, xpair[1], EV_READ|EV_ET|EV_PERSIST,
233 write_ev = event_new(base, xpair[1], EV_WRITE|EV_ET|EV_PERSIST
[all...] |
| regress_zlib.c | 286 evutil_socket_t xpair[2] = {-1, -1}; local
292 if (evutil_socketpair(AF_UNIX, SOCK_STREAM, 0, xpair) == -1) {
296 evutil_make_socket_nonblocking(xpair[0]);
297 evutil_make_socket_nonblocking(xpair[1]);
299 bev1 = bufferevent_socket_new(NULL, xpair[0], 0);
300 bev2 = bufferevent_socket_new(NULL, xpair[1], 0);
347 if (xpair[0] >= 0)
348 evutil_closesocket(xpair[0]);
349 if (xpair[1] >= 0)
350 evutil_closesocket(xpair[1])
[all...] |
| regress_bufferevent.c | 151 struct bufferevent *xpair[2]; local
152 tt_assert(0 == bufferevent_pair_new(NULL, 0, xpair));
153 bev1 = xpair[0];
154 bev2 = xpair[1];
353 struct bufferevent *xpair[2]; local
354 if (!bufferevent_pair_new(NULL, BEV_OPT_THREADSAFE, xpair)) {
355 bufferevent_free(xpair[0]);
356 bufferevent_free(xpair[1]);
419 struct bufferevent *xpair[2]; local
420 tt_assert(0 == bufferevent_pair_new(NULL, 0, xpair));
564 struct bufferevent *xpair[2]; local
1235 struct bufferevent *xpair[2]; local
1314 struct bufferevent *xpair[2]; local
[all...] |
| regress_buffer.c | 1139 evutil_socket_t xpair[2] = {-1, -1}; local
1245 if (evutil_ersatz_socketpair_(AF_INET, SOCK_STREAM, 0, xpair) == -1)
1248 if (evutil_socketpair(AF_UNIX, SOCK_STREAM, 0, xpair) == -1)
1251 evutil_make_socket_nonblocking(xpair[0]);
1252 evutil_make_socket_nonblocking(xpair[1]);
1271 wev = event_new(base, xpair[0], EV_WRITE|EV_PERSIST,
1273 rev = event_new(base, xpair[1], EV_READ|EV_PERSIST,
1303 if (xpair[0] >= 0)
1304 evutil_closesocket(xpair[0]);
1305 if (xpair[1] >= 0
2532 evutil_socket_t *xpair = testdata->pair; local
[all...] |
| regress.c | 481 evutil_socket_t *xpair = data->pair; local
496 ev = event_new(base, xpair[0], events, record_event_cb, &got_event);
502 tt_assert(!evutil_closesocket(xpair[1]));
504 xpair[1] = -1;
506 tt_assert(!shutdown(xpair[1], EVUTIL_SHUT_WR));
|
