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

Lines Matching defs:bev1
143 	struct bufferevent *bev1 = NULL, *bev2 = NULL;
151 		bev1 = pair[0];
153 		bufferevent_setcb(bev1, readcb, writecb, errorcb, bev1);
155 		tt_fd_op(bufferevent_getfd(bev1), ==, EVUTIL_INVALID_SOCKET);
156 		tt_ptr_op(bufferevent_get_underlying(bev1), ==, NULL);
157 		tt_ptr_op(bufferevent_pair_get_partner(bev1), ==, bev2);
158 		tt_ptr_op(bufferevent_pair_get_partner(bev2), ==, bev1);
160 		bev1 = bufferevent_new(pair[0], readcb, writecb, errorcb, NULL);
162 		tt_fd_op(bufferevent_getfd(bev1), ==, pair[0]);
163 		tt_ptr_op(bufferevent_get_underlying(bev1), ==, NULL);
164 		tt_ptr_op(bufferevent_pair_get_partner(bev1), ==, NULL);
173 		bufferevent_getcb(bev1, &r, &w, &e, &a);
177 		tt_ptr_op(a, ==, use_pair ? bev1 : NULL);
180 	bufferevent_disable(bev1, EV_READ);
183 	tt_int_op(bufferevent_get_enabled(bev1), ==, EV_WRITE);
189 	bufferevent_write(bev1, buffer, sizeof(buffer));
191 		tt_int_op(bufferevent_flush(bev1, EV_WRITE, flush), >=, 0);
197 	tt_ptr_op(bufferevent_pair_get_partner(bev1), ==, NULL);
198 	bufferevent_free(bev1);
410 	struct bufferevent *bev1 = NULL, *bev2 = NULL;
419 		bev1 = pair[0];
421 		bufferevent_setcb(bev1, NULL, wm_writecb, errorcb, NULL);
424 		bev1 = bufferevent_new(pair[0], NULL, wm_writecb, wm_errorcb, NULL);
427 	tt_assert(bev1);
429 	bufferevent_disable(bev1, EV_READ);
433 	bufferevent_getwatermark(bev1, EV_READ, &low, NULL);
450 	bufferevent_setwatermark(bev1, EV_WRITE, 100, 2000);
452 	bufferevent_getwatermark(bev1, EV_WRITE, &low, &high);
457 	int r = bufferevent_getwatermark(bev1, EV_WRITE | EV_READ, &low, &high);
461 	bufferevent_write(bev1, buffer, sizeof(buffer));
472 	if (bev1)
473 		bufferevent_free(bev1);
554 	struct bufferevent *bev1 = NULL, *bev2 = NULL;
564 		bev1 = pair[0];
567 		bev1 = bufferevent_socket_new(NULL, pair[0], 0);
570 	bev1_base = bev1;
576 	bev1 = bufferevent_filter_new(bev1, NULL, bufferevent_output_filter,
578 					  disable ? &bev1 : NULL);
582 	bufferevent_setcb(bev1, NULL, writecb, errorcb, NULL);
585 	tt_ptr_op(bufferevent_get_underlying(bev1), ==, bev1_base);
587 	tt_fd_op(bufferevent_getfd(bev1), ==, bufferevent_getfd(bev1_base));
590 	bufferevent_disable(bev1, EV_READ);
593 	bufferevent_write(bev1, buffer, sizeof(buffer));
601 	if (bev1)
602 		bufferevent_free(bev1);
732 	struct bufferevent *bev1=NULL, *bev2=NULL;
777 	bev1 = bufferevent_socket_new(data->base, -1, be_flags);
779 	tt_assert(bev1);
781 	bufferevent_setcb(bev1, reader_readcb,NULL, reader_eventcb, data->base);
784 	bufferevent_enable(bev1, EV_READ);
787 	tt_want(!bufferevent_socket_connect(bev1, sa, sizeof(localhost)));
798 	if (bev1)
799 		bufferevent_free(bev1);
981 	struct bufferevent *bev1 = NULL, *bev2 = NULL;
998 		bev1 = p[0];
1001 		bev1 = bufferevent_socket_new(data->base, data->pair[0], 0);
1004 	tt_assert(bev1);
1009 		bevf1 = bufferevent_filter_new(bev1, NULL, NULL,
1015 		bev1 = bevf1;
1022 	/* bev1 will try to write and read.  Both will time out. */
1027 	bufferevent_setcb(bev1, bev_timeout_read_cb, bev_timeout_write_cb,
1029 	bufferevent_set_timeouts(bev1, &tv_r, &tv_w);
1030 	bufferevent_write(bev1, "ABCDEFG", 7);
1031 	bufferevent_enable(bev1, EV_READ|EV_WRITE);
1072 	if (bev1)
1073 		bufferevent_free(bev1);
1234 	struct bufferevent *bev1 = NULL;
1239 	bev1 = pair[0];
1241 	tt_assert(0 == bufferevent_enable(bev1, EV_WRITE));
1246 	bufferevent_flush(bev1, EV_WRITE, BEV_FINISHED);
1253 	if (bev1)
1254 		bufferevent_free(bev1);
OpenGrok
