Lines Matching refs:bev1
128 struct bufferevent *bev1 = NULL, *bev2 = NULL; in test_bufferevent_impl() local
136 bev1 = pair[0]; in test_bufferevent_impl()
138 bufferevent_setcb(bev1, readcb, writecb, errorcb, bev1); in test_bufferevent_impl()
140 tt_int_op(bufferevent_getfd(bev1), ==, -1); in test_bufferevent_impl()
141 tt_ptr_op(bufferevent_get_underlying(bev1), ==, NULL); in test_bufferevent_impl()
142 tt_ptr_op(bufferevent_pair_get_partner(bev1), ==, bev2); in test_bufferevent_impl()
143 tt_ptr_op(bufferevent_pair_get_partner(bev2), ==, bev1); in test_bufferevent_impl()
145 bev1 = bufferevent_new(pair[0], readcb, writecb, errorcb, NULL); in test_bufferevent_impl()
147 tt_int_op(bufferevent_getfd(bev1), ==, pair[0]); in test_bufferevent_impl()
148 tt_ptr_op(bufferevent_get_underlying(bev1), ==, NULL); in test_bufferevent_impl()
149 tt_ptr_op(bufferevent_pair_get_partner(bev1), ==, NULL); in test_bufferevent_impl()
158 bufferevent_getcb(bev1, &r, &w, &e, &a); in test_bufferevent_impl()
162 tt_ptr_op(a, ==, use_pair ? bev1 : NULL); in test_bufferevent_impl()
165 bufferevent_disable(bev1, EV_READ); in test_bufferevent_impl()
168 tt_int_op(bufferevent_get_enabled(bev1), ==, EV_WRITE); in test_bufferevent_impl()
174 bufferevent_write(bev1, buffer, sizeof(buffer)); in test_bufferevent_impl()
176 tt_int_op(bufferevent_flush(bev1, EV_WRITE, flush), >=, 0); in test_bufferevent_impl()
182 tt_ptr_op(bufferevent_pair_get_partner(bev1), ==, NULL); in test_bufferevent_impl()
183 bufferevent_free(bev1); in test_bufferevent_impl()
395 struct bufferevent *bev1 = NULL, *bev2 = NULL; in test_bufferevent_watermarks_impl() local
404 bev1 = pair[0]; in test_bufferevent_watermarks_impl()
406 bufferevent_setcb(bev1, NULL, wm_writecb, errorcb, NULL); in test_bufferevent_watermarks_impl()
409 bev1 = bufferevent_new(pair[0], NULL, wm_writecb, wm_errorcb, NULL); in test_bufferevent_watermarks_impl()
412 tt_assert(bev1); in test_bufferevent_watermarks_impl()
414 bufferevent_disable(bev1, EV_READ); in test_bufferevent_watermarks_impl()
418 bufferevent_getwatermark(bev1, EV_READ, &low, NULL); in test_bufferevent_watermarks_impl()
435 bufferevent_setwatermark(bev1, EV_WRITE, 100, 2000); in test_bufferevent_watermarks_impl()
437 bufferevent_getwatermark(bev1, EV_WRITE, &low, &high); in test_bufferevent_watermarks_impl()
442 int r = bufferevent_getwatermark(bev1, EV_WRITE | EV_READ, &low, &high); in test_bufferevent_watermarks_impl()
446 bufferevent_write(bev1, buffer, sizeof(buffer)); in test_bufferevent_watermarks_impl()
457 if (bev1) in test_bufferevent_watermarks_impl()
458 bufferevent_free(bev1); in test_bufferevent_watermarks_impl()
539 struct bufferevent *bev1 = NULL, *bev2 = NULL; in test_bufferevent_filters_impl() local
549 bev1 = pair[0]; in test_bufferevent_filters_impl()
552 bev1 = bufferevent_socket_new(NULL, pair[0], 0); in test_bufferevent_filters_impl()
555 bev1_base = bev1; in test_bufferevent_filters_impl()
561 bev1 = bufferevent_filter_new(bev1, NULL, bufferevent_output_filter, in test_bufferevent_filters_impl()
563 disable ? &bev1 : NULL); in test_bufferevent_filters_impl()
567 bufferevent_setcb(bev1, NULL, writecb, errorcb, NULL); in test_bufferevent_filters_impl()
570 tt_ptr_op(bufferevent_get_underlying(bev1), ==, bev1_base); in test_bufferevent_filters_impl()
572 tt_int_op(bufferevent_getfd(bev1), ==, -1); in test_bufferevent_filters_impl()
575 bufferevent_disable(bev1, EV_READ); in test_bufferevent_filters_impl()
578 bufferevent_write(bev1, buffer, sizeof(buffer)); in test_bufferevent_filters_impl()
586 if (bev1) in test_bufferevent_filters_impl()
587 bufferevent_free(bev1); in test_bufferevent_filters_impl()
717 struct bufferevent *bev1=NULL, *bev2=NULL; in test_bufferevent_connect() local
762 bev1 = bufferevent_socket_new(data->base, -1, be_flags); in test_bufferevent_connect()
764 tt_assert(bev1); in test_bufferevent_connect()
766 bufferevent_setcb(bev1, reader_readcb,NULL, reader_eventcb, data->base); in test_bufferevent_connect()
769 bufferevent_enable(bev1, EV_READ); in test_bufferevent_connect()
772 tt_want(!bufferevent_socket_connect(bev1, sa, sizeof(localhost))); in test_bufferevent_connect()
783 if (bev1) in test_bufferevent_connect()
784 bufferevent_free(bev1); in test_bufferevent_connect()
945 struct bufferevent *bev1 = NULL, *bev2 = NULL; in test_bufferevent_timeouts() local
963 bev1 = p[0]; in test_bufferevent_timeouts()
966 bev1 = bufferevent_socket_new(data->base, data->pair[0], 0); in test_bufferevent_timeouts()
970 tt_assert(bev1); in test_bufferevent_timeouts()
975 bevf1 = bufferevent_filter_new(bev1, NULL, NULL, in test_bufferevent_timeouts()
981 bev1 = bevf1; in test_bufferevent_timeouts()
993 bufferevent_setcb(bev1, NULL, bev_timeout_write_cb, in test_bufferevent_timeouts()
995 bufferevent_setwatermark(bev1, EV_WRITE, 1024*1024+10, 0); in test_bufferevent_timeouts()
996 bufferevent_set_timeouts(bev1, &tv_r, &tv_w); in test_bufferevent_timeouts()
1000 bufferevent_write(bev1, "ABCDEFG", 7); in test_bufferevent_timeouts()
1005 struct evbuffer *output = bufferevent_get_output(bev1); in test_bufferevent_timeouts()
1013 bufferevent_enable(bev1, EV_READ|EV_WRITE); in test_bufferevent_timeouts()
1043 if (bev1) in test_bufferevent_timeouts()
1044 bufferevent_free(bev1); in test_bufferevent_timeouts()
1205 struct bufferevent *bev1 = NULL; in test_bufferevent_pair_flush() local
1210 bev1 = pair[0]; in test_bufferevent_pair_flush()
1212 tt_assert(0 == bufferevent_enable(bev1, EV_WRITE)); in test_bufferevent_pair_flush()
1217 bufferevent_flush(bev1, EV_WRITE, BEV_FINISHED); in test_bufferevent_pair_flush()
1224 if (bev1) in test_bufferevent_pair_flush()
1225 bufferevent_free(bev1); in test_bufferevent_pair_flush()