Cross Reference: /src/external/bsd/ntp/dist/sntp/libevent/bufferevent

Lines Matching defs:bev
91 	evutil_offsetof(struct bufferevent_private, bev),
102 bufferevent_socket_get_conn_address_(struct bufferevent *bev)
104 	struct bufferevent_private *bev_p = BEV_UPCAST(bev);
109 bufferevent_socket_set_conn_address_fd_(struct bufferevent *bev,
112 	struct bufferevent_private *bev_p = BEV_UPCAST(bev);
122 bufferevent_socket_set_conn_address_(struct bufferevent *bev,
125 	struct bufferevent_private *bev_p = BEV_UPCAST(bev);
365 	bufev = &bufev_p->bev;
382 bufferevent_socket_connect(struct bufferevent *bev,
385 	struct bufferevent_private *bufev_p = BEV_UPCAST(bev);
392 	bufferevent_incref_and_lock_(bev);
394 	fd = bufferevent_getfd(bev);
406 		if (bufferevent_async_can_connect_(bev)) {
407 			bufferevent_setfd(bev, fd);
408 			r = bufferevent_async_connect_(bev, fd, sa, socklen);
424 	if (BEV_IS_ASYNC(bev)) {
425 		event_assign(&bev->ev_write, bev->ev_base, fd,
426 		    EV_WRITE|EV_PERSIST|EV_FINALIZE, bufferevent_writecb, bev);
429 	bufferevent_setfd(bev, fd);
431 		if (! be_socket_enable(bev, EV_WRITE)) {
440 		bufferevent_trigger_nolock_(bev, EV_WRITE, BEV_OPT_DEFER_CALLBACKS);
444 		bufferevent_run_eventcb_(bev, BEV_EVENT_ERROR, BEV_OPT_DEFER_CALLBACKS);
445 		bufferevent_disable(bev, EV_WRITE|EV_READ);
454 	bufferevent_decref_and_unlock_(bev);
462 	struct bufferevent *bev = arg;
463 	struct bufferevent_private *bev_p = BEV_UPCAST(bev);
465 	BEV_LOCK(bev);
467 	bufferevent_unsuspend_write_(bev, BEV_SUSPEND_LOOKUP);
468 	bufferevent_unsuspend_read_(bev, BEV_SUSPEND_LOOKUP);
474 		bufferevent_decref_and_unlock_(bev);
479 		bufferevent_run_eventcb_(bev, BEV_EVENT_ERROR, 0);
480 		bufferevent_decref_and_unlock_(bev);
487 	bufferevent_socket_set_conn_address_(bev, ai->ai_addr, (int)ai->ai_addrlen);
488 	r = bufferevent_socket_connect(bev, ai->ai_addr, (int)ai->ai_addrlen);
490 		bufferevent_run_eventcb_(bev, BEV_EVENT_ERROR, 0);
491 	bufferevent_decref_and_unlock_(bev);
496 bufferevent_socket_connect_hostname(struct bufferevent *bev,
501 	struct bufferevent_private *bev_p = BEV_UPCAST(bev);
515 	BEV_LOCK(bev);
518 	bufferevent_suspend_write_(bev, BEV_SUSPEND_LOOKUP);
519 	bufferevent_suspend_read_(bev, BEV_SUSPEND_LOOKUP);
521 	bufferevent_incref_(bev);
523 	    portbuf, &hint, bufferevent_connect_getaddrinfo_cb, bev);
524 	BEV_UNLOCK(bev);
530 bufferevent_socket_get_dns_error(struct bufferevent *bev)
533 	struct bufferevent_private *bev_p = BEV_UPCAST(bev);
535 	BEV_LOCK(bev);
537 	BEV_UNLOCK(bev);
613 be_socket_flush(struct bufferevent *bev, short iotype,
694 be_socket_ctrl(struct bufferevent *bev, enum bufferevent_ctrl_op op,
699 		be_socket_setfd(bev, data->fd);
702 		data->fd = event_get_fd(&bev->ev_read);
OpenGrok
