X-Git-Url: http://git.liburcu.org/?a=blobdiff_plain;f=lttv%2Flttv%2Fsync%2Fevent_matching_distributor.c;h=6ea6c0fd95f3c1add42284e69161448e0c1b742d;hb=2f961b65e3422f23019286e9531b0a40070278ea;hp=4523ec530ec5e7b00a46200decfd959194643ba0;hpb=8d7d16dd4f5f6ae09f556a9b0b477baaa93d468c;p=lttv.git

diff --git a/lttv/lttv/sync/event_matching_distributor.c b/lttv/lttv/sync/event_matching_distributor.c
index 4523ec53..6ea6c0fd 100644
--- a/lttv/lttv/sync/event_matching_distributor.c
+++ b/lttv/lttv/sync/event_matching_distributor.c
@@ -54,14 +54,20 @@ static void matchEventDistributor(SyncState* const syncState, Event* const
 	event);
 static GArray* finalizeMatchingDistributor(SyncState* const syncState);
 static void printMatchingStatsDistributor(SyncState* const syncState);
-static void writeMatchingGraphsPlotsDistributor(SyncState* const syncState,
-	const unsigned int i, const unsigned int j);
-static void writeMatchingGraphsOptionsDistributor(SyncState* const syncState,
-	const unsigned int i, const unsigned int j);
+static void writeMatchingTraceTraceForePlotsDistributor(SyncState* const
+	syncState, const unsigned int i, const unsigned int j);
+static void writeMatchingTraceTraceBackPlotsDistributor(SyncState* const
+	syncState, const unsigned int i, const unsigned int j);
+static void writeMatchingTraceTraceOptionsDistributor(SyncState* const
+	syncState, const unsigned int i, const unsigned int j);
+static void writeMatchingTraceTimeForePlotsDistributor(SyncState* const
+	syncState, const unsigned int i, const unsigned int j);
+static void writeMatchingTraceTimeBackPlotsDistributor(SyncState* const
+	syncState, const unsigned int i, const unsigned int j);
+static void writeMatchingTraceTimeOptionsDistributor(SyncState* const
+	syncState, const unsigned int i, const unsigned int j);
 
 // Functions specific to this module
-static void registerMatchingDistributor() __attribute__((constructor (101)));
-
 void gfInitModule(gpointer data, gpointer user_data);
 void gfDestroyModule(gpointer data, gpointer user_data);
 void gfMatchEvent(gpointer data, gpointer user_data);
@@ -79,15 +85,23 @@ static MatchingModule matchingModuleDistributor = {
 	.matchEvent= &matchEventDistributor,
 	.finalizeMatching= &finalizeMatchingDistributor,
 	.printMatchingStats= &printMatchingStatsDistributor,
-	.writeMatchingGraphsPlots= &writeMatchingGraphsPlotsDistributor,
-	.writeMatchingGraphsOptions= &writeMatchingGraphsOptionsDistributor,
+	.graphFunctions= {
+		.writeTraceTraceForePlots=
+			&writeMatchingTraceTraceForePlotsDistributor,
+		.writeTraceTraceBackPlots=
+			&writeMatchingTraceTraceBackPlotsDistributor,
+		.writeTraceTraceOptions= &writeMatchingTraceTraceOptionsDistributor,
+		.writeTraceTimeForePlots= &writeMatchingTraceTimeForePlotsDistributor,
+		.writeTraceTimeBackPlots= &writeMatchingTraceTimeBackPlotsDistributor,
+		.writeTraceTimeOptions= &writeMatchingTraceTimeOptionsDistributor,
+	},
 };
 
 
 /*
  * Matching module registering function
  */
-static void registerMatchingDistributor()
+void registerMatchingDistributor()
 {
 	g_queue_push_tail(&matchingModules, &matchingModuleDistributor);
 }
@@ -210,14 +224,90 @@ static void printMatchingStatsDistributor(SyncState* const syncState)
  *   i:            first trace number
  *   j:            second trace number, garanteed to be larger than i
  */
-static void writeMatchingGraphsPlotsDistributor(SyncState* const syncState,
+static void writeMatchingTraceTraceForePlotsDistributor(SyncState* const
+	syncState, const unsigned int i, const unsigned int j)
+{
+	MatchingDataDistributor* matchingData= syncState->matchingData;
+
+	g_queue_foreach(matchingData->distributedModules, &gfGraphFunctionCall,
+		&(struct GraphAggregate) {offsetof(MatchingModule,
+			graphFunctions.writeTraceTraceForePlots), i, j});
+}
+
+
+/*
+ * Call the distributed graph lines functions (when they exist).
+ *
+ * Args:
+ *   syncState:    container for synchronization data
+ *   i:            first trace number
+ *   j:            second trace number, garanteed to be larger than i
+ */
+static void writeMatchingTraceTraceBackPlotsDistributor(SyncState* const
+	syncState, const unsigned int i, const unsigned int j)
+{
+	MatchingDataDistributor* matchingData= syncState->matchingData;
+
+	g_queue_foreach(matchingData->distributedModules, &gfGraphFunctionCall,
+		&(struct GraphAggregate) {offsetof(MatchingModule,
+			graphFunctions.writeTraceTraceBackPlots), i, j});
+}
+
+
+/*
+ * Call the distributed graph lines functions (when they exist).
+ *
+ * Args:
+ *   syncState:    container for synchronization data
+ *   i:            first trace number
+ *   j:            second trace number, garanteed to be larger than i
+ */
+static void writeMatchingTraceTimeForePlotsDistributor(SyncState* const
+	syncState, const unsigned int i, const unsigned int j)
+{
+	MatchingDataDistributor* matchingData= syncState->matchingData;
+
+	g_queue_foreach(matchingData->distributedModules, &gfGraphFunctionCall,
+		&(struct GraphAggregate) {offsetof(MatchingModule,
+			graphFunctions.writeTraceTimeForePlots), i, j});
+}
+
+
+/*
+ * Call the distributed graph lines functions (when they exist).
+ *
+ * Args:
+ *   syncState:    container for synchronization data
+ *   i:            first trace number
+ *   j:            second trace number, garanteed to be larger than i
+ */
+static void writeMatchingTraceTimeBackPlotsDistributor(SyncState* const
+	syncState, const unsigned int i, const unsigned int j)
+{
+	MatchingDataDistributor* matchingData= syncState->matchingData;
+
+	g_queue_foreach(matchingData->distributedModules, &gfGraphFunctionCall,
+		&(struct GraphAggregate) {offsetof(MatchingModule,
+			graphFunctions.writeTraceTimeBackPlots), i, j});
+}
+
+
+/*
+ * Call the distributed graph options functions (when they exist).
+ *
+ * Args:
+ *   syncState:    container for synchronization data
+ *   i:            first trace number
+ *   j:            second trace number, garanteed to be larger than i
+ */
+static void writeMatchingTraceTraceOptionsDistributor(SyncState* const syncState,
 	const unsigned int i, const unsigned int j)
 {
 	MatchingDataDistributor* matchingData= syncState->matchingData;
 
 	g_queue_foreach(matchingData->distributedModules, &gfGraphFunctionCall,
 		&(struct GraphAggregate) {offsetof(MatchingModule,
-			writeMatchingGraphsPlots), i, j});
+			graphFunctions.writeTraceTraceOptions), i, j});
 }
 
 
@@ -229,14 +319,14 @@ static void writeMatchingGraphsPlotsDistributor(SyncState* const syncState,
  *   i:            first trace number
  *   j:            second trace number, garanteed to be larger than i
  */
-static void writeMatchingGraphsOptionsDistributor(SyncState* const syncState,
+static void writeMatchingTraceTimeOptionsDistributor(SyncState* const syncState,
 	const unsigned int i, const unsigned int j)
 {
 	MatchingDataDistributor* matchingData= syncState->matchingData;
 
 	g_queue_foreach(matchingData->distributedModules, &gfGraphFunctionCall,
 		&(struct GraphAggregate) {offsetof(MatchingModule,
-			writeMatchingGraphsOptions), i, j});
+			graphFunctions.writeTraceTimeOptions), i, j});
 }
 
 
@@ -356,8 +446,10 @@ void gfGraphFunctionCall(gpointer data, gpointer user_data)
 {
 	SyncState* parallelSS= data;
 	struct GraphAggregate* aggregate= user_data;
-	void (*graphFunction)(struct _SyncState*, const unsigned int, const
-		unsigned int)= (void*) data + (size_t) aggregate->offset;
+	typedef void (*GraphFunction)(struct _SyncState*, const unsigned int,
+		const unsigned int);
+	GraphFunction graphFunction= *(GraphFunction*)((void*)
+		parallelSS->matchingModule + (size_t) aggregate->offset);
 
 	if (graphFunction != NULL)
 	{