Lines Matching refs:pair

147 		struct bufferevent *pair[2];  in test_bufferevent_impl()  local
148 tt_assert(0 == bufferevent_pair_new(NULL, 0, pair)); in test_bufferevent_impl()
149 bev1 = pair[0]; in test_bufferevent_impl()
150 bev2 = pair[1]; in test_bufferevent_impl()
158 bev1 = bufferevent_new(pair[0], readcb, writecb, errorcb, NULL); in test_bufferevent_impl()
159 bev2 = bufferevent_new(pair[1], readcb, writecb, errorcb, NULL); in test_bufferevent_impl()
160 tt_fd_op(bufferevent_getfd(bev1), ==, pair[0]); in test_bufferevent_impl()
349 struct bufferevent *pair[2]; in test_bufferevent_pair_release_lock() local
350 if (!bufferevent_pair_new(NULL, BEV_OPT_THREADSAFE, pair)) { in test_bufferevent_pair_release_lock()
351 bufferevent_free(pair[0]); in test_bufferevent_pair_release_lock()
352 bufferevent_free(pair[1]); in test_bufferevent_pair_release_lock()
415 struct bufferevent *pair[2]; in test_bufferevent_watermarks_impl() local
416 tt_assert(0 == bufferevent_pair_new(NULL, 0, pair)); in test_bufferevent_watermarks_impl()
417 bev1 = pair[0]; in test_bufferevent_watermarks_impl()
418 bev2 = pair[1]; in test_bufferevent_watermarks_impl()
422 bev1 = bufferevent_new(pair[0], NULL, wm_writecb, wm_errorcb, NULL); in test_bufferevent_watermarks_impl()
423 bev2 = bufferevent_new(pair[1], wm_readcb, NULL, wm_errorcb, NULL); in test_bufferevent_watermarks_impl()
560 struct bufferevent *pair[2]; in test_bufferevent_filters_impl() local
561 tt_assert(0 == bufferevent_pair_new(NULL, 0, pair)); in test_bufferevent_filters_impl()
562 bev1 = pair[0]; in test_bufferevent_filters_impl()
563 bev2 = pair[1]; in test_bufferevent_filters_impl()
565 bev1 = bufferevent_socket_new(NULL, pair[0], 0); in test_bufferevent_filters_impl()
566 bev2 = bufferevent_socket_new(NULL, pair[1], 0); in test_bufferevent_filters_impl()
999 bev1 = bufferevent_socket_new(data->base, data->pair[0], 0); in test_bufferevent_timeouts()
1000 bev2 = bufferevent_socket_new(data->base, data->pair[1], 0); in test_bufferevent_timeouts()
1231 struct bufferevent *pair[2]; in test_bufferevent_pair_flush() local
1236 tt_assert(0 == bufferevent_pair_new(data->base, 0, pair)); in test_bufferevent_pair_flush()
1237 bev1 = pair[0]; in test_bufferevent_pair_flush()
1238 bev2 = pair[1]; in test_bufferevent_pair_flush()
1310 struct bufferevent *pair[2]; in test_bufferevent_filter_data_stuck() local
1321 tt_assert(bufferevent_pair_new(data->base, options, pair) == 0); in test_bufferevent_filter_data_stuck()
1323 bufferevent_setwatermark(pair[0], EV_READ, 0, read_high_wm); in test_bufferevent_filter_data_stuck()
1324 bufferevent_setwatermark(pair[1], EV_READ, 0, read_high_wm); in test_bufferevent_filter_data_stuck()
1328 bufferevent_filter_new(pair[1], in test_bufferevent_filter_data_stuck()
1345 tt_assert(bufferevent_write(pair[0], payload, sizeof(payload)) == 0); in test_bufferevent_filter_data_stuck()
1351 if (pair[0]) in test_bufferevent_filter_data_stuck()
1352 bufferevent_free(pair[0]); in test_bufferevent_filter_data_stuck()