//to check if variables were previously set to 0, otherwise paje won't simulate them
static xbt_dict_t platform_variables; /* host or link name -> array of categories */
-//B
-static xbt_dict_t method_b_dict;
-
-//C
-static xbt_dict_t method_c_dict;
-
-//resource utilization tracing method
-static void (*TRACE_method_alloc) (void) = NULL;
-static void (*TRACE_method_release) (void) = NULL;
-static void (*TRACE_method_start) (smx_action_t action) = NULL;
-static void (*TRACE_method_event) (smx_action_t action, double now,
- double delta, const char *variable,
- const char *resource, double value) =
- NULL;
-static void (*TRACE_method_end) (smx_action_t action) = NULL;
-
//used by all methods
static void __TRACE_surf_check_variable_set_to_zero(double now,
const char *variable,
const char *resource)
{
- /* check if we have to set it to 0 */
- if (!xbt_dict_get_or_null(platform_variables, resource)) {
- xbt_dynar_t array = xbt_dynar_new(sizeof(char *), xbt_free);
- char *var_cpy = xbt_strdup(variable);
- xbt_dynar_push(array, &var_cpy);
+ /*
+ * To trace resource utilization, we use pajeAddVariable and pajeSubVariable only.
+ * The Paje simulator needs a pajeSetVariable in the first place so it knows
+ * the initial value of all variables for subsequent adds/subs. If we don't do
+ * so, the first pajeAddVariable is added to a non-determined value within
+ * the Paje simulator, causing analysis problems.
+ */
+
+ // create a key considering the resource and variable
+ int n = strlen(variable)+strlen(resource)+1;
+ char *key = (char*)xbt_malloc(n*sizeof(char));
+ snprintf (key, n, "%s%s", resource, variable);
+
+ // check if key exists: if it doesn't, set the variable to zero and mark this in the dict
+ if (!xbt_dict_get_or_null(platform_variables, key)) {
container_t container = getContainerByName (resource);
type_t type = getVariableType (variable, NULL, container->type);
new_pajeSetVariable (now, container, type, 0);
- xbt_dict_set(platform_variables, resource, array,
- xbt_dynar_free_voidp);
- } else {
- xbt_dynar_t array = xbt_dict_get(platform_variables, resource);
- unsigned int i;
- char *cat;
- int flag = 0;
- xbt_dynar_foreach(array, i, cat) {
- if (strcmp(variable, cat) == 0) {
- flag = 1;
- }
- }
- if (flag == 0) {
- char *var_cpy = xbt_strdup(variable);
- xbt_dynar_push(array, &var_cpy);
- if (TRACE_categorized ()){
- container_t container = getContainerByName (resource);
- type_t type = getVariableType (variable, NULL, container->type);
- new_pajeSetVariable (now, container, type, 0);
- }
- }
+ xbt_dict_set(platform_variables, key, (char*)"", NULL);
}
- /* end of check */
-}
-
-#define A_METHOD
-//A
-static void __TRACE_A_alloc(void)
-{
-}
-
-static void __TRACE_A_release(void)
-{
-}
-
-static void __TRACE_A_start(smx_action_t action)
-{
+ xbt_free(key);
}
+/*
static void __TRACE_A_event(smx_action_t action, double now, double delta,
const char *variable, const char *resource,
double value)
new_pajeAddVariable(now, container, type, value);
new_pajeSubVariable(now + delta, container, type, value);
}
+*/
-static void __TRACE_A_end(smx_action_t action)
-{
-}
-
-#define B_METHOD
-//B
-
-static void __TRACE_B_alloc(void)
-{
- method_b_dict = xbt_dict_new();
-}
-
-static void __TRACE_B_release(void)
-{
- char *key, *time;
- xbt_dict_cursor_t cursor = NULL;
- xbt_dict_foreach(method_b_dict, cursor, key, time) {
- char resource[INSTR_DEFAULT_STR_SIZE];
- char variable[INSTR_DEFAULT_STR_SIZE];
- char what[INSTR_DEFAULT_STR_SIZE];
- sscanf (key, "%s %s %s", resource, variable, what);
- if (strcmp(what, "time")==0){
- char key_value[INSTR_DEFAULT_STR_SIZE];
- snprintf (key_value, INSTR_DEFAULT_STR_SIZE, "%s %s value", resource, variable);
- char *value = xbt_dict_get_or_null (method_b_dict, key_value);
- container_t container = getContainerByName (resource);
- type_t type = getVariableType (variable, NULL, container->type);
- new_pajeSubVariable(atof(time), container, type, atof(value));
- }
- }
- xbt_dict_free(&method_b_dict);
-}
-
-static void __TRACE_B_start(smx_action_t action)
-{
-}
-
-static void __TRACE_B_event(smx_action_t action, double now, double delta,
- const char *variable, const char *resource,
- double value)
-{
- char key_time[INSTR_DEFAULT_STR_SIZE];
- char key_value[INSTR_DEFAULT_STR_SIZE];
- char nowstr[INSTR_DEFAULT_STR_SIZE];
- char valuestr[INSTR_DEFAULT_STR_SIZE];
- char nowdeltastr[INSTR_DEFAULT_STR_SIZE];
-
- snprintf (key_time, INSTR_DEFAULT_STR_SIZE, "%s %s time", resource, variable);
- snprintf (key_value, INSTR_DEFAULT_STR_SIZE, "%s %s value", resource, variable);
- snprintf (nowstr, INSTR_DEFAULT_STR_SIZE, "%f", now);
- snprintf (valuestr, INSTR_DEFAULT_STR_SIZE, "%f", value);
- snprintf (nowdeltastr, INSTR_DEFAULT_STR_SIZE, "%f", now+delta);
-
- char *lasttimestr = xbt_dict_get_or_null(method_b_dict, key_time);
- char *lastvaluestr = xbt_dict_get_or_null(method_b_dict, key_value);
- if (lasttimestr == NULL){
- __TRACE_surf_check_variable_set_to_zero(now, variable, resource);
- container_t container = getContainerByName (resource);
- type_t type = getVariableType (variable, NULL, container->type);
- new_pajeAddVariable(now, container, type, value);
- xbt_dict_set(method_b_dict, key_time, xbt_strdup(nowdeltastr), xbt_free);
- xbt_dict_set(method_b_dict, key_value, xbt_strdup(valuestr), xbt_free);
- }else{
- double lasttime = atof (lasttimestr);
- double lastvalue = atof (lastvaluestr);
-
- if (lastvalue == value){
- double dif = fabs(now - lasttime);
- if (dif < 0.000001){
- //perfect, just go on
- }else{
- //time changed, have to update
- container_t container = getContainerByName (resource);
- type_t type = getVariableType (variable, NULL, container->type);
- new_pajeSubVariable(lasttime, container, type, lastvalue);
- new_pajeAddVariable(now, container, type, value);
- }
- }else{
- //value changed, have to update
- container_t container = getContainerByName (resource);
- type_t type = getVariableType (variable, NULL, container->type);
- new_pajeSubVariable(lasttime, container, type, lastvalue);
- new_pajeAddVariable(now, container, type, value);
- }
- xbt_dict_set(method_b_dict, key_time, xbt_strdup(nowdeltastr), xbt_free);
- xbt_dict_set(method_b_dict, key_value, xbt_strdup(valuestr), xbt_free);
- }
- return;
-}
-
-static void __TRACE_B_end(smx_action_t action)
-{
-}
-
-#define C_METHOD
-//C
-static void __TRACE_C_alloc(void)
-{
- method_c_dict = xbt_dict_new();
-}
-
-static void __TRACE_C_release(void)
+static void instr_event (double now, double delta, type_t variable, container_t resource, double value)
{
- xbt_dict_free(&method_c_dict);
+ __TRACE_surf_check_variable_set_to_zero(now, variable->name, resource->name);
+ new_pajeAddVariable(now, resource, variable, value);
+ new_pajeSubVariable(now + delta, resource, variable, value);
}
-static void __TRACE_C_start(smx_action_t action)
-{
- char key[100];
- snprintf(key, 100, "%p", action);
-
- //check if exists
- if (xbt_dict_get_or_null(method_c_dict, key)) {
- xbt_dict_remove(method_c_dict, key); //should never execute here, but it does
- }
- xbt_dict_set(method_c_dict, key, xbt_dict_new(), xbt_free);
-}
-
-static void __TRACE_C_event(smx_action_t action, double now, double delta,
- const char *variable, const char *resource,
- double value)
-{
- char key[100];
- snprintf(key, 100, "%p", action);
-
- xbt_dict_t action_dict = xbt_dict_get(method_c_dict, key);
- //setting start time
- if (!xbt_dict_get_or_null(action_dict, "start")) {
- char start_time[100];
- snprintf(start_time, 100, "%f", now);
- xbt_dict_set(action_dict, "start", xbt_strdup(start_time), xbt_free);
- }
- //updating end time
- char end_time[100];
- snprintf(end_time, 100, "%f", now + delta);
- xbt_dict_set(action_dict, "end", xbt_strdup(end_time), xbt_free);
-
- //accumulate the value resource-variable
- char res_var[300];
- snprintf(res_var, 300, "%s %s", resource, variable);
- double current_value_f;
- char *current_value = xbt_dict_get_or_null(action_dict, res_var);
- if (current_value) {
- current_value_f = atof(current_value);
- current_value_f += value * delta;
- } else {
- current_value_f = value * delta;
- }
- char new_current_value[100];
- snprintf(new_current_value, 100, "%f", current_value_f);
- xbt_dict_set(action_dict, res_var, xbt_strdup(new_current_value),
- xbt_free);
-}
-
-static void __TRACE_C_end(smx_action_t action)
-{
- char key[100];
- snprintf(key, 100, "%p", action);
-
- xbt_dict_t action_dict = xbt_dict_get(method_c_dict, key);
- double start_time = atof(xbt_dict_get(action_dict, "start"));
- double end_time = atof(xbt_dict_get(action_dict, "end"));
-
- xbt_dict_cursor_t cursor = NULL;
- char *action_dict_key, *action_dict_value;
- xbt_dict_foreach(action_dict, cursor, action_dict_key, action_dict_value) {
- char resource[100], variable[100];
- if (sscanf(action_dict_key, "%s %s", resource, variable) != 2)
- continue;
- __TRACE_surf_check_variable_set_to_zero(start_time, variable,
- resource);
- if (end_time - start_time != 0) {
- container_t container = getContainerByName (resource);
- type_t type = getVariableType (variable, NULL, container->type);
- double val = atof(action_dict_value) / (end_time - start_time);
- new_pajeSubVariable(start_time, container, type, val);
- new_pajeAddVariable(end_time, container, type, val);
- }
- }
- xbt_dict_remove(method_c_dict, key);
-}
-
-#define RESOURCE_UTILIZATION_INTERFACE
/*
* TRACE_surf_link_set_utilization: entry point from SimGrid
*/
double value, double now,
double delta)
{
- if (!TRACE_is_active())
- return;
- if (!value)
- return;
//only trace link utilization if link is known by tracing mechanism
if (!knownContainerWithName(resource))
return;
XBT_DEBUG("UNCAT LINK [%f - %f] %s bandwidth_used %f", now, now+delta, resource, value);
container_t container = getContainerByName (resource);
type_t type = getVariableType("bandwidth_used", NULL, container->type);
- TRACE_surf_resource_utilization_event(smx_action, now, delta, type->name, container->name, value);
+ instr_event (now, delta, type, container, value);
}
//trace categorized utilization
XBT_DEBUG("CAT LINK [%f - %f] %s %s %f", now, now+delta, resource, category_type, value);
container_t container = getContainerByName (resource);
type_t type = getVariableType(category_type, NULL, container->type);
- TRACE_surf_resource_utilization_event(smx_action, now, delta, type->name, container->name, value);
+ instr_event (now, delta, type, container, value);
}
return;
}
double value, double now,
double delta)
{
- if (!TRACE_is_active())
- return;
//only trace host utilization if host is known by tracing mechanism
if (!knownContainerWithName(resource))
return;
XBT_DEBUG("UNCAT HOST [%f - %f] %s power_used %f", now, now+delta, resource, value);
container_t container = getContainerByName (resource);
type_t type = getVariableType("power_used", NULL, container->type);
- TRACE_surf_resource_utilization_event(smx_action, now, delta, type->name, container->name, value);
+ instr_event (now, delta, type, container, value);
}
//trace categorized utilization
XBT_DEBUG("CAT HOST [%f - %f] %s %s %f", now, now+delta, resource, category_type, value);
container_t container = getContainerByName (resource);
type_t type = getVariableType(category_type, NULL, container->type);
- TRACE_surf_resource_utilization_event(smx_action, now, delta, type->name, container->name, value);
+ instr_event (now, delta, type, container, value);
}
return;
}
-/*
- * __TRACE_surf_resource_utilization_*: entry points from tracing functions
- */
-void TRACE_surf_resource_utilization_start(smx_action_t action)
-{
- if (!TRACE_is_active())
- return;
- XBT_DEBUG("START %p", action);
- TRACE_method_start(action);
-}
-
-void TRACE_surf_resource_utilization_event(smx_action_t action, double now,
- double delta,
- const char *variable,
- const char *resource,
- double value)
-{
- if (!TRACE_is_active())
- return;
- XBT_DEBUG("EVENT %p [%f - %f] %s %s %f", action, now, now+delta, resource, variable, value);
- TRACE_method_event(action, now, delta, variable, resource, value);
-}
-
-void TRACE_surf_resource_utilization_end(smx_action_t action)
+void TRACE_surf_resource_utilization_alloc()
{
- if (!TRACE_is_active())
- return;
- TRACE_method_end(action);
- XBT_DEBUG("END %p", action);
+ platform_variables = xbt_dict_new_homogeneous(NULL);
}
void TRACE_surf_resource_utilization_release()
{
- if (!TRACE_is_active())
- return;
- TRACE_method_release();
-}
-
-static void __TRACE_define_method(char *method)
-{
- if (!strcmp(method, "a")) {
- TRACE_method_alloc = __TRACE_A_alloc;
- TRACE_method_release = __TRACE_A_release;
- TRACE_method_start = __TRACE_A_start;
- TRACE_method_event = __TRACE_A_event;
- TRACE_method_end = __TRACE_A_end;
- } else if (!strcmp(method, "c")) {
- TRACE_method_alloc = __TRACE_C_alloc;
- TRACE_method_release = __TRACE_C_release;
- TRACE_method_start = __TRACE_C_start;
- TRACE_method_event = __TRACE_C_event;
- TRACE_method_end = __TRACE_C_end;
- } else { //default is B
- TRACE_method_alloc = __TRACE_B_alloc;
- TRACE_method_release = __TRACE_B_release;
- TRACE_method_start = __TRACE_B_start;
- TRACE_method_event = __TRACE_B_event;
- TRACE_method_end = __TRACE_B_end;
- }
-}
-
-void TRACE_surf_resource_utilization_alloc()
-{
- platform_variables = xbt_dict_new();
- __TRACE_define_method(TRACE_get_platform_method());
- TRACE_method_alloc();
+ xbt_dict_free(&platform_variables);
}
#endif /* HAVE_TRACING */
