diff options
| -rw-r--r-- | daemon.c | 4 |
1 files changed, 4 insertions, 0 deletions
@@ -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); |