summaryrefslogtreecommitdiff
path: root/Simulator/src/simulation/workloads/WorkloadPool.cpp
diff options
context:
space:
mode:
authorFabian Mastenbroek <mail.fabianm@gmail.com>2017-07-09 23:48:06 +0200
committerFabian Mastenbroek <mail.fabianm@gmail.com>2017-07-09 23:48:06 +0200
commitc94d0c347fdbd8acc774df4ac17617a3f63e4507 (patch)
tree4b825dc642cb6eb9a060e54bf8d69288fbee4904 /Simulator/src/simulation/workloads/WorkloadPool.cpp
parentbc4c41e21a64b444bdbab3b6d1d407fd5d919419 (diff)
Delete old codebase
This change removes version 1 of the OpenDC simulator codebase as it will be replaced by a complete rewrite in the Kotlin language.
Diffstat (limited to 'Simulator/src/simulation/workloads/WorkloadPool.cpp')
-rw-r--r--Simulator/src/simulation/workloads/WorkloadPool.cpp70
1 files changed, 0 insertions, 70 deletions
diff --git a/Simulator/src/simulation/workloads/WorkloadPool.cpp b/Simulator/src/simulation/workloads/WorkloadPool.cpp
deleted file mode 100644
index 251dcb9a..00000000
--- a/Simulator/src/simulation/workloads/WorkloadPool.cpp
+++ /dev/null
@@ -1,70 +0,0 @@
-#include "simulation/workloads/WorkloadPool.h"
-#include "simulation/workloads/Workload.h"
-
-#include <iostream>
-#include <algorithm>
-
-namespace Simulation
-{
- void WorkloadPool::addWorkload(Workload w)
- {
- workloads.push_back(w);
- }
-
- std::vector<Workload*> WorkloadPool::getWorkloads(uint32_t currentTick)
- {
- std::vector<Workload*> filteredOnStarted;
- for(Workload& w : workloads)
- {
- if(w.getStartTick() < currentTick)
- filteredOnStarted.push_back(&w);
- }
-
- return filteredOnStarted;
- }
-
- Workload& WorkloadPool::getWorkload(int id)
- {
- auto it = std::find_if(workloads.begin(), workloads.end(), [id](Workload& w) {
- return (id == w.getId());
- });
-
- return *it;
- }
-
- void WorkloadPool::clearFinishedWorkloads()
- {
- auto it = workloads.begin();
- while(it != workloads.end())
- {
- if(it->isFinished())
- {
- std::cout << "Finished workload " << it->getId() << std::endl;
- int id = it->getId();
- setDependenciesFinished(id);
- it = workloads.erase(it);
- }
- else
- {
- ++it;
- }
- }
- }
-
- void WorkloadPool::setDependenciesFinished(int id)
- {
- for(auto& workload : workloads)
- {
- if(workload.getDependencyId() == id)
- {
- workload.dependencyFinished = true;
- std::cout << "Finished dependency of " << workload.getId() << std::endl;
- }
- }
- }
-
- bool WorkloadPool::isEmpty()
- {
- return this->workloads.size() == 0;
- }
-}