X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/4dc49c9d77bc2dcba754a985c4c03e02c4b737fd..7b0e03ac48be8e014d877060fbd385201b1b896f:/src/kernel/activity/IoImpl.hpp diff --git a/src/kernel/activity/IoImpl.hpp b/src/kernel/activity/IoImpl.hpp index 59ec127c0b..cbc2f0d185 100644 --- a/src/kernel/activity/IoImpl.hpp +++ b/src/kernel/activity/IoImpl.hpp @@ -1,38 +1,43 @@ -/* Copyright (c) 2007-2018. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2007-2019. 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. */ -#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" +#include 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, 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); + IoImpl& set_disk(resource::DiskImpl* disk); - 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