From 2dbcce88ab7a73304f770006bcae53461c6daddc Mon Sep 17 00:00:00 2001 From: Your Name Date: Wed, 18 Jun 2025 09:20:20 +0200 Subject: threaded the loadbalancing component --- daemon.c | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'daemon.c') diff --git a/daemon.c b/daemon.c index ea1ffaa..5c50f94 100644 --- a/daemon.c +++ b/daemon.c @@ -35,6 +35,10 @@ void *load_balance_thread(void *arg) { if ((max - min) > (avg / 2)) { printf("[daemon] Triggering migration: max load node %d -> min load node %d\n", max_id, min_id); // Call external script/function to checkpoint, scp, and restart + char cmd[512]; + snprintf(cmd, sizeof(cmd), "mpirun -np 1 -host node%d checkpointandbalance.sh %d &", min_id, max_id); + printf("[daemon] Running on node%d: %s\n", node_id, cmd); + system(cmd); char cmd[512]; snprintf(cmd, sizeof(cmd), "ssh node%d \"./migrate_heavy_job.sh %d %d\"", max_id, max_id, min_id); system(cmd); -- cgit v1.2.3