Add a module to distribute messages to many analysis modules

[lttv.git] / lttv / modules / text / sync_chain_batch.c

diff --git a/lttv/modules/text/sync_chain_batch.c b/lttv/modules/text/sync_chain_batch.c
index 86f3c657b27680cc977cafff86078c5a217dc477..3dfc72878591cd7472c68829c08de0253f410166 100644 (file)
--- a/lttv/modules/text/sync_chain_batch.c
+++ b/lttv/modules/text/sync_chain_batch.c
@@ -41,7 +41,7 @@
 #include <lttv/module.h>
 #include <lttv/option.h>
 #include <lttv/print.h>
-#include <lttv/sync/sync_chain_lttv.h>
+#include <lttv/sync/sync_chain.h>
 #include <ltt/ltt.h>
 #include <ltt/event.h>
 #include <ltt/trace.h>
@@ -303,14 +303,8 @@ void setupSyncChain(LttvTracesetContext* const traceSetContext)
                syncState->graphs= NULL;
        }
 
-       syncState->processingData= NULL;
-       result= g_queue_find_custom(&processingModules, "LTTV-standard",
-               &gcfCompareProcessing);
-       syncState->processingModule= (ProcessingModule*) result->data;
-
        tracesetChainState->graphsStream= NULL;
-       if (syncState->graphs &&
-               syncState->processingModule->writeProcessingGraphsPlots != NULL)
+       if (syncState->graphs)
        {
                char* cwd;
                int graphsFp;
@@ -338,18 +332,22 @@ void setupSyncChain(LttvTracesetContext* const traceSetContext)
                free(cwd);
        }
 
-       syncState->matchingData= NULL;
-       result= g_queue_find_custom(&matchingModules, "broadcast", &gcfCompareMatching);
-       syncState->matchingModule= (MatchingModule*) result->data;
-
        syncState->analysisData= NULL;
        result= g_queue_find_custom(&analysisModules, "eval",
                &gcfCompareAnalysis);
        syncState->analysisModule= (AnalysisModule*) result->data;
+       syncState->analysisModule->initAnalysis(syncState);
 
-       syncState->processingModule->initProcessing(syncState, traceSetContext);
+       syncState->matchingData= NULL;
+       result= g_queue_find_custom(&matchingModules, "broadcast", &gcfCompareMatching);
+       syncState->matchingModule= (MatchingModule*) result->data;
        syncState->matchingModule->initMatching(syncState);
-       syncState->analysisModule->initAnalysis(syncState);
+
+       syncState->processingData= NULL;
+       result= g_queue_find_custom(&processingModules, "LTTV-standard",
+               &gcfCompareProcessing);
+       syncState->processingModule= (ProcessingModule*) result->data;
+       syncState->processingModule->initProcessing(syncState, traceSetContext);
 }