From fe4080b8dd04acb2074ca72d36e3019acddea455 Mon Sep 17 00:00:00 2001 From: Adrien Gougeon Date: Wed, 15 Nov 2023 16:12:19 +0100 Subject: [PATCH] add get_name for batteries. update dag_from_json to support wfformat 1.4 --- examples/cpp/dag-from-json-simple/dag.json | 10 +++++----- include/simgrid/plugins/battery.hpp | 1 + src/dag/loaders.cpp | 4 ++-- 3 files changed, 8 insertions(+), 7 deletions(-) diff --git a/examples/cpp/dag-from-json-simple/dag.json b/examples/cpp/dag-from-json-simple/dag.json index ea7785097f..fecb6e4ca6 100644 --- a/examples/cpp/dag-from-json-simple/dag.json +++ b/examples/cpp/dag-from-json-simple/dag.json @@ -2,35 +2,35 @@ "name": "simple_json", "schemaVersion": "1.0", "workflow": { - "makespan": 0, + "makespanInSeconds": 0, "executedAt": "2023-03-09T00:00:00-00:00", "tasks": [ { "name": "c1", "type": "compute", "parents": [], - "runtime": 1e9, + "runtimeInSeconds": 1e9, "machine": "Tremblay" }, { "name": "t1", "type": "transfer", "parents": ["c1"], - "bytesWritten": 5e8, + "writtenBytes": 5e8, "machine": "Jupiter" }, { "name": "c2", "type": "compute", "parents": [], - "runtime": 5e9, + "runtimeInSeconds": 5e9, "machine": "Jupiter" }, { "name": "c3", "type": "compute", "parents": ["t1","c2"], - "runtime": 2e9, + "runtimeInSeconds": 2e9, "machine": "Jupiter" } ], diff --git a/include/simgrid/plugins/battery.hpp b/include/simgrid/plugins/battery.hpp index 058428beb4..61937a91a6 100644 --- a/include/simgrid/plugins/battery.hpp +++ b/include/simgrid/plugins/battery.hpp @@ -133,6 +133,7 @@ public: void set_load(const std::string& name, double power_w); void set_load(const std::string& name, bool active); void connect_host(s4u::Host* host, bool active = true); + std::string get_name() {return name_;} double get_state_of_charge(); double get_state_of_health(); double get_capacity(); diff --git a/src/dag/loaders.cpp b/src/dag/loaders.cpp index 8520de548e..57ec032b56 100644 --- a/src/dag/loaders.cpp +++ b/src/dag/loaders.cpp @@ -107,7 +107,7 @@ std::vector create_DAG_from_json(const std::string& filename) for (auto const& task: data["workflow"]["tasks"]) { if (task["type"] == "compute") { current = - Exec::init()->set_name(task["name"].get())->set_flops_amount(task["runtime"].get()); + Exec::init()->set_name(task["name"].get())->set_flops_amount(task["runtimeInSeconds"].get()); if (task.contains("machine")) dynamic_cast(current.get()) ->set_host(simgrid::s4u::Engine::get_instance()->host_by_name(task["machine"].get())); @@ -115,7 +115,7 @@ std::vector create_DAG_from_json(const std::string& filename) else if (task["type"] == "transfer"){ current = Comm::sendto_init() ->set_name(task["name"].get()) - ->set_payload_size(task["bytesWritten"].get()); + ->set_payload_size(task["writtenBytes"].get()); if (task.contains("machine")) comms_destinations[current] = simgrid::s4u::Engine::get_instance()->host_by_name(task["machine"].get()); -- 2.20.1