Home | History | Annotate | Download | only in test

Lines Matching defs:bev2

143 	struct bufferevent *bev1 = NULL, *bev2 = NULL;
152 bev2 = pair[1];
154 bufferevent_setcb(bev2, readcb, writecb, errorcb, NULL);
157 tt_ptr_op(bufferevent_pair_get_partner(bev1), ==, bev2);
158 tt_ptr_op(bufferevent_pair_get_partner(bev2), ==, bev1);
161 bev2 = bufferevent_new(pair[1], readcb, writecb, errorcb, NULL);
165 tt_ptr_op(bufferevent_pair_get_partner(bev2), ==, NULL);
181 bufferevent_enable(bev2, EV_READ);
184 tt_int_op(bufferevent_get_enabled(bev2), ==, EV_WRITE|EV_READ);
196 bufferevent_free(bev2);
410 struct bufferevent *bev1 = NULL, *bev2 = NULL;
420 bev2 = pair[1];
422 bufferevent_setcb(bev2, wm_readcb, NULL, errorcb, NULL);
425 bev2 = bufferevent_new(pair[1], wm_readcb, NULL, wm_errorcb, NULL);
428 tt_assert(bev2);
430 bufferevent_enable(bev2, EV_READ);
435 bufferevent_getwatermark(bev2, EV_WRITE, &low, NULL);
442 bufferevent_setwatermark(bev2, EV_READ, 10, 20);
444 bufferevent_getwatermark(bev2, EV_READ, &low, &high);
469 tt_assert(!event_pending(&bev2->ev_write, EV_WRITE, NULL));
474 if (bev2)
475 bufferevent_free(bev2);
554 struct bufferevent *bev1 = NULL, *bev2 = NULL;
565 bev2 = pair[1];
568 bev2 = bufferevent_socket_new(NULL, pair[1], 0);
571 bev2_base = bev2;
580 bev2 = bufferevent_filter_new(bev2, bufferevent_input_filter,
583 bufferevent_setcb(bev2, readcb, NULL, errorcb, NULL);
586 tt_ptr_op(bufferevent_get_underlying(bev2), ==, bev2_base);
588 tt_fd_op(bufferevent_getfd(bev2), ==, bufferevent_getfd(bev2_base));
591 bufferevent_enable(bev2, EV_READ);
603 if (bev2)
604 bufferevent_free(bev2);
732 struct bufferevent *bev1=NULL, *bev2=NULL;
778 bev2 = bufferevent_socket_new(data->base, -1, be_flags);
780 tt_assert(bev2);
782 bufferevent_setcb(bev2, reader_readcb,NULL, reader_eventcb, data->base);
785 bufferevent_enable(bev2, EV_READ);
788 tt_want(!bufferevent_socket_connect(bev2, sa, sizeof(localhost)));
801 if (bev2)
802 bufferevent_free(bev2);
981 struct bufferevent *bev1 = NULL, *bev2 = NULL;
999 bev2 = p[1];
1002 bev2 = bufferevent_socket_new(data->base, data->pair[1], 0);
1005 tt_assert(bev2);
1011 bevf2 = bufferevent_filter_new(bev2, NULL, NULL,
1016 bev2 = bevf2;
1020 bufferevent_disable(bev2, EV_READ);
1033 /* bev2 has nothing to say, and isn't listening. */
1034 bufferevent_setcb(bev2, bev_timeout_read_cb, bev_timeout_write_cb,
1039 bufferevent_set_timeouts(bev2, &tv_r, &tv_w);
1040 bufferevent_enable(bev2, EV_WRITE);
1074 if (bev2)
1075 bufferevent_free(bev2);
1235 struct bufferevent *bev2 = NULL;
1240 bev2 = pair[1];
1242 tt_assert(0 == bufferevent_enable(bev2, EV_READ));
1244 bufferevent_setcb(bev2, NULL, NULL, pair_flush_eventcb, &callback_what);
1255 if (bev2)
1256 bufferevent_free(bev2);