X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/978ba263685f9f76f4721930decccebbbf776816..e98ff738e16a6e5a18426c8686407511f4c0c8a4:/include/simgrid/s4u/Barrier.hpp diff --git a/include/simgrid/s4u/Barrier.hpp b/include/simgrid/s4u/Barrier.hpp index 85e2c0564c..2d6db86085 100644 --- a/include/simgrid/s4u/Barrier.hpp +++ b/include/simgrid/s4u/Barrier.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2018-2019. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2018-2023. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -6,39 +6,35 @@ #ifndef SIMGRID_S4U_BARRIER_HPP #define SIMGRID_S4U_BARRIER_HPP +#include +#include #include #include -#include #include #include #include -constexpr int SG_BARRIER_SERIAL_THREAD = -1; - -namespace simgrid { -namespace s4u { +namespace simgrid::s4u { class XBT_PUBLIC Barrier { -private: - MutexPtr mutex_; - ConditionVariablePtr cond_; - unsigned int expected_actors_; - unsigned int arrived_actors_ = 0; + kernel::activity::BarrierImpl* pimpl_; + friend kernel::activity::BarrierImpl; - /* refcounting */ - std::atomic_int_fast32_t refcount_{0}; + explicit Barrier(kernel::activity::BarrierImpl* pimpl) : pimpl_(pimpl) {} public: - explicit Barrier(unsigned int count); - ~Barrier() = default; #ifndef DOXYGEN Barrier(Barrier const&) = delete; Barrier& operator=(Barrier const&) = delete; #endif + /** \static Creates a barrier for the given amount of actors */ static BarrierPtr create(unsigned int expected_actors); + /** Blocks into the barrier. Every waiting actors will be unlocked once the expected amount of actors reaches the barrier */ int wait(); + /** Returns some debug information about the barrier */ + std::string to_string() const; #ifndef DOXYGEN /* refcounting */ @@ -46,7 +42,6 @@ public: friend XBT_PUBLIC void intrusive_ptr_release(Barrier* barrier); #endif }; -} // namespace s4u -} // namespace simgrid +} // namespace simgrid::s4u #endif