projects
/
lttv.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
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 <unistd.h>
#include "event_analysis.h"
-#include "sync_chain
_lttv
.h"
+#include "sync_chain.h"
#include "event_matching_broadcast.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)
{
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);
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);
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
}
}
else
@@
-288,7
+299,6
@@
static void printMatchingStatsBroadcast(SyncState* const syncState)
{
return;
}
{
return;
}
-
matchingData= (MatchingDataBroadcast*) syncState->matchingData;
printf("Broadcast matching stats:\n");
matchingData= (MatchingDataBroadcast*) syncState->matchingData;
printf("Broadcast matching stats:\n");
This page took
0.024403 seconds
and
4
git commands to generate.