int PMPI_Init_thread(int *argc, char ***argv, int required, int *provided)
{
if (provided != NULL) {
- *provided = MPI_THREAD_MULTIPLE;
+ *provided = MPI_THREAD_SINGLE;
}
return MPI_Init(argc, argv);
}
if (provided == NULL) {
retval = MPI_ERR_ARG;
} else {
- *provided = MPI_THREAD_MULTIPLE;
+ *provided = MPI_THREAD_SINGLE;
retval = MPI_SUCCESS;
}
return retval;
int dt_size_recv = 1;
if(!known)
dt_size_recv = smpi_datatype_size(recvtype);
+ if((smpi_comm_rank(comm)==root)){
extra->recvcounts= xbt_malloc(size*sizeof(int));
for(i=0; i< size; i++)//copy data to avoid bad free
extra->recvcounts[i] = recvcounts[i]*dt_size_recv;
-
+ }
TRACE_smpi_collective_in(rank, root_traced, __FUNCTION__,extra);
smpi_mpi_gatherv(sendtmpbuf, sendtmpcount, sendtmptype, recvbuf, recvcounts,
int dt_size_send = 1;
if(!known)
dt_size_send = smpi_datatype_size(sendtype);
+ if((smpi_comm_rank(comm)==root)){
extra->sendcounts= xbt_malloc(size*sizeof(int));
for(i=0; i< size; i++)//copy data to avoid bad free
extra->sendcounts[i] = sendcounts[i]*dt_size_send;
+ }
extra->datatype2 = encode_datatype(recvtype, &known);
int dt_size_recv = 1;
if(!known)
{
int retval = MPI_SUCCESS;
- strncpy(name, SIMIX_host_get_name(SIMIX_host_self()),
- strlen(SIMIX_host_get_name(SIMIX_host_self())) < MPI_MAX_PROCESSOR_NAME - 1 ?
- strlen(SIMIX_host_get_name(SIMIX_host_self())) +1 :
+ strncpy(name, sg_host_get_name(SIMIX_host_self()),
+ strlen(sg_host_get_name(SIMIX_host_self())) < MPI_MAX_PROCESSOR_NAME - 1 ?
+ strlen(sg_host_get_name(SIMIX_host_self())) +1 :
MPI_MAX_PROCESSOR_NAME - 1 );
*resultlen =
strlen(name) >