X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/45e426637aefc9860afe15b75812d48898975fe3..69aaa26fa5228c31e55086fa166479732a9cd1b7:/src/s4u/s4u_Io.cpp diff --git a/src/s4u/s4u_Io.cpp b/src/s4u/s4u_Io.cpp index c88ccc7fd4..a4aba5b2e0 100644 --- a/src/s4u/s4u_Io.cpp +++ b/src/s4u/s4u_Io.cpp @@ -7,6 +7,8 @@ #include "simgrid/s4u/Disk.hpp" #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 { @@ -14,26 +16,27 @@ 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() { - kernel::actor::simcall([this] { - (*boost::static_pointer_cast(pimpl_)) - .set_name(get_name()) - .set_disk(disk_->get_impl()) - .set_size(size_) - .set_type(type_) - .start(); - }); + kernel::actor::simcall( + [this] { (*boost::static_pointer_cast(pimpl_)).set_name(get_name()).start(); }); if (suspended_) pimpl_->suspend(); @@ -43,48 +46,52 @@ Io* Io::start() return this; } -Io* Io::cancel() +int Io::wait_any_for(const std::vector& ios, double timeout) { - simgrid::kernel::actor::simcall([this] { boost::static_pointer_cast(pimpl_)->cancel(); }); - state_ = State::CANCELED; - return this; + 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::IoWaitanySimcall observer{issuer, rios, timeout}; + int 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; } -Io* Io::wait() +IoPtr Io::set_disk(const_sg_disk_t disk) { - return this->wait_for(-1); -} - -Io* Io::wait_for(double timeout) -{ - if (state_ == State::INITED) - vetoable_start(); + xbt_assert(state_ == State::INITED || state_ == State::STARTING, "Cannot set disk once the Io is started"); - kernel::actor::ActorImpl* issuer = Actor::self()->get_impl(); - kernel::actor::simcall_blocking([this, issuer, timeout] { this->get_impl()->wait_for(issuer, timeout); }); - state_ = State::FINISHED; - this->release_dependencies(); + kernel::actor::simcall( + [this, disk] { boost::static_pointer_cast(pimpl_)->set_disk(disk->get_impl()); }); - on_completion(*this); - return this; -} + // Setting the disk may allow to start the activity, let's try + if (state_ == State::STARTING) + vetoable_start(); -IoPtr Io::set_disk(sg_disk_t disk) -{ - disk_ = disk; - return this; + return this; } IoPtr Io::set_size(sg_size_t size) { - size_ = size; - Activity::set_remaining(size_); + xbt_assert(state_ == State::INITED || state_ == State::STARTING, "Cannot set size once the Io is started"); + kernel::actor::simcall( + [this, size] { boost::static_pointer_cast(pimpl_)->set_size(size); }); + Activity::set_remaining(size); return this; } IoPtr Io::set_op_type(OpType type) { - type_ = type; + xbt_assert(state_ == State::INITED || state_ == State::STARTING, "Cannot set size once the Io is started"); + kernel::actor::simcall( + [this, type] { boost::static_pointer_cast(pimpl_)->set_type(type); }); return this; } @@ -100,5 +107,10 @@ sg_size_t Io::get_performed_ioops() const return boost::static_pointer_cast(pimpl_)->get_performed_ioops(); } +bool Io::is_assigned() const +{ + return boost::static_pointer_cast(pimpl_)->get_disk() != nullptr; +} + } // namespace s4u } // namespace simgrid