Initial code commit with organized dependencies

3 files changed, 155 insertions, 0 deletions

diff --git a/Testing/include/simulation/workloads/SimpleSchedulerTest.h b/Testing/include/simulation/workloads/SimpleSchedulerTest.h
new file mode 100644
index 00000000..07b4416f
--- /dev/null
+++ b/Testing/include/simulation/workloads/SimpleSchedulerTest.h
@@ -0,0 +1,106 @@
+#pragma once
+#include "simulation\workloads\SimpleScheduler.h"
+#include "simulation\workloads\Workload.h"
+#include "modeling\Machine.h"
+
+#include <vector>
+#include <gtest\gtest.h>
+
+TEST(SimpleSchedulerTest, ScheduleSingleMachine)
+{
+	// Initialization
+	Simulation::SimpleScheduler scheduler;
+	Simulation::Workload workload1(100, 0, 1, 1, 0);
+	Simulation::Workload workload2(150, 0, 1, 1, 0);
+	Modeling::Machine machine(10);
+
+	std::vector<std::reference_wrapper<Modeling::Machine>> machines;
+	machines.push_back(std::reference_wrapper<Modeling::Machine>(machine));
+	scheduler.addWorkload(workload1);
+	scheduler.addWorkload(workload2);
+
+	// Distribute tasks across machines
+	scheduler.schedule(machines);
+
+	// Do work
+	for (auto machine : machines)
+		machine.get().tick();
+
+	// Assert work done
+	auto workloads = scheduler.getWorkloads();
+	auto workload1Remaining = workloads.at(0).lock()->getRemainingOperations();
+	auto workload2Remaining = workloads.at(1).lock()->getRemainingOperations();
+	ASSERT_EQ(workload1Remaining, 90);
+	ASSERT_EQ(workload2Remaining, 150);
+}
+
+TEST(SimpleSchedulerTest, ScheduleMultipleMachine)
+{
+	// Initialization
+	Simulation::SimpleScheduler scheduler;
+	Simulation::Workload workload1(100, 0, 1, 1, 0);
+	Simulation::Workload workload2(150, 0, 1, 1, 0);
+	Modeling::Machine machine1(10);
+	Modeling::Machine machine2(30);
+
+	std::vector<std::reference_wrapper<Modeling::Machine>> machines;
+	machines.push_back(std::reference_wrapper<Modeling::Machine>(machine1));
+	machines.push_back(std::reference_wrapper<Modeling::Machine>(machine2));
+	scheduler.addWorkload(workload1);
+	scheduler.addWorkload(workload2);
+
+	// Distribute tasks across machines
+	scheduler.schedule(machines);
+
+	// Do work
+	for (auto machine : machines)
+		machine.get().tick();
+
+	// Assert work done
+	auto workloads = scheduler.getWorkloads();
+	auto workload1Remaining = workloads.at(0).lock()->getRemainingOperations();
+	auto workload2Remaining = workloads.at(1).lock()->getRemainingOperations();
+	ASSERT_EQ(workload1Remaining, 60);
+	ASSERT_EQ(workload2Remaining, 150);
+}
+
+TEST(SimpleSchedulerTest, ScheduleFinishTask)
+{
+	// Initialization
+	Simulation::SimpleScheduler scheduler;
+	Simulation::Workload workload1(100, 0, 1, 1, 0);
+	Modeling::Machine machine1(100);
+
+	std::vector<std::reference_wrapper<Modeling::Machine>> machines;
+	machines.push_back(std::reference_wrapper<Modeling::Machine>(machine1));
+	scheduler.addWorkload(workload1);
+	ASSERT_TRUE(scheduler.hasWorkloads());
+
+	// Distribute tasks across machines
+	scheduler.schedule(machines);
+
+	// Do work
+	for (auto machine : machines)
+		machine.get().tick();
+
+	// Distribute tasks across machines again, this is when finished workloads get cleared
+	scheduler.schedule(machines);
+
+	// Assert work done
+	auto workloads = scheduler.getWorkloads();
+	ASSERT_EQ(workloads.size(), 0);
+	ASSERT_FALSE(scheduler.hasWorkloads());
+}
+
+TEST(SimpleSchedulerTest, AddMultipleWorkloads)
+{
+	Simulation::SimpleScheduler ss;
+	std::vector<Simulation::Workload> workloads{
+		Simulation::Workload(100, 0, 1, 1, 0),
+		Simulation::Workload(100, 0, 1, 1, 0)
+	};
+	ss.addWorkloads(workloads);
+
+	ASSERT_TRUE(ss.hasWorkloads());
+	ASSERT_EQ(ss.getWorkloads().size(), 2);
+}
\ No newline at end of file
diff --git a/Testing/include/simulation/workloads/WorkloadHistoryTest.h b/Testing/include/simulation/workloads/WorkloadHistoryTest.h
new file mode 100644
index 00000000..4cf7f4e3
--- /dev/null
+++ b/Testing/include/simulation/workloads/WorkloadHistoryTest.h
@@ -0,0 +1,15 @@
+#pragma once
+#include "simulation\workloads\WorkloadHistory.h"
+
+#include <gtest\gtest.h>
+
+TEST(WorkloadHistoryTest, SetFlopsDone)
+{
+	Simulation::WorkloadHistory history;
+	history.setFlopsDone(1, 5);
+
+	auto a = history.history.at(0);
+
+	ASSERT_EQ(a.first, 1);
+	ASSERT_EQ(a.second, 5);
+}
\ No newline at end of file
diff --git a/Testing/include/simulation/workloads/WorkloadTest.h b/Testing/include/simulation/workloads/WorkloadTest.h
new file mode 100644
index 00000000..e0da2138
--- /dev/null
+++ b/Testing/include/simulation/workloads/WorkloadTest.h
@@ -0,0 +1,34 @@
+#pragma once
+#include "simulation\workloads\Workload.h"
+
+#include <gtest\gtest.h>
+
+TEST(WorkloadTest, Constructor)
+{
+	Simulation::Workload w(100, 0, 5, 3, 0);
+	ASSERT_EQ(false, w.isFinished());
+	ASSERT_EQ(5, w.getId());
+	ASSERT_EQ(100, w.getRemainingOperations());
+	ASSERT_EQ(100, w.getTotalOperations());
+}
+
+TEST(WorkloadTest, DoOperations)
+{
+	Simulation::Workload w(100, 0, 5, 3, 0);
+	w.doOperations(10);
+	ASSERT_EQ(90, w.getRemainingOperations());
+}
+
+TEST(WorkloadTest, GetTotalOperations)
+{
+	Simulation::Workload w(100, 0, 5, 3, 0);
+	w.doOperations(10);
+	ASSERT_EQ(100, w.getTotalOperations());
+}
+
+TEST(WorkloadTest, IsFinished)
+{
+	Simulation::Workload w(10, 0, 5, 3, 0);
+	w.doOperations(10);
+	ASSERT_EQ(true, w.isFinished());
+}