Cross Reference: /src/external/bsd/libevent/dist/test/regress

Lines Matching defs:bev1
145 	struct bufferevent *bev1 = NULL, *bev2 = NULL;
153 		bev1 = xpair[0];
155 		bufferevent_setcb(bev1, readcb, writecb, errorcb, bev1);
157 		tt_fd_op(bufferevent_getfd(bev1), ==, EVUTIL_INVALID_SOCKET);
158 		tt_ptr_op(bufferevent_get_underlying(bev1), ==, NULL);
159 		tt_ptr_op(bufferevent_pair_get_partner(bev1), ==, bev2);
160 		tt_ptr_op(bufferevent_pair_get_partner(bev2), ==, bev1);
162 		bev1 = bufferevent_new(pair[0], readcb, writecb, errorcb, NULL);
164 		tt_fd_op(bufferevent_getfd(bev1), ==, pair[0]);
165 		tt_ptr_op(bufferevent_get_underlying(bev1), ==, NULL);
166 		tt_ptr_op(bufferevent_pair_get_partner(bev1), ==, NULL);
175 		bufferevent_getcb(bev1, &r, &w, &e, &a);
179 		tt_ptr_op(a, ==, use_pair ? bev1 : NULL);
182 	bufferevent_disable(bev1, EV_READ);
185 	tt_int_op(bufferevent_get_enabled(bev1), ==, EV_WRITE);
191 	bufferevent_write(bev1, buffer, sizeof(buffer));
193 		tt_int_op(bufferevent_flush(bev1, EV_WRITE, flush), >=, 0);
199 	tt_ptr_op(bufferevent_pair_get_partner(bev1), ==, NULL);
200 	bufferevent_free(bev1);
412 	struct bufferevent *bev1 = NULL, *bev2 = NULL;
421 		bev1 = xpair[0];
423 		bufferevent_setcb(bev1, NULL, wm_writecb, errorcb, NULL);
426 		bev1 = bufferevent_new(pair[0], NULL, wm_writecb, wm_errorcb, NULL);
429 	tt_assert(bev1);
431 	bufferevent_disable(bev1, EV_READ);
435 	bufferevent_getwatermark(bev1, EV_READ, &low, NULL);
452 	bufferevent_setwatermark(bev1, EV_WRITE, 100, 2000);
454 	bufferevent_getwatermark(bev1, EV_WRITE, &low, &high);
459 	int r = bufferevent_getwatermark(bev1, EV_WRITE | EV_READ, &low, &high);
463 	bufferevent_write(bev1, buffer, sizeof(buffer));
474 	if (bev1)
475 		bufferevent_free(bev1);
556 	struct bufferevent *bev1 = NULL, *bev2 = NULL;
566 		bev1 = xpair[0];
569 		bev1 = bufferevent_socket_new(NULL, pair[0], 0);
572 	bev1_base = bev1;
578 	bev1 = bufferevent_filter_new(bev1, NULL, bufferevent_output_filter,
580 					  disable ? &bev1 : NULL);
584 	bufferevent_setcb(bev1, NULL, writecb, errorcb, NULL);
587 	tt_ptr_op(bufferevent_get_underlying(bev1), ==, bev1_base);
589 	tt_fd_op(bufferevent_getfd(bev1), ==, bufferevent_getfd(bev1_base));
592 	bufferevent_disable(bev1, EV_READ);
595 	bufferevent_write(bev1, buffer, sizeof(buffer));
603 	if (bev1)
604 		bufferevent_free(bev1);
734 	struct bufferevent *bev1=NULL, *bev2=NULL;
779 	bev1 = bufferevent_socket_new(data->base, -1, be_flags);
781 	tt_assert(bev1);
783 	bufferevent_setcb(bev1, reader_readcb,NULL, reader_eventcb, data->base);
786 	bufferevent_enable(bev1, EV_READ);
789 	tt_want(!bufferevent_socket_connect(bev1, sa, sizeof(localhost)));
800 	if (bev1)
801 		bufferevent_free(bev1);
983 	struct bufferevent *bev1 = NULL, *bev2 = NULL;
1000 		bev1 = p[0];
1003 		bev1 = bufferevent_socket_new(data->base, data->pair[0], 0);
1006 	tt_assert(bev1);
1011 		bevf1 = bufferevent_filter_new(bev1, NULL, NULL,
1017 		bev1 = bevf1;
1024 	/* bev1 will try to write and read.  Both will time out. */
1029 	bufferevent_setcb(bev1, bev_timeout_read_cb, bev_timeout_write_cb,
1031 	bufferevent_set_timeouts(bev1, &tv_r, &tv_w);
1032 	bufferevent_write(bev1, "ABCDEFG", 7);
1033 	bufferevent_enable(bev1, EV_READ|EV_WRITE);
1074 	if (bev1)
1075 		bufferevent_free(bev1);
1236 	struct bufferevent *bev1 = NULL;
1241 	bev1 = xpair[0];
1243 	tt_assert(0 == bufferevent_enable(bev1, EV_WRITE));
1248 	bufferevent_flush(bev1, EV_WRITE, BEV_FINISHED);
1255 	if (bev1)
1256 		bufferevent_free(bev1);
OpenGrok
