X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/985e0a5509e230076d22095da54dd0123d2afe5e..7604d0db48006a7a47120a2de9e7152063d5540c:/include/simgrid/s4u/Io.hpp diff --git a/include/simgrid/s4u/Io.hpp b/include/simgrid/s4u/Io.hpp index cb75b50242..2dc88c60b2 100644 --- a/include/simgrid/s4u/Io.hpp +++ b/include/simgrid/s4u/Io.hpp @@ -24,32 +24,19 @@ class XBT_PUBLIC Io : public Activity_T { friend kernel::EngineImpl; #endif - inline static xbt::signal on_start; - xbt::signal on_this_start; - protected: explicit Io(kernel::activity::IoImplPtr pimpl); Io* do_start() override; - void fire_on_completion() const override { on_completion(*this); } - void fire_on_this_completion() const override { on_this_completion(*this); } - void fire_on_suspend() const override { on_suspend(*this); } - void fire_on_this_suspend() const override { on_this_suspend(*this); } - void fire_on_resume() const override { on_resume(*this); } - void fire_on_this_resume() const override { on_this_resume(*this); } - void fire_on_veto() const override { on_veto(const_cast(*this)); } - void fire_on_this_veto() const override { on_this_veto(const_cast(*this)); } public: enum class OpType { READ, WRITE }; - static void on_start_cb(const std::function& cb) { on_start.connect(cb); } - void on_this_start_cb(const std::function& cb) { on_this_start.connect(cb); } - + /*! \static Initiate the creation of an I/O. Setters have to be called afterwards */ static IoPtr init(); - /*! take a vector of s4u::IoPtr and return when one of them is finished. + /*! \static take a vector of s4u::IoPtr and return when one of them is finished. * The return value is the rank of the first finished IoPtr. */ static ssize_t wait_any(const std::vector& ios) { return wait_any_for(ios, -1); } - /*! Same as wait_any, but with a timeout. If the timeout occurs, parameter last is returned.*/ + /*! \static Same as wait_any, but with a timeout. If the timeout occurs, parameter last is returned.*/ static ssize_t wait_any_for(const std::vector& ios, double timeout); double get_remaining() const override;