recv_buf 143 ompi/mca/coll/base/coll_base_reduce_scatter.c char *recv_buf = NULL, *recv_buf_free = NULL; recv_buf 179 ompi/mca/coll/base/coll_base_reduce_scatter.c recv_buf = recv_buf_free - gap; recv_buf 214 ompi/mca/coll/base/coll_base_reduce_scatter.c err = MCA_PML_CALL(recv(recv_buf, count, dtype, rank - 1, recv_buf 219 ompi/mca/coll/base/coll_base_reduce_scatter.c ompi_op_reduce(op, recv_buf, result_buf, count, dtype); recv_buf 302 ompi/mca/coll/base/coll_base_reduce_scatter.c err = MCA_PML_CALL(irecv(recv_buf + (ptrdiff_t)tmp_disps[recv_index] * extent, recv_buf 336 ompi/mca/coll/base/coll_base_reduce_scatter.c recv_buf + (ptrdiff_t)tmp_disps[recv_index] * extent, recv_buf 63 ompi/mca/coll/base/coll_base_reduce_scatter_block.c char *recv_buf = NULL, *recv_buf_free = NULL; recv_buf 91 ompi/mca/coll/base/coll_base_reduce_scatter_block.c recv_buf = recv_buf_free - gap; recv_buf 96 ompi/mca/coll/base/coll_base_reduce_scatter_block.c comm->c_coll->coll_reduce(sbuf, recv_buf, count, dtype, op, 0, recv_buf 101 ompi/mca/coll/base/coll_base_reduce_scatter_block.c err = comm->c_coll->coll_scatter(recv_buf, rcount, dtype, recv_buf 76 ompi/mca/coll/basic/coll_basic_reduce_scatter.c char *recv_buf = NULL, *recv_buf_free = NULL; recv_buf 113 ompi/mca/coll/basic/coll_basic_reduce_scatter.c recv_buf = recv_buf_free - gap; recv_buf 148 ompi/mca/coll/basic/coll_basic_reduce_scatter.c err = MCA_PML_CALL(recv(recv_buf, count, dtype, rank - 1, recv_buf 154 ompi/mca/coll/basic/coll_basic_reduce_scatter.c ompi_op_reduce(op, recv_buf, result_buf, count, dtype); recv_buf 237 ompi/mca/coll/basic/coll_basic_reduce_scatter.c err = MCA_PML_CALL(irecv(recv_buf + tmp_disps[recv_index] * extent, recv_buf 271 ompi/mca/coll/basic/coll_basic_reduce_scatter.c recv_buf + tmp_disps[recv_index] * extent, recv_buf 325 ompi/mca/coll/basic/coll_basic_reduce_scatter.c recv_buf = recv_buf_free - gap; recv_buf 334 ompi/mca/coll/basic/coll_basic_reduce_scatter.c comm->c_coll->coll_reduce(sbuf, recv_buf, count, dtype, op, 0, recv_buf 339 ompi/mca/coll/basic/coll_basic_reduce_scatter.c err = comm->c_coll->coll_scatterv(recv_buf, rcounts, disps, dtype, recv_buf 94 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c char **recv_buf, recv_buf 845 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c char **recv_buf = NULL; recv_buf 911 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c recv_buf = (char **) calloc (fh->f_size, sizeof(char *)); recv_buf 912 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if (NULL == recv_buf){ recv_buf 918 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if(recv_size[i]) recv_buf[i] = recv_buf 923 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c ret = MCA_PML_CALL(irecv(recv_buf[i], recv_buf 982 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c recv_buf, offset_len, recv_buf 1002 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if (recv_buf) { recv_buf 1004 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c free(recv_buf[i]); recv_buf 1007 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c free(recv_buf); recv_buf 1043 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c &(recv_buf[p][recv_buf_idx[p]]), size_in_buf); \ recv_buf 1068 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c char **recv_buf, recv_buf 71 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c *flat_buf, char **recv_buf, ADIO_Offset recv_buf 849 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c char **recv_buf = NULL; recv_buf 888 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c recv_buf = (char **) ADIOI_Malloc(nprocs * sizeof(char*)); recv_buf 890 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (recv_size[i]) recv_buf[i] = recv_buf 896 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c MPI_Irecv(recv_buf[i], recv_size[i], MPI_BYTE, i, recv_buf 946 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Fill_user_buffer(fd, buf, flat_buf, recv_buf, recv_buf 962 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (recv_size[i]) ADIOI_Free(recv_buf[i]); recv_buf 963 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Free(recv_buf); recv_buf 998 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c &(recv_buf[p][recv_buf_idx[p]]), size_in_buf); \ recv_buf 1019 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c *flat_buf, char **recv_buf, ADIO_Offset recv_buf 1143 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c char **recv_buf = NULL; recv_buf 1169 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c recv_buf = (char **) ADIOI_Malloc(nprocs * sizeof(char *)); recv_buf 1170 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (i=0; i<nprocs; i++) { recv_buf[i] = all_recv_buf + rdispls[i]; } recv_buf 1231 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Fill_user_buffer(fd, buf, flat_buf, recv_buf, recv_buf 1251 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Free( recv_buf ); recv_buf 153 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c char **recv_buf; recv_buf 161 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c *flat_buf, char **recv_buf, ADIO_Offset recv_buf 1030 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c char **recv_buf = NULL; recv_buf 1065 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c recv_buf = (char **) ADIOI_Malloc(nprocs * sizeof(char*)); recv_buf 1066 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->recv_buf = recv_buf; recv_buf 1068 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (recv_size[i]) recv_buf[i] = (char *)ADIOI_Malloc(recv_size[i]); recv_buf 1073 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c MPI_Irecv(recv_buf[i], recv_size[i], MPI_BYTE, i, recv_buf 1127 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->recv_buf, vars->offset_list, vars->len_list, recv_buf 1148 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (vars->recv_size[i]) ADIOI_Free(vars->recv_buf[i]); recv_buf 1149 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->recv_buf); recv_buf 43 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c *flat_buf, char **recv_buf, ADIO_Offset recv_buf 785 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c char **recv_buf = NULL; recv_buf 824 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c recv_buf = (char **) ADIOI_Malloc(nprocs * sizeof(char*)); recv_buf 826 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c if (recv_size[i]) recv_buf[i] = recv_buf 832 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c MPI_Irecv(recv_buf[i], recv_size[i], MPI_BYTE, i, recv_buf 882 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Fill_user_buffer(fd, buf, flat_buf, recv_buf, recv_buf 898 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c if (recv_size[i]) ADIOI_Free(recv_buf[i]); recv_buf 899 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Free(recv_buf); recv_buf 934 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c &(recv_buf[p][recv_buf_idx[p]]), size_in_buf); \ recv_buf 955 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c *flat_buf, char **recv_buf, ADIO_Offset recv_buf 218 ompi/mca/osc/ucx/osc_ucx_component.c char *recv_buf = NULL; recv_buf 360 ompi/mca/osc/ucx/osc_ucx_component.c recv_buf = (char *)calloc(comm_size, 2 * sizeof(uint64_t)); recv_buf 362 ompi/mca/osc/ucx/osc_ucx_component.c MPI_BYTE, recv_buf, 2 * sizeof(uint64_t), recv_buf 371 ompi/mca/osc/ucx/osc_ucx_component.c memcpy(&(module->addrs[i]), recv_buf + i * 2 * sizeof(uint64_t), sizeof(uint64_t)); recv_buf 372 ompi/mca/osc/ucx/osc_ucx_component.c memcpy(&(module->state_addrs[i]), recv_buf + i * 2 * sizeof(uint64_t) + sizeof(uint64_t), sizeof(uint64_t)); recv_buf 374 ompi/mca/osc/ucx/osc_ucx_component.c free(recv_buf);