- actions_on_system = 0;
- while (xbt_heap_size(simix_timers) > 0 && SIMIX_get_clock() >= SIMIX_timer_next()) {
- timer = xbt_heap_pop(simix_timers);
- fun = timer->func;
- arg = timer->args;
- free(timer);
- /* change in process, don't quit */
- actions_on_system = 1;
- DEBUG3("got %p %p at %f", fun, arg, timer->date);
- if (fun == SIMIX_process_create) {
- smx_process_arg_t args = arg;
- DEBUG2("Launching %s on %s", args->name, args->hostname);
- process = SIMIX_process_create(args->name, args->code,
- args->data, args->hostname,
- args->argc, args->argv,
- args->properties);
- /* verify if process has been created */
- if (!process) {
- xbt_free(args);
- continue;
- }
-
- if (args->kill_time > SIMIX_get_clock()) {
- SIMIX_timer_set(args->kill_time, &SIMIX_process_kill, process);
- }
- xbt_free(args);
- } else if (fun == simix_global->create_process_function) {
- smx_process_arg_t args = arg;
- DEBUG2("Launching %s on %s", args->name, args->hostname);
- process =
- (*simix_global->create_process_function) (args->name,
- args->code,
- args->data,
- args->hostname,
- args->argc,
- args->argv,
- args->properties);
- /* verify if process has been created */
- if (!process) {
- xbt_free(args);
- continue;
- }
- if (args->kill_time > SIMIX_get_clock()) {
- if (simix_global->kill_process_function)
- SIMIX_timer_set(args->kill_time, simix_global->kill_process_function, process);
- else
- SIMIX_timer_set(args->kill_time, &SIMIX_process_kill, process);
- }
- xbt_free(args);
- } else if (fun == SIMIX_process_kill) {
- process = arg;
- DEBUG2("Killing %s on %s", process->name, process->smx_host->name);
- SIMIX_process_kill(process, SIMIX_process_self());
- } else if (fun == simix_global->kill_process_function) {
- process = arg;
- (*simix_global->kill_process_function) (process);
- } else {
- //FIXME: ((void (*)(void*))fun)(arg);
- THROW_IMPOSSIBLE;
- }
- }
-
- /* Wake up all process waiting for the action finish */
- xbt_dynar_foreach(model_list, iter, model) {
- /* stop simulation case there are no actions to run */
- if ((xbt_swag_size(model->states.running_action_set)) ||
- (xbt_swag_size(model->states.ready_action_set)) ||
- (xbt_swag_size(model->states.done_action_set)) ||
- (xbt_swag_size(model->states.failed_action_set)))
- actions_on_system = 1;
-
- while ((action = xbt_swag_extract(model->states.failed_action_set))) {
- smx_action = action->data;
- if (smx_action) {
-// SIMIX_action_signal_all(smx_action);
- }
- }
- while ((action = xbt_swag_extract(model->states.done_action_set))) {
- smx_action = action->data;
- if (smx_action) {
-// SIMIX_action_signal_all(smx_action);
- }
- }
- }
- }
-
- if (xbt_heap_size(simix_timers) > 0) {
- actions_on_system = 1;
- }