X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/2f5a2e23987ab74ad87320adce1bb1c886595410..41964ff94baca68cd488f6f7181b90c1ed547781:/src/surf/cpu.c diff --git a/src/surf/cpu.c b/src/surf/cpu.c index cd3024a830..36774f132a 100644 --- a/src/surf/cpu.c +++ b/src/surf/cpu.c @@ -104,14 +104,22 @@ static int resource_used(void *resource_id) ((cpu_Cas01_t) resource_id)->constraint); } -static void action_free(surf_action_t action) +static int action_free(surf_action_t action) { - xbt_swag_remove(action, action->state_set); - if(((surf_action_cpu_Cas01_t)action)->variable) - lmm_variable_free(maxmin_system, ((surf_action_cpu_Cas01_t)action)->variable); - free(action); + action->using--; + if(!action->using) { + xbt_swag_remove(action, action->state_set); + if(((surf_action_cpu_Cas01_t)action)->variable) + lmm_variable_free(maxmin_system, ((surf_action_cpu_Cas01_t)action)->variable); + free(action); + return 1; + } + return 0; +} - return; +static void action_use(surf_action_t action) +{ + action->using++; } static void action_cancel(surf_action_t action) @@ -127,11 +135,11 @@ static void action_recycle(surf_action_t action) static void action_change_state(surf_action_t action, e_surf_action_state_t state) { - if((state==SURF_ACTION_DONE) || (state==SURF_ACTION_FAILED)) - if(((surf_action_cpu_Cas01_t)action)->variable) { - lmm_variable_disable(maxmin_system, ((surf_action_cpu_Cas01_t)action)->variable); - ((surf_action_cpu_Cas01_t)action)->variable = NULL; - } +/* if((state==SURF_ACTION_DONE) || (state==SURF_ACTION_FAILED)) */ +/* if(((surf_action_cpu_Cas01_t)action)->variable) { */ +/* lmm_variable_disable(maxmin_system, ((surf_action_cpu_Cas01_t)action)->variable); */ +/* ((surf_action_cpu_Cas01_t)action)->variable = NULL; */ +/* } */ surf_action_change_state(action, state); return; @@ -218,6 +226,7 @@ static surf_action_t execute(void *cpu, double size) action = xbt_new0(s_surf_action_cpu_Cas01_t, 1); + action->generic_action.using = 1; action->generic_action.cost = size; action->generic_action.remains = size; action->generic_action.max_duration = NO_MAX_DURATION; @@ -318,6 +327,7 @@ static void surf_cpu_resource_init_internal(void) surf_cpu_resource->common_public->action_get_state = surf_action_get_state; surf_cpu_resource->common_public->action_free = action_free; + surf_cpu_resource->common_public->action_use = action_use; surf_cpu_resource->common_public->action_cancel = action_cancel; surf_cpu_resource->common_public->action_recycle = action_recycle; surf_cpu_resource->common_public->action_change_state =