From bcb5cde966bef9e174da1c93cdb2158c0880a613 Mon Sep 17 00:00:00 2001 From: Frederic Suter Date: Mon, 10 Jul 2017 09:35:35 +0200 Subject: [PATCH] this writeActions stuff was never used --- src/surf/StorageImpl.cpp | 1 - src/surf/StorageImpl.hpp | 1 - src/surf/storage_n11.cpp | 29 +---------------------------- 3 files changed, 1 insertion(+), 30 deletions(-) diff --git a/src/surf/StorageImpl.cpp b/src/surf/StorageImpl.cpp index 95c0ffe301..8faa657e2b 100644 --- a/src/surf/StorageImpl.cpp +++ b/src/surf/StorageImpl.cpp @@ -66,7 +66,6 @@ StorageImpl::StorageImpl(Model* model, const char* name, lmm_system_t maxminSyst , usedSize_(0) , typeId_(type_id) , attach_(attach) - , writeActions_(std::vector()) { content_ = parseContent(content_name); turnOn(); diff --git a/src/surf/StorageImpl.hpp b/src/surf/StorageImpl.hpp index 4cfb23ddc6..4773a9b37e 100644 --- a/src/surf/StorageImpl.hpp +++ b/src/surf/StorageImpl.hpp @@ -169,7 +169,6 @@ public: std::map* parseContent(const char* filename); static std::unordered_map* storages; static std::unordered_map* storagesMap() { return StorageImpl::storages; } - std::vector writeActions_; lmm_constraint_t constraintWrite_; /* Constraint for maximum write bandwidth*/ lmm_constraint_t constraintRead_; /* Constraint for maximum write bandwidth*/ diff --git a/src/surf/storage_n11.cpp b/src/surf/storage_n11.cpp index 0cd5ebde27..03b357c554 100644 --- a/src/surf/storage_n11.cpp +++ b/src/surf/storage_n11.cpp @@ -69,19 +69,7 @@ StorageImpl* StorageN11Model::createStorage(const char* id, const char* type_id, double StorageN11Model::nextOccuringEvent(double now) { - double min_completion = StorageModel::nextOccuringEventFull(now); - - for(auto storage: p_storageList) { - double rate = 0; - // Foreach write action on that disk - for (auto write_action: storage->writeActions_) { - rate += lmm_variable_getvalue(write_action->getVariable()); - } - if(rate > 0) - min_completion = MIN(min_completion, (storage->size_-storage->usedSize_)/rate); - } - - return min_completion; + return StorageModel::nextOccuringEventFull(now); } void StorageN11Model::updateActionsState(double /*now*/, double delta) @@ -173,16 +161,6 @@ StorageAction *StorageN11::open(const char* mount, const char* path) StorageAction *StorageN11::close(surf_file_t fd) { XBT_DEBUG("\tClose file '%s' size '%llu'", fd->cname(), fd->size()); - // unref write actions from storage - for (std::vector::iterator it = writeActions_.begin(); it != writeActions_.end();) { - StorageAction *write_action = *it; - if ((write_action->file_) == fd) { - write_action->unref(); - it = writeActions_.erase(it); - } else { - ++it; - } - } StorageAction* action = new StorageN11Action(model(), 0, isOff(), this, CLOSE); return action; } @@ -241,11 +219,6 @@ StorageN11Action::StorageN11Action(Model* model, double cost, bool failed, Stora break; case WRITE: lmm_expand(model->getMaxminSystem(), storage->constraintWrite_, getVariable(), 1.0); - - //TODO there is something annoying with what's below. Have to sort it out... - // Action *action = this; - // storage->p_writeActions->push_back(action); - // ref(); break; default: THROW_UNIMPLEMENTED; -- 2.20.1