// if (src < ((inter_rank + 1) * num_core)) {
if (src < comm_size) {
Request::recv(tmp_buf, count, dtype, src, tag, comm, &status);
- if(op!=MPI_OP_NULL) op->apply( tmp_buf, rbuf, &count, &dtype);
+ if(op!=MPI_OP_NULL) op->apply( tmp_buf, rbuf, &count, dtype);
//printf("Node %d recv from node %d when mask is %d\n", rank, src, mask);
}
} else {
tmp_buf, curr_count, dtype, (dst * num_core), tag,
comm, &status);
- if(op!=MPI_OP_NULL) op->apply( tmp_buf, (char *)rbuf + recv_offset, &curr_count, &dtype);
+ if(op!=MPI_OP_NULL) op->apply( tmp_buf, (char *)rbuf + recv_offset, &curr_count, dtype);
mask *= 2;
curr_count /= 2;