sntp/libevent/bufferevent_sock.c

90 	evutil_offsetof(struct bufferevent_private, bev),
110 	    EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
129 	    EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
207 	    EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
336 	bufev = &bufev_p->bev;
353 bufferevent_socket_connect(struct bufferevent *bev,
357 	    EVUTIL_UPCAST(bev, struct bufferevent_private, bev);
364 	bufferevent_incref_and_lock_(bev);
369 	fd = bufferevent_getfd(bev);
381 		if (bufferevent_async_can_connect_(bev)) {
382 			bufferevent_setfd(bev, fd);
383 			r = bufferevent_async_connect_(bev, fd, sa, socklen);
399 	if (BEV_IS_ASYNC(bev)) {
400 		event_assign(&bev->ev_write, bev->ev_base, fd,
401 		    EV_WRITE|EV_PERSIST|EV_FINALIZE, bufferevent_writecb, bev);
404 	bufferevent_setfd(bev, fd);
406 		if (! be_socket_enable(bev, EV_WRITE)) {
415 		event_active(&bev->ev_write, EV_WRITE, 1);
421 		event_active(&bev->ev_write, EV_WRITE, 1);
427 	bufferevent_run_eventcb_(bev, BEV_EVENT_ERROR, 0);
432 	bufferevent_decref_and_unlock_(bev);
440 	struct bufferevent *bev = arg;
442 	    EVUTIL_UPCAST(bev, struct bufferevent_private, bev);
444 	BEV_LOCK(bev);
446 	bufferevent_unsuspend_write_(bev, BEV_SUSPEND_LOOKUP);
447 	bufferevent_unsuspend_read_(bev, BEV_SUSPEND_LOOKUP);
451 		bufferevent_run_eventcb_(bev, BEV_EVENT_ERROR, 0);
452 		bufferevent_decref_and_unlock_(bev);
460 	r = bufferevent_socket_connect(bev, ai->ai_addr, (int)ai->ai_addrlen);
462 	bufferevent_decref_and_unlock_(bev);
467 bufferevent_socket_connect_hostname(struct bufferevent *bev,
474 	    EVUTIL_UPCAST(bev, struct bufferevent_private, bev);
481 	BEV_LOCK(bev);
483 	BEV_UNLOCK(bev);
492 	bufferevent_suspend_write_(bev, BEV_SUSPEND_LOOKUP);
493 	bufferevent_suspend_read_(bev, BEV_SUSPEND_LOOKUP);
495 	bufferevent_incref_(bev);
497 	    &hint, bufferevent_connect_getaddrinfo_cb, bev);
502 		bufferevent_unsuspend_write_(bev, BEV_SUSPEND_LOOKUP);
503 		bufferevent_unsuspend_read_(bev, BEV_SUSPEND_LOOKUP);
504 		bufferevent_decref_(bev);
510 bufferevent_socket_get_dns_error(struct bufferevent *bev)
514 	    EVUTIL_UPCAST(bev, struct bufferevent_private, bev);
516 	BEV_LOCK(bev);
518 	BEV_UNLOCK(bev);
568 	    EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
585 	    EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
619 be_socket_flush(struct bufferevent *bev, short iotype,
652 	    EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
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);