EXIT_FAILURE_CLEAN = 0x08, // error at cleanup
};
- mutex_t proc_mutex;
- condition_t proc_cond;
+ // Cannot be globally initialized...
+ mutex_t* proc_mutex;
+ condition_t* proc_cond;
unsigned proc_counter = 0;
statistics comps;
try {
proc = opt::loba_algorithms.new_instance(opt::loba_algo, argc, argv);
- proc_mutex.acquire();
+ proc_mutex->acquire();
++proc_counter;
- proc_mutex.release();
+ proc_mutex->release();
result = proc->run();
- proc_mutex.acquire();
+ proc_mutex->acquire();
comps.push(proc->get_comp());
loads.push(proc->get_real_load());
// destroys a communication they had together.
--proc_counter;
- proc_cond.broadcast();
+ proc_cond->broadcast();
while (proc_counter > 0)
- proc_cond.wait(proc_mutex);
- proc_mutex.release();
+ proc_cond->wait(*proc_mutex);
+ proc_mutex->release();
delete proc;
}
static void check_for_lost_load()
{
double total_init = process::get_total_load_init();
-
double total_exit = process::get_total_load_exit();
double lost = total_init - total_exit;
double lost_ratio = 100.0 * lost / total_init;
exit_status = EXIT_FAILURE_SIMU; // =====
+ proc_mutex = new mutex_t();
+ proc_cond = new condition_t();
+
// Launch the MSG simulation.
XBT_INFO("Starting simulation at %f...", MSG_get_clock());
res = MSG_main();
simulated_time = MSG_get_clock();
XBT_INFO("Simulation ended at %f.", simulated_time);
+ delete proc_cond;
+ delete proc_mutex;
+
if (res != MSG_OK)
THROW1(0, 0, "MSG_main() failed with status %#x", res);