1 /* Copyright (c) 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012. The SimGrid Team.
2 * All rights reserved. */
4 /* This program is free software; you can redistribute it and/or modify it
5 * under the terms of the license (GNU LGPL) which comes with this package. */
7 /* ********************************************************************* */
8 /* TUTORIAL: New model */
9 /* ********************************************************************* */
13 #include "xbt/file_stat.h"
15 #include "surf_private.h"
16 #include "new_model_private.h"
17 #include "surf/surf_resource.h"
19 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(surf_new_model, surf,
20 "Logging specific to the SURF new model module");
22 surf_model_t surf_new_model = NULL;
23 lmm_system_t new_model_maxmin_system = NULL;
24 static int new_model_selective_update = 0;
26 new_model_running_action_set_that_does_not_need_being_checked = NULL;
28 #define GENERIC_LMM_ACTION(action) action->generic_lmm_action
29 #define GENERIC_ACTION(action) GENERIC_LMM_ACTION(action).generic_action
31 static void new_model_action_state_set(surf_action_t action, e_surf_action_state_t state);
32 static surf_action_t new_model_action_execute ();
34 static surf_action_t new_model_action_fct()
36 surf_action_t action = new_model_action_execute();
40 static surf_action_t new_model_action_execute ()
46 static void* new_model_create_resource(const char* id, const char* model,const char* type_id,const char* content_name)
52 static void new_model_finalize(void)
57 static void new_model_update_actions_state(double now, double delta)
62 static double new_model_share_resources(double NOW)
68 static int new_model_resource_used(void *resource_id)
74 static void new_model_resources_state(void *id, tmgr_trace_event_t event_type,
75 double value, double time)
80 static int new_model_action_unref(surf_action_t action)
86 static void new_model_action_cancel(surf_action_t action)
88 surf_action_state_set(action, SURF_ACTION_FAILED);
92 static void new_model_action_state_set(surf_action_t action, e_surf_action_state_t state)
94 surf_action_state_set(action, state);
98 static void new_model_action_suspend(surf_action_t action)
100 XBT_IN("(%p)", action);
101 if (((surf_action_lmm_t) action)->suspended != 2) {
102 lmm_update_variable_weight(new_model_maxmin_system,
103 ((surf_action_lmm_t) action)->variable,
105 ((surf_action_lmm_t) action)->suspended = 1;
110 static void new_model_action_resume(surf_action_t action)
115 static int new_model_action_is_suspended(surf_action_t action)
117 return (((surf_action_lmm_t) action)->suspended == 1);
120 static void new_model_action_set_max_duration(surf_action_t action, double duration)
125 static void new_model_action_set_priority(surf_action_t action, double priority)
130 static void new_model_define_callbacks()
134 static void surf_new_model_model_init_internal(void)
136 s_surf_action_t action;
138 XBT_DEBUG("surf_new_model_model_init_internal");
139 surf_new_model = surf_model_init();
141 new_model_running_action_set_that_does_not_need_being_checked =
142 xbt_swag_new(xbt_swag_offset(action, state_hookup));
144 surf_new_model->name = "Storage";
145 surf_new_model->action_unref = new_model_action_unref;
146 surf_new_model->action_cancel = new_model_action_cancel;
147 surf_new_model->action_state_set = new_model_action_state_set;
149 surf_new_model->model_private->finalize = new_model_finalize;
150 surf_new_model->model_private->update_actions_state = new_model_update_actions_state;
151 surf_new_model->model_private->share_resources = new_model_share_resources;
152 surf_new_model->model_private->resource_used = new_model_resource_used;
153 surf_new_model->model_private->update_resource_state = new_model_resources_state;
155 surf_new_model->suspend = new_model_action_suspend;
156 surf_new_model->resume = new_model_action_resume;
157 surf_new_model->is_suspended = new_model_action_is_suspended;
158 surf_new_model->set_max_duration = new_model_action_set_max_duration;
159 surf_new_model->set_priority = new_model_action_set_priority;
161 surf_new_model->extension.new_model.fct = new_model_action_fct;
162 surf_new_model->extension.new_model.create_resource = new_model_create_resource;
164 if (!new_model_maxmin_system) {
165 new_model_maxmin_system = lmm_system_new(new_model_selective_update);
170 void surf_new_model_model_init_default(void)
172 surf_new_model_model_init_internal();
173 new_model_define_callbacks();
175 xbt_dynar_push(model_list, &surf_new_model);