X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/d662c9d9b90723961229e619d980e28d2d66ef6d..7b0e03ac48be8e014d877060fbd385201b1b896f:/src/kernel/activity/IoImpl.hpp diff --git a/src/kernel/activity/IoImpl.hpp b/src/kernel/activity/IoImpl.hpp index b1275e3ac3..cbc2f0d185 100644 --- a/src/kernel/activity/IoImpl.hpp +++ b/src/kernel/activity/IoImpl.hpp @@ -3,8 +3,8 @@ /* 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. */ -#ifndef SIMIX_SYNCHRO_IO_HPP -#define SIMIX_SYNCHRO_IO_HPP +#ifndef SIMGRID_KERNEL_ACTIVITY_IO_HPP +#define SIMGRID_KERNEL_ACTIVITY_IO_HPP #include "src/kernel/activity/ActivityImpl.hpp" #include "surf/surf.hpp" @@ -14,24 +14,30 @@ namespace simgrid { namespace kernel { namespace activity { -class XBT_PUBLIC IoImpl : public ActivityImpl { +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; + public: - ~IoImpl() override; - explicit IoImpl(std::string name, surf::StorageImpl* storage); + 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); - void start(sg_size_t size, simgrid::s4u::Io::OpType type); - void post() override; - void cancel(); - double get_remaining(); sg_size_t get_performed_ioops() { return performed_ioops_; } - surf::StorageImpl* storage_ = nullptr; - sg_size_t performed_ioops_ = 0; - static simgrid::xbt::signal on_start; - 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