sntp/libevent/bufferevent_openssl.c

293 	struct bufferevent_private bev;
343 	evutil_offsetof(struct bufferevent_openssl, bev.bev),
356 upcast(struct bufferevent *bev)
359 	if (bev->be_ops != &bufferevent_ops_openssl)
361 	bev_o = (void*)( ((char*)bev) -
362 			 evutil_offsetof(struct bufferevent_openssl, bev.bev));
363 	EVUTIL_ASSERT(bev_o->bev.bev.be_ops == &bufferevent_ops_openssl);
391 		struct bufferevent *bev = &bev_ssl->bev.bev;
393 		r = bufferevent_add_event_(&bev->ev_read, &bev->timeout_read);
395 			r = bufferevent_add_event_(&bev->ev_write,
396 			    &bev->timeout_write);
411 		struct bufferevent *bev = &bev_ssl->bev.bev;
412 		r = bufferevent_add_event_(&bev->ev_write, &bev->timeout_write);
414 			r = bufferevent_add_event_(&bev->ev_read,
415 			    &bev->timeout_read);
429 		struct bufferevent *bev = &bev_ssl->bev.bev;
430 		event_del(&bev->ev_read);
442 		struct bufferevent *bev = &bev_ssl->bev.bev;
443 		event_del(&bev->ev_write);
468 	struct bufferevent *bev = &bev_ssl->bev.bev;
471 	if (!(bev->enabled & EV_WRITE))
473 	if (bev->enabled & EV_READ)
482 	struct bufferevent *bev = &bev_ssl->bev.bev;
485 	if (!(bev->enabled & EV_READ))
487 	if (bev->enabled & EV_WRITE)
541 	bufferevent_run_eventcb_(&bev_ssl->bev.bev, event, 0);
562 		bufferevent_decrement_write_buckets_(&bev_ssl->bev, w);
564 		bufferevent_decrement_read_buckets_(&bev_ssl->bev, r);
578 	struct bufferevent *bev = &bev_ssl->bev.bev;
579 	struct evbuffer *input = bev->input;
584 	if (bev_ssl->bev.read_suspended)
587 	atmost = bufferevent_get_read_max_(&bev_ssl->bev);
596 		if (bev_ssl->bev.read_suspended)
636 			BEV_RESET_GENERIC_READ_TIMEOUT(bev);
648 	struct bufferevent *bev = &bev_ssl->bev.bev;
649 	struct evbuffer *output = bev->output;
656 		atmost = bufferevent_get_write_max_(&bev_ssl->bev);
665 		if (bev_ssl->bev.write_suspended)
715 			BEV_RESET_GENERIC_WRITE_TIMEOUT(bev);
717 		bufferevent_trigger_nolock_(bev, EV_WRITE, 0);
729 bytes_to_read(struct bufferevent_openssl *bev)
731 	struct evbuffer *input = bev->bev.bev.input;
732 	struct event_watermark *wm = &bev->bev.bev.wm_read;
738 	if (bev->write_blocked_on_read) {
742 	if (! (bev->bev.bev.enabled & EV_READ)) {
746 	if (bev->bev.read_suspended) {
761 	limit = bufferevent_get_read_max_(&bev->bev);
798 		if (bev_ssl->bev.read_suspended)
830 		struct bufferevent *bev = &bev_ssl->bev.bev;
832 		bufferevent_trigger_nolock_(bev, EV_READ, 0);
837 		if (bev_ssl->bev.read_suspended ||
838 		    !(bev_ssl->bev.bev.enabled & EV_READ)) {
839 			event_del(&bev_ssl->bev.bev.ev_read);
848 	struct evbuffer *output = bev_ssl->bev.bev.output;
855 			struct bufferevent *bev = &bev_ssl->bev.bev;
857 			bufferevent_trigger_nolock_(bev, EV_READ, 0);
868 	while ((bev_ssl->bev.bev.enabled & EV_WRITE) &&
869 	    (! bev_ssl->bev.write_suspended) &&
884 			event_del(&bev_ssl->bev.bev.ev_write);
885 		} else if (bev_ssl->bev.write_suspended ||
886 		    !(bev_ssl->bev.bev.enabled & EV_WRITE)) {
888 			event_del(&bev_ssl->bev.bev.ev_write);
929 		bufferevent_run_eventcb_(&bev_ssl->bev.bev, event, 0);
936 	bufferevent_incref_and_lock_(&bev_ssl->bev.bev);
938 		bufferevent_run_eventcb_(&bev_ssl->bev.bev,
943 	bufferevent_decref_and_unlock_(&bev_ssl->bev.bev);
950 	bufferevent_incref_and_lock_(&bev_ssl->bev.bev);
952 		bufferevent_run_eventcb_(&bev_ssl->bev.bev,
957 	bufferevent_decref_and_unlock_(&bev_ssl->bev.bev);
969 		struct bufferevent *bev = &bev_ssl->bev.bev;
972 			fd = event_get_fd(&bev->ev_read);
974 			rpending = event_pending(&bev->ev_read, EV_READ, NULL);
975 			wpending = event_pending(&bev->ev_write, EV_WRITE, NULL);
976 			event_del(&bev->ev_read);
977 			event_del(&bev->ev_write);
979 		event_assign(&bev->ev_read, bev->ev_base, fd,
982 		event_assign(&bev->ev_write, bev->ev_base, fd,
986 			r1 = bufferevent_add_event_(&bev->ev_read, &bev->timeout_read);
988 			r2 = bufferevent_add_event_(&bev->ev_write, &bev->timeout_write);
1018 		bufferevent_enable(&bev_ssl->bev.bev, bev_ssl->bev.bev.enabled);
1019 		bufferevent_run_eventcb_(&bev_ssl->bev.bev,
1057 	bufferevent_incref_and_lock_(&bev_ssl->bev.bev);
1059 		bufferevent_run_eventcb_(&bev_ssl->bev.bev, BEV_EVENT_TIMEOUT, 0);
1062 	bufferevent_decref_and_unlock_(&bev_ssl->bev.bev);
1075 		struct bufferevent *bev = &bev_ssl->bev.bev;
1078 			fd = event_get_fd(&bev->ev_read);
1080 			event_del(&bev->ev_read);
1081 			event_del(&bev->ev_write);
1083 		event_assign(&bev->ev_read, bev->ev_base, fd,
1086 		event_assign(&bev->ev_write, bev->ev_base, fd,
1090 			r1 = bufferevent_add_event_(&bev->ev_read, &bev->timeout_read);
1091 			r2 = bufferevent_add_event_(&bev->ev_write, &bev->timeout_write);
1099 bufferevent_ssl_renegotiate(struct bufferevent *bev)
1101 	struct bufferevent_openssl *bev_ssl = upcast(bev);
1124 			r = bufferevent_add_event_(&bev_ssl->bev.bev.ev_write,
1125 			    &bev_ssl->bev.bev.timeout_write);
1134 be_openssl_enable(struct bufferevent *bev, short events)
1136 	struct bufferevent_openssl *bev_ssl = upcast(bev);
1149 			BEV_RESET_GENERIC_READ_TIMEOUT(bev);
1151 			BEV_RESET_GENERIC_WRITE_TIMEOUT(bev);
1162 be_openssl_disable(struct bufferevent *bev, short events)
1164 	struct bufferevent_openssl *bev_ssl = upcast(bev);
1175 			BEV_DEL_GENERIC_READ_TIMEOUT(bev);
1177 			BEV_DEL_GENERIC_WRITE_TIMEOUT(bev);
1183 be_openssl_unlink(struct bufferevent *bev)
1185 	struct bufferevent_openssl *bev_ssl = upcast(bev);
1187 	if (bev_ssl->bev.options & BEV_OPT_CLOSE_ON_FREE) {
1211 be_openssl_destruct(struct bufferevent *bev)
1213 	struct bufferevent_openssl *bev_ssl = upcast(bev);
1215 	if (bev_ssl->bev.options & BEV_OPT_CLOSE_ON_FREE) {
1229 be_openssl_adj_timeouts(struct bufferevent *bev)
1231 	struct bufferevent_openssl *bev_ssl = upcast(bev);
1234 		return bufferevent_generic_adj_timeouts_(bev);
1237 		if (event_pending(&bev->ev_read, EV_READ, NULL)) {
1238 			if (evutil_timerisset(&bev->timeout_read)) {
1239 				r1 = bufferevent_add_event_(&bev->ev_read, &bev->timeout_read);
1241 				event_remove_timer(&bev->ev_read);
1244 		if (event_pending(&bev->ev_write, EV_WRITE, NULL)) {
1245 			if (evutil_timerisset(&bev->timeout_write)) {
1246 				r2 = bufferevent_add_event_(&bev->ev_write, &bev->timeout_write);
1248 				event_remove_timer(&bev->ev_write);
1265 be_openssl_ctrl(struct bufferevent *bev,
1268 	struct bufferevent_openssl *bev_ssl = upcast(bev);
1291 		data->fd = event_get_fd(&bev->ev_read);
1331 	bev_p = &bev_ssl->bev;
1344 	bev_ssl->outbuf_cb = evbuffer_add_cb(bev_p->bev.output,
1348 		bufferevent_enable_locking_(&bev_ssl->bev.bev, NULL);
1351 		bufferevent_init_generic_timeout_cbs_(&bev_ssl->bev.bev);
1386 		bev_ssl->bev.bev.enabled = EV_READ|EV_WRITE;
1389 				if (event_add(&bev_ssl->bev.bev.ev_read, NULL) < 0)
1391 			if (event_add(&bev_ssl->bev.bev.ev_write, NULL) < 0)
1396 	return &bev_ssl->bev.bev;
1399 		bufferevent_free(&bev_ssl->bev.bev);
1468 bufferevent_openssl_get_allow_dirty_shutdown(struct bufferevent *bev)
1472 	BEV_LOCK(bev);
1473 	bev_ssl = upcast(bev);
1476 	BEV_UNLOCK(bev);
1481 bufferevent_openssl_set_allow_dirty_shutdown(struct bufferevent *bev,
1485 	BEV_LOCK(bev);
1486 	bev_ssl = upcast(bev);
1489 	BEV_UNLOCK(bev);
1493 bufferevent_get_openssl_error(struct bufferevent *bev)
1497 	BEV_LOCK(bev);
1498 	bev_ssl = upcast(bev);
1502 	BEV_UNLOCK(bev);