s_smpi_subtype_t *subtype = static_cast<s_smpi_subtype_t*>(datatype->substruct);
- if(((flags & RECV) && (flags & ACCUMULATE)) || (datatype->has_subtype == 1)){
+ if(((flags & RECV) && (flags & ACCUMULATE)) || (datatype->sizeof_substruct != 0)){
// This part handles the problem of non-contiguous memory
old_buf = buf;
buf = count==0 ? NULL : xbt_malloc(count*smpi_datatype_size(datatype));
- if ((datatype->has_subtype == 1) && (flags & SEND)) {
+ if ((datatype->sizeof_substruct != 0) && (flags & SEND)) {
subtype->serialize(old_buf, buf, count, datatype->substruct);
}
}
request->op = MPI_REPLACE;
request->send = 0;
request->recv = 0;
- if (flags & SEND) smpi_datatype_unuse(datatype);
+ // if (flags & SEND) smpi_datatype_unuse(datatype);
return request;
}
}
void* buf = request->buf;
- if ( (! (request->flags & SSEND)) &&
- (static_cast<int>(request->size) < xbt_cfg_get_int("smpi/send_is_detached_thresh"))) {
+ if ( (! (request->flags & SSEND)) && ((request->flags & RMA) ||
+ (static_cast<int>(request->size) < xbt_cfg_get_int("smpi/send_is_detached_thresh")))) {
void *oldbuf = NULL;
request->detached = 1;
XBT_DEBUG("Send request %p is detached", request);
request->refcount++;
- if(request->old_type->has_subtype == 0){
+ if(request->old_type->sizeof_substruct == 0){
oldbuf = request->buf;
if (!smpi_process_get_replaying() && oldbuf && request->size!=0){
if((smpi_privatize_global_variables)
print_request("Finishing", req);
MPI_Datatype datatype = req->old_type;
- if((req->flags & ACCUMULATE) || (datatype->has_subtype == 1)){
+ if((req->flags & ACCUMULATE) || (datatype->sizeof_substruct != 0)){
if (!smpi_process_get_replaying()){
if( smpi_privatize_global_variables && ((char*)req->old_buf >= smpi_start_data_exe)
&& ((char*)req->old_buf < smpi_start_data_exe + smpi_size_data_exe )){
}
}
- if(datatype->has_subtype == 1){
+ if(datatype->sizeof_substruct != 0){
// This part handles the problem of non-contignous memory the unserialization at the reception
s_smpi_subtype_t *subtype = static_cast<s_smpi_subtype_t*>(datatype->substruct);
if(req->flags & RECV)
}
}
smpi_comm_unuse(req->comm);
- smpi_datatype_unuse(datatype);
+ smpi_datatype_unuse(req->old_type);
}
if (TRACE_smpi_view_internals()) {
}
if(req->detached_sender!=NULL){
+ smpi_datatype_unuse(req->detached_sender->old_type);
+ smpi_comm_unuse(req->detached_sender->comm);
smpi_mpi_request_free(&(req->detached_sender));
}
if(req->flags & PERSISTENT)
{
int i, size, count;
int *displs;
- int rank = smpi_process_index();
+ int rank = smpi_comm_rank(comm);
void *tmpbuf;
/* arbitrarily choose root as rank 0 */