Home
last modified time | relevance | path

Searched refs:is_aggregator (Results 1 – 11 of 11) sorted by relevance

/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/common/ompio/
H A Dcommon_ompio_aggregators.h75 int *is_aggregator,
100 int *decision_list, int is_aggregator);
H A Dcommon_ompio_aggregators.c561 int is_aggregator = 0; in mca_common_ompio_create_groups() local
580 &is_aggregator, in mca_common_ompio_create_groups()
600 is_aggregator); in mca_common_ompio_create_groups()
659 int is_aggregator){ in mca_common_ompio_merge_initial_groups() argument
676 if(is_aggregator){ in mca_common_ompio_merge_initial_groups()
1225 int *is_aggregator, in mca_common_ompio_prepare_to_group() argument
1293 *is_aggregator = 1; in mca_common_ompio_prepare_to_group()
1297 if(*is_aggregator == 1){ in mca_common_ompio_prepare_to_group()
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/common/ompio/
H A Dcommon_ompio_aggregators.h80 int *is_aggregator,
105 int *decision_list, int is_aggregator);
H A Dcommon_ompio_aggregators.c554 int is_aggregator = 0; in mca_common_ompio_create_groups() local
574 &is_aggregator, in mca_common_ompio_create_groups()
594 is_aggregator); in mca_common_ompio_create_groups()
691 int is_aggregator){ in mca_common_ompio_merge_initial_groups() argument
708 if(is_aggregator){ in mca_common_ompio_merge_initial_groups()
1259 int *is_aggregator, in mca_common_ompio_prepare_to_group() argument
1329 *is_aggregator = 1; in mca_common_ompio_prepare_to_group()
1333 if(*is_aggregator == 1){ in mca_common_ompio_prepare_to_group()
/dports/net/mpich2/mpich2-1.5/src/mpi/romio/adio/common/
H A Dad_open.c14 static int is_aggregator(int rank, ADIO_File fd);
125 fd->is_agg = is_aggregator(rank, fd); in ADIO_Open()
194 int is_aggregator(int rank, ADIO_File fd ) { in is_aggregator() function
/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/io/romio314/romio/adio/common/
H A Dad_open.c14 static int is_aggregator(int rank, ADIO_File fd);
161 fd->is_agg = is_aggregator(rank, fd); in ADIO_Open()
220 int is_aggregator(int rank, ADIO_File fd ) { in is_aggregator() function
/dports/math/py-pandas/pandas-1.2.5/pandas/core/
H A Daggregation.py494 is_aggregator = lambda x: isinstance(x, (list, tuple, dict)) function
500 if any(is_aggregator(x) for _, x in func.items()):
503 if not is_aggregator(v):
711 is_aggregator = lambda x: isinstance(x, (list, tuple, dict)) function
721 if any(is_aggregator(x) for x in arg.values()):
/dports/net/mpich/mpich-3.4.3/src/mpi/romio/adio/common/
H A Dad_open.c11 static int is_aggregator(int rank, ADIO_File fd);
156 fd->is_agg = is_aggregator(rank, fd); in ADIO_Open()
233 int is_aggregator(int rank, ADIO_File fd) in is_aggregator() function
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/io/romio321/romio/adio/common/
H A Dad_open.c13 static int is_aggregator(int rank, ADIO_File fd);
166 fd->is_agg = is_aggregator(rank, fd); in ADIO_Open()
242 int is_aggregator(int rank, ADIO_File fd ) { in is_aggregator() function
/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/fcoll/two_phase/
H A Dfcoll_two_phase_file_write_all.c118 static int is_aggregator(int rank,
545 if (is_aggregator(fh->f_rank, in mca_fcoll_two_phase_file_write_all()
1508 int is_aggregator(int rank, in is_aggregator() function
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/fcoll/two_phase/
H A Dfcoll_two_phase_file_write_all.c118 static int is_aggregator(int rank,
549 if (is_aggregator(fh->f_rank, in mca_fcoll_two_phase_file_write_all()
1529 int is_aggregator(int rank, in is_aggregator() function