X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ea08504776a7b5b76f57bfee434b43ed572ca9f1..9fd6cbc6c3b06f4b09e3c3339ffb3cc8a68f9bfa:/include/simgrid/s4u/Activity.hpp diff --git a/include/simgrid/s4u/Activity.hpp b/include/simgrid/s4u/Activity.hpp index b91347cb16..615f7bb3ba 100644 --- a/include/simgrid/s4u/Activity.hpp +++ b/include/simgrid/s4u/Activity.hpp @@ -14,7 +14,17 @@ namespace s4u { /** @brief Activities * * This class is the ancestor of every activities that an actor can undertake. - * That is, of the actions that do take time in the simulated world. + * That is, activities are all the things that do take time to the actor in the simulated world. + * + * They are somewhat linked but not identical to simgrid::kernel::resource::Action, + * that are stuff occurring on a resource: + * + * - A sequential execution activity encompasses 2 actions: one for the exec itself, + * and a time-limited sleep used as timeout detector. + * - A point-to-point communication activity encompasses 3 actions: one for the comm itself + * (which spans on all links of the path), and one infinite sleep used as failure detector + * on both sender and receiver hosts. + * - Synchronization activities may possibly be connected to no action. */ class XBT_PUBLIC Activity { friend Comm; @@ -23,6 +33,9 @@ class XBT_PUBLIC Activity { friend Exec; friend XBT_PUBLIC void intrusive_ptr_release(Exec * e); friend XBT_PUBLIC void intrusive_ptr_add_ref(Exec * e); + friend Io; + friend XBT_PUBLIC void intrusive_ptr_release(Io* i); + friend XBT_PUBLIC void intrusive_ptr_add_ref(Io* i); protected: Activity() = default; @@ -32,7 +45,7 @@ public: Activity(Activity const&) = delete; Activity& operator=(Activity const&) = delete; - enum class State { inited = 0, started, canceled, errored, finished }; + enum class State { INITED = 0, STARTED, CANCELED, ERRORED, FINISHED }; /** Starts a previously created activity. * @@ -47,7 +60,7 @@ public: * Raises: timeout exception.*/ virtual Activity* wait(double timeout) = 0; /** Cancel that activity */ - //virtual void cancel(); + virtual Activity* cancel() = 0; /** Retrieve the current state of the activity */ Activity::State get_state() { return state_; } @@ -68,22 +81,27 @@ public: /** Retrieve the user data of the Activity */ void* get_user_data() { return user_data_; } + /** @deprecated See Activity::get_state()*/ XBT_ATTRIB_DEPRECATED_v323("Please use Activity::get_state()") Activity::State getState() { return state_; } + /** @deprecated See Activity::get_remaining() */ XBT_ATTRIB_DEPRECATED_v323("Please use Activity::get_remaining()") double getRemains() { return get_remaining(); } + /** @deprecated See Activity::set_remaining() */ XBT_ATTRIB_DEPRECATED_v323("Please use Activity::set_remaining()") Activity* setRemains(double remains) { return set_remaining(remains); } + /** @deprecated See Activity::set_user_data() */ XBT_ATTRIB_DEPRECATED_v323("Please use Activity::set_user_data()") Activity* setUserData(void* data) { return set_user_data(data); } + /** @deprecated See Activity::get_user_data() */ XBT_ATTRIB_DEPRECATED_v323("Please use Activity::get_user_data()") void* getUserData() { return user_data_; } private: simgrid::kernel::activity::ActivityImplPtr pimpl_ = nullptr; - Activity::State state_ = Activity::State::inited; - double remains_ = 0; + Activity::State state_ = Activity::State::INITED; + double remains_ = 0; void* user_data_ = nullptr; }; // class