* under the terms of the license (GNU LGPL) which comes with this package. */
#include "simgrid/s4u/Host.hpp"
+#include <climits>
#include "src/simix/smx_private.h"
+#include "src/smpi/private.h"
#include "src/smpi/smpi_comm.hpp"
#include "src/smpi/smpi_coll.hpp"
#include "src/smpi/smpi_datatype.hpp"
(*newcomm) = new Comm(cp, this->topo());
int ret = MPI_SUCCESS;
- if(!attributes()->empty()){
+ if (not attributes()->empty()) {
int flag;
void* value_out;
for(auto it : *attributes()){
}
MPI_Comm Comm::get_intra_comm(){
- if (this == MPI_COMM_UNINITIALIZED || this==MPI_COMM_WORLD)
+ if (this == MPI_COMM_UNINITIALIZED || this==MPI_COMM_WORLD)
return smpi_process()->comm_intra();
else return intra_comm_;
}
}
if(i != 0 && group_out != MPI_COMM_WORLD->group() && group_out != MPI_GROUP_EMPTY)
Group::unref(group_out);
-
+
Request::waitall(reqs, requests, MPI_STATUS_IGNORE);
xbt_free(requests);
}
smpi_process()->comm_world()->init_smp();
int comm_size = this->size();
-
- // If we are in replay - perform an ugly hack
+
+ // If we are in replay - perform an ugly hack
// tell SimGrid we are not in replay for a while, because we need the buffers to be copied for the following calls
bool replaying = false; //cache data to set it back again after
if(smpi_process()->replaying()){
is_blocked_=global_blocked;
}
xbt_free(leader_list);
-
+
if(replaying)
- smpi_process()->set_replaying(true);
+ smpi_process()->set_replaying(true);
}
MPI_Comm Comm::f2c(int id) {