coll 567 ompi/dpm/dpm.c opal_list_t coll; coll 575 ompi/dpm/dpm.c OBJ_CONSTRUCT(&coll, opal_list_t); coll 579 ompi/dpm/dpm.c if (OMPI_SUCCESS != (ret = construct_peers(group, &coll))) { coll 581 ompi/dpm/dpm.c OPAL_LIST_DESTRUCT(&coll); coll 586 ompi/dpm/dpm.c if (OMPI_SUCCESS != (ret = construct_peers(group, &coll))) { coll 588 ompi/dpm/dpm.c OPAL_LIST_DESTRUCT(&coll); coll 594 ompi/dpm/dpm.c if (OMPI_SUCCESS != (ret = opal_pmix.fence(&coll, false))) { coll 596 ompi/dpm/dpm.c OPAL_LIST_DESTRUCT(&coll); coll 599 ompi/dpm/dpm.c OPAL_LIST_DESTRUCT(&coll); coll 113 ompi/mca/coll/base/coll_base_find_available.c mca_coll_base_component_2_0_0_t *coll = coll 116 ompi/mca/coll/base/coll_base_find_available.c return coll->collm_init_query(enable_progress_threads, coll 133 ompi/mca/coll/base/coll_base_frame.c MCA_BASE_FRAMEWORK_DECLARE(ompi, coll, "Collectives", NULL, NULL, NULL, coll 89 orte/mca/grpcomm/base/base.h ORTE_DECLSPEC void orte_grpcomm_base_mark_distance_recv(orte_grpcomm_coll_t *coll, uint32_t distance); coll 90 orte/mca/grpcomm/base/base.h ORTE_DECLSPEC unsigned int orte_grpcomm_base_check_distance_recv(orte_grpcomm_coll_t *coll, uint32_t distance); coll 144 orte/mca/grpcomm/base/grpcomm_base_stubs.c orte_grpcomm_coll_t *coll; coll 179 orte/mca/grpcomm/base/grpcomm_base_stubs.c coll = orte_grpcomm_base_get_tracker(cd->sig, true); coll 180 orte/mca/grpcomm/base/grpcomm_base_stubs.c if (NULL == coll) { coll 186 orte/mca/grpcomm/base/grpcomm_base_stubs.c coll->cbfunc = cd->cbfunc; coll 187 orte/mca/grpcomm/base/grpcomm_base_stubs.c coll->cbdata = cd->cbdata; coll 192 orte/mca/grpcomm/base/grpcomm_base_stubs.c if (ORTE_SUCCESS == (rc = active->module->allgather(coll, cd->buf))) { coll 229 orte/mca/grpcomm/base/grpcomm_base_stubs.c orte_grpcomm_coll_t *coll; coll 236 orte/mca/grpcomm/base/grpcomm_base_stubs.c OPAL_LIST_FOREACH(coll, &orte_grpcomm_base.ongoing, orte_grpcomm_coll_t) { coll 238 orte/mca/grpcomm/base/grpcomm_base_stubs.c if (NULL == coll->sig->signature) { coll 241 orte/mca/grpcomm/base/grpcomm_base_stubs.c return coll; coll 246 orte/mca/grpcomm/base/grpcomm_base_stubs.c if (OPAL_EQUAL == (rc = opal_dss.compare(sig, coll->sig, ORTE_SIGNATURE))) { coll 250 orte/mca/grpcomm/base/grpcomm_base_stubs.c return coll; coll 262 orte/mca/grpcomm/base/grpcomm_base_stubs.c coll = OBJ_NEW(orte_grpcomm_coll_t); coll 263 orte/mca/grpcomm/base/grpcomm_base_stubs.c opal_dss.copy((void **)&coll->sig, (void *)sig, ORTE_SIGNATURE); coll 267 orte/mca/grpcomm/base/grpcomm_base_stubs.c (void)opal_dss.print(&tmp, NULL, coll->sig, ORTE_SIGNATURE); coll 273 orte/mca/grpcomm/base/grpcomm_base_stubs.c opal_list_append(&orte_grpcomm_base.ongoing, &coll->super); coll 276 orte/mca/grpcomm/base/grpcomm_base_stubs.c if (ORTE_SUCCESS != (rc = create_dmns(sig, &coll->dmns, &coll->ndmns))) { coll 287 orte/mca/grpcomm/base/grpcomm_base_stubs.c for (n=0; n < coll->ndmns; n++) { coll 288 orte/mca/grpcomm/base/grpcomm_base_stubs.c if (nm->name.vpid == coll->dmns[n]) { coll 289 orte/mca/grpcomm/base/grpcomm_base_stubs.c coll->nexpected++; coll 300 orte/mca/grpcomm/base/grpcomm_base_stubs.c for (n=0; n < coll->ndmns; n++) { coll 301 orte/mca/grpcomm/base/grpcomm_base_stubs.c if (coll->dmns[n] == ORTE_PROC_MY_NAME->vpid) { coll 302 orte/mca/grpcomm/base/grpcomm_base_stubs.c coll->nexpected++; coll 307 orte/mca/grpcomm/base/grpcomm_base_stubs.c return coll; coll 552 orte/mca/grpcomm/base/grpcomm_base_stubs.c void orte_grpcomm_base_mark_distance_recv (orte_grpcomm_coll_t *coll, coll 554 orte/mca/grpcomm/base/grpcomm_base_stubs.c opal_bitmap_set_bit (&coll->distance_mask_recv, distance); coll 557 orte/mca/grpcomm/base/grpcomm_base_stubs.c unsigned int orte_grpcomm_base_check_distance_recv (orte_grpcomm_coll_t *coll, coll 559 orte/mca/grpcomm/base/grpcomm_base_stubs.c return opal_bitmap_is_set_bit (&coll->distance_mask_recv, distance); coll 48 orte/mca/grpcomm/direct/grpcomm_direct.c static int allgather(orte_grpcomm_coll_t *coll, coll 124 orte/mca/grpcomm/direct/grpcomm_direct.c static int allgather(orte_grpcomm_coll_t *coll, coll 140 orte/mca/grpcomm/direct/grpcomm_direct.c if (OPAL_SUCCESS != (rc = opal_dss.pack(relay, &coll->sig, 1, ORTE_SIGNATURE))) { coll 169 orte/mca/grpcomm/direct/grpcomm_direct.c orte_grpcomm_coll_t *coll; coll 184 orte/mca/grpcomm/direct/grpcomm_direct.c if (NULL == (coll = orte_grpcomm_base_get_tracker(sig, true))) { coll 191 orte/mca/grpcomm/direct/grpcomm_direct.c coll->nreported++; coll 193 orte/mca/grpcomm/direct/grpcomm_direct.c opal_dss.copy_payload(&coll->bucket, buffer); coll 198 orte/mca/grpcomm/direct/grpcomm_direct.c (int)coll->nexpected, (int)coll->nreported)); coll 201 orte/mca/grpcomm/direct/grpcomm_direct.c if (coll->nreported == coll->nexpected) { coll 225 orte/mca/grpcomm/direct/grpcomm_direct.c opal_dss.copy_payload(reply, &coll->bucket); coll 244 orte/mca/grpcomm/direct/grpcomm_direct.c opal_dss.copy_payload(reply, &coll->bucket); coll 268 orte/mca/grpcomm/direct/grpcomm_direct.c opal_list_t coll; coll 288 orte/mca/grpcomm/direct/grpcomm_direct.c OBJ_CONSTRUCT(&coll, opal_list_t); coll 296 orte/mca/grpcomm/direct/grpcomm_direct.c OBJ_DESTRUCT(&coll); coll 307 orte/mca/grpcomm/direct/grpcomm_direct.c OBJ_DESTRUCT(&coll); coll 317 orte/mca/grpcomm/direct/grpcomm_direct.c OBJ_DESTRUCT(&coll); coll 330 orte/mca/grpcomm/direct/grpcomm_direct.c OBJ_DESTRUCT(&coll); coll 353 orte/mca/grpcomm/direct/grpcomm_direct.c OBJ_DESTRUCT(&coll); coll 365 orte/mca/grpcomm/direct/grpcomm_direct.c OBJ_DESTRUCT(&coll); coll 519 orte/mca/grpcomm/direct/grpcomm_direct.c orte_routed.get_routing_list(&coll); coll 522 orte/mca/grpcomm/direct/grpcomm_direct.c if (opal_list_is_empty(&coll)) { coll 530 orte/mca/grpcomm/direct/grpcomm_direct.c while (NULL != (item = opal_list_remove_first(&coll))) { coll 579 orte/mca/grpcomm/direct/grpcomm_direct.c OPAL_LIST_DESTRUCT(&coll); coll 605 orte/mca/grpcomm/direct/grpcomm_direct.c orte_grpcomm_coll_t *coll; coll 628 orte/mca/grpcomm/direct/grpcomm_direct.c if (NULL == (coll = orte_grpcomm_base_get_tracker(sig, false))) { coll 634 orte/mca/grpcomm/direct/grpcomm_direct.c if (NULL != coll->cbfunc) { coll 635 orte/mca/grpcomm/direct/grpcomm_direct.c coll->cbfunc(ret, buffer, coll->cbdata); coll 637 orte/mca/grpcomm/direct/grpcomm_direct.c opal_list_remove_item(&orte_grpcomm_base.ongoing, &coll->super); coll 638 orte/mca/grpcomm/direct/grpcomm_direct.c OBJ_RELEASE(coll); coll 123 orte/mca/grpcomm/grpcomm.h typedef int (*orte_grpcomm_base_module_allgather_fn_t)(orte_grpcomm_coll_t *coll, coll 795 orte/mca/plm/rsh/plm_rsh_module.c opal_list_t coll; coll 815 orte/mca/plm/rsh/plm_rsh_module.c OBJ_CONSTRUCT(&coll, opal_list_t); coll 816 orte/mca/plm/rsh/plm_rsh_module.c orte_routed.get_routing_list(&coll); coll 819 orte/mca/plm/rsh/plm_rsh_module.c if (0 == opal_list_get_size(&coll)) { coll 825 orte/mca/plm/rsh/plm_rsh_module.c OBJ_DESTRUCT(&coll); coll 834 orte/mca/plm/rsh/plm_rsh_module.c OBJ_DESTRUCT(&coll); coll 842 orte/mca/plm/rsh/plm_rsh_module.c OBJ_DESTRUCT(&coll); coll 847 orte/mca/plm/rsh/plm_rsh_module.c OPAL_LIST_FOREACH(child, &coll, orte_namelist_t) { coll 855 orte/mca/plm/rsh/plm_rsh_module.c OBJ_DESTRUCT(&coll); coll 884 orte/mca/plm/rsh/plm_rsh_module.c OPAL_LIST_DESTRUCT(&coll); coll 1033 orte/mca/plm/rsh/plm_rsh_module.c opal_list_t coll; coll 1180 orte/mca/plm/rsh/plm_rsh_module.c OBJ_CONSTRUCT(&coll, opal_list_t); coll 1181 orte/mca/plm/rsh/plm_rsh_module.c orte_routed.get_routing_list(&coll); coll 1201 orte/mca/plm/rsh/plm_rsh_module.c OPAL_LIST_FOREACH(child, &coll, orte_namelist_t) { coll 41 orte/mca/routed/base/base.h ORTE_DECLSPEC void orte_routed_base_xcast_routing(opal_list_t *coll, coll 40 orte/mca/routed/base/routed_base_fns.c void orte_routed_base_xcast_routing(opal_list_t *coll, opal_list_t *my_children) coll 63 orte/mca/routed/base/routed_base_fns.c opal_list_append(coll, &nm->super); coll 67 orte/mca/routed/base/routed_base_fns.c if (0 == opal_list_get_size(coll)) { coll 76 orte/mca/routed/base/routed_base_fns.c opal_list_append(coll, &nm->super); coll 85 orte/mca/routed/base/routed_base_fns.c opal_list_append(coll, &nm->super); coll 51 orte/mca/routed/binomial/routed_binomial.c static void get_routing_list(opal_list_t *coll); coll 512 orte/mca/routed/binomial/routed_binomial.c static void get_routing_list(opal_list_t *coll) coll 522 orte/mca/routed/binomial/routed_binomial.c orte_routed_base_xcast_routing(coll, &my_children); coll 51 orte/mca/routed/debruijn/routed_debruijn.c static void get_routing_list(opal_list_t *coll); coll 442 orte/mca/routed/debruijn/routed_debruijn.c static void get_routing_list(opal_list_t *coll) coll 451 orte/mca/routed/debruijn/routed_debruijn.c orte_routed_base_xcast_routing(coll, &my_children); coll 43 orte/mca/routed/direct/routed_direct.c static void get_routing_list(opal_list_t *coll); coll 317 orte/mca/routed/direct/routed_direct.c static void get_routing_list(opal_list_t *coll) coll 331 orte/mca/routed/direct/routed_direct.c orte_routed_base_xcast_routing(coll, &my_children); coll 53 orte/mca/routed/radix/routed_radix.c static void get_routing_list(opal_list_t *coll); coll 507 orte/mca/routed/radix/routed_radix.c static void get_routing_list(opal_list_t *coll) coll 516 orte/mca/routed/radix/routed_radix.c orte_routed_base_xcast_routing(coll, &my_children); coll 167 orte/mca/routed/routed.h typedef void (*orte_routed_module_get_routing_list_fn_t)(opal_list_t *coll); coll 139 test/monitoring/check_monitoring.c GENERATE_CS(coll, "coll_monitoring_messages", MPI_T_PVAR_CLASS_SIZE, MPI_T_PVAR_CLASS_SIZE)