X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/2b4662416289a826b9dcd961b4721172c3884cd1..d105f94a1512ae0528178dc4292b7d421ae3c039:/src/s4u/s4u_Io.cpp diff --git a/src/s4u/s4u_Io.cpp b/src/s4u/s4u_Io.cpp index 082d00b541..38050e152c 100644 --- a/src/s4u/s4u_Io.cpp +++ b/src/s4u/s4u_Io.cpp @@ -8,6 +8,7 @@ #include "simgrid/s4u/Io.hpp" #include "src/kernel/activity/IoImpl.hpp" #include "src/kernel/actor/ActorImpl.hpp" +#include "src/kernel/actor/SimcallObserver.hpp" #include "xbt/log.h" namespace simgrid { @@ -15,14 +16,21 @@ namespace s4u { xbt::signal Io::on_start; xbt::signal Io::on_completion; -Io::Io() +Io::Io(kernel::activity::IoImplPtr pimpl) { - pimpl_ = kernel::activity::IoImplPtr(new kernel::activity::IoImpl()); + pimpl_ = pimpl; +} + +void Io::complete(Activity::State state) +{ + Activity::complete(state); + on_completion(*this); } IoPtr Io::init() { - return IoPtr(new Io()); + auto pimpl = kernel::activity::IoImplPtr(new kernel::activity::IoImpl()); + return IoPtr(pimpl->get_iface()); } Io* Io::start() @@ -38,34 +46,25 @@ Io* Io::start() return this; } -Io* Io::cancel() -{ - kernel::actor::simcall([this] { boost::static_pointer_cast(pimpl_)->cancel(); }); - state_ = State::CANCELED; - on_completion(*this); - return this; -} - -Io* Io::wait() -{ - return this->wait_for(-1); -} - -Io* Io::wait_for(double timeout) +ssize_t Io::wait_any_for(const std::vector& ios, double timeout) { - if (state_ == State::INITED) - vetoable_start(); + std::vector rios(ios.size()); + std::transform(begin(ios), end(ios), begin(rios), + [](const IoPtr& io) { return static_cast(io->pimpl_.get()); }); kernel::actor::ActorImpl* issuer = kernel::actor::ActorImpl::self(); - kernel::actor::simcall_blocking([this, issuer, timeout] { this->get_impl()->wait_for(issuer, timeout); }); - state_ = State::FINISHED; - this->release_dependencies(); - - on_completion(*this); - return this; + kernel::actor::IoWaitanySimcall observer{issuer, rios, timeout}; + ssize_t changed_pos = kernel::actor::simcall_blocking( + [&observer] { + kernel::activity::IoImpl::wait_any_for(observer.get_issuer(), observer.get_ios(), observer.get_timeout()); + }, + &observer); + if (changed_pos != -1) + ios.at(changed_pos)->complete(State::FINISHED); + return changed_pos; } -IoPtr Io::set_disk(sg_disk_t disk) +IoPtr Io::set_disk(const_sg_disk_t disk) { xbt_assert(state_ == State::INITED || state_ == State::STARTING, "Cannot set disk once the Io is started");