1 /* Copyright (c) 2004, 2005, 2007, 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. */
7 #include "xbt/sysdep.h"
11 #include "trace_mgr_private.h"
12 #include "surf_private.h"
13 #include "xbt/RngStream.h"
16 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(surf_trace, surf, "Surf trace management");
18 static xbt_dict_t trace_list = NULL;
20 // a unique RngStream structure for everyone
21 // FIXME : has to be created by someone
22 static RngStream common_rng_stream = NULL;
24 XBT_INLINE tmgr_history_t tmgr_history_new(void)
28 h = xbt_new0(s_tmgr_history_t, 1);
30 h->heap = xbt_heap_new(8, xbt_free_f); /* Why 8 ? Well, why not... */
35 XBT_INLINE void tmgr_history_free(tmgr_history_t h)
37 xbt_heap_free(h->heap);
41 tmgr_trace_t tmgr_trace_new_from_generator(const char *id,
42 probabilist_event_generator_t generator1,
43 probabilist_event_generator_t generator2)
45 tmgr_trace_t trace = NULL;
47 RngStream rng_stream = NULL;
49 rng_stream = RngStream_CopyStream(common_rng_stream);
50 id_hash = xbt_str_hash(id);
51 RngStream_AdvanceState(rng_stream, 0, id_hash);
53 trace = xbt_new0(s_tmgr_trace_t, 1);
54 trace->type = e_trace_probabilist;
56 trace->s_probabilist.event_generator[0] = generator1;
57 trace->s_probabilist.event_generator[0]->rng_stream = rng_stream;
58 tmgr_event_generator_next_value(trace->s_probabilist.event_generator[0]);
60 //FIXME : may also be a parameter
61 trace->s_probabilist.next_event = 0;
63 if(generator2 == NULL) {
64 trace->s_probabilist.event_generator[1] = generator1;
66 trace->s_probabilist.event_generator[1] = generator2;
67 trace->s_probabilist.event_generator[1]->rng_stream = rng_stream;
68 tmgr_event_generator_next_value(trace->s_probabilist.event_generator[1]);
74 probabilist_event_generator_t tmgr_event_generator_new_uniform(double alpha,
77 probabilist_event_generator_t event_generator = NULL;
79 event_generator = xbt_new0(s_probabilist_event_generator_t, 1);
80 event_generator->type = e_generator_uniform;
81 event_generator->s_uniform_parameters.alpha = alpha;
82 event_generator->s_uniform_parameters.beta = beta;
84 tmgr_event_generator_next_value(event_generator);
86 return event_generator;
89 probabilist_event_generator_t tmgr_event_generator_new_exponential(double lambda)
91 probabilist_event_generator_t event_generator = NULL;
93 event_generator = xbt_new0(s_probabilist_event_generator_t, 1);
94 event_generator->type = e_generator_exponential;
95 event_generator->s_exponential_parameters.lambda = lambda;
97 return event_generator;
100 probabilist_event_generator_t tmgr_event_generator_new_weibull(double lambda,
103 probabilist_event_generator_t event_generator = NULL;
105 event_generator = xbt_new0(s_probabilist_event_generator_t, 1);
106 event_generator->type = e_generator_weibull;
107 event_generator->s_weibull_parameters.lambda = lambda;
108 event_generator->s_weibull_parameters.k = k;
110 tmgr_event_generator_next_value(event_generator);
112 return event_generator;
115 double tmgr_event_generator_next_value(probabilist_event_generator_t generator)
118 switch(generator->type) {
119 case e_generator_uniform:
120 generator->next_value = (RngStream_RandU01(generator->rng_stream)
121 * (generator->s_uniform_parameters.beta - generator->s_uniform_parameters.alpha))
122 + generator->s_uniform_parameters.alpha;
124 case e_generator_exponential:
125 generator->next_value = -log(RngStream_RandU01(generator->rng_stream))
126 / generator->s_exponential_parameters.lambda;
128 case e_generator_weibull:
129 generator->next_value = - generator->s_weibull_parameters.lambda
130 * pow( log(RngStream_RandU01(generator->rng_stream)),
131 1.0 / generator->s_weibull_parameters.k );
134 return generator->next_value;
137 tmgr_trace_t tmgr_trace_new_from_string(const char *id, const char *input,
140 tmgr_trace_t trace = NULL;
142 s_tmgr_event_t event;
143 tmgr_event_t last_event = NULL;
149 trace = xbt_dict_get_or_null(trace_list, id);
151 XBT_WARN("Ignoring redefinition of trace %s", id);
156 xbt_assert(periodicity >= 0,
157 "Invalid periodicity %lg (must be positive)", periodicity);
159 trace = xbt_new0(s_tmgr_trace_t, 1);
160 trace->type = e_trace_list;
161 trace->s_list.event_list = xbt_dynar_new(sizeof(s_tmgr_event_t), NULL);
163 list = xbt_str_split(input, "\n\r");
165 xbt_dynar_foreach(list, cpt, val) {
167 xbt_str_trim(val, " \t\n\r\x0B");
168 if (val[0] == '#' || val[0] == '\0' || val[0] == '%')
171 if (sscanf(val, "PERIODICITY " "%lg" "\n", &periodicity) == 1)
174 if (sscanf(val, "%lg" " " "%lg" "\n", &event.delta, &event.value) != 2)
175 xbt_die("%s:%d: Syntax error in trace\n%s", id, linecount, input);
178 if (last_event->delta > event.delta) {
179 xbt_die("%s:%d: Invalid trace: Events must be sorted, "
180 "but time %lg > time %lg.\n%s",
181 id, linecount, last_event->delta, event.delta, input);
183 last_event->delta = event.delta - last_event->delta;
185 xbt_dynar_push(trace->s_list.event_list, &event);
187 xbt_dynar_get_ptr(trace->s_list.event_list,
188 xbt_dynar_length(trace->s_list.event_list) - 1);
191 last_event->delta = periodicity;
194 trace_list = xbt_dict_new_homogeneous((void (*)(void *)) tmgr_trace_free);
196 xbt_dict_set(trace_list, id, (void *) trace, NULL);
198 xbt_dynar_free(&list);
202 tmgr_trace_t tmgr_trace_new_from_file(const char *filename)
206 tmgr_trace_t trace = NULL;
208 if ((!filename) || (strcmp(filename, "") == 0))
212 trace = xbt_dict_get_or_null(trace_list, filename);
214 XBT_WARN("Ignoring redefinition of trace %s", filename);
219 f = surf_fopen(filename, "r");
220 xbt_assert(f != NULL, "Cannot open file '%s' (path=%s)", filename,
221 xbt_str_join(surf_path, ":"));
223 tstr = xbt_str_from_file(f);
225 trace = tmgr_trace_new_from_string(filename, tstr, 0.);
231 tmgr_trace_t tmgr_empty_trace_new(void)
233 tmgr_trace_t trace = NULL;
234 s_tmgr_event_t event;
236 trace = xbt_new0(s_tmgr_trace_t, 1);
237 trace->type = e_trace_list;
238 trace->s_list.event_list = xbt_dynar_new(sizeof(s_tmgr_event_t), NULL);
242 xbt_dynar_push(trace->s_list.event_list, &event);
247 XBT_INLINE void tmgr_trace_free(tmgr_trace_t trace)
252 switch(trace->type) {
254 xbt_dynar_free(&(trace->s_list.event_list));
256 case e_trace_probabilist:
263 tmgr_trace_event_t tmgr_history_add_trace(tmgr_history_t h,
266 unsigned int offset, void *model)
268 tmgr_trace_event_t trace_event = NULL;
270 trace_event = xbt_new0(s_tmgr_trace_event_t, 1);
271 trace_event->trace = trace;
272 trace_event->idx = offset;
273 trace_event->model = model;
275 if(trace->type == e_trace_list) {
276 xbt_assert((trace_event->idx < xbt_dynar_length(trace->s_list.event_list)),
277 "You're referring to an event that does not exist!");
280 xbt_heap_push(h->heap, trace_event, start_time);
285 XBT_INLINE double tmgr_history_next_date(tmgr_history_t h)
287 if (xbt_heap_size(h->heap))
288 return (xbt_heap_maxkey(h->heap));
293 tmgr_trace_event_t tmgr_history_get_next_event_leq(tmgr_history_t h,
298 double event_date = tmgr_history_next_date(h);
299 tmgr_trace_event_t trace_event = NULL;
300 tmgr_event_t event = NULL;
301 tmgr_trace_t trace = NULL;
304 if (event_date > date)
307 if (!(trace_event = xbt_heap_pop(h->heap)))
310 trace = trace_event->trace;
311 *model = trace_event->model;
313 switch(trace->type) {
316 event = xbt_dynar_get_ptr(trace->s_list.event_list, trace_event->idx);
318 *value = event->value;
320 if (trace_event->idx < xbt_dynar_length(trace->s_list.event_list) - 1) {
321 xbt_heap_push(h->heap, trace_event, event_date + event->delta);
323 } else if (event->delta > 0) { /* Last element, checking for periodicity */
324 xbt_heap_push(h->heap, trace_event, event_date + event->delta);
325 trace_event->idx = 0;
326 } else { /* We don't need this trace_event anymore */
327 trace_event->free_me = 1;
331 case e_trace_probabilist:
333 //FIXME : Simplist and not tested
334 //Would only work for failure events for now
335 *value = (double) trace->s_probabilist.next_event;
336 if(trace->s_probabilist.next_event == 0) {
337 event_delta = tmgr_event_generator_next_value(trace->s_probabilist.event_generator[0]);
338 trace->s_probabilist.next_event = 0;
340 event_delta = tmgr_event_generator_next_value(trace->s_probabilist.event_generator[1]);
341 trace->s_probabilist.next_event = 1;
343 xbt_heap_push(h->heap, trace_event, event_date + event_delta);
351 XBT_INLINE void tmgr_finalize(void)
353 xbt_dict_free(&trace_list);
356 int tmgr_trace_event_free(tmgr_trace_event_t trace_event)
358 if (trace_event->free_me) {
359 xbt_free(trace_event);