202 |
(coupler->connector->recv->offsetInShared[i+1]- coupler->connector->recv->offsetInShared[i])*block_size, |
(coupler->connector->recv->offsetInShared[i+1]- coupler->connector->recv->offsetInShared[i])*block_size, |
203 |
MPI_DOUBLE, |
MPI_DOUBLE, |
204 |
coupler->connector->recv->neighbor[i], |
coupler->connector->recv->neighbor[i], |
205 |
mpi_info->msg_tag_counter+coupler->recv->neighbor[i], |
mpi_info->msg_tag_counter+coupler->connector->recv->neighbor[i], |
206 |
mpi_info->comm, |
mpi_info->comm, |
207 |
&(coupler->mpi_requests[i])); |
&(coupler->mpi_requests[i])); |
208 |
#endif |
#endif |
219 |
{ |
{ |
220 |
for (i=0; i< coupler->connector->send->numNeighbors; ++i) { |
for (i=0; i< coupler->connector->send->numNeighbors; ++i) { |
221 |
#ifdef PASO_MPI |
#ifdef PASO_MPI |
222 |
MPI_Issend(&(coupler->send_buffer[coupler->send->offsetInShared[i] * block_size]), |
MPI_Issend(&(coupler->send_buffer[coupler->connector->send->offsetInShared[i] * block_size]), |
223 |
(coupler->connector->send->offsetInShared[i+1]- coupler->connector->send->offsetInShared[i])*block_size, |
(coupler->connector->send->offsetInShared[i+1]- coupler->connector->send->offsetInShared[i])*block_size, |
224 |
MPI_DOUBLE, |
MPI_DOUBLE, |
225 |
coupler->connector->send->neighbor[i], |
coupler->connector->send->neighbor[i], |
226 |
mpi_info->msg_tag_counter+mpi_info->rank, |
mpi_info->msg_tag_counter+mpi_info->rank, |
227 |
mpi_info->comm, |
mpi_info->comm, |
228 |
&(coupler->mpi_requests[i+ coupler->recv->numNeighbors])); |
&(coupler->mpi_requests[i+ coupler->connector->recv->numNeighbors])); |
229 |
#endif |
#endif |
230 |
} |
} |
231 |
} |
} |