lev               114 opal/mca/event/libevent2022/libevent/include/event2/listener.h void evconnlistener_free(struct evconnlistener *lev);
lev               118 opal/mca/event/libevent2022/libevent/include/event2/listener.h int evconnlistener_enable(struct evconnlistener *lev);
lev               122 opal/mca/event/libevent2022/libevent/include/event2/listener.h int evconnlistener_disable(struct evconnlistener *lev);
lev               125 opal/mca/event/libevent2022/libevent/include/event2/listener.h struct event_base *evconnlistener_get_base(struct evconnlistener *lev);
lev               128 opal/mca/event/libevent2022/libevent/include/event2/listener.h evutil_socket_t evconnlistener_get_fd(struct evconnlistener *lev);
lev               132 opal/mca/event/libevent2022/libevent/include/event2/listener.h void evconnlistener_set_cb(struct evconnlistener *lev,
lev               136 opal/mca/event/libevent2022/libevent/include/event2/listener.h void evconnlistener_set_error_cb(struct evconnlistener *lev,
lev               158 opal/mca/event/libevent2022/libevent/listener.c 	struct evconnlistener_event *lev;
lev               178 opal/mca/event/libevent2022/libevent/listener.c 	lev = mm_calloc(1, sizeof(struct evconnlistener_event));
lev               179 opal/mca/event/libevent2022/libevent/listener.c 	if (!lev)
lev               182 opal/mca/event/libevent2022/libevent/listener.c 	lev->base.ops = &evconnlistener_event_ops;
lev               183 opal/mca/event/libevent2022/libevent/listener.c 	lev->base.cb = cb;
lev               184 opal/mca/event/libevent2022/libevent/listener.c 	lev->base.user_data = ptr;
lev               185 opal/mca/event/libevent2022/libevent/listener.c 	lev->base.flags = flags;
lev               186 opal/mca/event/libevent2022/libevent/listener.c 	lev->base.refcnt = 1;
lev               189 opal/mca/event/libevent2022/libevent/listener.c 		EVTHREAD_ALLOC_LOCK(lev->base.lock, EVTHREAD_LOCKTYPE_RECURSIVE);
lev               192 opal/mca/event/libevent2022/libevent/listener.c 	event_assign(&lev->listener, base, fd, EV_READ|EV_PERSIST,
lev               193 opal/mca/event/libevent2022/libevent/listener.c 	    listener_read_cb, lev);
lev               195 opal/mca/event/libevent2022/libevent/listener.c 	evconnlistener_enable(&lev->base);
lev               197 opal/mca/event/libevent2022/libevent/listener.c 	return &lev->base;
lev               257 opal/mca/event/libevent2022/libevent/listener.c evconnlistener_free(struct evconnlistener *lev)
lev               259 opal/mca/event/libevent2022/libevent/listener.c 	LOCK(lev);
lev               260 opal/mca/event/libevent2022/libevent/listener.c 	lev->cb = NULL;
lev               261 opal/mca/event/libevent2022/libevent/listener.c 	lev->errorcb = NULL;
lev               262 opal/mca/event/libevent2022/libevent/listener.c 	if (lev->ops->shutdown)
lev               263 opal/mca/event/libevent2022/libevent/listener.c 		lev->ops->shutdown(lev);
lev               264 opal/mca/event/libevent2022/libevent/listener.c 	listener_decref_and_unlock(lev);
lev               268 opal/mca/event/libevent2022/libevent/listener.c event_listener_destroy(struct evconnlistener *lev)
lev               271 opal/mca/event/libevent2022/libevent/listener.c 	    EVUTIL_UPCAST(lev, struct evconnlistener_event, base);
lev               274 opal/mca/event/libevent2022/libevent/listener.c 	if (lev->flags & LEV_OPT_CLOSE_ON_FREE)
lev               280 opal/mca/event/libevent2022/libevent/listener.c evconnlistener_enable(struct evconnlistener *lev)
lev               283 opal/mca/event/libevent2022/libevent/listener.c 	LOCK(lev);
lev               284 opal/mca/event/libevent2022/libevent/listener.c 	lev->enabled = 1;
lev               285 opal/mca/event/libevent2022/libevent/listener.c 	if (lev->cb)
lev               286 opal/mca/event/libevent2022/libevent/listener.c 		r = lev->ops->enable(lev);
lev               289 opal/mca/event/libevent2022/libevent/listener.c 	UNLOCK(lev);
lev               294 opal/mca/event/libevent2022/libevent/listener.c evconnlistener_disable(struct evconnlistener *lev)
lev               297 opal/mca/event/libevent2022/libevent/listener.c 	LOCK(lev);
lev               298 opal/mca/event/libevent2022/libevent/listener.c 	lev->enabled = 0;
lev               299 opal/mca/event/libevent2022/libevent/listener.c 	r = lev->ops->disable(lev);
lev               300 opal/mca/event/libevent2022/libevent/listener.c 	UNLOCK(lev);
lev               305 opal/mca/event/libevent2022/libevent/listener.c event_listener_enable(struct evconnlistener *lev)
lev               308 opal/mca/event/libevent2022/libevent/listener.c 	    EVUTIL_UPCAST(lev, struct evconnlistener_event, base);
lev               313 opal/mca/event/libevent2022/libevent/listener.c event_listener_disable(struct evconnlistener *lev)
lev               316 opal/mca/event/libevent2022/libevent/listener.c 	    EVUTIL_UPCAST(lev, struct evconnlistener_event, base);
lev               321 opal/mca/event/libevent2022/libevent/listener.c evconnlistener_get_fd(struct evconnlistener *lev)
lev               324 opal/mca/event/libevent2022/libevent/listener.c 	LOCK(lev);
lev               325 opal/mca/event/libevent2022/libevent/listener.c 	fd = lev->ops->getfd(lev);
lev               326 opal/mca/event/libevent2022/libevent/listener.c 	UNLOCK(lev);
lev               331 opal/mca/event/libevent2022/libevent/listener.c event_listener_getfd(struct evconnlistener *lev)
lev               334 opal/mca/event/libevent2022/libevent/listener.c 	    EVUTIL_UPCAST(lev, struct evconnlistener_event, base);
lev               339 opal/mca/event/libevent2022/libevent/listener.c evconnlistener_get_base(struct evconnlistener *lev)
lev               342 opal/mca/event/libevent2022/libevent/listener.c 	LOCK(lev);
lev               343 opal/mca/event/libevent2022/libevent/listener.c 	base = lev->ops->getbase(lev);
lev               344 opal/mca/event/libevent2022/libevent/listener.c 	UNLOCK(lev);
lev               349 opal/mca/event/libevent2022/libevent/listener.c event_listener_getbase(struct evconnlistener *lev)
lev               352 opal/mca/event/libevent2022/libevent/listener.c 	    EVUTIL_UPCAST(lev, struct evconnlistener_event, base);
lev               357 opal/mca/event/libevent2022/libevent/listener.c evconnlistener_set_cb(struct evconnlistener *lev,
lev               361 opal/mca/event/libevent2022/libevent/listener.c 	LOCK(lev);
lev               362 opal/mca/event/libevent2022/libevent/listener.c 	if (lev->enabled && !lev->cb)
lev               364 opal/mca/event/libevent2022/libevent/listener.c 	lev->cb = cb;
lev               365 opal/mca/event/libevent2022/libevent/listener.c 	lev->user_data = arg;
lev               367 opal/mca/event/libevent2022/libevent/listener.c 		evconnlistener_enable(lev);
lev               368 opal/mca/event/libevent2022/libevent/listener.c 	UNLOCK(lev);
lev               372 opal/mca/event/libevent2022/libevent/listener.c evconnlistener_set_error_cb(struct evconnlistener *lev,
lev               375 opal/mca/event/libevent2022/libevent/listener.c 	LOCK(lev);
lev               376 opal/mca/event/libevent2022/libevent/listener.c 	lev->errorcb = errorcb;
lev               377 opal/mca/event/libevent2022/libevent/listener.c 	UNLOCK(lev);
lev               383 opal/mca/event/libevent2022/libevent/listener.c 	struct evconnlistener *lev = p;
lev               388 opal/mca/event/libevent2022/libevent/listener.c 	LOCK(lev);
lev               406 opal/mca/event/libevent2022/libevent/listener.c 		if (!(lev->flags & LEV_OPT_LEAVE_SOCKETS_BLOCKING))
lev               409 opal/mca/event/libevent2022/libevent/listener.c 		if (lev->cb == NULL) {
lev               411 opal/mca/event/libevent2022/libevent/listener.c 			UNLOCK(lev);
lev               414 opal/mca/event/libevent2022/libevent/listener.c 		++lev->refcnt;
lev               415 opal/mca/event/libevent2022/libevent/listener.c 		cb = lev->cb;
lev               416 opal/mca/event/libevent2022/libevent/listener.c 		user_data = lev->user_data;
lev               417 opal/mca/event/libevent2022/libevent/listener.c 		UNLOCK(lev);
lev               418 opal/mca/event/libevent2022/libevent/listener.c 		cb(lev, new_fd, (struct sockaddr*)&ss, (int)socklen,
lev               420 opal/mca/event/libevent2022/libevent/listener.c 		LOCK(lev);
lev               421 opal/mca/event/libevent2022/libevent/listener.c 		if (lev->refcnt == 1) {
lev               422 opal/mca/event/libevent2022/libevent/listener.c 			int freed = listener_decref_and_unlock(lev);
lev               426 opal/mca/event/libevent2022/libevent/listener.c 		--lev->refcnt;
lev               430 opal/mca/event/libevent2022/libevent/listener.c 		UNLOCK(lev);
lev               433 opal/mca/event/libevent2022/libevent/listener.c 	if (lev->errorcb != NULL) {
lev               434 opal/mca/event/libevent2022/libevent/listener.c 		++lev->refcnt;
lev               435 opal/mca/event/libevent2022/libevent/listener.c 		errorcb = lev->errorcb;
lev               436 opal/mca/event/libevent2022/libevent/listener.c 		user_data = lev->user_data;
lev               437 opal/mca/event/libevent2022/libevent/listener.c 		UNLOCK(lev);
lev               438 opal/mca/event/libevent2022/libevent/listener.c 		errorcb(lev, user_data);
lev               439 opal/mca/event/libevent2022/libevent/listener.c 		LOCK(lev);
lev               440 opal/mca/event/libevent2022/libevent/listener.c 		listener_decref_and_unlock(lev);
lev               453 opal/mca/event/libevent2022/libevent/listener.c 	struct evconnlistener_iocp *lev;
lev               465 opal/mca/event/libevent2022/libevent/listener.c iocp_listener_event_add(struct evconnlistener_iocp *lev)
lev               467 opal/mca/event/libevent2022/libevent/listener.c 	if (lev->event_added)
lev               470 opal/mca/event/libevent2022/libevent/listener.c 	lev->event_added = 1;
lev               471 opal/mca/event/libevent2022/libevent/listener.c 	event_base_add_virtual(lev->event_base);
lev               475 opal/mca/event/libevent2022/libevent/listener.c iocp_listener_event_del(struct evconnlistener_iocp *lev)
lev               477 opal/mca/event/libevent2022/libevent/listener.c 	if (!lev->event_added)
lev               480 opal/mca/event/libevent2022/libevent/listener.c 	lev->event_added = 0;
lev               481 opal/mca/event/libevent2022/libevent/listener.c 	event_base_del_virtual(lev->event_base);
lev               485 opal/mca/event/libevent2022/libevent/listener.c new_accepting_socket(struct evconnlistener_iocp *lev, int family)
lev               505 opal/mca/event/libevent2022/libevent/listener.c 	res->lev = lev;
lev               538 opal/mca/event/libevent2022/libevent/listener.c 	if (!as->lev->base.enabled)
lev               549 opal/mca/event/libevent2022/libevent/listener.c 	    (char *)&as->lev->fd, sizeof(&as->lev->fd));
lev               551 opal/mca/event/libevent2022/libevent/listener.c 	if (!(as->lev->base.flags & LEV_OPT_LEAVE_SOCKETS_BLOCKING))
lev               554 opal/mca/event/libevent2022/libevent/listener.c 	if (event_iocp_port_associate(as->lev->port, s, 1) < 0) {
lev               561 opal/mca/event/libevent2022/libevent/listener.c 	if (ext->AcceptEx(as->lev->fd, s, as->addrbuf, 0,
lev               578 opal/mca/event/libevent2022/libevent/listener.c 		event_base_get_deferred_cb_queue(as->lev->event_base),
lev               600 opal/mca/event/libevent2022/libevent/listener.c 	struct evconnlistener *lev = &as->lev->base;
lev               609 opal/mca/event/libevent2022/libevent/listener.c 	LOCK(lev);
lev               613 opal/mca/event/libevent2022/libevent/listener.c 		listener_decref_and_unlock(lev);
lev               617 opal/mca/event/libevent2022/libevent/listener.c 	++lev->refcnt;
lev               622 opal/mca/event/libevent2022/libevent/listener.c 		errorcb = lev->errorcb;
lev               629 opal/mca/event/libevent2022/libevent/listener.c 		cb = lev->cb;
lev               636 opal/mca/event/libevent2022/libevent/listener.c 		    (char *)&as->lev->fd, sizeof(&as->lev->fd));
lev               638 opal/mca/event/libevent2022/libevent/listener.c 	data = lev->user_data;
lev               641 opal/mca/event/libevent2022/libevent/listener.c 	UNLOCK(lev);
lev               645 opal/mca/event/libevent2022/libevent/listener.c 		errorcb(lev, data);
lev               647 opal/mca/event/libevent2022/libevent/listener.c 		cb(lev, sock, sa_remote, socklen_remote, data);
lev               650 opal/mca/event/libevent2022/libevent/listener.c 	LOCK(lev);
lev               651 opal/mca/event/libevent2022/libevent/listener.c 	if (listener_decref_and_unlock(lev))
lev               665 opal/mca/event/libevent2022/libevent/listener.c 	LOCK(&as->lev->base);
lev               670 opal/mca/event/libevent2022/libevent/listener.c 			event_base_get_deferred_cb_queue(as->lev->event_base),
lev               674 opal/mca/event/libevent2022/libevent/listener.c 		struct evconnlistener *lev = &as->lev->base;
lev               676 opal/mca/event/libevent2022/libevent/listener.c 		listener_decref_and_unlock(lev);
lev               695 opal/mca/event/libevent2022/libevent/listener.c 			event_base_get_deferred_cb_queue(as->lev->event_base),
lev               699 opal/mca/event/libevent2022/libevent/listener.c 	UNLOCK(&as->lev->base);
lev               703 opal/mca/event/libevent2022/libevent/listener.c iocp_listener_enable(struct evconnlistener *lev)
lev               707 opal/mca/event/libevent2022/libevent/listener.c 	    EVUTIL_UPCAST(lev, struct evconnlistener_iocp, base);
lev               709 opal/mca/event/libevent2022/libevent/listener.c 	LOCK(lev);
lev               720 opal/mca/event/libevent2022/libevent/listener.c 	UNLOCK(lev);
lev               725 opal/mca/event/libevent2022/libevent/listener.c iocp_listener_disable_impl(struct evconnlistener *lev, int shutdown)
lev               729 opal/mca/event/libevent2022/libevent/listener.c 	    EVUTIL_UPCAST(lev, struct evconnlistener_iocp, base);
lev               731 opal/mca/event/libevent2022/libevent/listener.c 	LOCK(lev);
lev               746 opal/mca/event/libevent2022/libevent/listener.c 	if (shutdown && lev->flags & LEV_OPT_CLOSE_ON_FREE)
lev               749 opal/mca/event/libevent2022/libevent/listener.c 	UNLOCK(lev);
lev               754 opal/mca/event/libevent2022/libevent/listener.c iocp_listener_disable(struct evconnlistener *lev)
lev               756 opal/mca/event/libevent2022/libevent/listener.c 	return iocp_listener_disable_impl(lev,0);
lev               760 opal/mca/event/libevent2022/libevent/listener.c iocp_listener_destroy(struct evconnlistener *lev)
lev               763 opal/mca/event/libevent2022/libevent/listener.c 	    EVUTIL_UPCAST(lev, struct evconnlistener_iocp, base);
lev               767 opal/mca/event/libevent2022/libevent/listener.c 		iocp_listener_disable_impl(lev,1);
lev               773 opal/mca/event/libevent2022/libevent/listener.c iocp_listener_getfd(struct evconnlistener *lev)
lev               776 opal/mca/event/libevent2022/libevent/listener.c 	    EVUTIL_UPCAST(lev, struct evconnlistener_iocp, base);
lev               780 opal/mca/event/libevent2022/libevent/listener.c iocp_listener_getbase(struct evconnlistener *lev)
lev               783 opal/mca/event/libevent2022/libevent/listener.c 	    EVUTIL_UPCAST(lev, struct evconnlistener_iocp, base);
lev               806 opal/mca/event/libevent2022/libevent/listener.c 	struct evconnlistener_iocp *lev;
lev               826 opal/mca/event/libevent2022/libevent/listener.c 	lev = mm_calloc(1, sizeof(struct evconnlistener_iocp));
lev               827 opal/mca/event/libevent2022/libevent/listener.c 	if (!lev) {
lev               831 opal/mca/event/libevent2022/libevent/listener.c 	lev->base.ops = &evconnlistener_iocp_ops;
lev               832 opal/mca/event/libevent2022/libevent/listener.c 	lev->base.cb = cb;
lev               833 opal/mca/event/libevent2022/libevent/listener.c 	lev->base.user_data = ptr;
lev               834 opal/mca/event/libevent2022/libevent/listener.c 	lev->base.flags = flags;
lev               835 opal/mca/event/libevent2022/libevent/listener.c 	lev->base.refcnt = 1;
lev               836 opal/mca/event/libevent2022/libevent/listener.c 	lev->base.enabled = 1;
lev               838 opal/mca/event/libevent2022/libevent/listener.c 	lev->port = event_base_get_iocp(base);
lev               839 opal/mca/event/libevent2022/libevent/listener.c 	lev->fd = fd;
lev               840 opal/mca/event/libevent2022/libevent/listener.c 	lev->event_base = base;
lev               843 opal/mca/event/libevent2022/libevent/listener.c 	if (event_iocp_port_associate(lev->port, fd, 1) < 0)
lev               846 opal/mca/event/libevent2022/libevent/listener.c 	EVTHREAD_ALLOC_LOCK(lev->base.lock, EVTHREAD_LOCKTYPE_RECURSIVE);
lev               848 opal/mca/event/libevent2022/libevent/listener.c 	lev->n_accepting = N_SOCKETS_PER_LISTENER;
lev               849 opal/mca/event/libevent2022/libevent/listener.c 	lev->accepting = mm_calloc(lev->n_accepting,
lev               851 opal/mca/event/libevent2022/libevent/listener.c 	if (!lev->accepting) {
lev               855 opal/mca/event/libevent2022/libevent/listener.c 	for (i = 0; i < lev->n_accepting; ++i) {
lev               856 opal/mca/event/libevent2022/libevent/listener.c 		lev->accepting[i] = new_accepting_socket(lev, ss.ss_family);
lev               857 opal/mca/event/libevent2022/libevent/listener.c 		if (!lev->accepting[i]) {
lev               861 opal/mca/event/libevent2022/libevent/listener.c 		if (cb && start_accepting(lev->accepting[i]) < 0) {
lev               863 opal/mca/event/libevent2022/libevent/listener.c 			EnterCriticalSection(&lev->accepting[i]->lock);
lev               864 opal/mca/event/libevent2022/libevent/listener.c 			free_and_unlock_accepting_socket(lev->accepting[i]);
lev               867 opal/mca/event/libevent2022/libevent/listener.c 		++lev->base.refcnt;
lev               870 opal/mca/event/libevent2022/libevent/listener.c 	iocp_listener_event_add(lev);
lev               872 opal/mca/event/libevent2022/libevent/listener.c 	return &lev->base;
lev               875 opal/mca/event/libevent2022/libevent/listener.c 	mm_free(lev->accepting);
lev               878 opal/mca/event/libevent2022/libevent/listener.c 	EVTHREAD_FREE_LOCK(lev->base.lock, EVTHREAD_LOCKTYPE_RECURSIVE);
lev               880 opal/mca/event/libevent2022/libevent/listener.c 	mm_free(lev);
lev               477 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c 	struct evconnlistener *lev=NULL;
lev               511 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c 	lev = evconnlistener_new_bind(data->base, listen_cb, data->base,
lev               514 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c 	tt_assert(lev);
lev               518 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c 	if (regress_get_listener_addr(lev, sa, &slen) < 0) {
lev               522 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c 	tt_assert(!evconnlistener_enable(lev));
lev               541 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c 	if (lev)
lev               542 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c 		evconnlistener_free(lev);
lev               213 opal/mca/event/libevent2022/libevent/test/regress_testutils.c regress_get_listener_addr(struct evconnlistener *lev,
lev               216 opal/mca/event/libevent2022/libevent/test/regress_testutils.c 	evutil_socket_t s = evconnlistener_get_fd(lev);
lev                62 opal/mca/event/libevent2022/libevent/test/regress_testutils.h int regress_get_listener_addr(struct evconnlistener *lev,