Home
last modified time | relevance | path

Searched refs:recv_offset (Results 1 – 25 of 78) sorted by relevance

1234

/dports/net/mpich/mpich-3.4.3/src/mpi/coll/ireduce_scatter_block/
H A Direduce_scatter_block_intra_sched_noncommutative.c23 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 Direduce_scatter_block_tsp_recexch_algos.h30 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 Dreduce_scatter_block_intra_noncommutative.c37 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 Direduce_scatter_intra_sched_noncommutative.c33 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 Direduce_scatter_tsp_recexch_algos.h57 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 Dreduce_scatter_intra_noncommutative.c35 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 DMessageReader.java55 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 Diallgather_tsp_recexch_algos.h20 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 Diallgather_intra_sched_recursive_doubling.c55 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 Diallgatherv_tsp_recexch_algos.h22 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 Diallgatherv_intra_sched_recursive_doubling.c16 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 Dnettest_xti.h16 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 Dnettest_unix.h15 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 Dnettest_dlpi.h16 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 Dnettest_bsd.h64 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 Dnettest_sctp.h17 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 Dbcast_intra_scatter_recursive_doubling_allgather.c45 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 Dibcast_intra_sched_scatter_recursive_doubling_allgather.c60 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 Dallgatherv_intra_recursive_doubling.c39 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 Dremap2d.cpp100 &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 Dremap3d.cpp102 &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 Dremap_kokkos.cpp164 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 Dallgather_intra_recursive_doubling.c37 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 Dremap.cpp102 &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 Dallgatherv.c92 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()

1234