sntp/libevent/listener.c

88 	struct evconnlistener base;
94 	struct evconnlistener base;
109 evconnlistener_new_async(struct event_base *base,
156 evconnlistener_new(struct event_base *base,
163 	if (base && event_base_get_iocp_(base)) {
167 			return evconnlistener_new_async(base, cb, ptr, flags,
184 	lev->base.ops = &evconnlistener_event_ops;
185 	lev->base.cb = cb;
186 	lev->base.user_data = ptr;
187 	lev->base.flags = flags;
188 	lev->base.refcnt = 1;
190 	lev->base.accept4_flags = 0;
192 		lev->base.accept4_flags |= EVUTIL_SOCK_NONBLOCK;
194 		lev->base.accept4_flags |= EVUTIL_SOCK_CLOEXEC;
197 		EVTHREAD_ALLOC_LOCK(lev->base.lock, EVTHREAD_LOCKTYPE_RECURSIVE);
200 	event_assign(&lev->listener, base, fd, EV_READ|EV_PERSIST,
204 	    evconnlistener_enable(&lev->base);
206 	return &lev->base;
210 evconnlistener_new_bind(struct event_base *base, evconnlistener_cb cb,
253 	listener = evconnlistener_new(base, cb, ptr, flags, backlog, fd);
278 	    EVUTIL_UPCAST(lev, struct evconnlistener_event, base);
315 	    EVUTIL_UPCAST(lev, struct evconnlistener_event, base);
323 	    EVUTIL_UPCAST(lev, struct evconnlistener_event, base);
341 	    EVUTIL_UPCAST(lev, struct evconnlistener_event, base);
348 	struct event_base *base;
350 	base = lev->ops->getbase(lev);
352 	return base;
359 	    EVUTIL_UPCAST(lev, struct evconnlistener_event, base);
541 	if (!as->lev->base.enabled)
554 	if (!(as->lev->base.flags & LEV_OPT_LEAVE_SOCKETS_BLOCKING))
603 	struct evconnlistener *lev = &as->lev->base;
668 	LOCK(&as->lev->base);
677 		struct evconnlistener *lev = &as->lev->base;
702 	UNLOCK(&as->lev->base);
710 	    EVUTIL_UPCAST(lev, struct evconnlistener_iocp, base);
732 	    EVUTIL_UPCAST(lev, struct evconnlistener_iocp, base);
766 	    EVUTIL_UPCAST(lev, struct evconnlistener_iocp, base);
779 	    EVUTIL_UPCAST(lev, struct evconnlistener_iocp, base);
786 	    EVUTIL_UPCAST(lev, struct evconnlistener_iocp, base);
803 evconnlistener_new_async(struct event_base *base,
814 	if (!base || !event_base_get_iocp_(base))
834 	lev->base.ops = &evconnlistener_iocp_ops;
835 	lev->base.cb = cb;
836 	lev->base.user_data = ptr;
837 	lev->base.flags = flags;
838 	lev->base.refcnt = 1;
839 	lev->base.enabled = 1;
841 	lev->port = event_base_get_iocp_(base);
843 	lev->event_base = base;
849 	EVTHREAD_ALLOC_LOCK(lev->base.lock, EVTHREAD_LOCKTYPE_RECURSIVE);
870 		++lev->base.refcnt;
875 	return &lev->base;
881 	EVTHREAD_FREE_LOCK(lev->base.lock, EVTHREAD_LOCKTYPE_RECURSIVE);