X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/4dc49c9d77bc2dcba754a985c4c03e02c4b737fd..7013392b1a0a3aed2219fa352e81826f8657fbe2:/src/s4u/s4u_Storage.cpp diff --git a/src/s4u/s4u_Storage.cpp b/src/s4u/s4u_Storage.cpp index d1b2aa5597..78cfaf6c44 100644 --- a/src/s4u/s4u_Storage.cpp +++ b/src/s4u/s4u_Storage.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2006-2018. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2006-2019. 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. */ @@ -21,17 +21,17 @@ simgrid::xbt::signal Storage::on_creation; simgrid::xbt::signal Storage::on_destruction; simgrid::xbt::signal Storage::on_state_change; -Storage::Storage(std::string name, surf::StorageImpl* pimpl) : pimpl_(pimpl), name_(name) +Storage::Storage(std::string name, surf::StorageImpl* pimpl) : pimpl_(pimpl), name_(std::move(name)) { - simgrid::s4u::Engine::get_instance()->storage_register(name, this); + simgrid::s4u::Engine::get_instance()->storage_register(name_, this); } -Storage* Storage::by_name(std::string name) +Storage* Storage::by_name(const std::string& name) { return Engine::get_instance()->storage_by_name(name); } -Storage* Storage::by_name_or_null(std::string name) +Storage* Storage::by_name_or_null(const std::string& name) { return Engine::get_instance()->storage_by_name_or_null(name); } @@ -46,44 +46,40 @@ std::unordered_map* Storage::get_properties() return simgrid::simix::simcall([this] { return pimpl_->get_properties(); }); } -const char* Storage::get_property(std::string key) +const char* Storage::get_property(const std::string& key) { return this->pimpl_->get_property(key); } -void Storage::set_property(std::string key, std::string value) +void Storage::set_property(const std::string& key, std::string value) { simgrid::simix::simcall([this, key, value] { this->pimpl_->set_property(key, value); }); } -IoPtr Storage::io_init(sg_size_t size) +IoPtr Storage::io_init(sg_size_t size, Io::OpType type) { - IoPtr res = IoPtr(new Io(size)); - res->storage_ = this; - return res; + return IoPtr(new Io(this, size, type)); +} + +IoPtr Storage::read_async(sg_size_t size) +{ + return IoPtr(io_init(size, Io::OpType::READ))->start(); } sg_size_t Storage::read(sg_size_t size) { - IoPtr i = io_init(size); - i->set_io_type(Io::OpType::READ); - i->start()->wait(); - return i->get_performed_ioops(); + return IoPtr(io_init(size, Io::OpType::READ))->start()->wait()->get_performed_ioops(); } -sg_size_t Storage::write(sg_size_t size) +IoPtr Storage::write_async(sg_size_t size) { - IoPtr i = io_init(size); - i->set_io_type(Io::OpType::WRITE); - i->start()->wait(); - return i->get_performed_ioops(); + + return IoPtr(io_init(size, Io::OpType::WRITE)->start()); } -// Deprecated functions -void getStorageList(std::map* whereTo) +sg_size_t Storage::write(sg_size_t size) { - for (auto const& s : simgrid::s4u::Engine::get_instance()->get_all_storages()) - whereTo->insert({s->get_name(), s}); + return IoPtr(io_init(size, Io::OpType::WRITE))->start()->wait()->get_performed_ioops(); } } /* namespace s4u */