X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/b8df87e176f27b25534f27d7e240defa32ca35bc..fa194cfd4dc1694b23d8f5c4118005fa70a92db4:/src/kernel/activity/IoImpl.hpp diff --git a/src/kernel/activity/IoImpl.hpp b/src/kernel/activity/IoImpl.hpp index 456b325189..2ab4ff700d 100644 --- a/src/kernel/activity/IoImpl.hpp +++ b/src/kernel/activity/IoImpl.hpp @@ -8,31 +8,34 @@ #include "src/kernel/activity/ActivityImpl.hpp" #include "surf/surf.hpp" +#include namespace simgrid { namespace kernel { namespace activity { -class XBT_PUBLIC IoImpl : public ActivityImpl { +class XBT_PUBLIC IoImpl : public ActivityImpl_T { + resource::StorageImpl* storage_ = nullptr; + sg_size_t size_ = 0; + s4u::Io::OpType type_ = s4u::Io::OpType::READ; + sg_size_t performed_ioops_ = 0; + public: - ~IoImpl() override; - explicit IoImpl(std::string name, resource::Action* surf_action, s4u::Storage* storage); + IoImpl& set_size(sg_size_t size); + IoImpl& set_type(s4u::Io::OpType type); + IoImpl& set_storage(resource::StorageImpl* storage); - void suspend() override; - void resume() override; - void post() override; - void cancel(); - double get_remaining(); sg_size_t get_performed_ioops() { return performed_ioops_; } - s4u::Storage* storage_ = nullptr; - simgrid::kernel::resource::Action* surf_action_ = nullptr; - sg_size_t performed_ioops_ = 0; - static simgrid::xbt::signal on_creation; - static simgrid::xbt::signal on_completion; + IoImpl* start(); + void post() override; + void finish() override; + + static xbt::signal on_start; + static xbt::signal on_completion; }; -} -} -} // namespace simgrid::kernel::activity +} // namespace activity +} // namespace kernel +} // namespace simgrid #endif