1 /* Copyright (c) 2009, 2010. 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. */
8 #include "surf_private.h"
11 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(surf_timer, surf,
12 "Logging specific to SURF (timer)");
14 typedef struct surf_action_timer {
15 s_surf_action_t generic_action;
16 } s_surf_action_timer_t, *surf_action_timer_t;
18 typedef struct command {
19 s_surf_resource_t generic_resource; /* Must remain first, since we add this to a trace */
22 s_xbt_swag_hookup_t command_set_hookup;
23 surf_action_timer_t action;
24 } s_command_t, *command_t;
27 surf_model_t surf_timer_model = NULL;
28 static tmgr_trace_t empty_trace = NULL;
29 static xbt_swag_t command_pending = NULL;
30 static xbt_swag_t command_to_run = NULL;
31 static xbt_heap_t timer_heap = NULL;
33 static command_t command_new(void *fun, void *args)
35 command_t command = xbt_new0(s_command_t, 1);
37 command->generic_resource.model = surf_timer_model;
38 command->function = fun;
40 xbt_swag_insert(command, command_pending);
42 surf_action_new(sizeof(s_surf_action_timer_t), 0, surf_timer_model, 0);
46 static void command_free(command_t command)
48 if (xbt_swag_belongs(command, command_to_run)) {
49 xbt_swag_remove(command, command_to_run);
50 } else if (xbt_swag_belongs(command, command_pending)) {
51 xbt_swag_remove(command, command_pending);
53 xbt_swag_remove(command->action,
54 surf_timer_model->states.running_action_set);
55 xbt_free(command->action);
56 surf_resource_free((surf_resource_t) command);
60 static void parse_timer(void)
64 static void parse_file(const char *file)
68 static int resource_used(void *resource_id)
73 static void timer_action_state_set(surf_action_t action,
74 e_surf_action_state_t state)
80 static double share_resources(double now)
82 if (xbt_heap_size(timer_heap)) {
83 DEBUG1("Share resoure returning %lf", xbt_heap_maxkey(timer_heap));
84 return (xbt_heap_maxkey(timer_heap));
89 static void update_actions_state(double now, double delta)
91 while ((xbt_heap_size(timer_heap)) > 0
92 && (xbt_heap_maxkey(timer_heap) <= now + delta))
93 xbt_heap_pop(timer_heap);
97 static void update_resource_state(void *id,
98 tmgr_trace_event_t event_type,
99 double value, double date)
101 command_t command = id;
103 /* Move this command to the list of commands to execute */
104 xbt_swag_remove(command, command_pending);
105 xbt_swag_insert(command, command_to_run);
106 tmgr_trace_event_free(event_type);
108 DEBUG1("Insert command on date %lf", date);
113 static void set(double date, void *function, void *arg)
115 command_t command = NULL;
117 command = command_new(function, arg);
119 tmgr_history_add_trace(history, empty_trace, date, 0, command);
120 xbt_heap_push(timer_heap, NULL, date);
122 DEBUG1("Putting value %lf on heap", date);
126 static int get(void **function, void **arg)
128 command_t command = NULL;
130 command = xbt_swag_extract(command_to_run);
132 *function = command->function;
133 *arg = command->args;
134 command_free(command);
141 static void action_suspend(surf_action_t action)
146 static void action_resume(surf_action_t action)
151 static int action_is_suspended(surf_action_t action)
157 static void finalize(void)
159 xbt_heap_free(timer_heap);
162 tmgr_trace_free(empty_trace);
165 xbt_swag_free(command_pending);
166 xbt_swag_free(command_to_run);
168 surf_model_exit(surf_timer_model);
169 surf_timer_model = NULL;
172 static void surf_timer_model_init_internal(void)
174 surf_timer_model = surf_model_init();
176 surf_timer_model->name = "TIMER";
177 surf_timer_model->action_state_set = timer_action_state_set;
179 surf_timer_model->model_private->resource_used = resource_used;
180 surf_timer_model->model_private->share_resources = share_resources;
181 surf_timer_model->model_private->update_actions_state =
182 update_actions_state;
183 surf_timer_model->model_private->update_resource_state =
184 update_resource_state;
185 surf_timer_model->model_private->finalize = finalize;
187 surf_timer_model->suspend = action_suspend;
188 surf_timer_model->resume = action_resume;
189 surf_timer_model->is_suspended = action_is_suspended;
191 surf_timer_model->extension.timer.set = set;
192 surf_timer_model->extension.timer.get = get;
196 command_pending = xbt_swag_new(xbt_swag_offset(var, command_set_hookup));
197 command_to_run = xbt_swag_new(xbt_swag_offset(var, command_set_hookup));
200 empty_trace = tmgr_empty_trace_new();
201 timer_heap = xbt_heap_new(8, NULL);
204 void surf_timer_model_init(const char *filename)
206 if (surf_timer_model)
208 surf_timer_model_init_internal();
209 xbt_dynar_push(model_list, &surf_timer_model);