/dports/net/mpich/mpich-3.4.3/src/mpi/coll/ireduce_scatter_block/ |
H A D | ireduce_scatter_block_intra_sched_noncommutative.c | 23 int recv_offset, send_offset; in MPIR_Ireduce_scatter_block_intra_sched_noncommutative() local 75 recv_offset = 0; in MPIR_Ireduce_scatter_block_intra_sched_noncommutative() 86 recv_offset += size; in MPIR_Ireduce_scatter_block_intra_sched_noncommutative() 95 mpi_errno = MPIR_Sched_recv((incoming_data + recv_offset * true_extent), in MPIR_Ireduce_scatter_block_intra_sched_noncommutative() 104 mpi_errno = MPIR_Sched_reduce((incoming_data + recv_offset * true_extent), in MPIR_Ireduce_scatter_block_intra_sched_noncommutative() 105 (outgoing_data + recv_offset * true_extent), in MPIR_Ireduce_scatter_block_intra_sched_noncommutative() 110 mpi_errno = MPIR_Sched_reduce((outgoing_data + recv_offset * true_extent), in MPIR_Ireduce_scatter_block_intra_sched_noncommutative() 111 (incoming_data + recv_offset * true_extent), in MPIR_Ireduce_scatter_block_intra_sched_noncommutative() 120 send_offset = recv_offset; in MPIR_Ireduce_scatter_block_intra_sched_noncommutative() 126 result_ptr = (char *) (buf0_was_inout ? tmp_buf0 : tmp_buf1) + recv_offset * true_extent; in MPIR_Ireduce_scatter_block_intra_sched_noncommutative()
|
H A D | ireduce_scatter_block_tsp_recexch_algos.h | 30 int i, phase, offset, send_offset, recv_offset; in MPIR_TSP_Ireduce_scatter_block_sched_intra_recexch() local 145 recv_offset = offset * extent * recvcount; in MPIR_TSP_Ireduce_scatter_block_sched_intra_recexch() 149 recv_offset, recv_cnt * recvcount)); in MPIR_TSP_Ireduce_scatter_block_sched_intra_recexch() 160 (char *) tmp_results + recv_offset, in MPIR_TSP_Ireduce_scatter_block_sched_intra_recexch()
|
/dports/net/mpich/mpich-3.4.3/src/mpi/coll/reduce_scatter_block/ |
H A D | reduce_scatter_block_intra_noncommutative.c | 37 int recv_offset, send_offset; in MPIR_Reduce_scatter_block_intra_noncommutative() local 88 recv_offset = 0; in MPIR_Reduce_scatter_block_intra_noncommutative() 99 recv_offset += size; in MPIR_Reduce_scatter_block_intra_noncommutative() 107 incoming_data + recv_offset * true_extent, in MPIR_Reduce_scatter_block_intra_noncommutative() 122 mpi_errno = MPIR_Reduce_local(incoming_data + recv_offset * true_extent, in MPIR_Reduce_scatter_block_intra_noncommutative() 123 outgoing_data + recv_offset * true_extent, in MPIR_Reduce_scatter_block_intra_noncommutative() 128 mpi_errno = MPIR_Reduce_local(outgoing_data + recv_offset * true_extent, in MPIR_Reduce_scatter_block_intra_noncommutative() 129 incoming_data + recv_offset * true_extent, in MPIR_Reduce_scatter_block_intra_noncommutative() 137 send_offset = recv_offset; in MPIR_Reduce_scatter_block_intra_noncommutative() 143 result_ptr = (char *) (buf0_was_inout ? tmp_buf0 : tmp_buf1) + recv_offset * true_extent; in MPIR_Reduce_scatter_block_intra_noncommutative()
|
/dports/net/mpich/mpich-3.4.3/src/mpi/coll/ireduce_scatter/ |
H A D | ireduce_scatter_intra_sched_noncommutative.c | 33 int recv_offset, send_offset; in MPIR_Ireduce_scatter_intra_sched_noncommutative() local 89 recv_offset = 0; in MPIR_Ireduce_scatter_intra_sched_noncommutative() 100 recv_offset += size; in MPIR_Ireduce_scatter_intra_sched_noncommutative() 109 mpi_errno = MPIR_Sched_recv((incoming_data + recv_offset * true_extent), in MPIR_Ireduce_scatter_intra_sched_noncommutative() 118 mpi_errno = MPIR_Sched_reduce((incoming_data + recv_offset * true_extent), in MPIR_Ireduce_scatter_intra_sched_noncommutative() 119 (outgoing_data + recv_offset * true_extent), in MPIR_Ireduce_scatter_intra_sched_noncommutative() 124 mpi_errno = MPIR_Sched_reduce((outgoing_data + recv_offset * true_extent), in MPIR_Ireduce_scatter_intra_sched_noncommutative() 125 (incoming_data + recv_offset * true_extent), in MPIR_Ireduce_scatter_intra_sched_noncommutative() 134 send_offset = recv_offset; in MPIR_Ireduce_scatter_intra_sched_noncommutative() 140 result_ptr = (char *) (buf0_was_inout ? tmp_buf0 : tmp_buf1) + recv_offset * true_extent; in MPIR_Ireduce_scatter_intra_sched_noncommutative()
|
H A D | ireduce_scatter_tsp_recexch_algos.h | 57 int send_cnt, recv_cnt, send_offset, recv_offset, nvtcs, vtcs[2]; in MPIR_TSP_Ireduce_scatter_sched_intra_recexch_step2() local 98 recv_offset = displs[offset] * extent; in MPIR_TSP_Ireduce_scatter_sched_intra_recexch_step2() 105 recv_offset, recv_cnt)); in MPIR_TSP_Ireduce_scatter_sched_intra_recexch_step2() 107 MPIR_TSP_sched_irecv((char *) tmp_recvbuf + recv_offset, recv_cnt, in MPIR_TSP_Ireduce_scatter_sched_intra_recexch_step2() 114 MPIR_TSP_sched_reduce_local((char *) tmp_recvbuf + recv_offset, in MPIR_TSP_Ireduce_scatter_sched_intra_recexch_step2() 115 (char *) tmp_results + recv_offset, in MPIR_TSP_Ireduce_scatter_sched_intra_recexch_step2()
|
/dports/net/mpich/mpich-3.4.3/src/mpi/coll/reduce_scatter/ |
H A D | reduce_scatter_intra_noncommutative.c | 35 int recv_offset, send_offset; in MPIR_Reduce_scatter_intra_noncommutative() local 90 recv_offset = 0; in MPIR_Reduce_scatter_intra_noncommutative() 101 recv_offset += size; in MPIR_Reduce_scatter_intra_noncommutative() 109 incoming_data + recv_offset * true_extent, in MPIR_Reduce_scatter_intra_noncommutative() 124 mpi_errno = MPIR_Reduce_local(incoming_data + recv_offset * true_extent, in MPIR_Reduce_scatter_intra_noncommutative() 125 outgoing_data + recv_offset * true_extent, in MPIR_Reduce_scatter_intra_noncommutative() 130 MPIR_Reduce_local(outgoing_data + recv_offset * true_extent, in MPIR_Reduce_scatter_intra_noncommutative() 131 incoming_data + recv_offset * true_extent, size, datatype, op); in MPIR_Reduce_scatter_intra_noncommutative() 138 send_offset = recv_offset; in MPIR_Reduce_scatter_intra_noncommutative() 144 result_ptr = (char *) (buf0_was_inout ? tmp_buf0 : tmp_buf1) + recv_offset * true_extent; in MPIR_Reduce_scatter_intra_noncommutative()
|
/dports/net/seda/seda-release-20020712/seda/src/seda/sandStorm/test/bench/simple-p2p/ |
H A D | MessageReader.java | 55 int recv_offset = 0; in parse() local 59 while (recv_offset < recv_data.length) { in parse() 60 int toread = Math.min(MSG_SIZE - cur_offset, recv_data.length - recv_offset); in parse() 61 …n("MessageReader: recv_data.length "+recv_data.length+", recv_offset "+recv_offset+", cur_data.len… in parse() 62 System.arraycopy(recv_data, recv_offset, cur_data, cur_offset, toread); in parse() 64 recv_offset += toread; in parse()
|
/dports/net/mpich/mpich-3.4.3/src/mpi/coll/iallgather/ |
H A D | iallgather_tsp_recexch_algos.h | 20 int partner, offset, count, send_offset, recv_offset; in MPIR_TSP_Iallgather_sched_intra_recexch_data_exchange() local 40 recv_offset = offset * recv_extent * recvcount; in MPIR_TSP_Iallgather_sched_intra_recexch_data_exchange() 43 recv_offset, count)); in MPIR_TSP_Iallgather_sched_intra_recexch_data_exchange() 45 MPIR_TSP_sched_irecv(((char *) recvbuf + recv_offset), count * recvcount, recvtype, in MPIR_TSP_Iallgather_sched_intra_recexch_data_exchange() 63 int send_offset, recv_offset, i; in MPIR_TSP_Iallgather_sched_intra_recexch_step1() local 80 recv_offset = step1_recvfrom[i] * recv_extent * recvcount; in MPIR_TSP_Iallgather_sched_intra_recexch_step1() 81 MPIR_TSP_sched_irecv(((char *) recvbuf + recv_offset), recvcount, recvtype, in MPIR_TSP_Iallgather_sched_intra_recexch_step1() 101 int phase, i, j, count, nbr, send_offset, recv_offset, offset, rank_for_offset; in MPIR_TSP_Iallgather_sched_intra_recexch_step2() local 139 recv_offset = offset * recv_extent * recvcount; in MPIR_TSP_Iallgather_sched_intra_recexch_step2() 141 MPIR_TSP_sched_irecv(((char *) recvbuf + recv_offset), count * recvcount, recvtype, in MPIR_TSP_Iallgather_sched_intra_recexch_step2() [all …]
|
H A D | iallgather_intra_sched_recursive_doubling.c | 55 int offset, send_offset, recv_offset; in MPIR_Iallgather_intra_sched_recursive_doubling() local 111 recv_offset = dst_tree_root * recvcount * recvtype_extent; in MPIR_Iallgather_intra_sched_recursive_doubling() 118 mpi_errno = MPIR_Sched_recv_status(((char *) recvbuf + recv_offset), in MPIR_Iallgather_intra_sched_recursive_doubling()
|
/dports/net/mpich/mpich-3.4.3/src/mpi/coll/iallgatherv/ |
H A D | iallgatherv_tsp_recexch_algos.h | 22 int partner, offset, count, send_offset, recv_offset; in MPIR_TSP_Iallgatherv_sched_intra_recexch_data_exchange() local 48 recv_offset = displs[offset] * recv_extent; in MPIR_TSP_Iallgatherv_sched_intra_recexch_data_exchange() 54 recv_offset, recv_count)); in MPIR_TSP_Iallgatherv_sched_intra_recexch_data_exchange() 56 MPIR_TSP_sched_irecv(((char *) recvbuf + recv_offset), recv_count, recvtype, in MPIR_TSP_Iallgatherv_sched_intra_recexch_data_exchange() 75 int send_offset, recv_offset, i; in MPIR_TSP_Iallgatherv_sched_intra_recexch_step1() local 92 recv_offset = displs[step1_recvfrom[i]] * recv_extent; in MPIR_TSP_Iallgatherv_sched_intra_recexch_step1() 93 MPIR_TSP_sched_irecv(((char *) recvbuf + recv_offset), recvcounts[step1_recvfrom[i]], in MPIR_TSP_Iallgatherv_sched_intra_recexch_step1() 114 int phase, i, j, count, nbr, send_offset, recv_offset, offset, rank_for_offset; in MPIR_TSP_Iallgatherv_sched_intra_recexch_step2() local 156 recv_offset = displs[offset] * recv_extent; in MPIR_TSP_Iallgatherv_sched_intra_recexch_step2() 161 MPIR_TSP_sched_irecv(((char *) recvbuf + recv_offset), recv_count, recvtype, in MPIR_TSP_Iallgatherv_sched_intra_recexch_step2() [all …]
|
H A D | iallgatherv_intra_sched_recursive_doubling.c | 16 int curr_count, send_offset, incoming_count, recv_offset; in MPIR_Iallgatherv_intra_sched_recursive_doubling() local 99 recv_offset = 0; in MPIR_Iallgatherv_intra_sched_recursive_doubling() 101 recv_offset += recvcounts[j]; in MPIR_Iallgatherv_intra_sched_recursive_doubling() 111 mpi_errno = MPIR_Sched_recv(((char *) tmp_buf + recv_offset * recvtype_sz), in MPIR_Iallgatherv_intra_sched_recursive_doubling()
|
/dports/benchmarks/netperf/netperf-d566775bf/src/ |
H A D | nettest_xti.h | 16 int recv_offset; /* and at what offset from that alignment? */ member 63 int recv_offset; member 108 int recv_offset; member 154 int recv_offset; member 193 int recv_offset; member
|
H A D | nettest_unix.h | 15 int recv_offset; /* and at what offset from that */ member 63 int recv_offset; member 107 int recv_offset; member 146 int recv_offset; member
|
H A D | nettest_dlpi.h | 16 int recv_offset; /* and at what offset from that */ member 67 int recv_offset; member 113 int recv_offset; member 154 int recv_offset; member
|
H A D | nettest_bsd.h | 64 uint32_t recv_offset; /* offset from recv alignment */ member 200 int recv_offset; /* and at what offset from that alignment? */ member 301 int recv_offset; member 346 int recv_offset; member 392 int recv_offset; member 440 int recv_offset; member 480 int recv_offset; member 525 int recv_offset; member
|
H A D | nettest_sctp.h | 17 int recv_offset; /* and at what offset from that alignment? */ member 65 int recv_offset; member
|
/dports/net/mpich/mpich-3.4.3/src/mpi/coll/bcast/ |
H A D | bcast_intra_scatter_recursive_doubling_allgather.c | 45 int recv_offset, tree_root, nprocs_completed, offset; in MPIR_Bcast_intra_scatter_recursive_doubling_allgather() local 132 recv_offset = dst_tree_root * scatter_size; in MPIR_Bcast_intra_scatter_recursive_doubling_allgather() 137 ((char *) tmp_buf + recv_offset), in MPIR_Bcast_intra_scatter_recursive_doubling_allgather() 138 (nbytes - recv_offset < 0 ? 0 : nbytes - recv_offset), in MPIR_Bcast_intra_scatter_recursive_doubling_allgather()
|
/dports/net/mpich/mpich-3.4.3/src/mpi/coll/ibcast/ |
H A D | ibcast_intra_sched_scatter_recursive_doubling_allgather.c | 60 int recv_offset, tree_root, nprocs_completed, offset; in MPIR_Ibcast_intra_sched_scatter_recursive_doubling_allgather() local 148 recv_offset = dst_tree_root * scatter_size; in MPIR_Ibcast_intra_sched_scatter_recursive_doubling_allgather() 153 if ((nbytes - recv_offset) > 0) in MPIR_Ibcast_intra_sched_scatter_recursive_doubling_allgather() 154 incoming_count = MPL_MIN((nbytes - recv_offset), (mask * scatter_size)); in MPIR_Ibcast_intra_sched_scatter_recursive_doubling_allgather() 162 mpi_errno = MPIR_Sched_recv_status(((char *) tmp_buf + recv_offset), in MPIR_Ibcast_intra_sched_scatter_recursive_doubling_allgather()
|
/dports/net/mpich/mpich-3.4.3/src/mpi/coll/allgatherv/ |
H A D | allgatherv_intra_recursive_doubling.c | 39 send_offset, recv_offset, nprocs_completed, k, offset, tmp_mask, tree_root; in MPIR_Allgatherv_intra_recursive_doubling() local 107 recv_offset = 0; in MPIR_Allgatherv_intra_recursive_doubling() 109 recv_offset += recvcounts[j]; in MPIR_Allgatherv_intra_recursive_doubling() 114 ((char *) tmp_buf + recv_offset * recvtype_sz), in MPIR_Allgatherv_intra_recursive_doubling() 115 (total_count - recv_offset) * recvtype_sz, MPI_BYTE, dst, in MPIR_Allgatherv_intra_recursive_doubling()
|
/dports/science/sparta/sparta-20Oct2021/src/FFT/ |
H A D | remap2d.cpp | 100 &out[plan->recv_offset[irecv]],&plan->unpackplan[irecv]); in remap_2d() 108 &out[plan->recv_offset[irecv]],&plan->unpackplan[irecv]); in remap_2d() 283 plan->recv_offset = (int *) malloc(nrecv*sizeof(int)); in remap_2d_create_plan() 291 if (plan->recv_offset == NULL || plan->recv_size == NULL || in remap_2d_create_plan() 310 plan->recv_offset[nrecv] = nqty * ((overlap.jlo-out.jlo)*out.isize + in remap_2d_create_plan() 318 plan->recv_offset[nrecv] = nqty * ((overlap.ilo-out.ilo)*out.jsize + in remap_2d_create_plan() 415 free(plan->recv_offset); in remap_2d_destroy_plan()
|
H A D | remap3d.cpp | 102 &out[plan->recv_offset[irecv]],&plan->unpackplan[irecv]); in remap_3d() 110 &out[plan->recv_offset[irecv]],&plan->unpackplan[irecv]); in remap_3d() 188 &out[plan->recv_offset[nrecvmap[irecv]]], in remap_3d() 390 plan->recv_offset = (int *) malloc(nrecv*sizeof(int)); in remap_3d_create_plan() 398 if (plan->recv_offset == NULL || plan->recv_size == NULL || in remap_3d_create_plan() 417 plan->recv_offset[nrecv] = nqty * in remap_3d_create_plan() 428 plan->recv_offset[nrecv] = nqty * in remap_3d_create_plan() 439 plan->recv_offset[nrecv] = nqty * in remap_3d_create_plan() 661 free(plan->recv_offset); in remap_3d_destroy_plan()
|
/dports/science/lammps/lammps-stable_29Sep2021/src/KOKKOS/ |
H A D | remap_kokkos.cpp | 164 int out_offset = plan->recv_offset[irecv]; in remap_3d_kokkos() 179 int out_offset = plan->recv_offset[irecv]; in remap_3d_kokkos() 375 plan->recv_offset = (int *) malloc(nrecv*sizeof(int)); in remap_3d_create_plan_kokkos() 383 if (plan->recv_offset == nullptr || plan->recv_size == nullptr || in remap_3d_create_plan_kokkos() 402 plan->recv_offset[nrecv] = nqty * in remap_3d_create_plan_kokkos() 413 plan->recv_offset[nrecv] = nqty * in remap_3d_create_plan_kokkos() 424 plan->recv_offset[nrecv] = nqty * in remap_3d_create_plan_kokkos() 516 free(plan->recv_offset); in remap_3d_destroy_plan_kokkos()
|
/dports/net/mpich/mpich-3.4.3/src/mpi/coll/allgather/ |
H A D | allgather_intra_recursive_doubling.c | 37 send_offset, recv_offset, nprocs_completed, k, offset, tmp_mask, tree_root; in MPIR_Allgather_intra_recursive_doubling() local 80 recv_offset = dst_tree_root * recvcount * recvtype_extent; in MPIR_Allgather_intra_recursive_doubling() 86 ((char *) recvbuf + recv_offset), in MPIR_Allgather_intra_recursive_doubling()
|
/dports/science/lammps/lammps-stable_29Sep2021/src/KSPACE/ |
H A D | remap.cpp | 102 &out[plan->recv_offset[irecv]],&plan->unpackplan[irecv]); in remap_3d() 110 &out[plan->recv_offset[irecv]],&plan->unpackplan[irecv]); in remap_3d() 188 &out[plan->recv_offset[nrecvmap[irecv]]], in remap_3d() 390 plan->recv_offset = (int *) malloc(nrecv*sizeof(int)); in remap_3d_create_plan() 398 if (plan->recv_offset == nullptr || plan->recv_size == nullptr || in remap_3d_create_plan() 417 plan->recv_offset[nrecv] = nqty * in remap_3d_create_plan() 428 plan->recv_offset[nrecv] = nqty * in remap_3d_create_plan() 439 plan->recv_offset[nrecv] = nqty * in remap_3d_create_plan() 661 free(plan->recv_offset); in remap_3d_destroy_plan()
|
/dports/net/mpich2/mpich2-1.5/src/mpi/coll/ |
H A D | allgatherv.c | 92 send_offset, recv_offset, last_recv_cnt, nprocs_completed, k, in MPIR_Allgatherv_intra() local 185 recv_offset = 0; in MPIR_Allgatherv_intra() 187 recv_offset += recvcounts[j]; in MPIR_Allgatherv_intra() 192 ((char *)tmp_buf + recv_offset * recvtype_extent), in MPIR_Allgatherv_intra() 193 total_count - recv_offset, recvtype, dst, in MPIR_Allgatherv_intra() 385 recv_offset = 0; in MPIR_Allgatherv_intra() 387 recv_offset += recvcounts[j]; in MPIR_Allgatherv_intra() 388 recv_offset *= nbytes; in MPIR_Allgatherv_intra() 394 ((char *)tmp_buf + recv_offset), in MPIR_Allgatherv_intra() 395 tmp_buf_size-recv_offset, MPI_BYTE, dst, in MPIR_Allgatherv_intra()
|