Home | History | Annotate | Download | only in test

Lines Matching defs:bev2

145 	struct bufferevent *bev1 = NULL, *bev2 = NULL;
154 bev2 = xpair[1];
156 bufferevent_setcb(bev2, readcb, writecb, errorcb, NULL);
159 tt_ptr_op(bufferevent_pair_get_partner(bev1), ==, bev2);
160 tt_ptr_op(bufferevent_pair_get_partner(bev2), ==, bev1);
163 bev2 = bufferevent_new(pair[1], readcb, writecb, errorcb, NULL);
167 tt_ptr_op(bufferevent_pair_get_partner(bev2), ==, NULL);
183 bufferevent_enable(bev2, EV_READ);
186 tt_int_op(bufferevent_get_enabled(bev2), ==, EV_WRITE|EV_READ);
198 bufferevent_free(bev2);
412 struct bufferevent *bev1 = NULL, *bev2 = NULL;
422 bev2 = xpair[1];
424 bufferevent_setcb(bev2, wm_readcb, NULL, errorcb, NULL);
427 bev2 = bufferevent_new(pair[1], wm_readcb, NULL, wm_errorcb, NULL);
430 tt_assert(bev2);
432 bufferevent_enable(bev2, EV_READ);
437 bufferevent_getwatermark(bev2, EV_WRITE, &low, NULL);
444 bufferevent_setwatermark(bev2, EV_READ, 10, 20);
446 bufferevent_getwatermark(bev2, EV_READ, &low, &high);
471 tt_assert(!event_pending(&bev2->ev_write, EV_WRITE, NULL));
476 if (bev2)
477 bufferevent_free(bev2);
556 struct bufferevent *bev1 = NULL, *bev2 = NULL;
567 bev2 = xpair[1];
570 bev2 = bufferevent_socket_new(NULL, pair[1], 0);
573 bev2_base = bev2;
582 bev2 = bufferevent_filter_new(bev2, bufferevent_input_filter,
585 bufferevent_setcb(bev2, readcb, NULL, errorcb, NULL);
588 tt_ptr_op(bufferevent_get_underlying(bev2), ==, bev2_base);
590 tt_fd_op(bufferevent_getfd(bev2), ==, bufferevent_getfd(bev2_base));
593 bufferevent_enable(bev2, EV_READ);
605 if (bev2)
606 bufferevent_free(bev2);
734 struct bufferevent *bev1=NULL, *bev2=NULL;
780 bev2 = bufferevent_socket_new(data->base, -1, be_flags);
782 tt_assert(bev2);
784 bufferevent_setcb(bev2, reader_readcb,NULL, reader_eventcb, data->base);
787 bufferevent_enable(bev2, EV_READ);
790 tt_want(!bufferevent_socket_connect(bev2, sa, sizeof(localhost)));
803 if (bev2)
804 bufferevent_free(bev2);
983 struct bufferevent *bev1 = NULL, *bev2 = NULL;
1001 bev2 = p[1];
1004 bev2 = bufferevent_socket_new(data->base, data->pair[1], 0);
1007 tt_assert(bev2);
1013 bevf2 = bufferevent_filter_new(bev2, NULL, NULL,
1018 bev2 = bevf2;
1022 bufferevent_disable(bev2, EV_READ);
1035 /* bev2 has nothing to say, and isn't listening. */
1036 bufferevent_setcb(bev2, bev_timeout_read_cb, bev_timeout_write_cb,
1041 bufferevent_set_timeouts(bev2, &tv_r, &tv_w);
1042 bufferevent_enable(bev2, EV_WRITE);
1076 if (bev2)
1077 bufferevent_free(bev2);
1237 struct bufferevent *bev2 = NULL;
1242 bev2 = xpair[1];
1244 tt_assert(0 == bufferevent_enable(bev2, EV_READ));
1246 bufferevent_setcb(bev2, NULL, NULL, pair_flush_eventcb, &callback_what);
1257 if (bev2)
1258 bufferevent_free(bev2);