X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/255700918582111f0aacaa7b7fed87dcedc1a840..3c7c64745aa5e60415bb85af482c7b0d0fca2b2b:/src/kernel/activity/IoImpl.hpp diff --git a/src/kernel/activity/IoImpl.hpp b/src/kernel/activity/IoImpl.hpp index ed3c705ee8..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,29 +9,30 @@ #include "src/kernel/activity/ActivityImpl.hpp" #include -namespace simgrid { -namespace kernel { -namespace activity { +namespace simgrid::kernel::activity { class XBT_PUBLIC IoImpl : public ActivityImpl_T { - actor::ActorImpl* actor_ = nullptr; + 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_; } - actor::ActorImpl* get_actor() { return actor_; } 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); @@ -39,13 +40,9 @@ public: 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