pmix_ptl_globals 480 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_list_append(&pmix_ptl_globals.posted_recvs, &rcv->super); pmix_ptl_globals 215 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c pmix_list_prepend(&pmix_ptl_globals.posted_recvs, &rcv->super); pmix_ptl_globals 86 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/base.h PMIX_EXPORT extern pmix_ptl_globals_t pmix_ptl_globals; pmix_ptl_globals 59 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c pmix_ptl_globals_t pmix_ptl_globals = {{{0}}}; pmix_ptl_globals 72 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c pmix_ptl_globals.max_msg_size = max_msg_size * 1024 * 1024; pmix_ptl_globals 78 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c if (!pmix_ptl_globals.initialized) { pmix_ptl_globals 81 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c pmix_ptl_globals.initialized = false; pmix_ptl_globals 94 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c PMIX_LIST_DESTRUCT(&pmix_ptl_globals.actives); pmix_ptl_globals 95 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c PMIX_LIST_DESTRUCT(&pmix_ptl_globals.posted_recvs); pmix_ptl_globals 96 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c PMIX_LIST_DESTRUCT(&pmix_ptl_globals.unexpected_msgs); pmix_ptl_globals 97 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c PMIX_LIST_DESTRUCT(&pmix_ptl_globals.listeners); pmix_ptl_globals 107 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c pmix_ptl_globals.initialized = true; pmix_ptl_globals 108 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c PMIX_CONSTRUCT(&pmix_ptl_globals.actives, pmix_list_t); pmix_ptl_globals 109 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c PMIX_CONSTRUCT(&pmix_ptl_globals.posted_recvs, pmix_list_t); pmix_ptl_globals 110 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c PMIX_CONSTRUCT(&pmix_ptl_globals.unexpected_msgs, pmix_list_t); pmix_ptl_globals 111 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c pmix_ptl_globals.listen_thread_active = false; pmix_ptl_globals 112 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c PMIX_CONSTRUCT(&pmix_ptl_globals.listeners, pmix_list_t); pmix_ptl_globals 113 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_frame.c pmix_ptl_globals.current_tag = PMIX_PTL_TAG_DYNAMIC; pmix_ptl_globals 74 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c if (!pmix_ptl_globals.initialized) { pmix_ptl_globals 88 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c PMIX_LIST_FOREACH(active, &pmix_ptl_globals.actives, pmix_ptl_base_active_t) { pmix_ptl_globals 100 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c if (0 == pmix_list_get_size(&pmix_ptl_globals.listeners)) { pmix_ptl_globals 128 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c if (0 > pipe(pmix_ptl_globals.stop_thread)) { pmix_ptl_globals 134 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c if (pmix_fd_set_cloexec(pmix_ptl_globals.stop_thread[0]) != PMIX_SUCCESS || pmix_ptl_globals 135 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pmix_fd_set_cloexec(pmix_ptl_globals.stop_thread[1]) != PMIX_SUCCESS) { pmix_ptl_globals 137 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c close(pmix_ptl_globals.stop_thread[0]); pmix_ptl_globals 138 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c close(pmix_ptl_globals.stop_thread[1]); pmix_ptl_globals 142 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pmix_ptl_globals.listen_thread_active = true; pmix_ptl_globals 144 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pmix_ptl_globals.listen_thread_active = false; pmix_ptl_globals 159 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c if (!pmix_ptl_globals.listen_thread_active) { pmix_ptl_globals 165 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pmix_ptl_globals.listen_thread_active = false; pmix_ptl_globals 170 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c if (0 > write(pmix_ptl_globals.stop_thread[1], &i, sizeof(int))) { pmix_ptl_globals 176 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c PMIX_LIST_FOREACH(lt, &pmix_ptl_globals.listeners, pmix_listener_t) { pmix_ptl_globals 195 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c while (pmix_ptl_globals.listen_thread_active) { pmix_ptl_globals 198 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c PMIX_LIST_FOREACH(lt, &pmix_ptl_globals.listeners, pmix_listener_t) { pmix_ptl_globals 203 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c FD_SET(pmix_ptl_globals.stop_thread[0], &readfds); pmix_ptl_globals 204 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c max = (pmix_ptl_globals.stop_thread[0] > max) ? pmix_ptl_globals.stop_thread[0] : max; pmix_ptl_globals 214 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c if (!pmix_ptl_globals.listen_thread_active) { pmix_ptl_globals 216 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c close(pmix_ptl_globals.stop_thread[0]); pmix_ptl_globals 217 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c close(pmix_ptl_globals.stop_thread[1]); pmix_ptl_globals 230 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c PMIX_LIST_FOREACH(lt, &pmix_ptl_globals.listeners, pmix_listener_t) { pmix_ptl_globals 295 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pmix_ptl_globals.listen_thread_active = false; pmix_ptl_globals 72 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_select.c PMIX_LIST_FOREACH(active, &pmix_ptl_globals.actives, pmix_ptl_base_active_t) { pmix_ptl_globals 74 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_select.c pmix_list_insert_pos(&pmix_ptl_globals.actives, pmix_ptl_globals 82 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_select.c pmix_list_append(&pmix_ptl_globals.actives, &newactive->super); pmix_ptl_globals 87 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_select.c if (0 == pmix_list_get_size(&pmix_ptl_globals.actives)) { pmix_ptl_globals 95 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_select.c PMIX_LIST_FOREACH(active, &pmix_ptl_globals.actives, pmix_ptl_base_active_t) { pmix_ptl_globals 242 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c PMIX_LIST_FOREACH(rcv, &pmix_ptl_globals.posted_recvs, pmix_ptl_posted_recv_t) { pmix_ptl_globals 538 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (pmix_ptl_globals.max_msg_size < peer->recv_msg->hdr.nbytes) { pmix_ptl_globals 541 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c (unsigned long)pmix_ptl_globals.max_msg_size); pmix_ptl_globals 709 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_ptl_globals.current_tag++; pmix_ptl_globals 710 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (UINT32_MAX == pmix_ptl_globals.current_tag ) { pmix_ptl_globals 711 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_ptl_globals.current_tag = PMIX_PTL_TAG_DYNAMIC; pmix_ptl_globals 713 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c tag = pmix_ptl_globals.current_tag; pmix_ptl_globals 727 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_list_prepend(&pmix_ptl_globals.posted_recvs, &req->super); pmix_ptl_globals 775 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c PMIX_LIST_FOREACH(rcv, &pmix_ptl_globals.posted_recvs, pmix_ptl_posted_recv_t) { pmix_ptl_globals 804 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_list_remove_item(&pmix_ptl_globals.posted_recvs, &rcv->super); pmix_ptl_globals 825 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_list_append(&pmix_ptl_globals.unexpected_msgs, &msg->super); pmix_ptl_globals 38 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c if (!pmix_ptl_globals.initialized) { pmix_ptl_globals 42 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c PMIX_LIST_FOREACH(active, &pmix_ptl_globals.actives, pmix_ptl_base_active_t) { pmix_ptl_globals 70 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c pmix_list_prepend(&pmix_ptl_globals.posted_recvs, &req->super); pmix_ptl_globals 79 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c if (!pmix_ptl_globals.initialized) { pmix_ptl_globals 83 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c PMIX_LIST_FOREACH(active, &pmix_ptl_globals.actives, pmix_ptl_base_active_t) { pmix_ptl_globals 98 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c if (!pmix_ptl_globals.initialized) { pmix_ptl_globals 102 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c active = (pmix_ptl_base_active_t*)pmix_list_get_first(&pmix_ptl_globals.actives); pmix_ptl_globals 112 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c PMIX_LIST_FOREACH(active, &pmix_ptl_globals.actives, pmix_ptl_base_active_t) { pmix_ptl_globals 135 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c pmix_list_append(&pmix_ptl_globals.posted_recvs, &req->super); pmix_ptl_globals 139 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c PMIX_LIST_FOREACH_SAFE(msg, nmsg, &pmix_ptl_globals.unexpected_msgs, pmix_ptl_recv_t) { pmix_ptl_globals 154 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c pmix_list_remove_item(&pmix_ptl_globals.unexpected_msgs, &msg->super); pmix_ptl_globals 185 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c PMIX_LIST_FOREACH(rcv, &pmix_ptl_globals.posted_recvs, pmix_ptl_posted_recv_t) { pmix_ptl_globals 187 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c pmix_list_remove_item(&pmix_ptl_globals.posted_recvs, &rcv->super); pmix_ptl_globals 843 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_list_append(&pmix_ptl_globals.listeners, <->super); pmix_ptl_globals 851 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_ptl_globals.current_tag++; pmix_ptl_globals 852 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c if (UINT32_MAX == pmix_ptl_globals.current_tag ) { pmix_ptl_globals 853 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_ptl_globals.current_tag = PMIX_PTL_TAG_DYNAMIC; pmix_ptl_globals 855 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c tag = pmix_ptl_globals.current_tag; pmix_ptl_globals 868 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_list_prepend(&pmix_ptl_globals.posted_recvs, &req->super); pmix_ptl_globals 243 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pmix_list_append(&pmix_ptl_globals.listeners, <->super); pmix_ptl_globals 318 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pmix_list_remove_item(&pmix_ptl_globals.listeners, <->super); pmix_ptl_globals 399 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_list_append(&pmix_ptl_globals.posted_recvs, &req->super); pmix_ptl_globals 1246 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_LIST_FOREACH(lt, &pmix_ptl_globals.listeners, pmix_listener_t) { pmix_ptl_globals 447 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_list_append(&pmix_ptl_globals.posted_recvs, &rcv->super); pmix_ptl_globals 617 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_list_append(&pmix_ptl_globals.posted_recvs, &rcv->super);