projects
/
lttv.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Adds wall time field to events
[lttv.git]
/
lttv
/
lttv
/
sync
/
event_matching_tcp.c
diff --git
a/lttv/lttv/sync/event_matching_tcp.c
b/lttv/lttv/sync/event_matching_tcp.c
index 25e39858fb8b36c76c19c11bcd0efe5d64a5ba09..a8fdf5f007683630abfb967c0e29ac1a7889ad9f 100644
(file)
--- a/
lttv/lttv/sync/event_matching_tcp.c
+++ b/
lttv/lttv/sync/event_matching_tcp.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_tcp.h"
#include "event_matching_tcp.h"
@@
-69,6
+69,8
@@
static void writeMessagePoint(FILE* stream, const Message* const message);
static MatchingModule matchingModuleTCP = {
.name= "TCP",
static MatchingModule matchingModuleTCP = {
.name= "TCP",
+ .canMatch[TCP]= true,
+ .canMatch[UDP]= false,
.initMatching= &initMatchingTCP,
.destroyMatching= &destroyMatchingTCP,
.matchEvent= &matchEventTCP,
.initMatching= &initMatchingTCP,
.destroyMatching= &destroyMatchingTCP,
.matchEvent= &matchEventTCP,
@@
-231,12
+233,13
@@
static void partialDestroyMatchingTCP(SyncState* const syncState)
* Args:
* syncState container for synchronization data.
* event new event to match
* Args:
* syncState container for synchronization data.
* event new event to match
- * eventType type of event to match
*/
static void matchEventTCP(SyncState* const syncState, Event* const event)
{
MatchingDataTCP* matchingData;
*/
static void matchEventTCP(SyncState* const syncState, Event* const event)
{
MatchingDataTCP* matchingData;
+ g_assert(event->type == TCP);
+
matchingData= (MatchingDataTCP*) syncState->matchingData;
if (event->event.tcpEvent->direction == IN)
matchingData= (MatchingDataTCP*) syncState->matchingData;
if (event->event.tcpEvent->direction == IN)
@@
-643,14
+646,14
@@
static void writeMessagePoint(FILE* stream, const Message* const message)
if (message->inE->traceNum < message->outE->traceNum)
{
// CA is inE->traceNum
if (message->inE->traceNum < message->outE->traceNum)
{
// CA is inE->traceNum
- x= message->inE->
t
ime;
- y= message->outE->
t
ime;
+ x= message->inE->
cpuT
ime;
+ y= message->outE->
cpuT
ime;
}
else
{
// CA is outE->traceNum
}
else
{
// CA is outE->traceNum
- x= message->outE->
t
ime;
- y= message->inE->
t
ime;
+ x= message->outE->
cpuT
ime;
+ y= message->inE->
cpuT
ime;
}
fprintf(stream, "%20llu %20llu\n", x, y);
}
fprintf(stream, "%20llu %20llu\n", x, y);
This page took
0.024313 seconds
and
4
git commands to generate.