X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/d5b29830df70e823202e384a7655e4371193ecd7..c7e6ef1da2a535a2854db29a1dd8e469446a11f7:/src/s4u/s4u_storage.cpp?ds=sidebyside diff --git a/src/s4u/s4u_storage.cpp b/src/s4u/s4u_storage.cpp index d10a19d886..9123343960 100644 --- a/src/s4u/s4u_storage.cpp +++ b/src/s4u/s4u_storage.cpp @@ -3,26 +3,31 @@ /* 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 "../surf/StorageImpl.hpp" +#include "simgrid/s4u/File.hpp" #include "simgrid/s4u/Host.hpp" #include "simgrid/s4u/Storage.hpp" #include "simgrid/simix.hpp" +#include "src/surf/StorageImpl.hpp" #include namespace simgrid { +namespace xbt { +template class Extendable; +} + namespace s4u { std::map* allStorages() { std::unordered_map* map = surf::StorageImpl::storagesMap(); std::map* res = new std::map; - for (auto s : *map) + for (auto const& s : *map) res->insert({s.first, &(s.second->piface_)}); // Convert each entry into its interface return res; } -Storage* Storage::byName(const char* name) +Storage* Storage::byName(std::string name) { surf::StorageImpl* res = surf::StorageImpl::byName(name); if (res == nullptr) @@ -30,53 +35,85 @@ Storage* Storage::byName(const char* name) return &res->piface_; } -const char* Storage::name() +const std::string& Storage::getName() const +{ + return pimpl_->getName(); +} + +const char* Storage::getCname() const { - return pimpl_->cname(); + return pimpl_->getCname(); } -const char* Storage::type() +const char* Storage::getType() { return pimpl_->typeId_.c_str(); } -Host* Storage::host() +Host* Storage::getHost() { return attached_to_; } -sg_size_t Storage::sizeFree() +sg_size_t Storage::getSizeFree() { - return simgrid::simix::kernelImmediate([this] { return pimpl_->getFreeSize(); }); + FileSystemStorageExt* file_system = extension(); + + return pimpl_->getSize() - file_system->getUsedSize(); } -sg_size_t Storage::sizeUsed() +sg_size_t Storage::getSizeUsed() { - return simgrid::simix::kernelImmediate([this] { return pimpl_->getUsedSize(); }); + FileSystemStorageExt* file_system = extension(); + return file_system->getUsedSize(); } -sg_size_t Storage::size() { - return pimpl_->size_; +void Storage::decrUsedSize(sg_size_t size) +{ + FileSystemStorageExt* file_system = extension(); + file_system->decrUsedSize(size); +} + +void Storage::incrUsedSize(sg_size_t size) +{ + FileSystemStorageExt* file_system = extension(); + file_system->incrUsedSize(size); } -xbt_dict_t Storage::properties() +sg_size_t Storage::getSize() +{ + return pimpl_->getSize(); +} + +std::map* Storage::getProperties() { return simgrid::simix::kernelImmediate([this] { return pimpl_->getProperties(); }); } -const char* Storage::property(const char* key) +const char* Storage::getProperty(std::string key) +{ + return this->pimpl_->getProperty(key); +} + +void Storage::setProperty(std::string key, std::string value) +{ + simgrid::simix::kernelImmediate([this, key, value] { this->pimpl_->setProperty(key, value); }); +} + +std::map* Storage::getContent() { - return static_cast(xbt_dict_get_or_null(this->properties(), key)); + FileSystemStorageExt* file_system = extension(); + return file_system->getContent(); } -void Storage::setProperty(const char* key, char* value) +sg_size_t Storage::read(sg_size_t size) { - xbt_dict_set(this->properties(), key, value, nullptr); + return simcall_storage_read(pimpl_, size); } -std::map* Storage::content() +sg_size_t Storage::write(sg_size_t size) { - return simgrid::simix::kernelImmediate([this] { return pimpl_->getContent(); }); + return simcall_storage_write(pimpl_, size); } /*************