tmgr_history_add_trace(history, state_trace, 0.0, 0, cpu);
cpu->constraint =
tmgr_history_add_trace(history, state_trace, 0.0, 0, cpu);
cpu->constraint =
cpu->core * cpu->power_scale * cpu->power_peak);
xbt_lib_set(host_lib, name, SURF_CPU_LEVEL, cpu);
cpu->core * cpu->power_scale * cpu->power_peak);
xbt_lib_set(host_lib, name, SURF_CPU_LEVEL, cpu);
if (!action->refcount) {
xbt_swag_remove(action, action->state_set);
if (((surf_action_lmm_t) action)->variable)
if (!action->refcount) {
xbt_swag_remove(action, action->state_set);
if (((surf_action_lmm_t) action)->variable)
- surf_action_lmm_heap_remove(surf_cpu_model->action_heap,(surf_action_lmm_t)action);
- xbt_swag_remove(action, surf_cpu_model->modified_set);
+ surf_action_lmm_heap_remove(surf_cpu_model->model_private->action_heap,(surf_action_lmm_t)action);
+ xbt_swag_remove(action, surf_cpu_model->model_private->modified_set);
static void cpu_action_cancel(surf_action_t action)
{
surf_action_state_set(action, SURF_ACTION_FAILED);
static void cpu_action_cancel(surf_action_t action)
{
surf_action_state_set(action, SURF_ACTION_FAILED);
- if (surf_cpu_model->update_mechanism == UM_LAZY) {
- xbt_swag_remove(action, surf_cpu_model->modified_set);
- surf_action_lmm_heap_remove(surf_cpu_model->action_heap,(surf_action_lmm_t)action);
+ if (surf_cpu_model->model_private->update_mechanism == UM_LAZY) {
+ xbt_swag_remove(action, surf_cpu_model->model_private->modified_set);
+ surf_action_lmm_heap_remove(surf_cpu_model->model_private->action_heap,(surf_action_lmm_t)action);
GENERIC_LMM_ACTION(action).variable, 0));
TRACE_surf_host_set_utilization(cpu->generic_resource.name,
((surf_action_t)action)->category,
GENERIC_LMM_ACTION(action).variable, 0));
TRACE_surf_host_set_utilization(cpu->generic_resource.name,
((surf_action_t)action)->category,
- surf_action_lmm_heap_remove(surf_cpu_model->action_heap,(surf_action_lmm_t)action);
- surf_action_lmm_heap_insert(surf_cpu_model->action_heap,(surf_action_lmm_t)action, min, max_dur_flag ? MAX_DURATION : NORMAL);
+ surf_action_lmm_heap_remove(surf_cpu_model->model_private->action_heap,(surf_action_lmm_t)action);
+ surf_action_lmm_heap_insert(surf_cpu_model->model_private->action_heap,(surf_action_lmm_t)action, min, max_dur_flag ? MAX_DURATION : NORMAL);
XBT_DEBUG("Insert at heap action(%p) min %lf now %lf", action, min,
now);
} else DIE_IMPOSSIBLE;
}
//hereafter must have already the min value for this resource model
XBT_DEBUG("Insert at heap action(%p) min %lf now %lf", action, min,
now);
} else DIE_IMPOSSIBLE;
}
//hereafter must have already the min value for this resource model
- if (xbt_heap_size(surf_cpu_model->action_heap) > 0)
- min = xbt_heap_maxkey(surf_cpu_model->action_heap) - now;
+ if (xbt_heap_size(surf_cpu_model->model_private->action_heap) > 0)
+ min = xbt_heap_maxkey(surf_cpu_model->model_private->action_heap) - now;
}
static void cpu_update_actions_state_lazy(double now, double delta)
{
surf_action_cpu_Cas01_t action;
}
static void cpu_update_actions_state_lazy(double now, double delta)
{
surf_action_cpu_Cas01_t action;
- while ((xbt_heap_size(surf_cpu_model->action_heap) > 0)
- && (double_equals(xbt_heap_maxkey(surf_cpu_model->action_heap), now))) {
- action = xbt_heap_pop(surf_cpu_model->action_heap);
+ while ((xbt_heap_size(surf_cpu_model->model_private->action_heap) > 0)
+ && (double_equals(xbt_heap_maxkey(surf_cpu_model->model_private->action_heap), now))) {
+ action = xbt_heap_pop(surf_cpu_model->model_private->action_heap);
XBT_DEBUG("Action %p: finish", action);
GENERIC_ACTION(action).finish = surf_get_clock();
#ifdef HAVE_TRACING
if (TRACE_is_enabled()) {
cpu_Cas01_t cpu =
lmm_constraint_id(lmm_get_cnst_from_var
XBT_DEBUG("Action %p: finish", action);
GENERIC_ACTION(action).finish = surf_get_clock();
#ifdef HAVE_TRACING
if (TRACE_is_enabled()) {
cpu_Cas01_t cpu =
lmm_constraint_id(lmm_get_cnst_from_var
GENERIC_LMM_ACTION(action).variable, 0));
TRACE_surf_host_set_utilization(cpu->generic_resource.name,
((surf_action_t)action)->category,
GENERIC_LMM_ACTION(action).variable, 0));
TRACE_surf_host_set_utilization(cpu->generic_resource.name,
((surf_action_t)action)->category,
/* set the remains to 0 due to precision problems when updating the remaining amount */
GENERIC_ACTION(action).remains = 0;
cpu_action_state_set((surf_action_t) action, SURF_ACTION_DONE);
/* set the remains to 0 due to precision problems when updating the remaining amount */
GENERIC_ACTION(action).remains = 0;
cpu_action_state_set((surf_action_t) action, SURF_ACTION_DONE);
GENERIC_LMM_ACTION(action).variable, 0));
TRACE_surf_host_set_utilization(x->generic_resource.name,
GENERIC_LMM_ACTION(action).variable, 0));
TRACE_surf_host_set_utilization(x->generic_resource.name,
GENERIC_LMM_ACTION(action).variable,
cpu->power_scale * cpu->power_peak);
}
GENERIC_LMM_ACTION(action).variable,
cpu->power_scale * cpu->power_peak);
}
surf_action_t action = lmm_variable_id(var);
if (surf_action_state_get(action) == SURF_ACTION_RUNNING ||
surf_action_t action = lmm_variable_id(var);
if (surf_action_state_get(action) == SURF_ACTION_RUNNING ||
GENERIC_ACTION(action).priority,
CPU->power_scale * CPU->power_peak, 1);
GENERIC_ACTION(action).priority,
CPU->power_scale * CPU->power_peak, 1);
GENERIC_LMM_ACTION(action).index_heap = -1;
GENERIC_LMM_ACTION(action).last_update = surf_get_clock();
GENERIC_LMM_ACTION(action).last_value = 0.0;
}
GENERIC_LMM_ACTION(action).index_heap = -1;
GENERIC_LMM_ACTION(action).last_update = surf_get_clock();
GENERIC_LMM_ACTION(action).last_value = 0.0;
}
GENERIC_LMM_ACTION(action).variable, 1.0);
XBT_OUT();
return (surf_action_t) action;
GENERIC_LMM_ACTION(action).variable, 1.0);
XBT_OUT();
return (surf_action_t) action;
- if (surf_cpu_model->update_mechanism == UM_LAZY) { // remove action from the heap
- surf_action_lmm_heap_remove(surf_cpu_model->action_heap,(surf_action_lmm_t)action);
+ if (surf_cpu_model->model_private->update_mechanism == UM_LAZY) { // remove action from the heap
+ surf_action_lmm_heap_remove(surf_cpu_model->model_private->action_heap,(surf_action_lmm_t)action);
// this is necessary for a variable with weight 0 since such
// variables are ignored in lmm and we need to set its max_duration
// correctly at the next call to share_resources
// this is necessary for a variable with weight 0 since such
// variables are ignored in lmm and we need to set its max_duration
// correctly at the next call to share_resources
((surf_action_lmm_t) action)->variable,
0.0);
((surf_action_lmm_t) action)->suspended = 1;
((surf_action_lmm_t) action)->variable,
0.0);
((surf_action_lmm_t) action)->suspended = 1;
- if (surf_cpu_model->update_mechanism == UM_LAZY)
- surf_action_lmm_heap_remove(surf_cpu_model->action_heap,(surf_action_lmm_t)action);
+ if (surf_cpu_model->model_private->update_mechanism == UM_LAZY)
+ surf_action_lmm_heap_remove(surf_cpu_model->model_private->action_heap,(surf_action_lmm_t)action);
((surf_action_lmm_t) action)->variable,
action->priority);
((surf_action_lmm_t) action)->suspended = 0;
((surf_action_lmm_t) action)->variable,
action->priority);
((surf_action_lmm_t) action)->suspended = 0;
- if (surf_cpu_model->update_mechanism == UM_LAZY)
- surf_action_lmm_heap_remove(surf_cpu_model->action_heap,(surf_action_lmm_t)action);
+ if (surf_cpu_model->model_private->update_mechanism == UM_LAZY)
+ surf_action_lmm_heap_remove(surf_cpu_model->model_private->action_heap,(surf_action_lmm_t)action);
XBT_IN("(%p,%g)", action, duration);
action->max_duration = duration;
XBT_IN("(%p,%g)", action, duration);
action->max_duration = duration;
- if (surf_cpu_model->update_mechanism == UM_LAZY)
- surf_action_lmm_heap_remove(surf_cpu_model->action_heap,(surf_action_lmm_t)action);
+ if (surf_cpu_model->model_private->update_mechanism == UM_LAZY)
+ surf_action_lmm_heap_remove(surf_cpu_model->model_private->action_heap,(surf_action_lmm_t)action);
{
XBT_IN("(%p,%g)", action, priority);
action->priority = priority;
{
XBT_IN("(%p,%g)", action, priority);
action->priority = priority;
- if (surf_cpu_model->update_mechanism == UM_LAZY)
- surf_action_lmm_heap_remove(surf_cpu_model->action_heap,(surf_action_lmm_t)action);
+ if (surf_cpu_model->model_private->update_mechanism == UM_LAZY)
+ surf_action_lmm_heap_remove(surf_cpu_model->model_private->action_heap,(surf_action_lmm_t)action);
- lmm_system_free(surf_cpu_model->maxmin_system);
- surf_cpu_model->maxmin_system = NULL;
+ lmm_system_free(surf_cpu_model->model_private->maxmin_system);
+ surf_cpu_model->model_private->maxmin_system = NULL;
- if (surf_cpu_model->action_heap)
- xbt_heap_free(surf_cpu_model->action_heap);
- xbt_swag_free(surf_cpu_model->modified_set);
+ if (surf_cpu_model->model_private->action_heap)
+ xbt_heap_free(surf_cpu_model->model_private->action_heap);
+ xbt_swag_free(surf_cpu_model->model_private->modified_set);
surf_cpu_model = surf_model_init();
if (!strcmp(optim, "Full")) {
surf_cpu_model = surf_model_init();
if (!strcmp(optim, "Full")) {
- surf_cpu_model->update_mechanism = UM_FULL;
- surf_cpu_model->selective_update = select;
+ surf_cpu_model->model_private->update_mechanism = UM_FULL;
+ surf_cpu_model->model_private->selective_update = select;
surf_cpu_model->model_private->share_resources =
cpu_share_resources_lazy;
surf_cpu_model->model_private->update_actions_state =
cpu_update_actions_state_lazy;
surf_cpu_model->model_private->share_resources =
cpu_share_resources_lazy;
surf_cpu_model->model_private->update_actions_state =
cpu_update_actions_state_lazy;
surf_cpu_model->model_private->share_resources =
cpu_share_resources_full;
surf_cpu_model->model_private->update_actions_state =
surf_cpu_model->model_private->share_resources =
cpu_share_resources_full;
surf_cpu_model->model_private->update_actions_state =
surf_cpu_model->extension.cpu.create_resource = cpu_create_resource;
surf_cpu_model->extension.cpu.add_traces = cpu_add_traces_cpu;
surf_cpu_model->extension.cpu.create_resource = cpu_create_resource;
surf_cpu_model->extension.cpu.add_traces = cpu_add_traces_cpu;
- if (!surf_cpu_model->maxmin_system) {
- surf_cpu_model->maxmin_system = lmm_system_new(surf_cpu_model->selective_update);
+ if (!surf_cpu_model->model_private->maxmin_system) {
+ surf_cpu_model->model_private->maxmin_system = lmm_system_new(surf_cpu_model->model_private->selective_update);
- if (surf_cpu_model->update_mechanism == UM_LAZY) {
- surf_cpu_model->action_heap = xbt_heap_new(8, NULL);
- xbt_heap_set_update_callback(surf_cpu_model->action_heap,
+ if (surf_cpu_model->model_private->update_mechanism == UM_LAZY) {
+ surf_cpu_model->model_private->action_heap = xbt_heap_new(8, NULL);
+ xbt_heap_set_update_callback(surf_cpu_model->model_private->action_heap,