Add support for module options

[lttv.git] / lttv / lttv / sync / event_matching_broadcast.c

diff --git a/lttv/lttv/sync/event_matching_broadcast.c b/lttv/lttv/sync/event_matching_broadcast.c
index 9eb6e10861ef5ada8f5e6dcfd03a4a00c220230c..3db88e582251be8323ad830888ac08bdb98b71b0 100644 (file)
--- a/lttv/lttv/sync/event_matching_broadcast.c
+++ b/lttv/lttv/sync/event_matching_broadcast.c
@@ -26,7 +26,7 @@
 #include <unistd.h>
 
 #include "event_analysis.h"
-#include "sync_chain_lttv.h"
+#include "sync_chain.h"
 
 #include "event_matching_broadcast.h"
 
@@ -215,6 +215,11 @@ static void matchEventBroadcast(SyncState* const syncState, Event* const event)
                                g_queue_push_tail(broadcast->events, event);
                                if (broadcast->events->length == syncState->traceNb)
                                {
+                                       if (matchingData->stats)
+                                       {
+                                               matchingData->stats->totComplete++;
+                                       }
+
                                        g_hash_table_steal(matchingData->pendingBroadcasts, datagramKey);
                                        free(datagramKey);
                                        syncState->analysisModule->analyzeBroadcast(syncState, broadcast);
@@ -226,6 +231,12 @@ static void matchEventBroadcast(SyncState* const syncState, Event* const event)
                                broadcast= malloc(sizeof(Broadcast));
                                broadcast->events= g_queue_new();
                                g_queue_push_tail(broadcast->events, event);
+
+                               datagramKey= malloc(sizeof(DatagramKey));
+                               *datagramKey= *event->event.udpEvent->datagramKey;
+
+                               g_hash_table_insert(matchingData->pendingBroadcasts,
+                                       datagramKey, broadcast);
                        }
                }
                else
@@ -288,7 +299,6 @@ static void printMatchingStatsBroadcast(SyncState* const syncState)
        {
                return;
        }
-
        matchingData= (MatchingDataBroadcast*) syncState->matchingData;
 
        printf("Broadcast matching stats:\n");