comm_->group()->index(target_rank), smpi_process()->index(), SMPI_RMA_TAG+2, comm_,
MPI_OP_NULL);
- //start the send, with another process than us as sender.
+ //start the send, with another process than us as sender.
sreq->start();
//push request to receiver's win
xbt_mutex_acquire(send_win->mut_);
if(locked != 1)
return MPI_ERR_WIN;
}
- //FIXME: local version
+ //FIXME: local version
if(target_count*target_datatype->get_extent()>recv_win->size_)
return MPI_ERR_ARG;
return MPI_SUCCESS;
}
-int Win::get_accumulate( void *origin_addr, int origin_count, MPI_Datatype origin_datatype, void *result_addr,
- int result_count, MPI_Datatype result_datatype, int target_rank, MPI_Aint target_disp, int target_count,
+int Win::get_accumulate( void *origin_addr, int origin_count, MPI_Datatype origin_datatype, void *result_addr,
+ int result_count, MPI_Datatype result_datatype, int target_rank, MPI_Aint target_disp, int target_count,
MPI_Datatype target_datatype, MPI_Op op, MPI_Request* request){
//get sender pointer
int size = static_cast<int>(reqqs->size());
if (size > 0) {
size = 0;
- std::vector<MPI_Request>* myreqqs = new std::vector<MPI_Request>();
+ std::vector<MPI_Request> myreqqs;
std::vector<MPI_Request>::iterator iter = reqqs->begin();
while (iter != reqqs->end()){
if(((*iter)!=MPI_REQUEST_NULL) && (((*iter)->src() == rank) || ((*iter)->dst() == rank))){
- myreqqs->push_back(*iter);
- iter = reqqs->erase(iter);
- size++;
+ myreqqs.push_back(*iter);
+ iter = reqqs->erase(iter);
+ size++;
} else {
++iter;
}
}
if(size >0){
- MPI_Request* treqs = &(*myreqqs)[0];
+ MPI_Request* treqs = &myreqqs[0];
Request::waitall(size, treqs, MPI_STATUSES_IGNORE);
- myreqqs->clear();
- delete myreqqs;
+ myreqqs.clear();
}
}
xbt_mutex_release(mut_);