X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/a9dc23242c8a8a0084ad22a773b450dcd57f9f3c..793184f903550583a9d23a67374df45e9b67612d:/src/kernel/activity/IoImpl.hpp diff --git a/src/kernel/activity/IoImpl.hpp b/src/kernel/activity/IoImpl.hpp index 2c2ab5b323..6562f2e393 100644 --- a/src/kernel/activity/IoImpl.hpp +++ b/src/kernel/activity/IoImpl.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2007-2021. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2007-2023. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -9,39 +9,40 @@ #include "src/kernel/activity/ActivityImpl.hpp" #include -namespace simgrid { -namespace kernel { -namespace activity { +namespace simgrid::kernel::activity { class XBT_PUBLIC IoImpl : public ActivityImpl_T { + s4u::Host* host_ = nullptr; resource::DiskImpl* disk_ = nullptr; + s4u::Host* dst_host_ = nullptr; + resource::DiskImpl* dst_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_disk(resource::DiskImpl* disk); + IoImpl& set_host(s4u::Host* host); + s4u::Host* get_host() const { return host_; } + IoImpl& set_dst_disk(resource::DiskImpl* disk); + IoImpl& set_dst_host(s4u::Host* host); + s4u::Host* get_dst_host() const { return dst_host_; } + + IoImpl& update_sharing_penalty(double sharing_penalty); sg_size_t get_performed_ioops() const { return performed_ioops_; } resource::DiskImpl* get_disk() const { return disk_; } IoImpl* start(); - void post() override; + void set_exception(actor::ActorImpl* issuer) override; void finish() override; - static void wait_any_for(actor::ActorImpl* issuer, const std::vector& ios, double timeout); }; -} // namespace activity -} // namespace kernel -} // namespace simgrid +} // namespace simgrid::kernel::activity #endif