X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=lttv%2Flttv%2Fsync%2Fevent_processing_lttv_standard.c;h=f67ab107f0aa7df280314ea50cce503430e1b6b0;hb=85c9417b6ebc1e1cd25d479389c91926eb6948dc;hp=cef9f2b970f2a5f8712bb6b7355045ae931ff76a;hpb=70407e861d8430dbe06cc52e6fe4ed5c9cd0872a;p=lttv.git diff --git a/lttv/lttv/sync/event_processing_lttv_standard.c b/lttv/lttv/sync/event_processing_lttv_standard.c index cef9f2b9..f67ab107 100644 --- a/lttv/lttv/sync/event_processing_lttv_standard.c +++ b/lttv/lttv/sync/event_processing_lttv_standard.c @@ -461,7 +461,7 @@ static gboolean processEventLTTVStandard(void* hookData, void* callData) lttv_trace_get_hook_field(traceHook, 0)); inE->packetKey= NULL; - g_hash_table_insert(processingData->pendingRecv[traceNum], + g_hash_table_replace(processingData->pendingRecv[traceNum], inE->skb, inE); g_debug("Adding inE %p for skb %p to pendingRecv\n", inE, inE->skb); @@ -531,27 +531,6 @@ static gboolean processEventLTTVStandard(void* hookData, void* callData) g_debug("Input event %p for skb %p done\n", inE, skb); } } - else if (info->name == LTT_EVENT_PKFREE_SKB) - { - gboolean result; - void* skb; - - // Search pendingRecv for an event with the same skb - skb= (void*) (long) ltt_event_get_long_unsigned(event, - lttv_trace_get_hook_field(traceHook, 0)); - - result= g_hash_table_remove(processingData->pendingRecv[traceNum], - skb); - if (result == FALSE) - { - g_debug("No matching pending receive event found, \"shaddow" - "skb\" %p\n", skb); - } - else - { - g_debug("Non-TCP skb %p\n", skb); - } - } else if (info->name == LTT_EVENT_NETWORK_IPV4_INTERFACE) { char* name;