X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/5fc309f0124ca91be813d84d9c4f597162f07a05..f5f972472de4503232dcb8658fb650b6f7c40b80:/include/simgrid/s4u/Activity.hpp diff --git a/include/simgrid/s4u/Activity.hpp b/include/simgrid/s4u/Activity.hpp index 085c853c97..b846b3c90f 100644 --- a/include/simgrid/s4u/Activity.hpp +++ b/include/simgrid/s4u/Activity.hpp @@ -7,7 +7,9 @@ #define SIMGRID_S4U_ACTIVITY_HPP #include "xbt/asserts.h" +#include #include +#include #include namespace simgrid { @@ -86,17 +88,7 @@ public: /** Put some user data onto the Activity */ - kernel::activity::ActivityImplPtr get_impl() { return pimpl_; } - -#ifndef DOXYGEN - XBT_ATTRIB_DEPRECATED_v324("Please use Activity::wait_for()") virtual void wait(double timeout) = 0; - XBT_ATTRIB_DEPRECATED_v323("Please use Activity::get_state()") Activity::State getState() { return state_; } - XBT_ATTRIB_DEPRECATED_v323("Please use Activity::get_remaining()") double getRemains() { return get_remaining(); } - XBT_ATTRIB_DEPRECATED_v323("Please use Activity::set_remaining()") Activity* setRemains(double remains) - { - return set_remaining(remains); - } -#endif + kernel::activity::ActivityImpl* get_impl() const { return pimpl_.get(); } private: kernel::activity::ActivityImplPtr pimpl_ = nullptr; @@ -109,8 +101,19 @@ private: std::string name_ = ""; std::string tracing_category_ = ""; void* user_data_ = nullptr; + std::atomic_int_fast32_t refcount_{0}; public: +#ifndef DOXYGEN + friend void intrusive_ptr_release(AnyActivity* a) + { + if (a->refcount_.fetch_sub(1, std::memory_order_release) == 1) { + std::atomic_thread_fence(std::memory_order_acquire); + delete a; + } + } + friend void intrusive_ptr_add_ref(AnyActivity* a) { a->refcount_.fetch_add(1, std::memory_order_relaxed); } +#endif AnyActivity* set_name(const std::string& name) { xbt_assert(get_state() == State::INITED, "Cannot change the name of an activity after its start"); @@ -135,11 +138,6 @@ public: } void* get_user_data() { return user_data_; } - XBT_ATTRIB_DEPRECATED_v323("Please use Activity::set_user_data()") AnyActivity* setUserData(void* data) - { - return set_user_data(data); - } - XBT_ATTRIB_DEPRECATED_v323("Please use Activity::get_user_data()") void* getUserData() { return user_data_; } }; } // namespace s4u