89 	evutil_offsetof(struct bufferevent_private, bev),
100 bufferevent_socket_get_conn_address_(struct bufferevent *bev)  in bufferevent_socket_get_conn_address_()  argument
102 	struct bufferevent_private *bev_p = BEV_UPCAST(bev);  in bufferevent_socket_get_conn_address_()
107 bufferevent_socket_set_conn_address_fd_(struct bufferevent *bev,  in bufferevent_socket_set_conn_address_fd_()  argument
110 	struct bufferevent_private *bev_p = BEV_UPCAST(bev);  in bufferevent_socket_set_conn_address_fd_()
120 bufferevent_socket_set_conn_address_(struct bufferevent *bev,  in bufferevent_socket_set_conn_address_()  argument
123 	struct bufferevent_private *bev_p = BEV_UPCAST(bev);  in bufferevent_socket_set_conn_address_()
363 	bufev = &bufev_p->bev;  in bufferevent_socket_new()
380 bufferevent_socket_connect(struct bufferevent *bev,  in bufferevent_socket_connect()  argument
383 	struct bufferevent_private *bufev_p = BEV_UPCAST(bev);  in bufferevent_socket_connect()
390 	bufferevent_incref_and_lock_(bev);  in bufferevent_socket_connect()
392 	fd = bufferevent_getfd(bev);  in bufferevent_socket_connect()
404 		if (bufferevent_async_can_connect_(bev)) {  in bufferevent_socket_connect()
405 			bufferevent_setfd(bev, fd);  in bufferevent_socket_connect()
406 			r = bufferevent_async_connect_(bev, fd, sa, socklen);  in bufferevent_socket_connect()
422 	if (BEV_IS_ASYNC(bev)) {  in bufferevent_socket_connect()
423 		event_assign(&bev->ev_write, bev->ev_base, fd,  in bufferevent_socket_connect()
424 		    EV_WRITE|EV_PERSIST|EV_FINALIZE, bufferevent_writecb, bev);  in bufferevent_socket_connect()
427 	bufferevent_setfd(bev, fd);  in bufferevent_socket_connect()
429 		if (! be_socket_enable(bev, EV_WRITE)) {  in bufferevent_socket_connect()
438 		bufferevent_trigger_nolock_(bev, EV_WRITE, BEV_OPT_DEFER_CALLBACKS);  in bufferevent_socket_connect()
442 		bufferevent_run_eventcb_(bev, BEV_EVENT_ERROR, BEV_OPT_DEFER_CALLBACKS);  in bufferevent_socket_connect()
443 		bufferevent_disable(bev, EV_WRITE|EV_READ);  in bufferevent_socket_connect()
452 	bufferevent_decref_and_unlock_(bev);  in bufferevent_socket_connect()
460 	struct bufferevent *bev = arg;  in bufferevent_connect_getaddrinfo_cb()  local
461 	struct bufferevent_private *bev_p = BEV_UPCAST(bev);  in bufferevent_connect_getaddrinfo_cb()
463 	BEV_LOCK(bev);  in bufferevent_connect_getaddrinfo_cb()
465 	bufferevent_unsuspend_write_(bev, BEV_SUSPEND_LOOKUP);  in bufferevent_connect_getaddrinfo_cb()
466 	bufferevent_unsuspend_read_(bev, BEV_SUSPEND_LOOKUP);  in bufferevent_connect_getaddrinfo_cb()
472 		bufferevent_decref_and_unlock_(bev);  in bufferevent_connect_getaddrinfo_cb()
477 		bufferevent_run_eventcb_(bev, BEV_EVENT_ERROR, 0);  in bufferevent_connect_getaddrinfo_cb()
478 		bufferevent_decref_and_unlock_(bev);  in bufferevent_connect_getaddrinfo_cb()
485 	bufferevent_socket_set_conn_address_(bev, ai->ai_addr, (int)ai->ai_addrlen);  in bufferevent_connect_getaddrinfo_cb()
486 	r = bufferevent_socket_connect(bev, ai->ai_addr, (int)ai->ai_addrlen);  in bufferevent_connect_getaddrinfo_cb()
488 		bufferevent_run_eventcb_(bev, BEV_EVENT_ERROR, 0);  in bufferevent_connect_getaddrinfo_cb()
489 	bufferevent_decref_and_unlock_(bev);  in bufferevent_connect_getaddrinfo_cb()
494 bufferevent_socket_connect_hostname(struct bufferevent *bev,  in bufferevent_socket_connect_hostname()  argument
499 	struct bufferevent_private *bev_p = BEV_UPCAST(bev);  in bufferevent_socket_connect_hostname()
513 	BEV_LOCK(bev);  in bufferevent_socket_connect_hostname()
516 	bufferevent_suspend_write_(bev, BEV_SUSPEND_LOOKUP);  in bufferevent_socket_connect_hostname()
517 	bufferevent_suspend_read_(bev, BEV_SUSPEND_LOOKUP);  in bufferevent_socket_connect_hostname()
519 	bufferevent_incref_(bev);  in bufferevent_socket_connect_hostname()
521 	    portbuf, &hint, bufferevent_connect_getaddrinfo_cb, bev);  in bufferevent_socket_connect_hostname()
522 	BEV_UNLOCK(bev);  in bufferevent_socket_connect_hostname()
528 bufferevent_socket_get_dns_error(struct bufferevent *bev)  in bufferevent_socket_get_dns_error()  argument
531 	struct bufferevent_private *bev_p = BEV_UPCAST(bev);  in bufferevent_socket_get_dns_error()
533 	BEV_LOCK(bev);  in bufferevent_socket_get_dns_error()
535 	BEV_UNLOCK(bev);  in bufferevent_socket_get_dns_error()
611 be_socket_flush(struct bufferevent *bev, short iotype,  in be_socket_flush()  argument
692 be_socket_ctrl(struct bufferevent *bev, enum bufferevent_ctrl_op op,  in be_socket_ctrl()  argument
697 		be_socket_setfd(bev, data->fd);  in be_socket_ctrl()
700 		data->fd = event_get_fd(&bev->ev_read);  in be_socket_ctrl()