X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/5dd4f0820dc1b968aac1bd7213ab91bdb1107189..6a6157abf9619875297ff1d16c1e5c63c526d4c1:/src/surf/cpu_im.c diff --git a/src/surf/cpu_im.c b/src/surf/cpu_im.c index fe34934412..f4f3873fff 100644 --- a/src/surf/cpu_im.c +++ b/src/surf/cpu_im.c @@ -156,8 +156,6 @@ static void cpu_im_add_traces_cpu(void) static void cpu_im_define_callbacks(const char *file) { - - surf_parse_reset_parser(); surfxml_add_callback(STag_surfxml_host_cb_list, parse_cpu_im_init); surfxml_add_callback(ETag_surfxml_platform_cb_list, &cpu_im_add_traces_cpu); @@ -187,7 +185,7 @@ static int cpu_im_action_unref(surf_action_t action) if (action->category) xbt_free(action->category); #endif - free(action); + surf_action_free(&action); return 1; } return 0; @@ -247,7 +245,7 @@ static void cpu_im_update_remains(cpu_Cas01_im_t cpu, double now) cpu->last_update, now - cpu->last_update); #endif - DEBUG2("Update action(%p) remains %lf", action, + XBT_DEBUG("Update action(%p) remains %lf", action, GENERIC_ACTION(action).remains); } } @@ -296,7 +294,7 @@ static double cpu_im_share_resources(double now) GENERIC_ACTION(action).start + GENERIC_ACTION(action).max_duration; - DEBUG4("Action(%p) Start %lf Finish %lf Max_duration %lf", action, + XBT_DEBUG("Action(%p) Start %lf Finish %lf Max_duration %lf", action, GENERIC_ACTION(action).start, now + value, GENERIC_ACTION(action).max_duration); @@ -308,7 +306,7 @@ static double cpu_im_share_resources(double now) } if (min != -1) { xbt_heap_push(cpu_im_action_heap, action, min); - DEBUG2("Insert at heap action(%p) min %lf", action, min); + XBT_DEBUG("Insert at heap action(%p) min %lf", action, min); } } xbt_swag_remove(cpu, cpu_im_modified_cpu); @@ -324,7 +322,7 @@ static void cpu_im_update_actions_state(double now, double delta) while ((xbt_heap_size(cpu_im_action_heap) > 0) && (double_equals(xbt_heap_maxkey(cpu_im_action_heap), now))) { action = xbt_heap_pop(cpu_im_action_heap); - DEBUG1("Action %p: finish", action); + XBT_DEBUG("Action %p: finish", action); GENERIC_ACTION(action).finish = surf_get_clock(); /* set the remains to 0 due to precision problems when updating the remaining amount */ #ifdef HAVE_TRACING @@ -418,7 +416,7 @@ static void cpu_im_update_resource_state(void *id, if (tmgr_trace_event_free(event_type)) cpu->state_event = NULL; } else { - CRITICAL0("Unknown event ! \n"); + XBT_CRITICAL("Unknown event ! \n"); xbt_abort(); } @@ -430,7 +428,7 @@ static surf_action_t cpu_im_execute(void *cpu, double size) surf_action_cpu_Cas01_im_t action = NULL; cpu_Cas01_im_t CPU = cpu; - XBT_IN2("(%s,%g)", surf_resource_name(CPU), size); + XBT_IN("(%s,%g)", surf_resource_name(CPU), size); action = surf_action_new(sizeof(s_surf_action_cpu_Cas01_im_t), size, surf_cpu_model, @@ -448,7 +446,7 @@ static surf_action_t cpu_im_execute(void *cpu, double size) xbt_swag_insert(action, CPU->action_set); lmm_expand(cpu_im_maxmin_system, CPU->constraint, GENERIC_LMM_ACTION(action).variable, 1.0); - XBT_OUT; + XBT_OUT(); return (surf_action_t) action; } @@ -459,7 +457,7 @@ static surf_action_t cpu_im_action_sleep(void *cpu, double duration) if (duration > 0) duration = MAX(duration, MAXMIN_PRECISION); - XBT_IN2("(%s,%g)", surf_resource_name(cpu), duration); + XBT_IN("(%s,%g)", surf_resource_name(cpu), duration); action = (surf_action_cpu_Cas01_im_t) cpu_im_execute(cpu, 1.0); GENERIC_ACTION(action).max_duration = duration; GENERIC_LMM_ACTION(action).suspended = 2; @@ -475,13 +473,13 @@ static surf_action_t cpu_im_action_sleep(void *cpu, double duration) lmm_update_variable_weight(cpu_im_maxmin_system, GENERIC_LMM_ACTION(action).variable, 0.0); xbt_swag_insert(cpu, cpu_im_modified_cpu); - XBT_OUT; + XBT_OUT(); return (surf_action_t) action; } static void cpu_im_action_suspend(surf_action_t action) { - XBT_IN1("(%p)", action); + XBT_IN("(%p)", action); if (((surf_action_lmm_t) action)->suspended != 2) { lmm_update_variable_weight(cpu_im_maxmin_system, ((surf_action_lmm_t) action)->variable, @@ -491,13 +489,13 @@ static void cpu_im_action_suspend(surf_action_t action) ((surf_action_cpu_Cas01_im_t) action)->index_heap); xbt_swag_insert(ACTION_GET_CPU(action), cpu_im_modified_cpu); } - XBT_OUT; + XBT_OUT(); } static void cpu_im_action_resume(surf_action_t action) { - XBT_IN1("(%p)", action); + XBT_IN("(%p)", action); if (((surf_action_lmm_t) action)->suspended != 2) { lmm_update_variable_weight(cpu_im_maxmin_system, ((surf_action_lmm_t) action)->variable, @@ -505,7 +503,7 @@ static void cpu_im_action_resume(surf_action_t action) ((surf_action_lmm_t) action)->suspended = 0; xbt_swag_insert(ACTION_GET_CPU(action), cpu_im_modified_cpu); } - XBT_OUT; + XBT_OUT(); } static int cpu_im_action_is_suspended(surf_action_t action) @@ -516,44 +514,44 @@ static int cpu_im_action_is_suspended(surf_action_t action) static void cpu_im_action_set_max_duration(surf_action_t action, double duration) { - XBT_IN2("(%p,%g)", action, duration); + XBT_IN("(%p,%g)", action, duration); action->max_duration = duration; /* insert cpu in modified_cpu set to notice the max duration change */ xbt_swag_insert(ACTION_GET_CPU(action), cpu_im_modified_cpu); - XBT_OUT; + XBT_OUT(); } static void cpu_im_action_set_priority(surf_action_t action, double priority) { - XBT_IN2("(%p,%g)", action, priority); + XBT_IN("(%p,%g)", action, priority); action->priority = priority; lmm_update_variable_weight(cpu_im_maxmin_system, ((surf_action_lmm_t) action)->variable, priority); xbt_swag_insert(ACTION_GET_CPU(action), cpu_im_modified_cpu); - XBT_OUT; + XBT_OUT(); } #ifdef HAVE_TRACING static void cpu_im_action_set_category(surf_action_t action, const char *category) { - XBT_IN2("(%p,%s)", action, category); + XBT_IN("(%p,%s)", action, category); action->category = xbt_strdup (category); - XBT_OUT; + XBT_OUT(); } #endif static double cpu_im_action_get_remains(surf_action_t action) { - XBT_IN1("(%p)", action); + XBT_IN("(%p)", action); /* update remains before return it */ cpu_im_update_remains(ACTION_GET_CPU(action), surf_get_clock()); return action->remains; - XBT_OUT; + XBT_OUT(); } static e_surf_resource_state_t cpu_im_get_state(void *cpu)