X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/100c997ae6520bb2849cdeae2df85649d6da6732..900de20b50b969d43f494804b2b92eb4442ab4a3:/src/instr/instr_paje_trace.c diff --git a/src/instr/instr_paje_trace.c b/src/instr/instr_paje_trace.c index d325846f97..4a60ed3c16 100644 --- a/src/instr/instr_paje_trace.c +++ b/src/instr/instr_paje_trace.c @@ -8,8 +8,6 @@ #ifdef HAVE_TRACING -#define INSTR_PAJE_ASSERT(str) {xbt_assert1(str!=NULL&&strlen(str)>0, "'%s' is NULL or length is zero", #str);} - XBT_LOG_NEW_DEFAULT_SUBCATEGORY(instr_paje_trace, instr, "Paje tracing event system"); typedef enum { @@ -18,6 +16,7 @@ typedef enum { PAJE_DefineStateType, PAJE_DefineEventType, PAJE_DefineLinkType, + PAJE_DefineEntityValue, PAJE_CreateContainer, PAJE_DestroyContainer, PAJE_SetVariable, @@ -36,6 +35,7 @@ typedef struct paje_event { double timestamp; e_event_type event_type; void (*print) (paje_event_t event); + void (*free) (paje_event_t event); void *data; } s_paje_event_t; @@ -66,6 +66,11 @@ typedef struct s_defineLinkType { type_t dest; }s_defineLinkType_t; +typedef struct s_defineEntityValue *defineEntityValue_t; +typedef struct s_defineEntityValue { + val_t value; +}s_defineEntityValue_t; + typedef struct s_createContainer *createContainer_t; typedef struct s_createContainer { container_t container; @@ -101,14 +106,14 @@ typedef struct s_setState *setState_t; typedef struct s_setState { container_t container; type_t type; - char *value; + val_t value; }s_setState_t; typedef struct s_pushState *pushState_t; typedef struct s_pushState { container_t container; type_t type; - char *value; + val_t value; }s_pushState_t; typedef struct s_popState *popState_t; @@ -139,7 +144,7 @@ typedef struct s_newEvent *newEvent_t; typedef struct s_newEvent { container_t container; type_t type; - char *value; + val_t value; }s_newEvent_t; static FILE *tracing_file = NULL; @@ -150,9 +155,9 @@ void TRACE_paje_start(void) { char *filename = TRACE_get_filename(); tracing_file = fopen(filename, "w"); - xbt_assert1 (tracing_file != NULL, "Tracefile %s could not be opened for writing.", filename); + xbt_assert (tracing_file != NULL, "Tracefile %s could not be opened for writing.", filename); - DEBUG1("Filename %s is open for writing", filename); + XBT_DEBUG("Filename %s is open for writing", filename); /* output header */ TRACE_paje_create_header(); @@ -164,21 +169,42 @@ void TRACE_paje_end(void) { fclose(tracing_file); char *filename = TRACE_get_filename(); - DEBUG1("Filename %s is closed", filename); + XBT_DEBUG("Filename %s is closed", filename); } -void TRACE_paje_dump_buffer (void) +double TRACE_last_timestamp_to_dump = 0; +//dumps the trace file until the timestamp TRACE_last_timestamp_to_dump +void TRACE_paje_dump_buffer (int force) { - paje_event_t event; - while (xbt_dynar_length (buffer) > 0){ - xbt_dynar_remove_at (buffer, 0, &event); - event->print (event); + if (!TRACE_is_enabled()) return; + XBT_DEBUG("%s: dump until %f. starts", __FUNCTION__, TRACE_last_timestamp_to_dump); + if (force){ + paje_event_t event; + unsigned int i; + xbt_dynar_foreach(buffer, i, event){ + event->print (event); + event->free (event); + } + xbt_dynar_free (&buffer); + buffer = xbt_dynar_new (sizeof(paje_event_t), NULL); + }else{ + paje_event_t event; + while (!xbt_dynar_is_empty(buffer)){ + double head_timestamp = (*(paje_event_t*)xbt_dynar_get_ptr(buffer, 0))->timestamp; + if (head_timestamp > TRACE_last_timestamp_to_dump){ + break; + } + xbt_dynar_remove_at (buffer, 0, &event); + event->print (event); + event->free (event); + } } + XBT_DEBUG("%s: ends", __FUNCTION__); } void TRACE_paje_create_header(void) { - DEBUG0 ("Define paje header"); + XBT_DEBUG ("Define paje header"); fprintf(tracing_file, "\ %%EventDef PajeDefineContainerType %d \n\ %% Alias string \n\ @@ -198,7 +224,7 @@ void TRACE_paje_create_header(void) %%EndEventDef \n\ %%EventDef PajeDefineEventType %d \n\ %% Alias string \n\ -%% EntityType string \n\ +%% ContainerType string \n\ %% Name string \n\ %% Color color \n\ %%EndEventDef \n\ @@ -209,6 +235,12 @@ void TRACE_paje_create_header(void) %% DestContainerType string \n\ %% Name string \n\ %%EndEventDef \n\ +%%EventDef PajeDefineEntityValue %d \n\ +%% Alias string \n\ +%% EntityType string \n\ +%% Name string \n\ +%% Color color \n\ +%%EndEventDef \n\ %%EventDef PajeCreateContainer %d \n\ %% Time date \n\ %% Alias string \n\ @@ -219,46 +251,46 @@ void TRACE_paje_create_header(void) %%EventDef PajeDestroyContainer %d \n\ %% Time date \n\ %% Type string \n\ -%% Container string \n\ +%% Name string \n\ %%EndEventDef \n\ %%EventDef PajeSetVariable %d \n\ %% Time date \n\ -%% EntityType string \n\ +%% Type string \n\ %% Container string \n\ -%% Value string \n\ +%% Value double \n\ %%EndEventDef\n\ %%EventDef PajeAddVariable %d \n\ %% Time date \n\ -%% EntityType string \n\ +%% Type string \n\ %% Container string \n\ -%% Value string \n\ +%% Value double \n\ %%EndEventDef\n\ %%EventDef PajeSubVariable %d \n\ %% Time date \n\ -%% EntityType string \n\ +%% Type string \n\ %% Container string \n\ -%% Value string \n\ +%% Value double \n\ %%EndEventDef\n\ %%EventDef PajeSetState %d \n\ %% Time date \n\ -%% EntityType string \n\ +%% Type string \n\ %% Container string \n\ %% Value string \n\ %%EndEventDef\n\ %%EventDef PajePushState %d \n\ %% Time date \n\ -%% EntityType string \n\ +%% Type string \n\ %% Container string \n\ %% Value string \n\ %%EndEventDef\n\ %%EventDef PajePopState %d \n\ %% Time date \n\ -%% EntityType string \n\ +%% Type string \n\ %% Container string \n\ %%EndEventDef\n\ %%EventDef PajeStartLink %d \n\ %% Time date \n\ -%% EntityType string \n\ +%% Type string \n\ %% Container string \n\ %% Value string \n\ %% SourceContainer string \n\ @@ -266,7 +298,7 @@ void TRACE_paje_create_header(void) %%EndEventDef\n\ %%EventDef PajeEndLink %d \n\ %% Time date \n\ -%% EntityType string \n\ +%% Type string \n\ %% Container string \n\ %% Value string \n\ %% DestContainer string \n\ @@ -274,7 +306,7 @@ void TRACE_paje_create_header(void) %%EndEventDef\n\ %%EventDef PajeNewEvent %d \n\ %% Time date \n\ -%% EntityType string \n\ +%% Type string \n\ %% Container string \n\ %% Value string \n\ %%EndEventDef\n", @@ -283,6 +315,7 @@ void TRACE_paje_create_header(void) PAJE_DefineStateType, PAJE_DefineEventType, PAJE_DefineLinkType, + PAJE_DefineEntityValue, PAJE_CreateContainer, PAJE_DestroyContainer, PAJE_SetVariable, @@ -299,27 +332,30 @@ void TRACE_paje_create_header(void) /* internal do the instrumentation module */ static void insert_into_buffer (paje_event_t tbi) { + if (TRACE_buffer() == 0){ + tbi->print (tbi); + tbi->free (tbi); + return; + } + XBT_DEBUG("%s: insert event_type=%d, timestamp=%f, buffersize=%ld)", __FUNCTION__, tbi->event_type, tbi->timestamp, xbt_dynar_length(buffer)); + unsigned int i; - if (xbt_dynar_length(buffer) == 0){ - xbt_dynar_push (buffer, &tbi); - }else{ - int inserted = 0; - for (i = 0; i < xbt_dynar_length(buffer); i++){ - paje_event_t e1 = *(paje_event_t*)xbt_dynar_get_ptr(buffer, i); - if (e1->timestamp > tbi->timestamp){ - xbt_dynar_insert_at (buffer, i, &tbi); - inserted = 1; - break; - } - } - if (!inserted){ - xbt_dynar_push (buffer, &tbi); - } + for (i = xbt_dynar_length(buffer); i > 0; i--) { + paje_event_t e1 = *(paje_event_t*)xbt_dynar_get_ptr(buffer, i - 1); + if (e1->timestamp <= tbi->timestamp) + break; } + xbt_dynar_insert_at(buffer, i, &tbi); + if (i == 0) + XBT_DEBUG("%s: inserted at beginning", __FUNCTION__); + else + XBT_DEBUG("%s: inserted at%s %d", __FUNCTION__, + (i == xbt_dynar_length(buffer) - 1 ? " end, pos =" : ""), i); } static void print_pajeDefineContainerType(paje_event_t event) { + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, event->event_type); fprintf(tracing_file, "%d %s %s %s\n", event->event_type, ((defineContainerType_t)event->data)->type->id, @@ -329,6 +365,7 @@ static void print_pajeDefineContainerType(paje_event_t event) static void print_pajeDefineVariableType(paje_event_t event) { + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, event->event_type); fprintf(tracing_file, "%d %s %s %s \"%s\"\n", event->event_type, ((defineVariableType_t)event->data)->type->id, @@ -339,6 +376,7 @@ static void print_pajeDefineVariableType(paje_event_t event) static void print_pajeDefineStateType(paje_event_t event) { + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, event->event_type); fprintf(tracing_file, "%d %s %s %s\n", event->event_type, ((defineStateType_t)event->data)->type->id, @@ -348,6 +386,7 @@ static void print_pajeDefineStateType(paje_event_t event) static void print_pajeDefineEventType(paje_event_t event) { + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, event->event_type); fprintf(tracing_file, "%d %s %s %s \"%s\"\n", event->event_type, ((defineEventType_t)event->data)->type->id, @@ -358,6 +397,7 @@ static void print_pajeDefineEventType(paje_event_t event) static void print_pajeDefineLinkType(paje_event_t event) { + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, event->event_type); fprintf(tracing_file, "%d %s %s %s %s %s\n", event->event_type, ((defineLinkType_t)event->data)->type->id, @@ -367,17 +407,29 @@ static void print_pajeDefineLinkType(paje_event_t event) ((defineLinkType_t)event->data)->type->name); } +static void print_pajeDefineEntityValue (paje_event_t event) +{ + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, event->event_type); + fprintf(tracing_file, "%d %s %s %s \"%s\"\n", + event->event_type, + ((defineEntityValue_t)event->data)->value->id, + ((defineEntityValue_t)event->data)->value->father->id, + ((defineEntityValue_t)event->data)->value->name, + ((defineEntityValue_t)event->data)->value->color); +} + static void print_pajeCreateContainer(paje_event_t event) { + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); if (event->timestamp == 0){ - fprintf(tracing_file, "%d 0 %s %s %s %s\n", + fprintf(tracing_file, "%d 0 %s %s %s \"%s\"\n", event->event_type, ((createContainer_t)event->data)->container->id, ((createContainer_t)event->data)->container->type->id, ((createContainer_t)event->data)->container->father->id, ((createContainer_t)event->data)->container->name); }else{ - fprintf(tracing_file, "%d %lf %s %s %s %s\n", + fprintf(tracing_file, "%d %lf %s %s %s \"%s\"\n", event->event_type, event->timestamp, ((createContainer_t)event->data)->container->id, @@ -389,6 +441,7 @@ static void print_pajeCreateContainer(paje_event_t event) static void print_pajeDestroyContainer(paje_event_t event) { + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); if (event->timestamp == 0){ fprintf(tracing_file, "%d 0 %s %s\n", event->event_type, @@ -405,6 +458,7 @@ static void print_pajeDestroyContainer(paje_event_t event) static void print_pajeSetVariable(paje_event_t event) { + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); if (event->timestamp == 0){ fprintf(tracing_file, "%d 0 %s %s %f\n", event->event_type, @@ -423,6 +477,7 @@ static void print_pajeSetVariable(paje_event_t event) static void print_pajeAddVariable(paje_event_t event) { + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); if (event->timestamp == 0){ fprintf(tracing_file, "%d 0 %s %s %f\n", event->event_type, @@ -441,6 +496,7 @@ static void print_pajeAddVariable(paje_event_t event) static void print_pajeSubVariable(paje_event_t event) { + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); if (event->timestamp == 0){ fprintf(tracing_file, "%d 0 %s %s %f\n", event->event_type, @@ -459,42 +515,45 @@ static void print_pajeSubVariable(paje_event_t event) static void print_pajeSetState(paje_event_t event) { + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); if (event->timestamp == 0){ fprintf(tracing_file, "%d 0 %s %s %s\n", event->event_type, ((setState_t)event->data)->type->id, ((setState_t)event->data)->container->id, - ((setState_t)event->data)->value); + ((setState_t)event->data)->value->id); }else{ fprintf(tracing_file, "%d %lf %s %s %s\n", event->event_type, event->timestamp, ((setState_t)event->data)->type->id, ((setState_t)event->data)->container->id, - ((setState_t)event->data)->value); + ((setState_t)event->data)->value->id); } } static void print_pajePushState(paje_event_t event) { + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); if (event->timestamp == 0){ fprintf(tracing_file, "%d 0 %s %s %s\n", event->event_type, ((pushState_t)event->data)->type->id, ((pushState_t)event->data)->container->id, - ((pushState_t)event->data)->value); + ((pushState_t)event->data)->value->id); }else{ fprintf(tracing_file, "%d %lf %s %s %s\n", event->event_type, event->timestamp, ((pushState_t)event->data)->type->id, ((pushState_t)event->data)->container->id, - ((pushState_t)event->data)->value); + ((pushState_t)event->data)->value->id); } } static void print_pajePopState(paje_event_t event) { + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); if (event->timestamp == 0){ fprintf(tracing_file, "%d 0 %s %s\n", event->event_type, @@ -511,6 +570,7 @@ static void print_pajePopState(paje_event_t event) static void print_pajeStartLink(paje_event_t event) { + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); if (event->timestamp == 0){ fprintf(tracing_file, "%d 0 %s %s %s %s %s\n", event->event_type, @@ -533,6 +593,7 @@ static void print_pajeStartLink(paje_event_t event) static void print_pajeEndLink(paje_event_t event) { + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); if (event->timestamp == 0){ fprintf(tracing_file, "%d 0 %s %s %s %s %s\n", event->event_type, @@ -555,20 +616,35 @@ static void print_pajeEndLink(paje_event_t event) static void print_pajeNewEvent (paje_event_t event) { + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); if (event->timestamp == 0){ fprintf(tracing_file, "%d 0 %s %s %s\n", event->event_type, ((newEvent_t)event->data)->type->id, ((newEvent_t)event->data)->container->id, - ((newEvent_t)event->data)->value); + ((newEvent_t)event->data)->value->id); }else{ fprintf(tracing_file, "%d %lf %s %s %s\n", event->event_type, event->timestamp, ((newEvent_t)event->data)->type->id, ((newEvent_t)event->data)->container->id, - ((newEvent_t)event->data)->value); + ((newEvent_t)event->data)->value->id); + } +} + +static void free_paje_event (paje_event_t event) +{ + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + if (event->event_type == PAJE_StartLink){ + xbt_free (((startLink_t)(event->data))->value); + xbt_free (((startLink_t)(event->data))->key); + }else if (event->event_type == PAJE_EndLink){ + xbt_free (((endLink_t)(event->data))->value); + xbt_free (((endLink_t)(event->data))->key); } + xbt_free (event->data); + xbt_free (event); } void new_pajeDefineContainerType(type_t type) @@ -577,16 +653,15 @@ void new_pajeDefineContainerType(type_t type) event->event_type = PAJE_DefineContainerType; event->timestamp = 0; event->print = print_pajeDefineContainerType; + event->free = free_paje_event; event->data = xbt_new0(s_defineContainerType_t, 1); ((defineContainerType_t)(event->data))->type = type; + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, event->event_type); + //print it event->print (event); - - //destroy it - xbt_free (event->data); - xbt_free (event); - event = NULL; + event->free (event); } void new_pajeDefineVariableType(type_t type) @@ -595,16 +670,15 @@ void new_pajeDefineVariableType(type_t type) event->event_type = PAJE_DefineVariableType; event->timestamp = 0; event->print = print_pajeDefineVariableType; + event->free = free_paje_event; event->data = xbt_new0(s_defineVariableType_t, 1); ((defineVariableType_t)(event->data))->type = type; + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, event->event_type); + //print it event->print (event); - - //destroy it - xbt_free (event->data); - xbt_free (event); - event = NULL; + event->free (event); } void new_pajeDefineStateType(type_t type) @@ -613,16 +687,15 @@ void new_pajeDefineStateType(type_t type) event->event_type = PAJE_DefineStateType; event->timestamp = 0; event->print = print_pajeDefineStateType; + event->free = free_paje_event; event->data = xbt_new0(s_defineStateType_t, 1); ((defineStateType_t)(event->data))->type = type; + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, event->event_type); + //print it event->print (event); - - //destroy it - xbt_free (event->data); - xbt_free (event); - event = NULL; + event->free (event); } void new_pajeDefineEventType(type_t type) @@ -631,16 +704,15 @@ void new_pajeDefineEventType(type_t type) event->event_type = PAJE_DefineEventType; event->timestamp = 0; event->print = print_pajeDefineEventType; + event->free = free_paje_event; event->data = xbt_new0(s_defineEventType_t, 1); ((defineEventType_t)(event->data))->type = type; + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, event->event_type); + //print it event->print (event); - - //destroy it - xbt_free (event->data); - xbt_free (event); - event = NULL; + event->free (event); } void new_pajeDefineLinkType(type_t type, type_t source, type_t dest) @@ -649,18 +721,34 @@ void new_pajeDefineLinkType(type_t type, type_t source, type_t dest) event->event_type = PAJE_DefineLinkType; event->timestamp = 0; event->print = print_pajeDefineLinkType; + event->free = free_paje_event; event->data = xbt_new0(s_defineLinkType_t, 1); ((defineLinkType_t)(event->data))->type = type; ((defineLinkType_t)(event->data))->source = source; ((defineLinkType_t)(event->data))->dest = dest; + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, event->event_type); + //print it event->print (event); + event->free (event); +} - //destroy it - xbt_free (event->data); - xbt_free (event); - event = NULL; +void new_pajeDefineEntityValue (val_t value) +{ + paje_event_t event = xbt_new0(s_paje_event_t, 1); + event->event_type = PAJE_DefineEntityValue; + event->timestamp = 0; + event->print = print_pajeDefineEntityValue; + event->free = free_paje_event; + event->data = xbt_new0(s_defineEntityValue_t, 1); + ((defineEntityValue_t)(event->data))->value = value; + + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, event->event_type); + + //print it + event->print (event); + event->free (event); } void new_pajeCreateContainer (container_t container) @@ -669,16 +757,15 @@ void new_pajeCreateContainer (container_t container) event->event_type = PAJE_CreateContainer; event->timestamp = SIMIX_get_clock(); event->print = print_pajeCreateContainer; + event->free = free_paje_event; event->data = xbt_new0(s_createContainer_t, 1); ((createContainer_t)(event->data))->container = container; + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + //print it event->print (event); - - //destroy it - xbt_free (event->data); - xbt_free (event); - event = NULL; + event->free (event); } void new_pajeDestroyContainer (container_t container) @@ -687,16 +774,15 @@ void new_pajeDestroyContainer (container_t container) event->event_type = PAJE_DestroyContainer; event->timestamp = SIMIX_get_clock(); event->print = print_pajeDestroyContainer; + event->free = free_paje_event; event->data = xbt_new0(s_destroyContainer_t, 1); ((destroyContainer_t)(event->data))->container = container; + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + //print it event->print (event); - - //destroy it - xbt_free (event->data); - xbt_free (event); - event = NULL; + event->free (event); } void new_pajeSetVariable (double timestamp, container_t container, type_t type, double value) @@ -705,21 +791,15 @@ void new_pajeSetVariable (double timestamp, container_t container, type_t type, event->event_type = PAJE_SetVariable; event->timestamp = timestamp; event->print = print_pajeSetVariable; + event->free = free_paje_event; event->data = xbt_new0(s_setVariable_t, 1); ((setVariable_t)(event->data))->type = type; ((setVariable_t)(event->data))->container = container; ((setVariable_t)(event->data))->value = value; - insert_into_buffer (event); - return; - - //print it - event->print (event); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); - //destroy it - xbt_free (event->data); - xbt_free (event); - event = NULL; + insert_into_buffer (event); } @@ -729,21 +809,15 @@ void new_pajeAddVariable (double timestamp, container_t container, type_t type, event->event_type = PAJE_AddVariable; event->timestamp = timestamp; event->print = print_pajeAddVariable; + event->free = free_paje_event; event->data = xbt_new0(s_addVariable_t, 1); ((addVariable_t)(event->data))->type = type; ((addVariable_t)(event->data))->container = container; ((addVariable_t)(event->data))->value = value; - insert_into_buffer (event); - return; - - //print it - event->print (event); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); - //destroy it - xbt_free (event->data); - xbt_free (event); - event = NULL; + insert_into_buffer (event); } void new_pajeSubVariable (double timestamp, container_t container, type_t type, double value) @@ -752,70 +826,50 @@ void new_pajeSubVariable (double timestamp, container_t container, type_t type, event->event_type = PAJE_SubVariable; event->timestamp = timestamp; event->print = print_pajeSubVariable; + event->free = free_paje_event; event->data = xbt_new0(s_subVariable_t, 1); ((subVariable_t)(event->data))->type = type; ((subVariable_t)(event->data))->container = container; ((subVariable_t)(event->data))->value = value; - insert_into_buffer (event); - return; + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); - //print it - event->print (event); - - //destroy it - xbt_free (event->data); - xbt_free (event); - event = NULL; + insert_into_buffer (event); } -void new_pajeSetState (double timestamp, container_t container, type_t type, const char *value) +void new_pajeSetState (double timestamp, container_t container, type_t type, val_t value) { paje_event_t event = xbt_new0(s_paje_event_t, 1); event->event_type = PAJE_SetState; event->timestamp = timestamp; event->print = print_pajeSetState; + event->free = free_paje_event; event->data = xbt_new0(s_setState_t, 1); ((setState_t)(event->data))->type = type; ((setState_t)(event->data))->container = container; - ((setState_t)(event->data))->value = xbt_strdup(value); + ((setState_t)(event->data))->value = value; - insert_into_buffer (event); - return; - - //print it - event->print (event); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); - //destroy it - xbt_free (((setState_t)(event->data))->value); - xbt_free (event->data); - xbt_free (event); - event = NULL; + insert_into_buffer (event); } -void new_pajePushState (double timestamp, container_t container, type_t type, const char *value) +void new_pajePushState (double timestamp, container_t container, type_t type, val_t value) { paje_event_t event = xbt_new0(s_paje_event_t, 1); event->event_type = PAJE_PushState; event->timestamp = timestamp; event->print = print_pajePushState; + event->free = free_paje_event; event->data = xbt_new0(s_pushState_t, 1); ((pushState_t)(event->data))->type = type; ((pushState_t)(event->data))->container = container; - ((pushState_t)(event->data))->value = xbt_strdup(value); - - insert_into_buffer (event); - return; + ((pushState_t)(event->data))->value = value; - //print it - event->print (event); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); - //destroy it - xbt_free (((pushState_t)(event->data))->value); - xbt_free (event->data); - xbt_free (event); - event = NULL; + insert_into_buffer (event); } @@ -825,20 +879,14 @@ void new_pajePopState (double timestamp, container_t container, type_t type) event->event_type = PAJE_PopState; event->timestamp = timestamp; event->print = print_pajePopState; + event->free = free_paje_event; event->data = xbt_new0(s_popState_t, 1); ((popState_t)(event->data))->type = type; ((popState_t)(event->data))->container = container; - insert_into_buffer (event); - return; + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); - //print it - event->print (event); - - //destroy it - xbt_free (event->data); - xbt_free (event); - event = NULL; + insert_into_buffer (event); } void new_pajeStartLink (double timestamp, container_t container, type_t type, container_t sourceContainer, const char *value, const char *key) @@ -847,6 +895,7 @@ void new_pajeStartLink (double timestamp, container_t container, type_t type, co event->event_type = PAJE_StartLink; event->timestamp = timestamp; event->print = print_pajeStartLink; + event->free = free_paje_event; event->data = xbt_new0(s_startLink_t, 1); ((startLink_t)(event->data))->type = type; ((startLink_t)(event->data))->container = container; @@ -854,18 +903,9 @@ void new_pajeStartLink (double timestamp, container_t container, type_t type, co ((startLink_t)(event->data))->value = xbt_strdup(value); ((startLink_t)(event->data))->key = xbt_strdup(key); - insert_into_buffer (event); - return; + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); - //print it - event->print (event); - - //destroy it - xbt_free (((startLink_t)(event->data))->value); - xbt_free (((startLink_t)(event->data))->key); - xbt_free (event->data); - xbt_free (event); - event = NULL; + insert_into_buffer (event); } void new_pajeEndLink (double timestamp, container_t container, type_t type, container_t destContainer, const char *value, const char *key) @@ -874,6 +914,7 @@ void new_pajeEndLink (double timestamp, container_t container, type_t type, cont event->event_type = PAJE_EndLink; event->timestamp = timestamp; event->print = print_pajeEndLink; + event->free = free_paje_event; event->data = xbt_new0(s_endLink_t, 1); ((endLink_t)(event->data))->type = type; ((endLink_t)(event->data))->container = container; @@ -881,58 +922,26 @@ void new_pajeEndLink (double timestamp, container_t container, type_t type, cont ((endLink_t)(event->data))->value = xbt_strdup(value); ((endLink_t)(event->data))->key = xbt_strdup(key); - insert_into_buffer (event); - return; - - //print it - event->print (event); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); - //destroy it - xbt_free (((endLink_t)(event->data))->value); - xbt_free (((endLink_t)(event->data))->key); - xbt_free (event->data); - xbt_free (event); - event = NULL; + insert_into_buffer (event); } -void new_pajeNewEvent (double timestamp, container_t container, type_t type, const char *value) +void new_pajeNewEvent (double timestamp, container_t container, type_t type, val_t value) { paje_event_t event = xbt_new0(s_paje_event_t, 1); event->event_type = PAJE_NewEvent; event->timestamp = timestamp; event->print = print_pajeNewEvent; + event->free = free_paje_event; event->data = xbt_new0(s_newEvent_t, 1); ((newEvent_t)(event->data))->type = type; ((newEvent_t)(event->data))->container = container; - ((newEvent_t)(event->data))->value = xbt_strdup(value); - - insert_into_buffer (event); - return; + ((newEvent_t)(event->data))->value = value; - //print it - event->print (event); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); - //destroy it - xbt_free (((newEvent_t)(event->data))->value); - xbt_free (event->data); - xbt_free (event); - event = NULL; -} -// -//void pajeNewEvent(double time, const char *entityType, -// const char *container, const char *value) -//{ -// INSTR_PAJE_ASSERT(entityType); -// INSTR_PAJE_ASSERT(container); -// INSTR_PAJE_ASSERT(value); -// -// if (time == 0){ -// fprintf(tracing_file, "%d 0 %s %s %s\n", pajeNewEventId, -// entityType, container, value); -// }else{ -// fprintf(tracing_file, "%d %lf %s %s %s\n", pajeNewEventId, time, -// entityType, container, value); -// } -//} + insert_into_buffer (event); +} #endif /* HAVE_TRACING */