X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/dc9b8feaddd53842f6204f4f24409b2382393fa9..93ae3804979dbbefc774e5a70acc32a4407dd7e8:/src/kernel/activity/IoImpl.cpp diff --git a/src/kernel/activity/IoImpl.cpp b/src/kernel/activity/IoImpl.cpp index c76752f8aa..822ff10cea 100644 --- a/src/kernel/activity/IoImpl.cpp +++ b/src/kernel/activity/IoImpl.cpp @@ -37,13 +37,6 @@ namespace simgrid { namespace kernel { namespace activity { -IoImpl::IoImpl(const std::string& name, surf::StorageImpl* storage) : ActivityImpl(name), storage_(storage) -{ - this->state_ = SIMIX_RUNNING; - - XBT_DEBUG("Create io impl %p", this); -} - IoImpl::~IoImpl() { if (surf_action_ != nullptr) @@ -51,13 +44,38 @@ IoImpl::~IoImpl() XBT_DEBUG("Destroy io %p", this); } -IoImpl* IoImpl::start(sg_size_t size, simgrid::s4u::Io::OpType type) +IoImplPtr IoImpl::set_name(const std::string& name) +{ + ActivityImpl::set_name(name); + return this; +} + +IoImplPtr IoImpl::set_type(s4u::Io::OpType type) +{ + type_ = type; + return this; +} + +IoImplPtr IoImpl::set_size(sg_size_t size) +{ + size_ = size; + return this; +} + +IoImplPtr IoImpl::set_storage(resource::StorageImpl* storage) +{ + storage_ = storage; + return this; +} + +IoImpl* IoImpl::start() { - surf_action_ = storage_->io_start(size, type); + state_ = SIMIX_RUNNING; + surf_action_ = storage_->io_start(size_, type_); surf_action_->set_data(this); XBT_DEBUG("Create IO synchro %p %s", this, get_cname()); - simgrid::kernel::activity::IoImpl::on_start(this); + IoImpl::on_start(this); return this; } @@ -79,10 +97,10 @@ void IoImpl::post() { performed_ioops_ = surf_action_->get_cost(); switch (surf_action_->get_state()) { - case simgrid::kernel::resource::Action::State::FAILED: + case resource::Action::State::FAILED: state_ = SIMIX_FAILED; break; - case simgrid::kernel::resource::Action::State::FINISHED: + case resource::Action::State::FINISHED: state_ = SIMIX_DONE; break; default: