X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/befbbbe1fbb31663a8f91e24ce12df271cf4ae79..5bc3597e1513c7b94497ae0ea819e5fa2e28058a:/src/surf/StorageImpl.cpp diff --git a/src/surf/StorageImpl.cpp b/src/surf/StorageImpl.cpp index aea1e2602a..122bfde350 100644 --- a/src/surf/StorageImpl.cpp +++ b/src/surf/StorageImpl.cpp @@ -32,7 +32,7 @@ simgrid::xbt::signal storage std::unordered_map* StorageImpl::storages = new std::unordered_map(); -StorageImpl* StorageImpl::byName(const char* name) +StorageImpl* StorageImpl::byName(std::string name) { if (storages->find(name) == storages->end()) return nullptr; @@ -58,17 +58,15 @@ StorageModel::~StorageModel() * Resource * ************/ -StorageImpl::StorageImpl(Model* model, const char* name, lmm_system_t maxminSystem, double bread, double bwrite, - const char* type_id, const char* content_name, sg_size_t size, const char* attach) - : Resource(model, name, lmm_constraint_new(maxminSystem, this, MAX(bread, bwrite))) +StorageImpl::StorageImpl(Model* model, std::string name, lmm_system_t maxminSystem, double bread, double bwrite, + std::string type_id, std::string content_name, sg_size_t size, std::string attach) + : Resource(model, name.c_str(), lmm_constraint_new(maxminSystem, this, MAX(bread, bwrite))) , piface_(this) + , typeId_(type_id) , size_(size) - , usedSize_(0) - , typeId_(xbt_strdup(type_id)) - , writeActions_(std::vector()) + , attach_(attach) { content_ = parseContent(content_name); - attach_ = xbt_strdup(attach); turnOn(); XBT_DEBUG("Create resource with Bread '%f' Bwrite '%f' and Size '%llu'", bread, bwrite, size); constraintRead_ = lmm_constraint_new(maxminSystem, this, bread); @@ -79,22 +77,17 @@ StorageImpl::StorageImpl(Model* model, const char* name, lmm_system_t maxminSyst StorageImpl::~StorageImpl() { storageDestructedCallbacks(this); - if (content_ != nullptr) { - for (auto entry : *content_) - delete entry.second; + if (content_ != nullptr) delete content_; - } - free(typeId_); - free(attach_); } -std::map* StorageImpl::parseContent(const char* filename) +std::map* StorageImpl::parseContent(std::string filename) { usedSize_ = 0; - if ((not filename) || (strcmp(filename, "") == 0)) + if (filename.empty()) return nullptr; - std::map* parse_content = new std::map(); + std::map* parse_content = new std::map(); std::ifstream* fs = surf_ifsopen(filename); @@ -105,13 +98,11 @@ std::map* StorageImpl::parseContent(const char* filenam boost::trim(line); if (line.length() > 0) { boost::split(tokens, line, boost::is_any_of(" \t"), boost::token_compress_on); - xbt_assert(tokens.size() == 2, "Parse error in %s: %s", filename, line.c_str()); + xbt_assert(tokens.size() == 2, "Parse error in %s: %s", filename.c_str(), line.c_str()); sg_size_t size = std::stoull(tokens.at(1)); usedSize_ += size; - sg_size_t* psize = new sg_size_t; - *psize = size; - parse_content->insert({tokens.front(), psize}); + parse_content->insert({tokens.front(), size}); } } while (not fs->eof()); delete fs; @@ -144,7 +135,7 @@ void StorageImpl::turnOff() } } -std::map* StorageImpl::getContent() +std::map* StorageImpl::getContent() { /* For the moment this action has no cost, but in the future we could take in account access latency of the disk */ return content_; @@ -163,20 +154,6 @@ sg_size_t StorageImpl::getUsedSize() /********** * Action * **********/ -StorageAction::StorageAction(Model* model, double cost, bool failed, StorageImpl* storage, - e_surf_action_storage_type_t type) - : Action(model, cost, failed), type_(type), storage_(storage), file_(nullptr) -{ - progress_ = 0; -}; - -StorageAction::StorageAction(Model* model, double cost, bool failed, lmm_variable_t var, StorageImpl* storage, - e_surf_action_storage_type_t type) - : Action(model, cost, failed, var), type_(type), storage_(storage), file_(nullptr) -{ - progress_ = 0; -} - void StorageAction::setState(Action::State state) { Action::State old = getState();