X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/08e7455d67920bbd7a87f440d00f2c1e071314a0..a9dc23242c8a8a0084ad22a773b450dcd57f9f3c:/src/kernel/activity/IoImpl.hpp diff --git a/src/kernel/activity/IoImpl.hpp b/src/kernel/activity/IoImpl.hpp index e1ed124f57..2c2ab5b323 100644 --- a/src/kernel/activity/IoImpl.hpp +++ b/src/kernel/activity/IoImpl.hpp @@ -7,7 +7,6 @@ #define SIMGRID_KERNEL_ACTIVITY_IO_HPP #include "src/kernel/activity/ActivityImpl.hpp" -#include "surf/surf.hpp" #include namespace simgrid { @@ -15,27 +14,31 @@ namespace kernel { namespace activity { class XBT_PUBLIC IoImpl : public ActivityImpl_T { - resource::StorageImpl* storage_ = nullptr; - resource::DiskImpl* disk_ = nullptr; - sg_size_t size_ = 0; - s4u::Io::OpType type_ = s4u::Io::OpType::READ; - sg_size_t performed_ioops_ = 0; + resource::DiskImpl* disk_ = nullptr; + double sharing_penalty_ = 1.0; + sg_size_t size_ = 0; + s4u::Io::OpType type_ = s4u::Io::OpType::READ; + sg_size_t performed_ioops_ = 0; resource::Action* timeout_detector_ = nullptr; + s4u::Io* piface_; public: + IoImpl(); + s4u::Io* get_iface() { return piface_; } + + IoImpl& set_sharing_penalty(double sharing_penalty); IoImpl& set_timeout(double timeout) override; IoImpl& set_size(sg_size_t size); IoImpl& set_type(s4u::Io::OpType type); - IoImpl& set_storage(resource::StorageImpl* storage); IoImpl& set_disk(resource::DiskImpl* disk); sg_size_t get_performed_ioops() const { return performed_ioops_; } resource::DiskImpl* get_disk() const { return disk_; } - resource::StorageImpl* get_storage() const { return storage_; } IoImpl* start(); void post() override; void finish() override; + static void wait_any_for(actor::ActorImpl* issuer, const std::vector& ios, double timeout); }; } // namespace activity } // namespace kernel