X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=lttv%2Flttv%2Fsync%2Fsync_chain_lttv.c;h=cd8532a990c5eed3ff640dc19ec807fedb3dd17a;hb=d4721e1a5216f34570d7e10257f85601cb3991bc;hp=9652f346328da0f6138f10bed0107ecbe1a82468;hpb=76be6fc24daf61767bf7f0c2e64f4691fbb56c63;p=lttv.git diff --git a/lttv/lttv/sync/sync_chain_lttv.c b/lttv/lttv/sync/sync_chain_lttv.c index 9652f346..cd8532a9 100644 --- a/lttv/lttv/sync/sync_chain_lttv.c +++ b/lttv/lttv/sync/sync_chain_lttv.c @@ -206,24 +206,8 @@ void syncTraceset(LttvTracesetContext* const traceSetContext) syncState->graphs= NULL; } - // Identify and initialize processing module - syncState->processingData= NULL; - if (optionSyncNull.present) - { - result= g_queue_find_custom(&processingModules, "LTTV-null", - &gcfCompareProcessing); - } - else - { - result= g_queue_find_custom(&processingModules, "LTTV-standard", - &gcfCompareProcessing); - } - g_assert(result != NULL); - syncState->processingModule= (ProcessingModule*) result->data; - graphsStream= NULL; - if (syncState->graphs && - syncState->processingModule->writeProcessingGraphsPlots != NULL) + if (syncState->graphs) { char* cwd; int graphsFp; @@ -251,11 +235,27 @@ void syncTraceset(LttvTracesetContext* const traceSetContext) free(cwd); } - // Identify matching and analysis modules + // Identify and initialize modules + syncState->processingData= NULL; + if (optionSyncNull.present) + { + result= g_queue_find_custom(&processingModules, "LTTV-null", + &gcfCompareProcessing); + } + else + { + result= g_queue_find_custom(&processingModules, "LTTV-standard", + &gcfCompareProcessing); + } + g_assert(result != NULL); + syncState->processingModule= (ProcessingModule*) result->data; + + syncState->matchingData= NULL; result= g_queue_find_custom(&matchingModules, "TCP", &gcfCompareMatching); g_assert(result != NULL); syncState->matchingModule= (MatchingModule*) result->data; + syncState->analysisData= NULL; result= g_queue_find_custom(&analysisModules, optionSyncAnalysis.arg, &gcfCompareAnalysis); if (result != NULL) @@ -267,16 +267,12 @@ void syncTraceset(LttvTracesetContext* const traceSetContext) g_error("Analysis module '%s' not found", optionSyncAnalysis.arg); } - syncState->processingModule->initProcessing(syncState, traceSetContext); - - syncState->matchingData= NULL; - syncState->analysisData= NULL; - if (!optionSyncNull.present) { - syncState->matchingModule->initMatching(syncState); syncState->analysisModule->initAnalysis(syncState); + syncState->matchingModule->initMatching(syncState); } + syncState->processingModule->initProcessing(syncState, traceSetContext); // Process traceset lttv_process_traceset_seek_time(traceSetContext, ltt_time_zero);