grp 878 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c struct bufferevent_rate_limit_group *grp) grp 881 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c LOCK_GROUP(grp); grp 882 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = grp->rate_limit.read_limit; grp 883 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c UNLOCK_GROUP(grp); grp 891 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c struct bufferevent_rate_limit_group *grp) grp 894 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c LOCK_GROUP(grp); grp 895 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = grp->rate_limit.write_limit; grp 896 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c UNLOCK_GROUP(grp); grp 958 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c struct bufferevent_rate_limit_group *grp, ev_ssize_t decr) grp 962 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c LOCK_GROUP(grp); grp 963 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c old_limit = grp->rate_limit.read_limit; grp 964 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c new_limit = (grp->rate_limit.read_limit -= decr); grp 967 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c _bev_group_suspend_reading(grp); grp 969 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c _bev_group_unsuspend_reading(grp); grp 972 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c UNLOCK_GROUP(grp); grp 978 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c struct bufferevent_rate_limit_group *grp, ev_ssize_t decr) grp 982 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c LOCK_GROUP(grp); grp 983 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c old_limit = grp->rate_limit.write_limit; grp 984 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c new_limit = (grp->rate_limit.write_limit -= decr); grp 987 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c _bev_group_suspend_writing(grp); grp 989 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c _bev_group_unsuspend_writing(grp); grp 992 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c UNLOCK_GROUP(grp); grp 997 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_rate_limit_group_get_totals(struct bufferevent_rate_limit_group *grp, grp 1000 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c EVUTIL_ASSERT(grp != NULL); grp 1002 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c *total_read_out = grp->total_read; grp 1004 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c *total_written_out = grp->total_written; grp 1008 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bufferevent_rate_limit_group_reset_totals(struct bufferevent_rate_limit_group *grp) grp 1010 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c grp->total_read = grp->total_written = 0; grp 129 opal/mca/pmix/pmix4x/pmix/examples/asyncgroup.c char *grp; grp 145 opal/mca/pmix/pmix4x/pmix/examples/asyncgroup.c grp = info[n].value.data.string; grp 154 opal/mca/pmix/pmix4x/pmix/examples/asyncgroup.c rc = PMIx_Group_join_nb(grp, source, PMIX_GROUP_ACCEPT, NULL, 0, grpcomplete, NULL); grp 794 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Group_construct(const char grp[], grp 799 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Group_construct_nb(const char grp[], grp 848 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Group_invite(const char grp[], grp 853 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Group_invite_nb(const char grp[], grp 894 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Group_join(const char grp[], grp 900 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Group_join_nb(const char grp[], grp 923 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Group_leave(const char grp[], grp 926 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Group_leave_nb(const char grp[], grp 954 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Group_destruct(const char grp[], grp 957 opal/mca/pmix/pmix4x/pmix/include/pmix.h PMIX_EXPORT pmix_status_t PMIx_Group_destruct_nb(const char grp[], grp 516 opal/mca/pmix/pmix4x/pmix/include/pmix_server.h typedef pmix_status_t (*pmix_server_grp_fn_t)(pmix_group_operation_t op, char grp[], grp 121 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_EXPORT pmix_status_t PMIx_Group_construct(const char grp[], grp 152 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (PMIX_SUCCESS != (rc = PMIx_Group_construct_nb(grp, procs, nprocs, info, ninfo, info_cbfunc, cb))) { grp 171 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_EXPORT pmix_status_t PMIx_Group_construct_nb(const char grp[], grp 238 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c msg, &grp, 1, PMIX_STRING); grp 300 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_EXPORT pmix_status_t PMIx_Group_destruct(const char grp[], grp 329 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (PMIX_SUCCESS != (rc = PMIx_Group_destruct_nb(grp, info, ninfo, op_cbfunc, (void*)&cb))) { grp 346 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_EXPORT pmix_status_t PMIx_Group_destruct_nb(const char grp[], grp 376 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (NULL == grp) { grp 412 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c msg, &grp, 1, PMIX_STRING); grp 573 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_EXPORT pmix_status_t PMIx_Group_invite(const char grp[], grp 596 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (NULL == grp || NULL == procs) { grp 602 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c rc = PMIx_Group_invite_nb(grp, procs, nprocs, info, ninfo, info_cbfunc, (void*)&cb); grp 640 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_INFO_LOAD(&cb.info[n], PMIX_GROUP_ID, grp, PMIX_STRING); grp 660 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_EXPORT pmix_status_t PMIx_Group_invite_nb(const char grp[], grp 690 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (NULL == grp || NULL == procs) { grp 772 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_INFO_LOAD(&cb->info[n], PMIX_GROUP_ID, grp, PMIX_STRING); grp 796 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_EXPORT pmix_status_t PMIx_Group_join(const char grp[], grp 823 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (PMIX_SUCCESS != (rc = PMIx_Group_join_nb(grp, leader, opt, info, ninfo, info_cbfunc, cb))) { grp 839 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_EXPORT pmix_status_t PMIx_Group_join_nb(const char grp[], grp 938 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_group_t *grp; grp 968 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c grp = PMIX_NEW(pmix_group_t); grp 969 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c grp->grpid = strdup(grpid); grp 970 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c grp->nmbrs = cd->ntargets; grp 971 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_PROC_CREATE(grp->members, grp->nmbrs); grp 972 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c memcpy(grp->members, cd->targets, cd->ntargets * sizeof(pmix_proc_t)); grp 973 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_list_append(&pmix_server_globals.groups, &grp->super); grp 797 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_group_t *grp; grp 840 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_LIST_FOREACH(grp, &pmix_server_globals.groups, pmix_group_t) { grp 842 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (PMIX_CHECK_NSPACE(procs[n].nspace, grp->grpid)) { grp 845 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c gcd->grp = grp; grp 851 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c nmbrs += grp->nmbrs - 1; // account for replacing current proc grp 870 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c memcpy(&newprocs[n], &gcd->grp->members[gcd->rank], sizeof(pmix_proc_t)); grp 874 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c memcpy(&newprocs[n], gcd->grp->members, gcd->grp->nmbrs * sizeof(pmix_proc_t)); grp 875 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c n += gcd->grp->nmbrs; grp 3711 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_group_t *grp = (pmix_group_t*)trk->cbdata; grp 3742 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL != grp) { grp 3743 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_remove_item(&pmix_server_globals.groups, &grp->super); grp 3744 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_RELEASE(grp); grp 3887 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_group_t *grp, *pgrp; grp 3914 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c grp = NULL; grp 3917 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c grp = pgrp; grp 3921 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == grp) { grp 3923 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c grp = PMIX_NEW(pmix_group_t); grp 3924 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == grp) { grp 3928 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c grp->grpid = grpid; grp 3929 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_append(&pmix_server_globals.groups, &grp->super); grp 3956 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == grp->members) { grp 4006 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c grp->members = procs; grp 4007 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c grp->nmbrs = nprocs; grp 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))) { grp 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))) { grp 4044 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->cbdata = grp; grp 4076 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c for (n=0; n < grp->nmbrs; n++) { grp 4079 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (PMIX_RANK_LOCAL_PEERS == grp->members[n].rank || grp 4080 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_RANK_LOCAL_NODE == grp->members[n].rank) { grp 4089 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (PMIX_CHECK_PROCID(&grp->members[n], &pr->info->pname)) { grp 4177 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c rc = pmix_host_server.group(PMIX_GROUP_CONSTRUCT, grp->grpid, grp 4218 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_group_t *grp, *pgrp; grp 4238 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c grp = NULL; grp 4241 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c grp = pgrp; grp 4249 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == grp) { grp 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))) { grp 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))) { grp 4292 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c trk->cbdata = grp; grp 4328 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c rc = pmix_host_server.group(PMIX_GROUP_DESTRUCT, grp->grpid, grp 4329 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c grp->members, grp->nmbrs, grp 156 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_group_t *grp; grp 320 orte/mca/rmaps/resilient/rmaps_resilient.c int grp; grp 345 orte/mca/rmaps/resilient/rmaps_resilient.c grp = 0; grp 348 orte/mca/rmaps/resilient/rmaps_resilient.c ftgrp->ftgrp = grp++;