X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/6657e92cd04d7a30edd662d9edbc8bfa0b381979..bdfe4f8674f98efbf2d67ad854ef83a1d5f855ed:/src/instr/instr_paje_trace.c diff --git a/src/instr/instr_paje_trace.c b/src/instr/instr_paje_trace.c index e4a6fa4f56..625519d8e9 100644 --- a/src/instr/instr_paje_trace.c +++ b/src/instr/instr_paje_trace.c @@ -1,34 +1,16 @@ -/* Copyright (c) 2010. The SimGrid Team. +/* Copyright (c) 2010-2013. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ #include "instr/instr_private.h" +#include "xbt/virtu.h" /* sg_cmdline */ #ifdef HAVE_TRACING XBT_LOG_NEW_DEFAULT_SUBCATEGORY(instr_paje_trace, instr, "Paje tracing event system"); -typedef enum { - PAJE_DefineContainerType, - PAJE_DefineVariableType, - PAJE_DefineStateType, - PAJE_DefineEventType, - PAJE_DefineLinkType, - PAJE_CreateContainer, - PAJE_DestroyContainer, - PAJE_SetVariable, - PAJE_AddVariable, - PAJE_SubVariable, - PAJE_SetState, - PAJE_PushState, - PAJE_PopState, - PAJE_StartLink, - PAJE_EndLink, - PAJE_NewEvent, -} e_event_type; - typedef struct paje_event *paje_event_t; typedef struct paje_event { double timestamp; @@ -65,6 +47,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; @@ -100,14 +87,15 @@ 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; + int size; }s_pushState_t; typedef struct s_popState *popState_t; @@ -116,6 +104,12 @@ typedef struct s_popState { type_t type; }s_popState_t; +typedef struct s_resetState *resetState_t; +typedef struct s_resetState { + container_t container; + type_t type; +}s_resetState_t; + typedef struct s_startLink *startLink_t; typedef struct s_startLink { container_t container; @@ -123,6 +117,7 @@ typedef struct s_startLink { container_t sourceContainer; char *value; char *key; + int size; }s_startLink_t; typedef struct s_endLink *endLink_t; @@ -138,23 +133,70 @@ 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; +FILE *tracing_file = NULL; static xbt_dynar_t buffer = NULL; +static void dump_comment (const char *comment) +{ + if (!strlen(comment)) return; + fprintf (tracing_file, "# %s\n", comment); +} + +static void dump_comment_file (const char *filename) +{ + if (!strlen(filename)) return; + FILE *file = fopen (filename, "r"); + if (!file){ + THROWF (system_error, 1, "Comment file %s could not be opened for reading.", filename); + } + while (!feof(file)){ + char c; + c = fgetc(file); + if (feof(file)) break; + fprintf (tracing_file, "# "); + while (c != '\n'){ + fprintf (tracing_file, "%c", c); + c = fgetc(file); + if (feof(file)) break; + } + fprintf (tracing_file, "\n"); + } + fclose(file); +} + + 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); + if (tracing_file == NULL){ + THROWF (system_error, 1, "Tracefile %s could not be opened for writing.", filename); + } + + XBT_DEBUG("Filename %s is open for writing", filename); + + /* output generator version */ + fprintf (tracing_file, "#This file was generated using SimGrid-%d.%d.%d\n", SIMGRID_VERSION_MAJOR, SIMGRID_VERSION_MINOR, SIMGRID_VERSION_PATCH); + fprintf (tracing_file, "#["); + unsigned int cpt; + char *str; + xbt_dynar_foreach (xbt_cmdline, cpt, str){ + fprintf(tracing_file, "%s ",str); + } + fprintf (tracing_file, "]\n"); - DEBUG1("Filename %s is open for writing", filename); + /* output one line comment */ + dump_comment (TRACE_get_comment()); + + /* output comment file */ + dump_comment_file (TRACE_get_comment_file()); /* output header */ - TRACE_paje_create_header(); + TRACE_header(TRACE_basic(),TRACE_display_sizes()); buffer = xbt_dynar_new (sizeof(paje_event_t), NULL); } @@ -163,179 +205,71 @@ void TRACE_paje_end(void) { fclose(tracing_file); char *filename = TRACE_get_filename(); - DEBUG1("Filename %s is closed", filename); + xbt_dynar_free (&buffer); + XBT_DEBUG("Filename %s is closed", filename); } double TRACE_last_timestamp_to_dump = 0; //dumps the trace file until the timestamp TRACE_last_timestamp_to_dump -void TRACE_paje_dump_buffer (void) -{ - DEBUG2("%s: dump until %f. starts", __FUNCTION__, TRACE_last_timestamp_to_dump); - paje_event_t event; - while (xbt_dynar_length (buffer) > 0){ - double head_timestamp = (*(paje_event_t*)xbt_dynar_get_ptr(buffer, 0))->timestamp; - if (head_timestamp > TRACE_last_timestamp_to_dump){ - break; +void TRACE_paje_dump_buffer (int force) +{ + 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; + unsigned int cursor; + xbt_dynar_foreach(buffer, cursor, event) { + double head_timestamp = event->timestamp; + if (head_timestamp > TRACE_last_timestamp_to_dump){ + break; + } + event->print (event); + event->free (event); } - xbt_dynar_remove_at (buffer, 0, &event); - event->print (event); - event->free (event); + xbt_dynar_remove_n_at(buffer, cursor, 0); } - DEBUG1("%s: ends", __FUNCTION__); -} - -void TRACE_paje_create_header(void) -{ - DEBUG0 ("Define paje header"); - fprintf(tracing_file, "\ -%%EventDef PajeDefineContainerType %d \n\ -%% Alias string \n\ -%% ContainerType string \n\ -%% Name string \n\ -%%EndEventDef \n\ -%%EventDef PajeDefineVariableType %d \n\ -%% Alias string \n\ -%% ContainerType string \n\ -%% Name string \n\ -%% Color color \n\ -%%EndEventDef \n\ -%%EventDef PajeDefineStateType %d \n\ -%% Alias string \n\ -%% ContainerType string \n\ -%% Name string \n\ -%%EndEventDef \n\ -%%EventDef PajeDefineEventType %d \n\ -%% Alias string \n\ -%% EntityType string \n\ -%% Name string \n\ -%% Color color \n\ -%%EndEventDef \n\ -%%EventDef PajeDefineLinkType %d \n\ -%% Alias string \n\ -%% ContainerType string \n\ -%% SourceContainerType string \n\ -%% DestContainerType string \n\ -%% Name string \n\ -%%EndEventDef \n\ -%%EventDef PajeCreateContainer %d \n\ -%% Time date \n\ -%% Alias string \n\ -%% Type string \n\ -%% Container string \n\ -%% Name string \n\ -%%EndEventDef \n\ -%%EventDef PajeDestroyContainer %d \n\ -%% Time date \n\ -%% Type string \n\ -%% Container string \n\ -%%EndEventDef \n\ -%%EventDef PajeSetVariable %d \n\ -%% Time date \n\ -%% EntityType string \n\ -%% Container string \n\ -%% Value string \n\ -%%EndEventDef\n\ -%%EventDef PajeAddVariable %d \n\ -%% Time date \n\ -%% EntityType string \n\ -%% Container string \n\ -%% Value string \n\ -%%EndEventDef\n\ -%%EventDef PajeSubVariable %d \n\ -%% Time date \n\ -%% EntityType string \n\ -%% Container string \n\ -%% Value string \n\ -%%EndEventDef\n\ -%%EventDef PajeSetState %d \n\ -%% Time date \n\ -%% EntityType string \n\ -%% Container string \n\ -%% Value string \n\ -%%EndEventDef\n\ -%%EventDef PajePushState %d \n\ -%% Time date \n\ -%% EntityType string \n\ -%% Container string \n\ -%% Value string \n\ -%%EndEventDef\n\ -%%EventDef PajePopState %d \n\ -%% Time date \n\ -%% EntityType string \n\ -%% Container string \n\ -%%EndEventDef\n\ -%%EventDef PajeStartLink %d \n\ -%% Time date \n\ -%% EntityType string \n\ -%% Container string \n\ -%% Value string \n\ -%% SourceContainer string \n\ -%% Key string \n\ -%%EndEventDef\n\ -%%EventDef PajeEndLink %d \n\ -%% Time date \n\ -%% EntityType string \n\ -%% Container string \n\ -%% Value string \n\ -%% DestContainer string \n\ -%% Key string \n\ -%%EndEventDef\n\ -%%EventDef PajeNewEvent %d \n\ -%% Time date \n\ -%% EntityType string \n\ -%% Container string \n\ -%% Value string \n\ -%%EndEventDef\n", - PAJE_DefineContainerType, - PAJE_DefineVariableType, - PAJE_DefineStateType, - PAJE_DefineEventType, - PAJE_DefineLinkType, - PAJE_CreateContainer, - PAJE_DestroyContainer, - PAJE_SetVariable, - PAJE_AddVariable, - PAJE_SubVariable, - PAJE_SetState, - PAJE_PushState, - PAJE_PopState, - PAJE_StartLink, - PAJE_EndLink, - PAJE_NewEvent); + XBT_DEBUG("%s: ends", __FUNCTION__); } /* internal do the instrumentation module */ static void insert_into_buffer (paje_event_t tbi) { - DEBUG4("%s: insert event_type=%d, timestamp=%f, buffersize=%ld)", __FUNCTION__, tbi->event_type, tbi->timestamp, xbt_dynar_length(buffer)); + if (TRACE_buffer() == 0){ + tbi->print (tbi); + tbi->free (tbi); + return; + } + XBT_DEBUG("%s: insert event_type=%d, timestamp=%f, buffersize=%lu)", + __FUNCTION__, (int)tbi->event_type, tbi->timestamp, xbt_dynar_length(buffer)); unsigned int i; - if (xbt_dynar_length(buffer) == 0){ - xbt_dynar_push (buffer, &tbi); - DEBUG1("%s: inserted at beginning", __FUNCTION__); - }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); - DEBUG2("%s: inserted at %d", __FUNCTION__, i); - inserted = 1; - break; - } - } - if (!inserted){ - xbt_dynar_push (buffer, &tbi); - DEBUG1("%s: inserted at end", __FUNCTION__); - } + 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 %u", __FUNCTION__, + (i == xbt_dynar_length(buffer) - 1 ? " end, pos =" : ""), i); } static void print_pajeDefineContainerType(paje_event_t event) { - DEBUG2("%s: event_type=%d", __FUNCTION__, event->event_type); + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, (int)event->event_type); fprintf(tracing_file, "%d %s %s %s\n", - event->event_type, + (int)event->event_type, ((defineContainerType_t)event->data)->type->id, ((defineContainerType_t)event->data)->type->father->id, ((defineContainerType_t)event->data)->type->name); @@ -343,9 +277,9 @@ static void print_pajeDefineContainerType(paje_event_t event) static void print_pajeDefineVariableType(paje_event_t event) { - DEBUG2("%s: event_type=%d", __FUNCTION__, event->event_type); + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, (int)event->event_type); fprintf(tracing_file, "%d %s %s %s \"%s\"\n", - event->event_type, + (int)event->event_type, ((defineVariableType_t)event->data)->type->id, ((defineVariableType_t)event->data)->type->father->id, ((defineVariableType_t)event->data)->type->name, @@ -354,9 +288,9 @@ static void print_pajeDefineVariableType(paje_event_t event) static void print_pajeDefineStateType(paje_event_t event) { - DEBUG2("%s: event_type=%d", __FUNCTION__, event->event_type); + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, (int)event->event_type); fprintf(tracing_file, "%d %s %s %s\n", - event->event_type, + (int)event->event_type, ((defineStateType_t)event->data)->type->id, ((defineStateType_t)event->data)->type->father->id, ((defineStateType_t)event->data)->type->name); @@ -364,20 +298,19 @@ static void print_pajeDefineStateType(paje_event_t event) static void print_pajeDefineEventType(paje_event_t event) { - DEBUG2("%s: event_type=%d", __FUNCTION__, event->event_type); - fprintf(tracing_file, "%d %s %s %s \"%s\"\n", - event->event_type, + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, (int)event->event_type); + fprintf(tracing_file, "%d %s %s %s\n", + (int)event->event_type, ((defineEventType_t)event->data)->type->id, ((defineEventType_t)event->data)->type->father->id, - ((defineEventType_t)event->data)->type->name, - ((defineEventType_t)event->data)->type->color); + ((defineEventType_t)event->data)->type->name); } static void print_pajeDefineLinkType(paje_event_t event) { - DEBUG2("%s: event_type=%d", __FUNCTION__, event->event_type); + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, (int)event->event_type); fprintf(tracing_file, "%d %s %s %s %s %s\n", - event->event_type, + (int)event->event_type, ((defineLinkType_t)event->data)->type->id, ((defineLinkType_t)event->data)->type->father->id, ((defineLinkType_t)event->data)->source->id, @@ -385,19 +318,30 @@ 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__, (int)event->event_type); + fprintf(tracing_file, "%d %s %s %s \"%s\"\n", + (int)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) { - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); if (event->timestamp == 0){ - fprintf(tracing_file, "%d 0 %s %s %s %s\n", - event->event_type, + fprintf(tracing_file, "%d 0 %s %s %s \"%s\"\n", + (int)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", - event->event_type, + fprintf(tracing_file, "%d %lf %s %s %s \"%s\"\n", + (int)event->event_type, event->timestamp, ((createContainer_t)event->data)->container->id, ((createContainer_t)event->data)->container->type->id, @@ -408,15 +352,15 @@ static void print_pajeCreateContainer(paje_event_t event) static void print_pajeDestroyContainer(paje_event_t event) { - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); if (event->timestamp == 0){ fprintf(tracing_file, "%d 0 %s %s\n", - event->event_type, + (int)event->event_type, ((destroyContainer_t)event->data)->container->type->id, ((destroyContainer_t)event->data)->container->id); }else{ fprintf(tracing_file, "%d %lf %s %s\n", - event->event_type, + (int)event->event_type, event->timestamp, ((destroyContainer_t)event->data)->container->type->id, ((destroyContainer_t)event->data)->container->id); @@ -425,16 +369,16 @@ static void print_pajeDestroyContainer(paje_event_t event) static void print_pajeSetVariable(paje_event_t event) { - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); if (event->timestamp == 0){ fprintf(tracing_file, "%d 0 %s %s %f\n", - event->event_type, + (int)event->event_type, ((setVariable_t)event->data)->type->id, ((setVariable_t)event->data)->container->id, ((setVariable_t)event->data)->value); }else{ fprintf(tracing_file, "%d %lf %s %s %f\n", - event->event_type, + (int)event->event_type, event->timestamp, ((setVariable_t)event->data)->type->id, ((setVariable_t)event->data)->container->id, @@ -444,16 +388,16 @@ static void print_pajeSetVariable(paje_event_t event) static void print_pajeAddVariable(paje_event_t event) { - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); if (event->timestamp == 0){ fprintf(tracing_file, "%d 0 %s %s %f\n", - event->event_type, + (int)event->event_type, ((addVariable_t)event->data)->type->id, ((addVariable_t)event->data)->container->id, ((addVariable_t)event->data)->value); }else{ fprintf(tracing_file, "%d %lf %s %s %f\n", - event->event_type, + (int)event->event_type, event->timestamp, ((addVariable_t)event->data)->type->id, ((addVariable_t)event->data)->container->id, @@ -463,16 +407,16 @@ static void print_pajeAddVariable(paje_event_t event) static void print_pajeSubVariable(paje_event_t event) { - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); if (event->timestamp == 0){ fprintf(tracing_file, "%d 0 %s %s %f\n", - event->event_type, + (int)event->event_type, ((subVariable_t)event->data)->type->id, ((subVariable_t)event->data)->container->id, ((subVariable_t)event->data)->value); }else{ fprintf(tracing_file, "%d %lf %s %s %f\n", - event->event_type, + (int)event->event_type, event->timestamp, ((subVariable_t)event->data)->type->id, ((subVariable_t)event->data)->container->id, @@ -482,88 +426,148 @@ static void print_pajeSubVariable(paje_event_t event) static void print_pajeSetState(paje_event_t event) { - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); if (event->timestamp == 0){ fprintf(tracing_file, "%d 0 %s %s %s\n", - event->event_type, + (int)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, + (int)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) { - DEBUG3("%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); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); + if (!TRACE_display_sizes()){ + if (event->timestamp == 0){ + fprintf(tracing_file, "%d 0 %s %s %s\n", + (int)event->event_type, + ((pushState_t)event->data)->type->id, + ((pushState_t)event->data)->container->id, + ((pushState_t)event->data)->value->id); + }else{ + fprintf(tracing_file, "%d %lf %s %s %s\n", + (int)event->event_type, + event->timestamp, + ((pushState_t)event->data)->type->id, + ((pushState_t)event->data)->container->id, + ((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); + if (event->timestamp == 0){ + fprintf(tracing_file, "%d 0 %s %s %s %d\n", + (int)event->event_type, + ((pushState_t)event->data)->type->id, + ((pushState_t)event->data)->container->id, + ((pushState_t)event->data)->value->id, + ((pushState_t)event->data)->size); + }else{ + fprintf(tracing_file, "%d %lf %s %s %s %d\n", + (int)event->event_type, + event->timestamp, + ((pushState_t)event->data)->type->id, + ((pushState_t)event->data)->container->id, + ((pushState_t)event->data)->value->id, + ((pushState_t)event->data)->size); + } + } } static void print_pajePopState(paje_event_t event) { - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); if (event->timestamp == 0){ fprintf(tracing_file, "%d 0 %s %s\n", - event->event_type, + (int)event->event_type, ((popState_t)event->data)->type->id, ((popState_t)event->data)->container->id); }else{ fprintf(tracing_file, "%d %lf %s %s\n", - event->event_type, + (int)event->event_type, event->timestamp, ((popState_t)event->data)->type->id, ((popState_t)event->data)->container->id); } } -static void print_pajeStartLink(paje_event_t event) +static void print_pajeResetState(paje_event_t event) { - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); if (event->timestamp == 0){ - fprintf(tracing_file, "%d 0 %s %s %s %s %s\n", - event->event_type, - ((startLink_t)event->data)->type->id, - ((startLink_t)event->data)->container->id, - ((startLink_t)event->data)->value, - ((startLink_t)event->data)->sourceContainer->id, - ((startLink_t)event->data)->key); - }else { - fprintf(tracing_file, "%d %lf %s %s %s %s %s\n", - event->event_type, + fprintf(tracing_file, "%d 0 %s %s\n", + (int)event->event_type, + ((resetState_t)event->data)->type->id, + ((resetState_t)event->data)->container->id); + }else{ + fprintf(tracing_file, "%d %lf %s %s\n", + (int)event->event_type, event->timestamp, - ((startLink_t)event->data)->type->id, - ((startLink_t)event->data)->container->id, - ((startLink_t)event->data)->value, - ((startLink_t)event->data)->sourceContainer->id, - ((startLink_t)event->data)->key); + ((resetState_t)event->data)->type->id, + ((resetState_t)event->data)->container->id); + } +} + +static void print_pajeStartLink(paje_event_t event) +{ + if (!TRACE_display_sizes()){ + if (event->timestamp == 0){ + fprintf(tracing_file, "%d 0 %s %s %s %s %s\n", + (int)event->event_type, + ((startLink_t)event->data)->type->id, + ((startLink_t)event->data)->container->id, + ((startLink_t)event->data)->value, + ((startLink_t)event->data)->sourceContainer->id, + ((startLink_t)event->data)->key); + }else { + fprintf(tracing_file, "%d %lf %s %s %s %s %s\n", + (int)event->event_type, + event->timestamp, + ((startLink_t)event->data)->type->id, + ((startLink_t)event->data)->container->id, + ((startLink_t)event->data)->value, + ((startLink_t)event->data)->sourceContainer->id, + ((startLink_t)event->data)->key); + } + }else{ + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); + if (event->timestamp == 0){ + fprintf(tracing_file, "%d 0 %s %s %s %s %s %d\n", + (int)event->event_type, + ((startLink_t)event->data)->type->id, + ((startLink_t)event->data)->container->id, + ((startLink_t)event->data)->value, + ((startLink_t)event->data)->sourceContainer->id, + ((startLink_t)event->data)->key, + ((startLink_t)event->data)->size); + }else { + fprintf(tracing_file, "%d %lf %s %s %s %s %s %d\n", + (int)event->event_type, + event->timestamp, + ((startLink_t)event->data)->type->id, + ((startLink_t)event->data)->container->id, + ((startLink_t)event->data)->value, + ((startLink_t)event->data)->sourceContainer->id, + ((startLink_t)event->data)->key, + ((startLink_t)event->data)->size); + } } } static void print_pajeEndLink(paje_event_t event) { - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); if (event->timestamp == 0){ fprintf(tracing_file, "%d 0 %s %s %s %s %s\n", - event->event_type, + (int)event->event_type, ((endLink_t)event->data)->type->id, ((endLink_t)event->data)->container->id, ((endLink_t)event->data)->value, @@ -571,7 +575,7 @@ static void print_pajeEndLink(paje_event_t event) ((endLink_t)event->data)->key); }else { fprintf(tracing_file, "%d %lf %s %s %s %s %s\n", - event->event_type, + (int)event->event_type, event->timestamp, ((endLink_t)event->data)->type->id, ((endLink_t)event->data)->container->id, @@ -583,38 +587,37 @@ static void print_pajeEndLink(paje_event_t event) static void print_pajeNewEvent (paje_event_t event) { - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); if (event->timestamp == 0){ fprintf(tracing_file, "%d 0 %s %s %s\n", - event->event_type, + (int)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, + (int)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) { - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); - if (event->event_type == PAJE_SetState) { - xbt_free (((setState_t)(event->data))->value); - }else if (event->event_type == PAJE_PushState) { - xbt_free (((pushState_t)(event->data))->value); - }else if (event->event_type == PAJE_NewEvent){ - xbt_free (((newEvent_t)(event->data))->value); - }else if (event->event_type == PAJE_StartLink){ + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); + switch (event->event_type){ + case PAJE_StartLink: xbt_free (((startLink_t)(event->data))->value); xbt_free (((startLink_t)(event->data))->key); - }else if (event->event_type == PAJE_EndLink){ + break; + case PAJE_EndLink: xbt_free (((endLink_t)(event->data))->value); xbt_free (((endLink_t)(event->data))->key); + break; + default: + break; } xbt_free (event->data); xbt_free (event); @@ -630,7 +633,7 @@ void new_pajeDefineContainerType(type_t type) event->data = xbt_new0(s_defineContainerType_t, 1); ((defineContainerType_t)(event->data))->type = type; - DEBUG2("%s: event_type=%d", __FUNCTION__, event->event_type); + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, (int)event->event_type); //print it event->print (event); @@ -647,7 +650,7 @@ void new_pajeDefineVariableType(type_t type) event->data = xbt_new0(s_defineVariableType_t, 1); ((defineVariableType_t)(event->data))->type = type; - DEBUG2("%s: event_type=%d", __FUNCTION__, event->event_type); + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, (int)event->event_type); //print it event->print (event); @@ -664,7 +667,7 @@ void new_pajeDefineStateType(type_t type) event->data = xbt_new0(s_defineStateType_t, 1); ((defineStateType_t)(event->data))->type = type; - DEBUG2("%s: event_type=%d", __FUNCTION__, event->event_type); + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, (int)event->event_type); //print it event->print (event); @@ -681,7 +684,7 @@ void new_pajeDefineEventType(type_t type) event->data = xbt_new0(s_defineEventType_t, 1); ((defineEventType_t)(event->data))->type = type; - DEBUG2("%s: event_type=%d", __FUNCTION__, event->event_type); + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, (int)event->event_type); //print it event->print (event); @@ -700,7 +703,24 @@ void new_pajeDefineLinkType(type_t type, type_t source, type_t dest) ((defineLinkType_t)(event->data))->source = source; ((defineLinkType_t)(event->data))->dest = dest; - DEBUG2("%s: event_type=%d", __FUNCTION__, event->event_type); + XBT_DEBUG("%s: event_type=%d", __FUNCTION__, (int)event->event_type); + + //print it + event->print (event); + event->free (event); +} + +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__, (int)event->event_type); //print it event->print (event); @@ -717,7 +737,7 @@ void new_pajeCreateContainer (container_t container) event->data = xbt_new0(s_createContainer_t, 1); ((createContainer_t)(event->data))->container = container; - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); //print it event->print (event); @@ -734,7 +754,7 @@ void new_pajeDestroyContainer (container_t container) event->data = xbt_new0(s_destroyContainer_t, 1); ((destroyContainer_t)(event->data))->container = container; - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); //print it event->print (event); @@ -753,7 +773,7 @@ void new_pajeSetVariable (double timestamp, container_t container, type_t type, ((setVariable_t)(event->data))->container = container; ((setVariable_t)(event->data))->value = value; - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); insert_into_buffer (event); } @@ -771,7 +791,7 @@ void new_pajeAddVariable (double timestamp, container_t container, type_t type, ((addVariable_t)(event->data))->container = container; ((addVariable_t)(event->data))->value = value; - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); insert_into_buffer (event); } @@ -788,12 +808,12 @@ void new_pajeSubVariable (double timestamp, container_t container, type_t type, ((subVariable_t)(event->data))->container = container; ((subVariable_t)(event->data))->value = value; - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); 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; @@ -803,15 +823,15 @@ void new_pajeSetState (double timestamp, container_t container, type_t type, con 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; - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); 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; @@ -821,9 +841,28 @@ void new_pajePushState (double timestamp, container_t container, type_t type, co 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); + ((pushState_t)(event->data))->value = value; + ((pushState_t)(event->data))->size = -1; - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); + + insert_into_buffer (event); +} + +void new_pajePushStateWithSize (double timestamp, container_t container, type_t type, val_t value, int size) +{ + 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 = value; + ((pushState_t)(event->data))->size = size; + + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); insert_into_buffer (event); } @@ -840,7 +879,24 @@ void new_pajePopState (double timestamp, container_t container, type_t type) ((popState_t)(event->data))->type = type; ((popState_t)(event->data))->container = container; - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); + + insert_into_buffer (event); +} + + +void new_pajeResetState (double timestamp, container_t container, type_t type) +{ + paje_event_t event = xbt_new0(s_paje_event_t, 1); + event->event_type = PAJE_ResetState; + event->timestamp = timestamp; + event->print = print_pajeResetState; + event->free = free_paje_event; + event->data = xbt_new0(s_resetState_t, 1); + ((resetState_t)(event->data))->type = type; + ((resetState_t)(event->data))->container = container; + + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); insert_into_buffer (event); } @@ -858,8 +914,28 @@ void new_pajeStartLink (double timestamp, container_t container, type_t type, co ((startLink_t)(event->data))->sourceContainer = sourceContainer; ((startLink_t)(event->data))->value = xbt_strdup(value); ((startLink_t)(event->data))->key = xbt_strdup(key); + ((startLink_t)(event->data))->size = -1; + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); + + insert_into_buffer (event); +} + +void new_pajeStartLinkWithSize (double timestamp, container_t container, type_t type, container_t sourceContainer, const char *value, const char *key, int size) +{ + paje_event_t event = xbt_new0(s_paje_event_t, 1); + 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; + ((startLink_t)(event->data))->sourceContainer = sourceContainer; + ((startLink_t)(event->data))->value = xbt_strdup(value); + ((startLink_t)(event->data))->key = xbt_strdup(key); + ((startLink_t)(event->data))->size = size; - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); insert_into_buffer (event); } @@ -878,12 +954,12 @@ 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); - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); 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; @@ -893,9 +969,9 @@ void new_pajeNewEvent (double timestamp, container_t container, type_t type, con 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); + ((newEvent_t)(event->data))->value = value; - DEBUG3("%s: event_type=%d, timestamp=%f", __FUNCTION__, event->event_type, event->timestamp); + XBT_DEBUG("%s: event_type=%d, timestamp=%f", __FUNCTION__, (int)event->event_type, event->timestamp); insert_into_buffer (event); }