288 bufferevent_openssl_check_fd(struct bufferevent *bev, int filter)  in bufferevent_openssl_check_fd()  argument
290 	tt_fd_op(bufferevent_getfd(bev), !=, EVUTIL_INVALID_SOCKET);  in bufferevent_openssl_check_fd()
291 	tt_fd_op(bufferevent_setfd(bev, EVUTIL_INVALID_SOCKET), ==, 0);  in bufferevent_openssl_check_fd()
293 		tt_fd_op(bufferevent_getfd(bev), !=, EVUTIL_INVALID_SOCKET);  in bufferevent_openssl_check_fd()
295 		tt_fd_op(bufferevent_getfd(bev), ==, EVUTIL_INVALID_SOCKET);  in bufferevent_openssl_check_fd()
302 bufferevent_openssl_check_freed(struct bufferevent *bev)  in bufferevent_openssl_check_freed()  argument
304 	tt_int_op(event_pending(&bev->ev_read, EVLIST_ALL, NULL), ==, 0);  in bufferevent_openssl_check_freed()
305 	tt_int_op(event_pending(&bev->ev_write, EVLIST_ALL, NULL), ==, 0);  in bufferevent_openssl_check_freed()
312 free_on_cb(struct bufferevent *bev, void *ctx)  in free_on_cb()  argument
314 	TT_BLATHER(("free_on_cb: %p", bev));  in free_on_cb()
315 	bufferevent_free(bev);  in free_on_cb()
319 respond_to_number(struct bufferevent *bev, void *ctx)  in respond_to_number()  argument
321 	struct evbuffer *b = bufferevent_get_input(bev);  in respond_to_number()
338 		bufferevent_free(bev); /* Should trigger close on other side. */  in respond_to_number()
342 		SSL_renegotiate(bufferevent_openssl_get_ssl(bev));  in respond_to_number()
345 	evbuffer_add_printf(bufferevent_get_output(bev),  in respond_to_number()
348 	bufferevent_enable(bev, EV_WRITE);  in respond_to_number()
349 	bufferevent_disable(bev, EV_READ);  in respond_to_number()
353 done_writing_cb(struct bufferevent *bev, void *ctx)  in done_writing_cb()  argument
355 	struct evbuffer *b = bufferevent_get_output(bev);  in done_writing_cb()
359 	bufferevent_disable(bev, EV_WRITE);  in done_writing_cb()
360 	bufferevent_enable(bev, EV_READ);  in done_writing_cb()
364 eventcb(struct bufferevent *bev, short what, void *ctx)  in eventcb()  argument
375 		ssl = bufferevent_openssl_get_ssl(bev);  in eventcb()
389 			evbuffer_add_printf(bufferevent_get_output(bev), "1\n");  in eventcb()
394 			bufferevent_openssl_check_fd(bev, type & REGRESS_OPENSSL_FILTER);  in eventcb()
397 			bufferevent_openssl_check_freed(bev);  in eventcb()
399 		bufferevent_free(bev);  in eventcb()
404 			bufferevent_openssl_check_fd(bev, type & REGRESS_OPENSSL_FILTER);  in eventcb()
407 			bufferevent_openssl_check_freed(bev);  in eventcb()
409 		bufferevent_free(bev);  in eventcb()
414 			bufferevent_openssl_check_fd(bev, type & REGRESS_OPENSSL_FILTER);  in eventcb()
417 			bufferevent_openssl_check_freed(bev);  in eventcb()
419 		bufferevent_free(bev);  in eventcb()
574 	struct bufferevent *bev = arg;  in acceptcb_deferred()  local
575 	bufferevent_enable(bev, EV_READ|EV_WRITE);  in acceptcb_deferred()
582 	struct bufferevent *bev;  in acceptcb()  local
591 	bev = bufferevent_openssl_socket_new(  in acceptcb()
594 	tt_assert(bev);  in acceptcb()
596 	bufferevent_setcb(bev, respond_to_number, NULL, eventcb,  in acceptcb()
602 		    acceptcb_deferred, bev, &when);  in acceptcb()
603 		bufferevent_disable(bev, EV_READ|EV_WRITE);  in acceptcb()
605 		bufferevent_enable(bev, EV_READ|EV_WRITE);  in acceptcb()
734 	struct bufferevent *bev;  in regress_bufferevent_openssl_connect()  local
761 	bev = bufferevent_openssl_socket_new(  in regress_bufferevent_openssl_connect()
765 	tt_assert(bev);  in regress_bufferevent_openssl_connect()
767 	bufferevent_setcb(bev, respond_to_number, free_on_cb, eventcb,  in regress_bufferevent_openssl_connect()
776 	    bufferevent_socket_connect(bev, (struct sockaddr*)&ss, slen));  in regress_bufferevent_openssl_connect()
782 		rw.fd = bufferevent_getfd(bev);  in regress_bufferevent_openssl_connect()
788 	evbuffer_add_printf(bufferevent_get_output(bev), "1\n");  in regress_bufferevent_openssl_connect()
789 	bufferevent_enable(bev, EV_READ|EV_WRITE);  in regress_bufferevent_openssl_connect()
808 	struct bufferevent *bev;  member
812 wm_transfer(struct bufferevent *bev, void *arg)  in wm_transfer()  argument
815 	struct evbuffer *in  = bufferevent_get_input(bev);  in wm_transfer()
816 	struct evbuffer *out = bufferevent_get_output(bev);  in wm_transfer()
822 			ctx->server ? "server" : "client", bev));  in wm_transfer()
823 		bufferevent_setcb(bev, NULL, NULL, NULL, NULL);  in wm_transfer()
824 		bufferevent_disable(bev, EV_READ);  in wm_transfer()
826 			event_base_loopbreak(bufferevent_get_base(bev));  in wm_transfer()
837 		ctx->server ? "server" : "client", bev,  in wm_transfer()
845 wm_eventcb(struct bufferevent *bev, short what, void *arg)  in wm_eventcb()  argument
849 		ctx->server ? "server" : "client", bev, what));  in wm_eventcb()
860 	struct bufferevent *bev;  in wm_acceptcb()  local
867 	bev = bufferevent_openssl_socket_new(  in wm_acceptcb()
871 		ctx->server ? "server" : "client", bev));  in wm_acceptcb()
873 	bufferevent_setwatermark(bev, EV_READ, 0, ctx->wm_high);  in wm_acceptcb()
874 	bufferevent_setcb(bev, wm_transfer, NULL, wm_eventcb, ctx);  in wm_acceptcb()
875 	bufferevent_enable(bev, EV_READ|EV_WRITE);  in wm_acceptcb()
876 	ctx->bev = bev;  in wm_acceptcb()
888 	struct bufferevent *bev;  in regress_bufferevent_openssl_wm()  local
947 		bev = bufferevent_socket_new(data->base, -1, client.flags);  in regress_bufferevent_openssl_wm()
948 		tt_assert(bev);  in regress_bufferevent_openssl_wm()
949 		bev = bufferevent_openssl_filter_new(  in regress_bufferevent_openssl_wm()
950 			base, bev, ssl, BUFFEREVENT_SSL_CONNECTING, client.flags);  in regress_bufferevent_openssl_wm()
952 		bev = bufferevent_openssl_socket_new(  in regress_bufferevent_openssl_wm()
957 	tt_assert(bev);  in regress_bufferevent_openssl_wm()
958 	client.bev = bev;  in regress_bufferevent_openssl_wm()
963 	bufferevent_setwatermark(bev, EV_READ, 0, client.wm_high);  in regress_bufferevent_openssl_wm()
964 	bufferevent_setcb(bev, wm_transfer, NULL, wm_eventcb, &client);  in regress_bufferevent_openssl_wm()
969 	tt_assert(!bufferevent_socket_connect(bev, (struct sockaddr*)&ss, slen));  in regress_bufferevent_openssl_wm()
970 	tt_assert(!evbuffer_add_buffer_reference(bufferevent_get_output(bev), client.data));  in regress_bufferevent_openssl_wm()
971 	tt_assert(!bufferevent_enable(bev, EV_READ|EV_WRITE));  in regress_bufferevent_openssl_wm()
983 	bufferevent_free(client.bev);  in regress_bufferevent_openssl_wm()
984 	bufferevent_free(server.bev);  in regress_bufferevent_openssl_wm()