lt 82 contrib/scaling/mpi_memprobe.c opal_list_t query, response, *lt; lt 121 contrib/scaling/mpi_memprobe.c lt = (opal_list_t*)kv->data.ptr; lt 122 contrib/scaling/mpi_memprobe.c if (NULL != lt) { lt 123 contrib/scaling/mpi_memprobe.c OPAL_LIST_FOREACH(ival, lt, opal_value_t) { lt 848 opal/mca/pmix/ext2x/ext2x.c opal_list_t *lt; lt 998 opal/mca/pmix/ext2x/ext2x.c lt = OBJ_NEW(opal_list_t); lt 1000 opal/mca/pmix/ext2x/ext2x.c kv->data.ptr = (void*)lt; lt 1003 opal/mca/pmix/ext2x/ext2x.c opal_list_append(lt, &ival->super); lt 1010 opal/mca/pmix/ext2x/ext2x.c OPAL_LIST_RELEASE(lt); lt 967 opal/mca/pmix/ext3x/ext3x.c opal_list_t *lt; lt 1186 opal/mca/pmix/ext3x/ext3x.c lt = OBJ_NEW(opal_list_t); lt 1188 opal/mca/pmix/ext3x/ext3x.c kv->data.ptr = (void*)lt; lt 1191 opal/mca/pmix/ext3x/ext3x.c opal_list_append(lt, &ival->super); lt 1202 opal/mca/pmix/ext3x/ext3x.c OPAL_LIST_RELEASE(lt); lt 721 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/opa/pnet_opa.c pmix_pnet_resource_t *lt, *lst; lt 761 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/opa/pnet_opa.c PMIX_LIST_FOREACH(lt, &nd->resources, pmix_pnet_resource_t) { lt 762 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/opa/pnet_opa.c if (0 == strcmp(lt->name, "opa")) { lt 763 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/opa/pnet_opa.c lst = lt; lt 840 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/opa/pnet_opa.c PMIX_LIST_FOREACH(lt, &nd->resources, pmix_pnet_resource_t) { lt 841 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/opa/pnet_opa.c if (0 == strcmp(lt->name, "opa")) { lt 842 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/opa/pnet_opa.c PMIX_LIST_FOREACH(res, <->resources, opa_resource_t) { lt 1087 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c pmix_pnet_resource_t *lt, *lst; lt 1126 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c PMIX_LIST_FOREACH(lt, &nd->resources, pmix_pnet_resource_t) { lt 1127 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c if (0 == strcmp(lt->name, "tcp")) { lt 1128 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c lst = lt; lt 1183 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c PMIX_LIST_FOREACH(lt, &nd->resources, pmix_pnet_resource_t) { lt 1184 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c if (0 == strcmp(lt->name, "tcp")) { lt 1185 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c PMIX_LIST_FOREACH(prts, <->resources, tcp_available_ports_t) { lt 154 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pmix_listener_t *lt; lt 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) { lt 177 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c CLOSE_THE_SOCKET(lt->socket); lt 178 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c lt->socket = -1; lt 189 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pmix_listener_t *lt; lt 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) { lt 199 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c FD_SET(lt->socket, &readfds); lt 200 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c max = (lt->socket > max) ? lt->socket : max; lt 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) { lt 238 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c if (0 == FD_ISSET(lt->socket, &readfds)) { lt 251 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pending_connection->protocol = lt->protocol; lt 252 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pending_connection->ptl = lt->ptl; lt 254 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c EV_WRITE, lt->cbfunc, pending_connection); lt 255 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_listener.c pending_connection->sd = accept(lt->socket, lt 346 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_listener_t *lt; lt 557 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c lt = PMIX_NEW(pmix_listener_t); lt 558 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c lt->varname = strdup("PMIX_SERVER_URI4:PMIX_SERVER_URI3:PMIX_SERVER_URI2:PMIX_SERVER_URI21"); lt 559 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c lt->protocol = PMIX_PROTOCOL_V2; lt 560 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c lt->ptl = (struct pmix_ptl_module_t*)&pmix_ptl_tcp_module; lt 561 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c lt->cbfunc = connection_handler; lt 565 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c lt->socket = socket(mca_ptl_tcp_component.connection.ss_family, SOCK_STREAM, 0); lt 566 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (lt->socket < 0) { lt 572 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (setsockopt (lt->socket, SOL_SOCKET, SO_REUSEADDR, (const char *)&flags, sizeof(flags)) < 0) { lt 576 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 582 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (pmix_fd_set_cloexec(lt->socket) != PMIX_SUCCESS) { lt 583 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 587 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (bind(lt->socket, (struct sockaddr*)&mca_ptl_tcp_component.connection, sizeof(struct sockaddr)) < 0) { lt 589 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 594 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (getsockname(lt->socket, (struct sockaddr*)&mca_ptl_tcp_component.connection, &addrlen) < 0) { lt 597 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 602 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (listen(lt->socket, SOMAXCONN) < 0) { lt 604 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 609 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if ((flags = fcntl(lt->socket, F_GETFL, 0)) < 0) { lt 611 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 615 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (fcntl(lt->socket, F_SETFL, flags) < 0) { lt 617 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 636 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c rc = asprintf(<->uri, "%s.%d;%s%s:%d", pmix_globals.myid.nspace, pmix_globals.myid.rank, prefix, myconnhost, myport); lt 637 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c if (0 > rc || NULL == lt->uri) { lt 638 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 642 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c "ptl:tcp URI %s", lt->uri); lt 648 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_VALUE_LOAD(urikv->value, lt->uri, PMIX_STRING); lt 657 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c fprintf(stdout, "%s\n", lt->uri); lt 660 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c fprintf(stderr, "%s\n", lt->uri); lt 668 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 674 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c fprintf(fp, "%s\n", lt->uri); lt 692 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 699 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c fprintf(fp, "%s\n", lt->uri); lt 706 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 719 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 729 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 736 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c fprintf(fp, "%s\n", lt->uri); lt 743 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 757 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 767 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 774 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c fprintf(fp, "%s\n", lt->uri); lt 781 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 791 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 801 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 808 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c fprintf(fp, "%s\n", lt->uri); lt 815 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c CLOSE_THE_SOCKET(lt->socket); lt 843 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_list_append(&pmix_ptl_globals.listeners, <->super); lt 848 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c PMIX_RELEASE(lt); lt 171 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pmix_listener_t *lt; lt 212 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c lt = PMIX_NEW(pmix_listener_t); lt 218 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(lt); lt 225 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(lt); lt 231 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c lt->varname = strdup("PMIX_SERVER_URI:PMIX_SERVER_URI2USOCK"); lt 232 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (0 > asprintf(<->uri, "%s:%lu:%s", pmix_globals.myid.nspace, lt 234 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(lt); lt 240 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c lt->protocol = PMIX_PROTOCOL_V1; lt 241 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c lt->ptl = (struct pmix_ptl_module_t*)&pmix_ptl_usock_module; lt 242 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c lt->cbfunc = connection_handler; lt 243 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pmix_list_append(&pmix_ptl_globals.listeners, <->super); lt 246 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c lt->socket = socket(PF_UNIX, SOCK_STREAM, 0); lt 247 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (lt->socket < 0) { lt 253 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (pmix_fd_set_cloexec(lt->socket) != PMIX_SUCCESS) { lt 254 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(lt->socket); lt 258 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (bind(lt->socket, (struct sockaddr*)address, addrlen) < 0) { lt 260 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(lt->socket); lt 264 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (lt->owner_given) { lt 265 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (0 != chown(address->sun_path, lt->owner, -1)) { lt 267 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(lt->socket); lt 271 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (lt->group_given) { lt 272 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (0 != chown(address->sun_path, -1, lt->group)) { lt 274 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(lt->socket); lt 279 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (0 != chmod(address->sun_path, lt->mode)) { lt 281 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(lt->socket); lt 286 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (listen(lt->socket, SOMAXCONN) < 0) { lt 288 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(lt->socket); lt 293 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if ((flags = fcntl(lt->socket, F_GETFL, 0)) < 0) { lt 295 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(lt->socket); lt 299 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (fcntl(lt->socket, F_SETFL, flags) < 0) { lt 301 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c CLOSE_THE_SOCKET(lt->socket); lt 308 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c rc = pmix_host_server.listener(lt->socket, listener_cb, (void*)lt); lt 318 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pmix_list_remove_item(&pmix_ptl_globals.listeners, <->super); lt 319 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c PMIX_RELEASE(lt); lt 1224 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_listener_t *lt; lt 1246 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_LIST_FOREACH(lt, &pmix_ptl_globals.listeners, pmix_listener_t) { lt 1247 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c if (NULL != lt->uri && NULL != lt->varname) { lt 1248 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c varnames = pmix_argv_split(lt->varname, ':'); lt 1250 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_setenv(varnames[n], lt->uri, true, env); lt 966 opal/mca/pmix/pmix4x/pmix4x.c opal_list_t *lt; lt 1179 opal/mca/pmix/pmix4x/pmix4x.c lt = OBJ_NEW(opal_list_t); lt 1181 opal/mca/pmix/pmix4x/pmix4x.c kv->data.ptr = (void*)lt; lt 1184 opal/mca/pmix/pmix4x/pmix4x.c opal_list_append(lt, &ival->super); lt 1195 opal/mca/pmix/pmix4x/pmix4x.c OPAL_LIST_RELEASE(lt);