X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/50ddfe2f5b5035e0ed9556b334d6977ee81ff83a..f71d97e36f0e6bfb6e03ff1c630ce020a74f943a:/src/s4u/s4u_Io.cpp diff --git a/src/s4u/s4u_Io.cpp b/src/s4u/s4u_Io.cpp index 88d78a7040..aec4f16d51 100644 --- a/src/s4u/s4u_Io.cpp +++ b/src/s4u/s4u_Io.cpp @@ -1,78 +1,111 @@ -/* Copyright (c) 2018. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2018-2021. 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. */ +#include "simgrid/s4u/Actor.hpp" +#include "simgrid/s4u/Disk.hpp" #include "simgrid/s4u/Io.hpp" -#include "simgrid/s4u/Storage.hpp" #include "src/kernel/activity/IoImpl.hpp" -#include "src/simix/smx_io_private.hpp" +#include "src/kernel/actor/ActorImpl.hpp" #include "xbt/log.h" -XBT_LOG_NEW_DEFAULT_SUBCATEGORY(s4u_io, s4u_activity, "S4U asynchronous IOs"); - namespace simgrid { namespace s4u { +xbt::signal Io::on_start; +xbt::signal Io::on_completion; + +Io::Io() +{ + pimpl_ = kernel::activity::IoImplPtr(new kernel::activity::IoImpl()); +} -Activity* Io::start() +IoPtr Io::init() { - set_remaining(size_); - pimpl_ = simix::simcall([this] { return SIMIX_io_start(name_, size_, storage_, type_); }); + return IoPtr(new Io()); +} + +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(); + }); + + if (suspended_) + pimpl_->suspend(); + state_ = State::STARTED; + on_start(*this); return this; } -Activity* Io::cancel() +Io* Io::cancel() { - simgrid::simix::simcall([this] { dynamic_cast(pimpl_.get())->cancel(); }); + simgrid::kernel::actor::simcall([this] { boost::static_pointer_cast(pimpl_)->cancel(); }); state_ = State::CANCELED; + on_completion(*this); return this; } -Activity* Io::wait() +Io* Io::wait() { - simcall_io_wait(pimpl_); - state_ = State::FINISHED; - return this; + return this->wait_for(-1); } -Activity* Io::wait(double timeout) +Io* Io::wait_for(double timeout) { - THROW_UNIMPLEMENTED; + if (state_ == State::INITED) + vetoable_start(); + + 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; } -/** @brief Returns the amount of flops that remain to be done */ -double Io::get_remaining() +IoPtr Io::set_disk(sg_disk_t disk) { - return simgrid::simix::simcall( - [this]() { return boost::static_pointer_cast(pimpl_)->get_remaining(); }); + disk_ = disk; + + // Setting the disk may allow to start the activity, let's try + if (state_ == State::STARTING) + vetoable_start(); + + return this; } -sg_size_t Io::get_performed_ioops() +IoPtr Io::set_size(sg_size_t size) { - return simgrid::simix::simcall( - [this]() { return boost::static_pointer_cast(pimpl_)->get_performed_ioops(); }); + size_ = size; + Activity::set_remaining(size_); + return this; } -IoPtr Io::set_io_type(OpType type) +IoPtr Io::set_op_type(OpType type) { - xbt_assert(state_ == State::INITED, "Cannot change the name of an exec after its start"); type_ = type; return this; } -void intrusive_ptr_release(simgrid::s4u::Io* i) +/** @brief Returns the amount of flops that remain to be done */ +double Io::get_remaining() const { - if (i->refcount_.fetch_sub(1, std::memory_order_release) == 1) { - std::atomic_thread_fence(std::memory_order_acquire); - delete i; - } + return kernel::actor::simcall( + [this]() { return boost::static_pointer_cast(pimpl_)->get_remaining(); }); } -void intrusive_ptr_add_ref(simgrid::s4u::Io* i) +sg_size_t Io::get_performed_ioops() const { - i->refcount_.fetch_add(1, std::memory_order_relaxed); + return boost::static_pointer_cast(pimpl_)->get_performed_ioops(); } + } // namespace s4u } // namespace simgrid