void * buf_tmp = xbt_malloc(count);
- subtype->serialize( sendbuf, buf_tmp,1, subtype);
+ subtype->serialize( sendbuf, buf_tmp,count/smpi_datatype_size(sendtype), subtype);
subtype = recvtype->substruct;
- subtype->unserialize( buf_tmp, recvbuf,1, subtype);
+ subtype->unserialize( buf_tmp, recvbuf,count/smpi_datatype_size(recvtype), subtype);
free(buf_tmp);
}
type_c->old_type->substruct);
contiguous_vector_char += type_c->block_length*type_c->size_oldtype;
+ if((i+1)%type_c->block_count ==0)
+ noncontiguous_vector_char += type_c->block_length*smpi_datatype_get_extent(type_c->old_type);
+ else
noncontiguous_vector_char += type_c->block_stride*smpi_datatype_get_extent(type_c->old_type);
}
}
type_c->block_length,
type_c->old_type->substruct);
contiguous_vector_char += type_c->block_length*type_c->size_oldtype;
+ if((i+1)%type_c->block_count ==0)
+ noncontiguous_vector_char += type_c->block_length*smpi_datatype_get_extent(type_c->old_type);
+ else
noncontiguous_vector_char += type_c->block_stride*smpi_datatype_get_extent(type_c->old_type);
}
}
void *struct_type, int flags){
MPI_Datatype new_t= xbt_new(s_smpi_mpi_datatype_t,1);
new_t->size = size;
- new_t->has_subtype = has_subtype;
+ new_t->has_subtype = size>0? has_subtype:0;
new_t->lb = lb;
new_t->ub = ub;
new_t->flags = flags;
type_c->old_type->substruct);
contiguous_vector_char += type_c->block_length*type_c->size_oldtype;
+ if((i+1)%type_c->block_count ==0)
+ noncontiguous_vector_char += type_c->block_length*type_c->size_oldtype;
+ else
noncontiguous_vector_char += type_c->block_stride;
}
}
type_c->block_length,
type_c->old_type->substruct);
contiguous_vector_char += type_c->block_length*type_c->size_oldtype;
+ if((i+1)%type_c->block_count ==0)
+ noncontiguous_vector_char += type_c->block_length*type_c->size_oldtype;
+ else
noncontiguous_vector_char += type_c->block_stride;
}
}
int smpi_op_is_commute(MPI_Op op)
{
- return op-> is_commute;
+ return (op==MPI_OP_NULL) ? 1 : op-> is_commute;
}
void smpi_op_destroy(MPI_Op op)