#include "sync_chain.h"
-#ifndef g_info
-#define g_info(format...) g_log (G_LOG_DOMAIN, G_LOG_LEVEL_INFO, format)
-#endif
-
-
static void init();
static void destroy();
struct timeval startTime, endTime;
struct rusage startUsage, endUsage;
GList* result;
- FILE* graphsStream;
+ unsigned int i;
int retval;
if (!optionSync.present)
}
if (optionSyncGraphs.present)
- {
- syncState->graphs= optionSyncGraphsDir.arg;
- }
- else
- {
- syncState->graphs= NULL;
- }
-
- graphsStream= NULL;
- if (syncState->graphs)
{
char* cwd;
int graphsFp;
// Create the graph directory right away in case the module initialization
// functions have something to write in it.
- cwd= changeToGraphDir(syncState->graphs);
+ syncState->graphsDir= optionSyncGraphsDir.arg;
+ cwd= changeToGraphDir(optionSyncGraphsDir.arg);
if ((graphsFp= open("graphs.gnu", O_WRONLY | O_CREAT | O_TRUNC, S_IRUSR |
S_IWUSR | S_IXUSR | S_IRGRP | S_IWGRP | S_IXGRP | S_IROTH
{
g_error(strerror(errno));
}
- if ((graphsStream= fdopen(graphsFp, "w")) == NULL)
+ if ((syncState->graphsStream= fdopen(graphsFp, "w")) == NULL)
{
g_error(strerror(errno));
}
+ fprintf(syncState->graphsStream,
+ "#!/usr/bin/gnuplot\n\n"
+ "set terminal postscript eps color size 8in,6in\n");
+
retval= chdir(cwd);
if (retval == -1)
{
}
free(cwd);
}
+ else
+ {
+ syncState->graphsStream= NULL;
+ syncState->graphsDir= NULL;
+ }
// Identify and initialize modules
syncState->processingData= NULL;
syncState->processingModule->finalizeProcessing(syncState);
// Write graphs file
- if (graphsStream != NULL)
+ if (optionSyncGraphs.present)
{
- unsigned int i, j;
-
- fprintf(graphsStream,
- "#!/usr/bin/gnuplot\n\n"
- "set terminal postscript eps color size 8in,6in\n");
+ writeGraphsScript(syncState);
- // Cover the upper triangular matrix, i is the reference node.
- for (i= 0; i < syncState->traceNb; i++)
- {
- for (j= i + 1; j < syncState->traceNb; j++)
- {
- long pos;
-
- fprintf(graphsStream,
- "\nset output \"%03d-%03d.eps\"\n"
- "plot \\\n", i, j);
-
- syncState->processingModule->writeProcessingGraphsPlots(graphsStream,
- syncState, i, j);
-
- // Remove the ", \\\n" from the last graph plot line
- fflush(graphsStream);
- pos= ftell(graphsStream);
- if (ftruncate(fileno(graphsStream), pos - 4) == -1)
- {
- g_error(strerror(errno));
- }
- if (fseek(graphsStream, 0, SEEK_END) == -1)
- {
- g_error(strerror(errno));
- }
-
- fprintf(graphsStream,
- "\nset output \"%1$03d-%2$03d.eps\"\n"
- "set key inside right bottom\n"
- "set title \"\"\n"
- "set xlabel \"Clock %1$u\"\n"
- "set xtics nomirror\n"
- "set ylabel \"Clock %2$u\"\n"
- "set ytics nomirror\n", i, j);
-
- syncState->processingModule->writeProcessingGraphsOptions(graphsStream,
- syncState, i, j);
-
- fprintf(graphsStream,
- "replot\n");
- }
- }
-
- if (fclose(graphsStream) != 0)
+ if (fclose(syncState->graphsStream) != 0)
{
g_error(strerror(errno));
}
{
syncState->processingModule->printProcessingStats(syncState);
}
+ if (syncState->matchingModule->printMatchingStats != NULL)
+ {
+ syncState->matchingModule->printMatchingStats(syncState);
+ }
+ if (syncState->analysisModule->printAnalysisStats != NULL)
+ {
+ syncState->analysisModule->printAnalysisStats(syncState);
+ }
+
+ if (optionSyncStats.present)
+ {
+ printf("Resulting synchronization factors:\n");
+ for (i= 0; i < syncState->traceNb; i++)
+ {
+ LttTrace* t;
+
+ t= traceSetContext->traces[i]->t;
+
+ printf("\ttrace %u drift= %g offset= %g (%f) start time= %ld.%09ld\n",
+ i, t->drift, t->offset, (double) tsc_to_uint64(t->freq_scale,
+ t->start_freq, t->offset) / NANOSECONDS_PER_SECOND,
+ t->start_time_from_tsc.tv_sec,
+ t->start_time_from_tsc.tv_nsec);
+ }
+ }
syncState->processingModule->destroyProcessing(syncState);
if (syncState->matchingModule != NULL)