trk 51 ompi/interlib/interlib.c myreg_t *trk = (myreg_t*)cbdata; trk 53 ompi/interlib/interlib.c trk->status = status; trk 55 ompi/interlib/interlib.c trk->active = false; trk 95 ompi/interlib/interlib.c myreg_t trk; trk 99 ompi/interlib/interlib.c trk.status = OPAL_ERROR; trk 100 ompi/interlib/interlib.c trk.active = true; trk 121 ompi/interlib/interlib.c (void*)&trk); trk 122 ompi/interlib/interlib.c OMPI_LAZY_WAIT_FOR_COMPLETION(trk.active); trk 126 ompi/interlib/interlib.c if (OPAL_SUCCESS != trk.status) { trk 127 ompi/interlib/interlib.c return trk.status; trk 628 opal/mca/pmix/pmix4x/pmix/src/common/pmix_attributes.c pmix_attribute_trk_t *trk, *tptr; trk 641 opal/mca/pmix/pmix4x/pmix/src/common/pmix_attributes.c trk = NULL; trk 642 opal/mca/pmix/pmix4x/pmix/src/common/pmix_attributes.c for (m=0; NULL != fns[m] && NULL == trk; m++) { trk 645 opal/mca/pmix/pmix4x/pmix/src/common/pmix_attributes.c trk = tptr; trk 649 opal/mca/pmix/pmix4x/pmix/src/common/pmix_attributes.c if (NULL == trk || NULL == trk->attrs) { trk 658 opal/mca/pmix/pmix4x/pmix/src/common/pmix_attributes.c PMIX_DATA_ARRAY_CREATE(darray, trk->nattrs, PMIX_REGATTR); trk 662 opal/mca/pmix/pmix4x/pmix/src/common/pmix_attributes.c for (m=0; m < trk->nattrs; m++) { trk 663 opal/mca/pmix/pmix4x/pmix/src/common/pmix_attributes.c PMIX_REGATTR_XFER(®array[m], &trk->attrs[m]); trk 818 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_list_t trk; trk 978 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_CONSTRUCT(&trk, pmix_list_t); trk 995 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_LIST_FOREACH(nm, &trk, pmix_namelist_t) { trk 1031 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_list_append(&trk, &nm->super); trk 1094 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_LIST_DESTRUCT(&trk); trk 336 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h pmix_server_trkr_t *trk; trk 378 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_track_elem_t *trk = ns_trk + i; trk 379 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (trk->in_use) { trk 380 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_DESTRUCT(trk); trk 2448 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ns_track_elem_t *trk = NULL; trk 2489 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c trk = pmix_value_array_get_item(ds_ctx->ns_track_array, dstor_track_idx); trk 2490 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (true == trk->in_use) { trk 2491 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_DESTRUCT(trk); trk 102 opal/mca/pmix/pmix4x/pmix/src/mca/gds/base/gds_base_fns.c pmix_server_trkr_t *trk = (pmix_server_trkr_t*)cbdata; trk 120 opal/mca/pmix/pmix4x/pmix/src/mca/gds/base/gds_base_fns.c if ((PMIX_COLLECT_YES == trk->collect_type) && trk 147 opal/mca/pmix/pmix4x/pmix/src/mca/gds/base/gds_base_fns.c if (trk->collect_type != ctype) { trk 221 opal/mca/pmix/pmix4x/pmix/src/mca/gds/base/gds_base_fns.c if (pmix_list_get_size(&trk->nslist) == 1) { trk 223 opal/mca/pmix/pmix4x/pmix/src/mca/gds/base/gds_base_fns.c nm = (pmix_nspace_caddy_t*)pmix_list_get_first(&trk->nslist); trk 225 opal/mca/pmix/pmix4x/pmix/src/mca/gds/base/gds_base_fns.c PMIX_LIST_FOREACH(nm, &trk->nslist, pmix_nspace_caddy_t) { trk 371 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_hash_trkr_t *trk, *t; trk 387 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk = NULL; trk 390 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk = t; trk 394 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (NULL == trk) { trk 396 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk = PMIX_NEW(pmix_hash_trkr_t); trk 397 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (NULL == trk) { trk 401 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk->nptr = nptr; trk 402 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk->ns = strdup(nptr->nspace); trk 403 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_list_append(&myhashes, &trk->super); trk 413 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c ht = &trk->internal; trk 555 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (!trk->gdata_added) { trk 578 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk->gdata_added = true; trk 595 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_hash_trkr_t *trk, *t; trk 605 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk = NULL; trk 608 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk = t; trk 612 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (NULL == trk) { trk 616 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c ht = &trk->internal; trk 693 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_hash_trkr_t *trk, *t2; trk 729 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk = NULL; trk 732 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk = t2; trk 733 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (NULL == trk->ns) { trk 734 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk->ns = strdup(ns->nspace); trk 739 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (NULL == trk) { trk 740 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk = PMIX_NEW(pmix_hash_trkr_t); trk 741 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk->ns = strdup(ns->nspace); trk 743 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk->nptr = ns; trk 744 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_list_append(&myhashes, &trk->super); trk 1078 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_hash_trkr_t *trk, *t; trk 1093 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk = NULL; trk 1096 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk = t; trk 1100 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (NULL == trk) { trk 1102 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk = PMIX_NEW(pmix_hash_trkr_t); trk 1103 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk->ns = strdup(proc->nspace); trk 1104 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_list_append(&myhashes, &trk->super); trk 1128 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (PMIX_SUCCESS != (rc = pmix_hash_store(&trk->internal, proc->rank, kp))) { trk 1139 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (PMIX_SUCCESS != (rc = pmix_hash_store(&trk->internal, proc->rank, kv))) { trk 1144 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (PMIX_SUCCESS != (rc = pmix_hash_store(&trk->remote, proc->rank, kv))) { trk 1149 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (PMIX_SUCCESS != (rc = pmix_hash_store(&trk->local, proc->rank, kv))) { trk 1154 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (PMIX_SUCCESS != (rc = pmix_hash_store(&trk->remote, proc->rank, kv))) { trk 1176 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (PMIX_SUCCESS != (rc = pmix_hash_store(&trk->local, proc->rank, kp))) { trk 1206 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_hash_trkr_t *trk, *t; trk 1216 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk = NULL; trk 1219 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk = t; trk 1223 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (NULL == trk) { trk 1225 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk = PMIX_NEW(pmix_hash_trkr_t); trk 1226 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk->ns = strdup(proc->nspace); trk 1227 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_list_append(&myhashes, &trk->super); trk 1242 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (PMIX_SUCCESS != (rc = pmix_hash_store(&trk->remote, proc->rank, kv))) { trk 1267 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_hash_trkr_t *trk, *t; trk 1287 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk = NULL; trk 1290 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk = t; trk 1294 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (NULL == trk) { trk 1299 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c ht = &trk->internal; trk 1344 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk = NULL; trk 1347 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c trk = t; trk 1351 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (NULL == trk) { trk 1362 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c ht = &trk->internal; trk 1365 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c ht = &trk->local; trk 1367 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c ht = &trk->remote; trk 1411 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (PMIX_GLOBAL == scope && ht == &trk->local) { trk 1413 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c ht = &trk->remote; trk 1430 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c if (ht == &trk->internal) { trk 1432 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c ht = &trk->local; trk 1434 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c } else if (ht == &trk->local) { trk 1436 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c ht = &trk->remote; trk 109 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c tcp_port_tracker_t *trk, trk 194 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c tcp_available_ports_t *trk; trk 223 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk = PMIX_NEW(tcp_available_ports_t); trk 224 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c if (NULL == trk) { trk 236 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c pmix_util_parse_range_options(p, &trk->ports); trk 237 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk->nports = pmix_argv_count(trk->ports); trk 243 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk->plane = strdup(p); trk 246 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk->type = strdup(grps[n]); trk 248 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c "TYPE: %s PLANE %s", trk->type, trk 249 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c (NULL == trk->plane) ? "NULL" : trk->plane); trk 250 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c pmix_list_append(&available, &trk->super); trk 312 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c tcp_port_tracker_t *trk; trk 465 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk = PMIX_NEW(tcp_port_tracker_t); trk 466 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c if (NULL == trk) { trk 470 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk->nspace = strdup(nptr->nspace); trk 472 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk->src = avail; trk 473 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c pmix_list_append(&allocations, &trk->super); trk 474 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c rc = process_request(nptr, idkey, ports_per_node, trk, &mylist); trk 477 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c pmix_list_remove_item(&allocations, &trk->super); trk 478 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c PMIX_RELEASE(trk); trk 506 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk = PMIX_NEW(tcp_port_tracker_t); trk 507 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c if (NULL == trk) { trk 511 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk->nspace = strdup(nptr->nspace); trk 513 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk->src = avail; trk 514 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c pmix_list_append(&allocations, &trk->super); trk 515 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c rc = process_request(nptr, idkey, ports_per_node, trk, &mylist); trk 518 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c pmix_list_remove_item(&allocations, &trk->super); trk 519 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c PMIX_RELEASE(trk); trk 542 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk = PMIX_NEW(tcp_port_tracker_t); trk 543 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c if (NULL == trk) { trk 547 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk->nspace = strdup(nptr->nspace); trk 549 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk->src = aptr; trk 550 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c pmix_list_append(&allocations, &trk->super); trk 551 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c rc = process_request(nptr, idkey, ports_per_node, trk, &mylist); trk 554 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c pmix_list_remove_item(&allocations, &trk->super); trk 555 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c PMIX_RELEASE(trk); trk 607 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk = PMIX_NEW(tcp_port_tracker_t); trk 608 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c if (NULL == trk) { trk 613 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk->nspace = strdup(nptr->nspace); trk 615 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk->src = avail; trk 616 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c pmix_list_append(&allocations, &trk->super); trk 617 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c rc = process_request(nptr, idkey, ports_per_node, trk, &mylist); trk 620 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c pmix_list_remove_item(&allocations, &trk->super); trk 621 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c PMIX_RELEASE(trk); trk 639 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk = PMIX_NEW(tcp_port_tracker_t); trk 640 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c if (NULL == trk) { trk 644 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk->nspace = strdup(nptr->nspace); trk 646 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c trk->src = avail; trk 647 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c pmix_list_append(&allocations, &trk->super); trk 648 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c rc = process_request(nptr, idkey, ports_per_node, trk, &mylist); trk 651 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c pmix_list_remove_item(&allocations, &trk->super); trk 652 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c PMIX_RELEASE(trk); trk 851 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c tcp_port_tracker_t *trk; trk 863 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c PMIX_LIST_FOREACH(trk, &allocations, tcp_port_tracker_t) { trk 864 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c if (0 == strcmp(nptr->nspace, trk->nspace)) { trk 865 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c pmix_list_remove_item(&allocations, &trk->super); trk 866 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c PMIX_RELEASE(trk); trk 992 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c tcp_port_tracker_t *trk, trk 999 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c tcp_available_ports_t *avail = trk->src; trk 1026 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c pmix_argv_append_nosize(&trk->ports, avail->ports[m]); trk 1057 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c kv->value->data.string = strdup(trk->src->type); trk 1059 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c if (NULL != trk->src->plane) { trk 1071 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/tcp/pnet_tcp.c kv->value->data.string = strdup(trk->src->plane); trk 65 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_server_trkr_t *trk, *tnxt; trk 97 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c PMIX_LIST_FOREACH_SAFE(trk, tnxt, &pmix_server_globals.collectives, pmix_server_trkr_t) { trk 99 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c PMIX_LIST_FOREACH_SAFE(rinfo, rnext, &trk->local_cbs, pmix_server_caddy_t) { trk 104 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c --trk->nlocal; trk 106 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_list_remove_item(&trk->local_cbs, &rinfo->super); trk 111 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (trk->host_called) { trk 114 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (trk->def_complete && trk->nlocal == pmix_list_get_size(&trk->local_cbs)) { trk 116 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (trk->local) { trk 120 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (PMIX_FENCENB_CMD == trk->type) { trk 121 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (NULL != trk->modexcbfunc) { trk 122 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c trk->modexcbfunc(PMIX_ERR_LOST_CONNECTION_TO_CLIENT, NULL, 0, trk, NULL, NULL); trk 124 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c } else if (PMIX_CONNECTNB_CMD == trk->type) { trk 125 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (NULL != trk->op_cbfunc) { trk 126 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c trk->op_cbfunc(PMIX_ERR_LOST_CONNECTION_TO_CLIENT, trk); trk 128 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c } else if (PMIX_DISCONNECTNB_CMD == trk->type) { trk 129 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (NULL != trk->op_cbfunc) { trk 130 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c trk->op_cbfunc(PMIX_ERR_LOST_CONNECTION_TO_CLIENT, trk); trk 138 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c if (PMIX_FENCENB_CMD == trk->type) { trk 139 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c trk->host_called = true; trk 140 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c rc = pmix_host_server.fence_nb(trk->pcs, trk->npcs, trk 141 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c trk->info, trk->ninfo, trk 142 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c NULL, 0, trk->modexcbfunc, trk); trk 144 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_list_remove_item(&pmix_server_globals.collectives, &trk->super); trk 145 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c PMIX_RELEASE(trk); trk 147 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c } else if (PMIX_CONNECTNB_CMD == trk->type) { trk 148 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c trk->host_called = true; trk 149 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c rc = pmix_host_server.connect(trk->pcs, trk->npcs, trk->info, trk->ninfo, trk->op_cbfunc, trk); trk 151 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_list_remove_item(&pmix_server_globals.collectives, &trk->super); trk 152 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c PMIX_RELEASE(trk); trk 154 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c } else if (PMIX_DISCONNECTNB_CMD == trk->type) { trk 155 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c trk->host_called = true; trk 156 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c rc = pmix_host_server.disconnect(trk->pcs, trk->npcs, trk->info, trk->ninfo, trk->op_cbfunc, trk); trk 158 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_list_remove_item(&pmix_server_globals.collectives, &trk->super); trk 159 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c PMIX_RELEASE(trk); trk 119 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_progress_tracker_t *trk = pmix_progress_tracker_get_by_base((struct event_base *)EV_A); trk 120 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c assert(NULL != trk); trk 121 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pthread_mutex_lock (&trk->mutex); trk 123 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c PMIX_LIST_FOREACH_SAFE(cd, next, &trk->list, pmix_event_caddy_t) { trk 135 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_list_remove_item(&trk->list, &cd->super); trk 138 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pthread_mutex_unlock (&trk->mutex); trk 143 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_progress_tracker_t *trk = pmix_progress_tracker_get_by_base(ev->ev_base); trk 144 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c if ((NULL != trk) && !pthread_equal(pthread_self(), trk->engine.t_handle)) { trk 149 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pthread_mutex_lock(&trk->mutex); trk 150 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_list_append(&trk->list, &cd->super); trk 151 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c ev_async_send ((struct ev_loop *)trk->ev_base, &trk->async); trk 152 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pthread_mutex_unlock(&trk->mutex); trk 162 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_progress_tracker_t *trk = pmix_progress_tracker_get_by_base(ev->ev_base); trk 163 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c if ((NULL != trk) && !pthread_equal(pthread_self(), trk->engine.t_handle)) { trk 167 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pthread_mutex_lock(&trk->mutex); trk 168 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_list_append(&trk->list, &cd->super); trk 169 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c ev_async_send ((struct ev_loop *)trk->ev_base, &trk->async); trk 170 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pthread_mutex_unlock(&trk->mutex); trk 179 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_progress_tracker_t *trk = pmix_progress_tracker_get_by_base(ev->ev_base); trk 180 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c if ((NULL != trk) && !pthread_equal(pthread_self(), trk->engine.t_handle)) { trk 186 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pthread_mutex_lock(&trk->mutex); trk 187 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_list_append(&trk->list, &cd->super); trk 188 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c ev_async_send ((struct ev_loop *)trk->ev_base, &trk->async); trk 189 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pthread_mutex_unlock(&trk->mutex); trk 196 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_progress_tracker_t *trk = pmix_progress_tracker_get_by_base(ev_base); trk 197 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c assert(NULL != trk); trk 198 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c ev_async_send ((struct ev_loop *)trk->ev_base, &trk->async); trk 216 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_progress_tracker_t *trk = (pmix_progress_tracker_t*)cbdata; trk 218 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_event_add(&trk->block, &long_timeout); trk 227 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_progress_tracker_t *trk = (pmix_progress_tracker_t*)t->t_arg; trk 229 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c while (trk->ev_active) { trk 230 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_event_loop(trk->ev_base, PMIX_EVLOOP_ONCE); trk 236 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c static void stop_progress_engine(pmix_progress_tracker_t *trk) trk 238 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c assert(trk->ev_active); trk 239 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c trk->ev_active = false; trk 242 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_event_base_loopbreak(trk->ev_base); trk 244 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_thread_join(&trk->engine, NULL); trk 247 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c static int start_progress_engine(pmix_progress_tracker_t *trk) trk 249 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c assert(!trk->ev_active); trk 250 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c trk->ev_active = true; trk 253 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c trk->engine.t_run = progress_engine; trk 254 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c trk->engine.t_arg = trk; trk 256 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c int rc = pmix_thread_start(&trk->engine); trk 266 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_progress_tracker_t *trk; trk 279 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c PMIX_LIST_FOREACH(trk, &tracking, pmix_progress_tracker_t) { trk 280 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c if (0 == strcmp(name, trk->name)) { trk 282 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c ++trk->refcount; trk 284 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c return trk->ev_base; trk 288 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c trk = PMIX_NEW(pmix_progress_tracker_t); trk 289 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c if (NULL == trk) { trk 294 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c trk->name = strdup(name); trk 295 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c if (NULL == trk->name) { trk 297 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c PMIX_RELEASE(trk); trk 301 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c if (NULL == (trk->ev_base = pmix_event_base_create())) { trk 303 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c PMIX_RELEASE(trk); trk 309 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_event_assign(&trk->block, trk->ev_base, -1, PMIX_EV_PERSIST, trk 310 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c dummy_timeout_cb, trk); trk 311 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_event_add(&trk->block, &long_timeout); trk 314 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c ev_async_init (&trk->async, pmix_libev_ev_async_cb); trk 315 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c ev_async_start((struct ev_loop *)trk->ev_base, &trk->async); trk 319 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c PMIX_CONSTRUCT(&trk->engine, pmix_thread_t); trk 320 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c trk->engine_constructed = true; trk 321 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c if (PMIX_SUCCESS != (rc = start_progress_engine(trk))) { trk 323 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c PMIX_RELEASE(trk); trk 326 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_list_append(&tracking, &trk->super); trk 328 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c return trk->ev_base; trk 333 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_progress_tracker_t *trk; trk 345 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c PMIX_LIST_FOREACH(trk, &tracking, pmix_progress_tracker_t) { trk 346 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c if (0 == strcmp(name, trk->name)) { trk 348 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c --trk->refcount; trk 351 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c if (trk->refcount > 0) { trk 356 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c if (trk->ev_active) { trk 357 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c stop_progress_engine(trk); trk 359 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_list_remove_item(&tracking, &trk->super); trk 360 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c PMIX_RELEASE(trk); trk 370 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_progress_tracker_t *trk; trk 382 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c PMIX_LIST_FOREACH(trk, &tracking, pmix_progress_tracker_t) { trk 383 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c if (0 == strcmp(name, trk->name)) { trk 385 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c if (trk->refcount > 0) { trk 389 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_list_remove_item(&tracking, &trk->super); trk 390 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c PMIX_RELEASE(trk); trk 403 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_progress_tracker_t *trk; trk 415 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c PMIX_LIST_FOREACH(trk, &tracking, pmix_progress_tracker_t) { trk 416 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c if (0 == strcmp(name, trk->name)) { trk 417 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c if (trk->ev_active) { trk 418 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c stop_progress_engine(trk); trk 430 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_progress_tracker_t *trk; trk 433 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c PMIX_LIST_FOREACH(trk, &tracking, pmix_progress_tracker_t) { trk 434 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c if(trk->ev_base == base) { trk 435 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c return trk; trk 445 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c pmix_progress_tracker_t *trk; trk 457 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c PMIX_LIST_FOREACH(trk, &tracking, pmix_progress_tracker_t) { trk 458 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c if (0 == strcmp(name, trk->name)) { trk 459 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c if (trk->ev_active) { trk 463 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_progress_threads.c return start_progress_engine(trk); trk 795 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_server_trkr_t *trk = tcd->trk; trk 815 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c if (PMIX_FENCENB_CMD == trk->type) { trk 823 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c if (trk->hybrid) { trk 833 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c if (0 == pmix_list_get_size(&trk->local_cbs)) { trk 834 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_host_server.fence_nb(trk->pcs, trk->npcs, trk 835 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c trk->info, trk->ninfo, trk 836 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c data, sz, trk->modexcbfunc, trk); trk 841 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c cd = (pmix_server_caddy_t*)pmix_list_get_first(&trk->local_cbs); trk 846 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c unsigned char tmp = (unsigned char)trk->collect_type; trk 849 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c if (PMIX_COLLECT_YES == trk->collect_type) { trk 854 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_LIST_FOREACH(cd, &trk->local_cbs, pmix_server_caddy_t) { trk 871 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c if (trk->hybrid || first) { trk 926 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_host_server.fence_nb(trk->pcs, trk->npcs, trk 927 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c trk->info, trk->ninfo, trk 928 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c data, sz, trk->modexcbfunc, trk); trk 929 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c } else if (PMIX_CONNECTNB_CMD == trk->type) { trk 930 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_host_server.connect(trk->pcs, trk->npcs, trk 931 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c trk->info, trk->ninfo, trk 932 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c trk->op_cbfunc, trk); trk 933 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c } else if (PMIX_DISCONNECTNB_CMD == trk->type) { trk 934 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_host_server.disconnect(trk->pcs, trk->npcs, trk 935 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c trk->info, trk->ninfo, trk 936 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c trk->op_cbfunc, trk); trk 940 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_list_remove_item(&pmix_server_globals.collectives, &trk->super); trk 941 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_RELEASE(trk); trk 951 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_server_trkr_t *trk; trk 1004 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_LIST_FOREACH(trk, &pmix_server_globals.collectives, pmix_server_trkr_t) { trk 1007 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c if (trk->def_complete) { trk 1015 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c for (i=0; i < trk->npcs; i++) { trk 1022 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c 0 == strcmp(trk->pcs[i].nspace, ns->nspace)) { trk 1029 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c if (0 != strncmp(trk->pcs[i].nspace, nptr->nspace, PMIX_MAX_NSLEN)) { trk 1034 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c if (PMIX_RANK_WILDCARD == trk->pcs[i].rank || trk 1035 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c iptr->pname.rank == trk->pcs[i].rank) { trk 1037 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c ++trk->nlocal; trk 1043 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c trk->def_complete = all_def; trk 1045 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c if (trk->def_complete && pmix_list_get_size(&trk->local_cbs) == trk->nlocal) { trk 1050 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_EXECUTE_COLLECTIVE(tcd, trk, pmix_server_execute_collective); trk 314 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_server_trkr_t *trk; trk 333 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_LIST_FOREACH(trk, &pmix_server_globals.collectives, pmix_server_trkr_t) { trk 339 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL != trk->id && 0 == strcmp(id, trk->id)) { trk 340 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c return trk; trk 343 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (nprocs != trk->npcs) { trk 346 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (type != trk->type) { trk 353 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c for (j=0; j < trk->npcs; j++) { trk 354 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (0 == strcmp(procs[i].nspace, trk->pcs[j].nspace) && trk 355 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c procs[i].rank == trk->pcs[j].rank) { trk 361 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (trk->npcs == matches) { trk 362 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c return trk; trk 389 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_server_trkr_t *trk; trk 410 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk = PMIX_NEW(pmix_server_trkr_t); trk 411 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == trk) { trk 417 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->id = strdup(id); trk 422 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_PROC_CREATE(trk->pcs, nprocs); trk 423 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == trk->pcs) { trk 425 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_RELEASE(trk); trk 428 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c memcpy(trk->pcs, procs, nprocs * sizeof(pmix_proc_t)); trk 429 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->npcs = nprocs; trk 431 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->type = type; trk 436 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_strncpy(trk->pcs[i].nspace, procs[i].nspace, PMIX_MAX_NSLEN); trk 437 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->pcs[i].rank = procs[i].rank; trk 458 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_LIST_FOREACH(nm, &trk->nslist, pmix_nspace_caddy_t) { trk 463 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if ((pmix_nspace_caddy_t*)pmix_list_get_end(&trk->nslist) == nm) { trk 467 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_append(&trk->nslist, &nm->super); trk 490 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c ++trk->nlocal; trk 498 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->def_complete = true; trk 500 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_append(&pmix_server_globals.collectives, &trk->super); trk 501 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c return trk; trk 512 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL != cd->trk->modexcbfunc) { trk 513 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cd->trk->modexcbfunc(PMIX_ERR_TIMEOUT, NULL, 0, cd->trk, NULL, NULL); trk 518 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_remove_item(&cd->trk->local_cbs, &cd->super); trk 522 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c static pmix_status_t _collect_data(pmix_server_trkr_t *trk, trk 547 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (PMIX_COLLECT_YES == trk->collect_type) { trk 563 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_LIST_FOREACH(scd, &trk->local_cbs, pmix_server_caddy_t) { trk 636 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_LIST_FOREACH(scd, &trk->local_cbs, pmix_server_caddy_t) { trk 651 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (pmix_list_get_size(&trk->nslist) == 1) { trk 654 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_LIST_FOREACH(nm, &trk->nslist, pmix_nspace_caddy_t) { trk 788 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_server_trkr_t *trk; trk 918 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = get_tracker(NULL, procs, nprocs, PMIX_FENCENB_CMD))) { trk 920 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = new_tracker(NULL, procs, nprocs, PMIX_FENCENB_CMD))) { trk 930 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->type = PMIX_FENCENB_CMD; trk 931 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->modexcbfunc = modexcbfunc; trk 934 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->collect_type = PMIX_COLLECT_YES; trk 936 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->collect_type = PMIX_COLLECT_NO; trk 939 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c switch (trk->collect_type) { trk 942 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->collect_type = PMIX_COLLECT_INVALID; trk 947 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->collect_type = PMIX_COLLECT_INVALID; trk 958 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == trk->info) { trk 959 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->info = info; trk 960 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->ninfo = ninfo; trk 970 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_append(&trk->local_cbs, &cd->super); trk 973 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_RETAIN(trk); trk 974 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cd->trk = trk; trk 985 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (trk->def_complete && trk 986 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_get_size(&trk->local_cbs) == trk->nlocal) { trk 997 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (PMIX_SUCCESS != (rc = _collect_data(trk, &bucket))) { trk 1005 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->host_called = true; trk 1006 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c rc = pmix_host_server.fence_nb(trk->pcs, trk->npcs, trk 1007 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->info, trk->ninfo, trk 1008 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c data, sz, trk->modexcbfunc, trk); trk 1010 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_remove_item(&pmix_server_globals.collectives, &trk->super); trk 1011 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_RELEASE(trk); trk 1012 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cd->trk = NULL; trk 1571 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_server_trkr_t *trk; trk 1630 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = get_tracker(NULL, procs, nprocs, PMIX_DISCONNECTNB_CMD))) { trk 1632 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = new_tracker(NULL, procs, nprocs, PMIX_DISCONNECTNB_CMD))) { trk 1638 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->op_cbfunc = cbfunc; trk 1643 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == trk->info && NULL != info) { trk 1644 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->info = info; trk 1645 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->ninfo = ninfo; trk 1652 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_append(&trk->local_cbs, &cd->super); trk 1657 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (trk->def_complete && trk 1658 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_get_size(&trk->local_cbs) == trk->nlocal) { trk 1659 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->host_called = true; trk 1660 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c rc = pmix_host_server.disconnect(trk->pcs, trk->npcs, trk->info, trk->ninfo, cbfunc, trk); trk 1664 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_remove_item(&trk->local_cbs, &cd->super); trk 1685 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL != cd->trk->op_cbfunc) { trk 1686 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cd->trk->op_cbfunc(PMIX_ERR_TIMEOUT, cd->trk); trk 1691 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_remove_item(&cd->trk->local_cbs, &cd->super); trk 1704 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_server_trkr_t *trk; trk 1775 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = get_tracker(NULL, procs, nprocs, PMIX_CONNECTNB_CMD))) { trk 1777 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = new_tracker(NULL, procs, nprocs, PMIX_CONNECTNB_CMD))) { trk 1787 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->op_cbfunc = cbfunc; trk 1792 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == trk->info && NULL != info) { trk 1793 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->info = info; trk 1794 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->ninfo = ninfo; trk 1801 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_append(&trk->local_cbs, &cd->super); trk 1807 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (trk->def_complete && trk 1808 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_get_size(&trk->local_cbs) == trk->nlocal) { trk 1809 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->host_called = true; trk 1810 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c rc = pmix_host_server.connect(trk->pcs, trk->npcs, trk->info, trk->ninfo, cbfunc, trk); trk 1814 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_remove_item(&trk->local_cbs, &cd->super); trk 1821 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_RETAIN(trk); trk 1822 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cd->trk = trk; trk 3699 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_remove_item(&cd->trk->local_cbs, &cd->super); trk 3706 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_server_trkr_t *trk = scd->tracker; trk 3711 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_group_t *grp = (pmix_group_t*)trk->cbdata; trk 3721 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c (NULL == trk) ? 0 : (int)pmix_list_get_size(&trk->local_cbs)); trk 3723 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == trk) { trk 3734 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (trk->event_active) { trk 3735 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_del(&trk->ev); trk 3740 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (trk->hybrid) { trk 3765 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_LIST_FOREACH(cd, &trk->local_cbs, pmix_server_caddy_t) { trk 3786 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_GDS_STORE_MODEX(ret, nptr->ns, &xfer, trk); trk 3795 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_LIST_FOREACH(cd, &trk->local_cbs, pmix_server_caddy_t) { trk 3807 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (!trk->hybrid) { trk 3826 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_remove_item(&pmix_server_globals.collectives, &trk->super); trk 3827 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_RELEASE(trk); trk 3890 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_server_trkr_t *trk; trk 4030 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = get_tracker(grp->grpid, grp->members, grp->nmbrs, PMIX_GROUP_CONSTRUCT_CMD))) { trk 4032 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = new_tracker(grp->grpid, grp->members, grp->nmbrs, PMIX_GROUP_CONSTRUCT_CMD))) { trk 4040 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->collect_type = PMIX_COLLECT_YES; trk 4042 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->hybrid = false; trk 4044 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->cbdata = grp; trk 4048 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->info = info; trk 4049 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->ninfo = ninfo; trk 4071 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->local = true; trk 4073 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->local = false; trk 4075 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->local = true; trk 4096 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->local = false; trk 4109 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_append(&trk->local_cbs, &cd->super); trk 4113 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_evtimer_set(pmix_globals.evbase, &trk->ev, trk 4114 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c grp_timeout, trk); trk 4115 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_evtimer_add(&trk->ev, &tv); trk 4116 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->event_active = true; trk 4123 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (trk->def_complete && trk 4124 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_get_size(&trk->local_cbs) == trk->nlocal) { trk 4126 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c "local group op complete with %d procs", (int)trk->npcs); trk 4128 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (trk->local) { trk 4132 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c grpcbfunc(PMIX_SUCCESS, NULL, 0, trk, NULL, NULL); trk 4139 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_remove_item(&pmix_server_globals.collectives, &trk->super); trk 4140 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_RELEASE(trk); trk 4150 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c rc = _collect_data(trk, &bucket); trk 4152 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (trk->event_active) { trk 4153 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_del(&trk->ev); trk 4156 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_remove_item(&pmix_server_globals.collectives, &trk->super); trk 4157 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_RELEASE(trk); trk 4166 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c n2 = trk->ninfo + 1; trk 4168 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c for (n=0; n < trk->ninfo; n++) { trk 4169 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_INFO_XFER(&iptr[n], &trk->info[n]); trk 4173 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_INFO_FREE(trk->info, trk->ninfo); trk 4174 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->info = iptr; trk 4175 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->ninfo = n2; trk 4178 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->pcs, trk->npcs, trk 4179 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->info, trk->ninfo, trk 4180 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c grpcbfunc, trk); trk 4182 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (trk->event_active) { trk 4183 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_del(&trk->ev); trk 4187 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c grpcbfunc(PMIX_SUCCESS, NULL, 0, trk, NULL, NULL); trk 4191 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_remove_item(&pmix_server_globals.collectives, &trk->super); trk 4192 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_RELEASE(trk); trk 4217 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_server_trkr_t *trk; trk 4280 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = get_tracker(grp->grpid, grp->members, grp->nmbrs, PMIX_GROUP_DESTRUCT_CMD))) { trk 4282 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (trk = new_tracker(grp->grpid, grp->members, grp->nmbrs, PMIX_GROUP_DESTRUCT_CMD))) { trk 4288 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->collect_type = PMIX_COLLECT_NO; trk 4290 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->hybrid = true; trk 4292 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->cbdata = grp; trk 4298 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == trk->info) { trk 4299 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->info = info; trk 4300 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->ninfo = ninfo; trk 4309 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_append(&trk->local_cbs, &cd->super); trk 4313 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_evtimer_set(pmix_globals.evbase, &trk->ev, trk 4314 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c grp_timeout, trk); trk 4315 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_evtimer_add(&trk->ev, &tv); trk 4316 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->event_active = true; trk 4323 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (trk->def_complete && trk 4324 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_get_size(&trk->local_cbs) == trk->nlocal) { trk 4326 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c "local group op complete %d", (int)trk->nlocal); trk 4330 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->info, trk->ninfo, trk 4331 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c grpcbfunc, trk); trk 4333 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (trk->event_active) { trk 4334 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_event_del(&trk->ev); trk 4338 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c grpcbfunc(PMIX_SUCCESS, NULL, 0, trk, NULL, NULL); trk 4342 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_remove_item(&pmix_server_globals.collectives, &trk->super); trk 4343 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_RELEASE(trk); trk 4406 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cd->trk = NULL; trk 4414 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL != cd->trk) { trk 4415 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_RELEASE(cd->trk); trk 38 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_server_trkr_t *trk; trk 222 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h (c)->trk = (t); \ trk 235 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h bool pmix_server_trk_update(pmix_server_trkr_t *trk); trk 91 opal/runtime/opal_progress_threads.c opal_progress_tracker_t *trk = (opal_progress_tracker_t*)cbdata; trk 93 opal/runtime/opal_progress_threads.c opal_event_add(&trk->block, &long_timeout); trk 102 opal/runtime/opal_progress_threads.c opal_progress_tracker_t *trk = (opal_progress_tracker_t*)t->t_arg; trk 104 opal/runtime/opal_progress_threads.c while (trk->ev_active) { trk 105 opal/runtime/opal_progress_threads.c opal_event_loop(trk->ev_base, OPAL_EVLOOP_ONCE); trk 111 opal/runtime/opal_progress_threads.c static void stop_progress_engine(opal_progress_tracker_t *trk) trk 113 opal/runtime/opal_progress_threads.c assert(trk->ev_active); trk 114 opal/runtime/opal_progress_threads.c trk->ev_active = false; trk 118 opal/runtime/opal_progress_threads.c opal_event_base_loopbreak(trk->ev_base); trk 120 opal/runtime/opal_progress_threads.c opal_thread_join(&trk->engine, NULL); trk 123 opal/runtime/opal_progress_threads.c static int start_progress_engine(opal_progress_tracker_t *trk) trk 125 opal/runtime/opal_progress_threads.c assert(!trk->ev_active); trk 126 opal/runtime/opal_progress_threads.c trk->ev_active = true; trk 129 opal/runtime/opal_progress_threads.c trk->engine.t_run = progress_engine; trk 130 opal/runtime/opal_progress_threads.c trk->engine.t_arg = trk; trk 132 opal/runtime/opal_progress_threads.c int rc = opal_thread_start(&trk->engine); trk 142 opal/runtime/opal_progress_threads.c opal_progress_tracker_t *trk; trk 155 opal/runtime/opal_progress_threads.c OPAL_LIST_FOREACH(trk, &tracking, opal_progress_tracker_t) { trk 156 opal/runtime/opal_progress_threads.c if (0 == strcmp(name, trk->name)) { trk 158 opal/runtime/opal_progress_threads.c ++trk->refcount; trk 160 opal/runtime/opal_progress_threads.c return trk->ev_base; trk 164 opal/runtime/opal_progress_threads.c trk = OBJ_NEW(opal_progress_tracker_t); trk 165 opal/runtime/opal_progress_threads.c if (NULL == trk) { trk 170 opal/runtime/opal_progress_threads.c trk->name = strdup(name); trk 171 opal/runtime/opal_progress_threads.c if (NULL == trk->name) { trk 173 opal/runtime/opal_progress_threads.c OBJ_RELEASE(trk); trk 177 opal/runtime/opal_progress_threads.c if (NULL == (trk->ev_base = opal_event_base_create())) { trk 179 opal/runtime/opal_progress_threads.c OBJ_RELEASE(trk); trk 185 opal/runtime/opal_progress_threads.c opal_event_set(trk->ev_base, &trk->block, -1, OPAL_EV_PERSIST, trk 186 opal/runtime/opal_progress_threads.c dummy_timeout_cb, trk); trk 187 opal/runtime/opal_progress_threads.c opal_event_add(&trk->block, &long_timeout); trk 190 opal/runtime/opal_progress_threads.c OBJ_CONSTRUCT(&trk->engine, opal_thread_t); trk 191 opal/runtime/opal_progress_threads.c trk->engine_constructed = true; trk 192 opal/runtime/opal_progress_threads.c if (OPAL_SUCCESS != (rc = start_progress_engine(trk))) { trk 194 opal/runtime/opal_progress_threads.c OBJ_RELEASE(trk); trk 197 opal/runtime/opal_progress_threads.c opal_list_append(&tracking, &trk->super); trk 199 opal/runtime/opal_progress_threads.c return trk->ev_base; trk 204 opal/runtime/opal_progress_threads.c opal_progress_tracker_t *trk; trk 216 opal/runtime/opal_progress_threads.c OPAL_LIST_FOREACH(trk, &tracking, opal_progress_tracker_t) { trk 217 opal/runtime/opal_progress_threads.c if (0 == strcmp(name, trk->name)) { trk 219 opal/runtime/opal_progress_threads.c --trk->refcount; trk 222 opal/runtime/opal_progress_threads.c if (trk->refcount > 0) { trk 227 opal/runtime/opal_progress_threads.c if (trk->ev_active) { trk 228 opal/runtime/opal_progress_threads.c stop_progress_engine(trk); trk 231 opal/runtime/opal_progress_threads.c opal_list_remove_item(&tracking, &trk->super); trk 232 opal/runtime/opal_progress_threads.c OBJ_RELEASE(trk); trk 245 opal/runtime/opal_progress_threads.c opal_progress_tracker_t *trk; trk 257 opal/runtime/opal_progress_threads.c OPAL_LIST_FOREACH(trk, &tracking, opal_progress_tracker_t) { trk 258 opal/runtime/opal_progress_threads.c if (0 == strcmp(name, trk->name)) { trk 259 opal/runtime/opal_progress_threads.c if (trk->ev_active) { trk 260 opal/runtime/opal_progress_threads.c stop_progress_engine(trk); trk 272 opal/runtime/opal_progress_threads.c opal_progress_tracker_t *trk; trk 284 opal/runtime/opal_progress_threads.c OPAL_LIST_FOREACH(trk, &tracking, opal_progress_tracker_t) { trk 285 opal/runtime/opal_progress_threads.c if (0 == strcmp(name, trk->name)) { trk 286 opal/runtime/opal_progress_threads.c if (trk->ev_active) { trk 290 opal/runtime/opal_progress_threads.c return start_progress_engine(trk); trk 633 orte/orted/orted_submit.c trackr_t *trk; trk 637 orte/orted/orted_submit.c if (NULL != (trk = (trackr_t*)opal_pointer_array_get_item(&tool_jobs, i))) { trk 638 orte/orted/orted_submit.c OBJ_RELEASE(trk); trk 683 orte/orted/orted_submit.c trackr_t *trk; trk 688 orte/orted/orted_submit.c if (NULL == (trk = (trackr_t*)opal_pointer_array_get_item(&tool_jobs, index))) { trk 699 orte/orted/orted_submit.c if (OPAL_SUCCESS != (rc = opal_dss.pack(req, &trk->jdata->jobid, 1, ORTE_JOBID))) { trk 754 orte/orted/orted_submit.c trackr_t *trk; trk 804 orte/orted/orted_submit.c trk = OBJ_NEW(trackr_t); trk 805 orte/orted/orted_submit.c trk->jdata = jdata; trk 806 orte/orted/orted_submit.c trk->launch_cb = launch_cb; trk 807 orte/orted/orted_submit.c trk->launch_cbdata = launch_cbdata; trk 808 orte/orted/orted_submit.c trk->complete_cb = complete_cb; trk 809 orte/orted/orted_submit.c trk->complete_cbdata = complete_cbdata; trk 810 orte/orted/orted_submit.c trk->index = opal_pointer_array_add(&tool_jobs, trk); trk 814 orte/orted/orted_submit.c orte_set_attribute(&jdata->attributes, ORTE_JOB_ROOM_NUM, ORTE_ATTR_GLOBAL, &trk->index, OPAL_INT); trk 1143 orte/orted/orted_submit.c if (OPAL_SUCCESS != (rc = opal_dss.pack(req, &trk->index, 1, OPAL_INT))) { trk 1152 orte/orted/orted_submit.c *index = trk->index; trk 2047 orte/orted/orted_submit.c trackr_t *trk; trk 2076 orte/orted/orted_submit.c if (NULL == (trk = (trackr_t*)opal_pointer_array_get_item(&tool_jobs, tool_job_index))) { trk 2080 orte/orted/orted_submit.c trk->jdata->jobid = jobid; trk 2087 orte/orted/orted_submit.c if (OPAL_SUCCESS == opal_dss.unpack(buffer, &trk->jdata->state, &cnt, ORTE_JOB_STATE_T)) { trk 2091 orte/orted/orted_submit.c app = (orte_app_context_t*)opal_pointer_array_get_item(trk->jdata->apps, proc->app_idx); trk 2094 orte/orted/orted_submit.c orte_print_aborted_job(trk->jdata, app, proc, node); trk 2099 orte/orted/orted_submit.c if (NULL != trk->launch_cb) { trk 2100 orte/orted/orted_submit.c trk->launch_cb(tool_job_index, trk->jdata, ret, trk->launch_cbdata); trk 2106 orte/orted/orted_submit.c OBJ_RELEASE(trk); trk 2121 orte/orted/orted_submit.c trackr_t *trk; trk 2148 orte/orted/orted_submit.c if (NULL == (trk = (trackr_t*)opal_pointer_array_get_item(&tool_jobs, tool_job_index))) { trk 2158 orte/orted/orted_submit.c opal_dss.unpack(buffer, &trk->jdata->state, &cnt, ORTE_JOB_STATE_T); trk 2162 orte/orted/orted_submit.c app = (orte_app_context_t*)opal_pointer_array_get_item(trk->jdata->apps, proc->app_idx); trk 2165 orte/orted/orted_submit.c orte_print_aborted_job(trk->jdata, app, proc, node); trk 2169 orte/orted/orted_submit.c if (NULL != trk && NULL != trk->complete_cb) { trk 2170 orte/orted/orted_submit.c trk->complete_cb(tool_job_index, trk->jdata, ret, trk->complete_cbdata); trk 2174 orte/orted/orted_submit.c OBJ_RELEASE(trk); trk 195 orte/runtime/orte_wait.c orte_wait_tracker_t *trk = (orte_wait_tracker_t*)cbdata; trk 198 orte/runtime/orte_wait.c ORTE_ACQUIRE_OBJECT(trk); trk 201 orte/runtime/orte_wait.c if (t2->child == trk->child) { trk 204 orte/runtime/orte_wait.c OBJ_RELEASE(trk); trk 209 orte/runtime/orte_wait.c OBJ_RELEASE(trk); trk 214 orte/runtime/orte_wait.c orte_wait_tracker_t *trk; trk 223 orte/runtime/orte_wait.c trk = OBJ_NEW(orte_wait_tracker_t); trk 225 orte/runtime/orte_wait.c trk->child = child; trk 226 orte/runtime/orte_wait.c ORTE_THREADSHIFT(trk, orte_event_base, cancel_callback, ORTE_SYS_PRI);