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,