X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/8c354c48ec90c997cc7213ce96ca97d882934166..6761e997f501c19abb9cf5329733d556b1dfcfd8:/src/surf/cpu.c diff --git a/src/surf/cpu.c b/src/surf/cpu.c index 0fa4303209..0568742ee2 100644 --- a/src/surf/cpu.c +++ b/src/surf/cpu.c @@ -6,55 +6,45 @@ * under the terms of the license (GNU LGPL) which comes with this package. */ #include "cpu_private.h" -#include "xbt/dict.h" -XBT_LOG_NEW_DEFAULT_SUBCATEGORY(cpu, surf, +XBT_LOG_NEW_DEFAULT_SUBCATEGORY(surf_cpu, surf, "Logging specific to the SURF CPU module"); -surf_cpu_resource_t surf_cpu_resource = NULL; +surf_cpu_model_t surf_cpu_model = NULL; +lmm_system_t cpu_maxmin_system = NULL; -static xbt_dict_t cpu_set = NULL; +xbt_dict_t cpu_set = NULL; -static void cpu_free(void *CPU) +static void cpu_free(void *cpu) { -/* cpu_t cpu = CPU; */ -/* lmm_constraint_free(maxmin_system,cpu->constraint); */ -/* Clean somewhere else ! */ - - xbt_free(CPU); + free(((cpu_Cas01_t) cpu)->name); + free(cpu); } -/* power_scale is the basic power of the cpu when the cpu is - completely available. power_initial is therefore expected to be - comprised between 0.0 and 1.0, just as the values of power_trace. - state_trace values mean SURF_CPU_ON if >0 and SURF_CPU_OFF - otherwise. -*/ -static cpu_t cpu_new(const char *name, xbt_maxmin_float_t power_scale, - xbt_maxmin_float_t power_initial, - tmgr_trace_t power_trace, - e_surf_cpu_state_t state_initial, - tmgr_trace_t state_trace) +static cpu_Cas01_t cpu_new(char *name, double power_scale, + double power_initial, + tmgr_trace_t power_trace, + e_surf_cpu_state_t state_initial, + tmgr_trace_t state_trace) { - cpu_t cpu = xbt_new0(s_cpu_t, 1); + cpu_Cas01_t cpu = xbt_new0(s_cpu_Cas01_t, 1); - cpu->resource = (surf_resource_t) surf_cpu_resource; + cpu->model = (surf_model_t) surf_cpu_model; cpu->name = name; cpu->power_scale = power_scale; + xbt_assert0(cpu->power_scale > 0, "Power has to be >0"); cpu->power_current = power_initial; -/* cpu->power_trace = power_trace; */ if (power_trace) cpu->power_event = tmgr_history_add_trace(history, power_trace, 0.0, 0, cpu); cpu->state_current = state_initial; -/* cpu->state_trace = state_trace; */ if (state_trace) cpu->state_event = tmgr_history_add_trace(history, state_trace, 0.0, 0, cpu); cpu->constraint = - lmm_constraint_new(maxmin_system, cpu, + lmm_constraint_new(cpu_maxmin_system, cpu, cpu->power_current * cpu->power_scale); xbt_dict_set(cpu_set, name, cpu, cpu_free); @@ -62,43 +52,28 @@ static cpu_t cpu_new(const char *name, xbt_maxmin_float_t power_scale, return cpu; } -/* - Semantic: name scale initial power initial state - power trace state trace - - Token: TOKEN_WORD TOKEN_WORD TOKEN_WORD TOKEN_WORD TOKEN_WORD TOKEN_WORD - Type: string float float string ON/OFF string -*/ - static void parse_cpu(void) { - e_surf_token_t token; char *name = NULL; - xbt_maxmin_float_t power_scale = 0.0; - xbt_maxmin_float_t power_initial = 0.0; - tmgr_trace_t power_trace = NULL;; + double power_scale = 0.0; + double power_initial = 0.0; + tmgr_trace_t power_trace = NULL; e_surf_cpu_state_t state_initial = SURF_CPU_OFF; tmgr_trace_t state_trace = NULL; - name = xbt_strdup(surf_parse_text); + name = xbt_strdup(A_surfxml_cpu_name); + surf_parse_get_double(&power_scale, A_surfxml_cpu_power); + surf_parse_get_double(&power_initial, A_surfxml_cpu_availability); + surf_parse_get_trace(&power_trace, A_surfxml_cpu_availability_file); - surf_parse_float(&power_scale); - surf_parse_float(&power_initial); - surf_parse_trace(&power_trace); - - token = surf_parse(); /* state_initial */ - xbt_assert1((token == TOKEN_WORD), "Parse error line %d", line_pos); - if (strcmp(surf_parse_text, "ON") == 0) + xbt_assert0((A_surfxml_cpu_state == A_surfxml_cpu_state_ON) || + (A_surfxml_cpu_state == A_surfxml_cpu_state_OFF), + "Invalid state"); + if (A_surfxml_cpu_state == A_surfxml_cpu_state_ON) state_initial = SURF_CPU_ON; - else if (strcmp(surf_parse_text, "OFF") == 0) + if (A_surfxml_cpu_state == A_surfxml_cpu_state_OFF) state_initial = SURF_CPU_OFF; - else { - CRITICAL2("Invalid cpu state (line %d): %s neq ON or OFF\n", line_pos, - surf_parse_text); - xbt_abort(); - } - - surf_parse_trace(&state_trace); + surf_parse_get_trace(&state_trace, A_surfxml_cpu_state_file); cpu_new(name, power_scale, power_initial, power_trace, state_initial, state_trace); @@ -106,128 +81,116 @@ static void parse_cpu(void) static void parse_file(const char *file) { - e_surf_token_t token; - - find_section(file, "CPU"); - - while (1) { - token = surf_parse(); - - if (token == TOKEN_END_SECTION) - break; - if (token == TOKEN_NEWLINE) - continue; - - if (token == TOKEN_WORD) - parse_cpu(); - else { - CRITICAL1("Parse error line %d\n", line_pos); - xbt_abort(); - } - } - - close_section("CPU"); + surf_parse_reset_parser(); + ETag_surfxml_cpu_fun = parse_cpu; + surf_parse_open(file); + xbt_assert1((!surf_parse()), "Parse error in %s", file); + surf_parse_close(); } static void *name_service(const char *name) { - void *cpu = NULL; - - xbt_dict_get(cpu_set, name, &cpu); - - return cpu; + return xbt_dict_get_or_null(cpu_set, name); } -static const char *get_resource_name(void *resource_id) +static const char *get_model_name(void *model_id) { - return ((cpu_t) resource_id)->name; + return ((cpu_Cas01_t) model_id)->name; } -static int resource_used(void *resource_id) +static int model_used(void *model_id) { - return lmm_constraint_used(maxmin_system, - ((cpu_t) resource_id)->constraint); + return lmm_constraint_used(cpu_maxmin_system, + ((cpu_Cas01_t) model_id)->constraint); } -static void action_free(surf_action_t action) +static int action_free(surf_action_t action) { - surf_action_cpu_t Action = (surf_action_cpu_t) action; - - xbt_swag_remove(action, action->state_set); - lmm_variable_free(maxmin_system, Action->variable); - xbt_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(cpu_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) { + surf_action_change_state(action, SURF_ACTION_FAILED); return; } static void action_recycle(surf_action_t action) { - return; + DIE_IMPOSSIBLE; } 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(cpu_maxmin_system, ((surf_action_cpu_Cas01_t)action)->variable); */ +/* ((surf_action_cpu_Cas01_t)action)->variable = NULL; */ +/* } */ + surf_action_change_state(action, state); return; } -static xbt_heap_float_t share_resources(xbt_heap_float_t now) +static double share_models(double now) { - surf_action_cpu_t action = NULL; - xbt_swag_t running_actions = - surf_cpu_resource->common_public->states.running_action_set; - xbt_maxmin_float_t min = -1; - xbt_maxmin_float_t value = -1; - lmm_solve(maxmin_system); - - action = xbt_swag_getFirst(running_actions); - if (!action) - return -1.0; - value = lmm_variable_getvalue(action->variable); - min = action->generic_action.remains / value; - - xbt_swag_foreach(action, running_actions) { - value = action->generic_action.remains / - lmm_variable_getvalue(action->variable); - if (value < min) - min = value; - } - - return min; + s_surf_action_cpu_Cas01_t action; + return generic_maxmin_share_models2(surf_cpu_model->common_public-> + states.running_action_set, + xbt_swag_offset(action, variable), + cpu_maxmin_system, lmm_solve); } -static void update_actions_state(xbt_heap_float_t now, - xbt_heap_float_t delta) +static void update_actions_state(double now, double delta) { - surf_action_cpu_t action = NULL; - surf_action_cpu_t next_action = NULL; + surf_action_cpu_Cas01_t action = NULL; + surf_action_cpu_Cas01_t next_action = NULL; xbt_swag_t running_actions = - surf_cpu_resource->common_public->states.running_action_set; - xbt_swag_t failed_actions = - surf_cpu_resource->common_public->states.failed_action_set; + surf_cpu_model->common_public->states.running_action_set; + /* FIXME: UNUSED + xbt_swag_t failed_actions = + surf_cpu_model->common_public->states.failed_action_set; + */ xbt_swag_foreach_safe(action, next_action, running_actions) { - action->generic_action.remains -= - lmm_variable_getvalue(action->variable) * delta; -/* if(action->generic_action.remains<.00001) action->generic_action.remains=0; */ - if (action->generic_action.remains <= 0) { + double_update(&(action->generic_action.remains), + lmm_variable_getvalue(action->variable) * delta); + if (action->generic_action.max_duration != NO_MAX_DURATION) + double_update(&(action->generic_action.max_duration), delta); + if ((action->generic_action.remains <= 0) && + (lmm_get_variable_weight(action->variable) > 0)) { + action->generic_action.finish = surf_get_clock(); + action_change_state((surf_action_t) action, SURF_ACTION_DONE); + } else if ((action->generic_action.max_duration != NO_MAX_DURATION) && + (action->generic_action.max_duration <= 0)) { + action->generic_action.finish = surf_get_clock(); action_change_state((surf_action_t) action, SURF_ACTION_DONE); - } else { /* Need to check that none of the resource has failed */ + } else { /* Need to check that none of the model has failed */ lmm_constraint_t cnst = NULL; int i = 0; - cpu_t cpu = NULL; + cpu_Cas01_t cpu = NULL; while ((cnst = - lmm_get_cnst_from_var(maxmin_system, action->variable, + lmm_get_cnst_from_var(cpu_maxmin_system, action->variable, i++))) { cpu = lmm_constraint_id(cnst); if (cpu->state_current == SURF_CPU_OFF) { + action->generic_action.finish = surf_get_clock(); action_change_state((surf_action_t) action, SURF_ACTION_FAILED); break; } @@ -235,26 +198,18 @@ static void update_actions_state(xbt_heap_float_t now, } } - xbt_swag_foreach_safe(action, next_action, failed_actions) { - lmm_variable_disable(maxmin_system, action->variable); - } - return; } -static void update_resource_state(void *id, +static void update_model_state(void *id, tmgr_trace_event_t event_type, - xbt_maxmin_float_t value) + double value) { - cpu_t cpu = id; - -/* printf("[" XBT_HEAP_FLOAT_T "] Asking to update CPU \"%s\" with value " */ -/* XBT_MAXMIN_FLOAT_T " for event %p\n", surf_get_clock(), cpu->name, */ -/* value, event_type); */ + cpu_Cas01_t cpu = id; if (event_type == cpu->power_event) { cpu->power_current = value; - lmm_update_constraint_bound(maxmin_system,cpu->constraint, + lmm_update_constraint_bound(cpu_maxmin_system, cpu->constraint, cpu->power_current * cpu->power_scale); } else if (event_type == cpu->state_event) { if (value > 0) @@ -269,110 +224,220 @@ static void update_resource_state(void *id, return; } -static surf_action_t execute(void *cpu, xbt_maxmin_float_t size) +static surf_action_t execute(void *cpu, double size) { - surf_action_cpu_t action = NULL; - cpu_t CPU = cpu; + surf_action_cpu_Cas01_t action = NULL; + cpu_Cas01_t CPU = cpu; - action = xbt_new0(s_surf_action_cpu_t, 1); + XBT_IN2("(%s,%g)", CPU->name, 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.start = -1.0; + action->generic_action.priority = 1.0; + action->generic_action.max_duration = NO_MAX_DURATION; + action->generic_action.start = surf_get_clock(); action->generic_action.finish = -1.0; -/* action->generic_action.callback = cpu; */ - action->generic_action.callback = NULL; - action->generic_action.resource_type = - (surf_resource_t) surf_cpu_resource; + action->generic_action.model_type = + (surf_model_t) surf_cpu_model; + action->suspended = 0; /* Should be useless because of the + calloc but it seems to help valgrind... */ if (CPU->state_current == SURF_CPU_ON) action->generic_action.state_set = - surf_cpu_resource->common_public->states.running_action_set; + surf_cpu_model->common_public->states.running_action_set; else action->generic_action.state_set = - surf_cpu_resource->common_public->states.failed_action_set; + surf_cpu_model->common_public->states.failed_action_set; xbt_swag_insert(action, action->generic_action.state_set); - action->variable = lmm_variable_new(maxmin_system, action, 1.0, -1.0, 1); - lmm_expand(maxmin_system, ((cpu_t) cpu)->constraint, action->variable, - 1.0); + action->variable = lmm_variable_new(cpu_maxmin_system, action, + action->generic_action.priority, + -1.0, 1); + lmm_expand(cpu_maxmin_system, CPU->constraint, action->variable, 1.0); + XBT_OUT; + return (surf_action_t) action; +} +static surf_action_t action_sleep(void *cpu, double duration) +{ + surf_action_cpu_Cas01_t action = NULL; + + XBT_IN2("(%s,%g)", ((cpu_Cas01_t) cpu)->name, duration); + action = (surf_action_cpu_Cas01_t) execute(cpu, 1.0); + action->generic_action.max_duration = duration; + action->suspended = 2; + lmm_update_variable_weight(cpu_maxmin_system, action->variable, 0.0); + XBT_OUT; return (surf_action_t) action; } +static void action_suspend(surf_action_t action) +{ + XBT_IN1("(%p)", action); + if (((surf_action_cpu_Cas01_t) action)->suspended != 2) { + lmm_update_variable_weight(cpu_maxmin_system, + ((surf_action_cpu_Cas01_t) action)-> + variable, 0.0); + ((surf_action_cpu_Cas01_t) action)->suspended = 1; + } + XBT_OUT; +} + +static void action_resume(surf_action_t action) +{ + XBT_IN1("(%p)", action); + if (((surf_action_cpu_Cas01_t) action)->suspended != 2) { + lmm_update_variable_weight(cpu_maxmin_system, + ((surf_action_cpu_Cas01_t) action)-> + variable, action->priority); + ((surf_action_cpu_Cas01_t) action)->suspended = 0; + } + XBT_OUT; +} + +static int action_is_suspended(surf_action_t action) +{ + return (((surf_action_cpu_Cas01_t) action)->suspended == 1); +} + +static void action_set_max_duration(surf_action_t action, double duration) +{ + XBT_IN2("(%p,%g)", action, duration); + action->max_duration = duration; + XBT_OUT; +} + +static void action_set_priority(surf_action_t action, double priority) +{ + XBT_IN2("(%p,%g)", action, priority); + action->priority = priority; + lmm_update_variable_weight(cpu_maxmin_system, ((surf_action_cpu_Cas01_t) action)->variable, priority); + + XBT_OUT; +} + static e_surf_cpu_state_t get_state(void *cpu) { - return SURF_CPU_OFF; + return ((cpu_Cas01_t) cpu)->state_current; +} + +static double get_speed(void *cpu, double load) +{ + return load * (((cpu_Cas01_t) cpu)->power_scale); +} + +static double get_available_speed(void *cpu) +{ + /* number between 0 and 1 */ + return ((cpu_Cas01_t) cpu)->power_current; } static void finalize(void) { xbt_dict_free(&cpu_set); - xbt_swag_free(surf_cpu_resource->common_public->states.ready_action_set); - xbt_swag_free(surf_cpu_resource->common_public->states. + xbt_swag_free(surf_cpu_model->common_public->states.ready_action_set); + xbt_swag_free(surf_cpu_model->common_public->states. running_action_set); - xbt_swag_free(surf_cpu_resource->common_public->states. + xbt_swag_free(surf_cpu_model->common_public->states. failed_action_set); - xbt_swag_free(surf_cpu_resource->common_public->states.done_action_set); - xbt_free(surf_cpu_resource->common_public); - xbt_free(surf_cpu_resource->common_private); - xbt_free(surf_cpu_resource->extension_public); + xbt_swag_free(surf_cpu_model->common_public->states.done_action_set); + free(surf_cpu_model->common_public); + free(surf_cpu_model->common_private); + free(surf_cpu_model->extension_public); - xbt_free(surf_cpu_resource); - surf_cpu_resource = NULL; + free(surf_cpu_model); + surf_cpu_model = NULL; } -static void surf_cpu_resource_init_internal(void) +static void surf_cpu_model_init_internal(void) { s_surf_action_t action; - surf_cpu_resource = xbt_new0(s_surf_cpu_resource_t, 1); + surf_cpu_model = xbt_new0(s_surf_cpu_model_t, 1); + + surf_cpu_model->common_private = + xbt_new0(s_surf_model_private_t, 1); + surf_cpu_model->common_public = xbt_new0(s_surf_model_public_t, 1); - surf_cpu_resource->common_private = - xbt_new0(s_surf_resource_private_t, 1); - surf_cpu_resource->common_public = xbt_new0(s_surf_resource_public_t, 1); -/* surf_cpu_resource->extension_private = xbt_new0(s_surf_cpu_resource_extension_private_t,1); */ - surf_cpu_resource->extension_public = - xbt_new0(s_surf_cpu_resource_extension_public_t, 1); + surf_cpu_model->extension_public = + xbt_new0(s_surf_cpu_model_extension_public_t, 1); - surf_cpu_resource->common_public->states.ready_action_set = + surf_cpu_model->common_public->states.ready_action_set = xbt_swag_new(xbt_swag_offset(action, state_hookup)); - surf_cpu_resource->common_public->states.running_action_set = + surf_cpu_model->common_public->states.running_action_set = xbt_swag_new(xbt_swag_offset(action, state_hookup)); - surf_cpu_resource->common_public->states.failed_action_set = + surf_cpu_model->common_public->states.failed_action_set = xbt_swag_new(xbt_swag_offset(action, state_hookup)); - surf_cpu_resource->common_public->states.done_action_set = + surf_cpu_model->common_public->states.done_action_set = xbt_swag_new(xbt_swag_offset(action, state_hookup)); - surf_cpu_resource->common_public->name_service = name_service; - surf_cpu_resource->common_public->get_resource_name = get_resource_name; - surf_cpu_resource->common_public->action_get_state = + surf_cpu_model->common_public->name_service = name_service; + surf_cpu_model->common_public->get_model_name = get_model_name; + surf_cpu_model->common_public->action_get_state = surf_action_get_state; - surf_cpu_resource->common_public->action_free = action_free; - 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 = + surf_cpu_model->common_public->action_get_start_time = + surf_action_get_start_time; + surf_cpu_model->common_public->action_get_finish_time = + surf_action_get_finish_time; + surf_cpu_model->common_public->action_free = action_free; + surf_cpu_model->common_public->action_use = action_use; + surf_cpu_model->common_public->action_cancel = action_cancel; + surf_cpu_model->common_public->action_recycle = action_recycle; + surf_cpu_model->common_public->action_change_state = action_change_state; + surf_cpu_model->common_public->action_set_data = surf_action_set_data; + surf_cpu_model->common_public->name = "CPU"; - surf_cpu_resource->common_private->resource_used = resource_used; - surf_cpu_resource->common_private->share_resources = share_resources; - surf_cpu_resource->common_private->update_actions_state = + surf_cpu_model->common_private->model_used = model_used; + surf_cpu_model->common_private->share_models = share_models; + surf_cpu_model->common_private->update_actions_state = update_actions_state; - surf_cpu_resource->common_private->update_resource_state = - update_resource_state; - surf_cpu_resource->common_private->finalize = finalize; - - surf_cpu_resource->extension_public->execute = execute; - surf_cpu_resource->extension_public->get_state = get_state; + surf_cpu_model->common_private->update_model_state = + update_model_state; + surf_cpu_model->common_private->finalize = finalize; + + surf_cpu_model->common_public->suspend = action_suspend; + surf_cpu_model->common_public->resume = action_resume; + surf_cpu_model->common_public->is_suspended = action_is_suspended; + surf_cpu_model->common_public->set_max_duration = + action_set_max_duration; + surf_cpu_model->common_public->set_priority = action_set_priority; + surf_cpu_model->extension_public->execute = execute; + surf_cpu_model->extension_public->sleep = action_sleep; + + surf_cpu_model->extension_public->get_state = get_state; + surf_cpu_model->extension_public->get_speed = get_speed; + surf_cpu_model->extension_public->get_available_speed = + get_available_speed; cpu_set = xbt_dict_new(); - xbt_assert0(maxmin_system, "surf_init has to be called first!"); + if (!cpu_maxmin_system) + cpu_maxmin_system = lmm_system_new(); } -void surf_cpu_resource_init(const char *filename) +/*********************************************************************/ +/* Basic sharing model for CPU: that is where all this started... ;) */ +/*********************************************************************/ +/* @InProceedings{casanova01simgrid, */ +/* author = "H. Casanova", */ +/* booktitle = "Proceedings of the IEEE Symposium on Cluster Computing */ +/* and the Grid (CCGrid'01)", */ +/* publisher = "IEEE Computer Society", */ +/* title = "Simgrid: {A} Toolkit for the Simulation of Application */ +/* Scheduling", */ +/* year = "2001", */ +/* month = may, */ +/* note = "Available at */ +/* \url{http://grail.sdsc.edu/papers/simgrid_ccgrid01.ps.gz}." */ +/* } */ +void surf_cpu_model_init_Cas01(const char *filename) { - surf_cpu_resource_init_internal(); + if (surf_cpu_model) + return; + surf_cpu_model_init_internal(); parse_file(filename); - xbt_dynar_push(resource_list, &surf_cpu_resource); + xbt_dynar_push(model_list, &surf_cpu_model); }