std::atomic_int_fast32_t refcount_{1};
s4u::Barrier piface_;
unsigned int expected_actors_;
- // std::vector<actor::ActorImpl*> arrived_actors_;
std::deque<BarrierAcquisitionImplPtr> ongoing_acquisitions_;
static unsigned next_id_;
unsigned id_ = next_id_++;
friend s4u::Barrier;
public:
- BarrierImpl(int expected_actors) : piface_(this), expected_actors_(expected_actors) {}
+ explicit BarrierImpl(int expected_actors) : piface_(this), expected_actors_(expected_actors) {}
BarrierImpl(BarrierImpl const&) = delete;
BarrierImpl& operator=(BarrierImpl const&) = delete;
delete sem;
}
}
- unsigned get_id() { return id_; }
-
+ unsigned get_id() const { return id_; }
s4u::Semaphore& sem() { return piface_; }
};
} // namespace activity
colls::allgather(&connected_wins_[rank_], sizeof(MPI_Win), MPI_BYTE, connected_wins_.data(), sizeof(MPI_Win),
MPI_BYTE, comm);
if (MC_is_active() || MC_record_replay_is_active()){
- if (bar_.get() == 0) // First to arrive on the barrier
+ if (bar_.get() == nullptr) // First to arrive on the barrier
bar_ = s4u::Barrier::create(comm->size());
bar_->wait();
}else{
SET_TESTS_PROPERTIES(mbi-${basefile} PROPERTIES DEPENDS mbi-${basefile})
SET_TESTS_PROPERTIES(mbi-${basefile} PROPERTIES DEPENDS simgrid-mc)
endforeach()
+ file(REMOVE_RECURSE ${CMAKE_BINARY_DIR}/MBI/tmp) # Clean temp files
if("${CMAKE_BINARY_DIR}" STREQUAL "${CMAKE_HOME_DIRECTORY}")
else()