XBT_INFO("Sleep long enough for everyone to be done with previous batch of work");
MSG_process_sleep(1000-MSG_get_clock());
- XBT_INFO("Add one more process per VM, and dispatch a batch of work to everyone");
+ XBT_INFO("Add one more process per VM");
for (i=0;i<xbt_dynar_length(vms);i++) {
msg_vm_t vm = xbt_dynar_get_as(vms,i,msg_vm_t);
char slavename[64];
MSG_vm_migrate(vm,slaves[2]);
MSG_vm_resume(vm);
}
+
work_batch(slaves_count*2);
XBT_INFO("Let's shut down the simulation. 10 first processes will be shut down cleanly while the second half will forcefully get killed");
for (i=0;i<xbt_dynar_length(vms);i++) {
msg_vm_t vm = xbt_dynar_get_as(vms,i,msg_vm_t);
MSG_vm_shutdown(vm);
+ MSG_vm_destroy(vm);
}
XBT_INFO("Goodbye now!");
MSG_task_destroy(task);
task = NULL;
}
+
free(mailbox_name);
return 0;
} /* end_of_slave */