*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
- * Foundation, Inc., 59 Temple Place - Suite 330, Boston,
- * MA 02111-1307, USA.
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
+ * MA 02110-1301, USA.
*/
#ifdef HAVE_CONFIG_H
struct TracesetChainState* tracesetChainState;
SyncState* syncState;
GList* result;
- int retval;
tracesetChainState= g_hash_table_lookup(tracesetChainStates, traceSetContext);
syncState= malloc(sizeof(SyncState));
tracesetChainState->syncState= syncState;
syncState->traceNb= lttv_traceset_number(traceSetContext->ts);
+ // Statistics are always on with eval
syncState->stats= true;
if (optionEvalGraphs)
{
- char* cwd;
- int graphsFp;
-
// Create the graph directory right away in case the module initialization
// functions have something to write in it.
syncState->graphsDir= optionEvalGraphsDir;
- cwd= changeToGraphDir(optionEvalGraphsDir);
-
- 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
- | S_IWOTH | S_IXOTH)) == -1)
- {
- g_error(strerror(errno));
- }
- 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)
- {
- g_error(strerror(errno));
- }
- free(cwd);
+ syncState->graphsStream= createGraphsDir(syncState->graphsDir);
}
else
{
syncState->graphsDir= NULL;
}
+ syncState->reductionData= NULL;
+ syncState->reductionModule= NULL;
+
syncState->analysisData= NULL;
result= g_queue_find_custom(&analysisModules, "eval",
&gcfCompareAnalysis);
SyncState* syncState;
struct timeval endTime;
struct rusage endUsage;
- unsigned int i, j;
- int retval;
tracesetChainState= g_hash_table_lookup(tracesetChainStates, traceSetContext);
syncState= tracesetChainState->syncState;
- syncState->processingModule->finalizeProcessing(syncState);
+ freeAllFactors(syncState->processingModule->finalizeProcessing(syncState),
+ syncState->traceNb);
// Write graphs file
if (optionEvalGraphs)
{
- // 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 pos1, pos2, trunc;
-
- fprintf(syncState->graphsStream,
- "\nreset\n"
- "set output \"%03d-%03d.eps\"\n"
- "plot \\\n", i, j);
- pos1= ftell(syncState->graphsStream);
-
- if (syncState->processingModule->writeProcessingGraphsPlots)
- {
- syncState->processingModule->writeProcessingGraphsPlots(syncState,
- i, j);
- }
- if (syncState->matchingModule->writeMatchingGraphsPlots)
- {
- syncState->matchingModule->writeMatchingGraphsPlots(syncState,
- i, j);
- }
- if (syncState->analysisModule->writeAnalysisGraphsPlots)
- {
- syncState->analysisModule->writeAnalysisGraphsPlots(syncState,
- i, j);
- }
-
- fflush(syncState->graphsStream);
- pos2= ftell(syncState->graphsStream);
- if (pos1 != pos2)
- {
- // Remove the ", \\\n" from the last graph plot line
- trunc= pos2 - 4;
- }
- else
- {
- // Remove the "plot \\\n" line to avoid creating an invalid
- // gnuplot script
- trunc= pos2 - 7;
- }
-
- if (ftruncate(fileno(syncState->graphsStream), trunc) == -1)
- {
- g_error(strerror(errno));
- }
- if (fseek(syncState->graphsStream, 0, SEEK_END) == -1)
- {
- g_error(strerror(errno));
- }
-
- fprintf(syncState->graphsStream,
- "\nset output \"%1$03d-%2$03d.eps\"\n"
- "set title \"\"\n", i, j);
-
- if (syncState->processingModule->writeProcessingGraphsOptions)
- {
- syncState->processingModule->writeProcessingGraphsOptions(syncState,
- i, j);
- }
- if (syncState->matchingModule->writeMatchingGraphsOptions)
- {
- syncState->matchingModule->writeMatchingGraphsOptions(syncState,
- i, j);
- }
- if (syncState->analysisModule->writeAnalysisGraphsOptions)
- {
- syncState->analysisModule->writeAnalysisGraphsOptions(syncState,
- i, j);
- }
-
- if (pos1 != pos2)
- {
- fprintf(syncState->graphsStream, "replot\n");
- }
- }
- }
+ writeGraphsScript(syncState);
if (fclose(syncState->graphsStream) != 0)
{
- g_error(strerror(errno));
+ g_error("%s", strerror(errno));
}
}
- if (syncState->processingModule->printProcessingStats != NULL)
- {
- syncState->processingModule->printProcessingStats(syncState);
- }
- if (syncState->matchingModule->printMatchingStats != NULL)
- {
- syncState->matchingModule->printMatchingStats(syncState);
- }
- if (syncState->analysisModule->printAnalysisStats != NULL)
- {
- syncState->analysisModule->printAnalysisStats(syncState);
- }
-
- 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);
- }
+ printStats(syncState);
syncState->processingModule->destroyProcessing(syncState);
if (syncState->matchingModule != NULL)
{
syncState->analysisModule->destroyAnalysis(syncState);
}
+ if (syncState->reductionModule != NULL)
+ {
+ syncState->reductionModule->destroyReduction(syncState);
+ }
free(syncState);
gettimeofday(&endTime, 0);
- retval= getrusage(RUSAGE_SELF, &endUsage);
+ getrusage(RUSAGE_SELF, &endUsage);
timeDiff(&endTime, &tracesetChainState->startTime);
timeDiff(&endUsage.ru_utime, &tracesetChainState->startUsage.ru_utime);
projects / lttv.git / blobdiff