X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/e9119c20b55464a6a1c867edc1a7a2d95b070847..7685128879fd2a88a5b9226114c223c65517668c:/include/simgrid/s4u/Io.hpp diff --git a/include/simgrid/s4u/Io.hpp b/include/simgrid/s4u/Io.hpp index 6052171851..4e7ae31a54 100644 --- a/include/simgrid/s4u/Io.hpp +++ b/include/simgrid/s4u/Io.hpp @@ -10,28 +10,41 @@ #include #include +#include namespace simgrid { namespace s4u { +/** I/O Activity, representing the asynchronous disk access. + * + * They are generated from simgrid::s4u::Storage::read() and simgrid::s4u::Storage::write(). + */ + class XBT_PUBLIC Io : public Activity { - explicit Io(sg_size_t size) : Activity(), size_(size) {} +public: + enum class OpType { READ, WRITE }; + +private: + explicit Io(sg_size_t size, OpType type) : Activity(), size_(size), type_(type) {} public: friend XBT_PUBLIC void intrusive_ptr_release(simgrid::s4u::Io* i); friend XBT_PUBLIC void intrusive_ptr_add_ref(simgrid::s4u::Io* i); - friend Storage; // Factory of IOs + friend simgrid::s4u::Storage; // Factory of IOs - enum class OpType { READ, WRITE }; ~Io() = default; - Activity* start() override; - Activity* wait() override; - Activity* wait(double timeout) override; - Activity* cancel() override; + Io* start() override; + Io* wait() override; + Io* wait_for(double timeout) override; + Io* cancel() override; + bool test() override; double get_remaining() override; sg_size_t get_performed_ioops(); - IoPtr set_io_type(OpType type); + +#ifndef DOXYGEN + XBT_ATTRIB_DEPRECATED_v324("Please use Io::wait_for()") void wait(double t) override { wait_for(t); } +#endif private: sg_size_t size_ = 0;