aboutsummaryrefslogtreecommitdiff
path: root/example/reader_util.c
diff options
context:
space:
mode:
authorLuca Deri <deri@ntop.org>2019-11-21 13:31:56 +0100
committerLuca Deri <deri@ntop.org>2019-11-21 13:31:56 +0100
commita58c838c4c579ee298ec617bb9322876d6a6dac5 (patch)
tree34cf7df9e843681db2ebacf06f61a8cf0f918204 /example/reader_util.c
parentf91f2c57ef75bbb2206440edd6e2156731d6f56a (diff)
Added flow duration and goodput in output (-v and -c)
Diffstat (limited to 'example/reader_util.c')
-rw-r--r--example/reader_util.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/example/reader_util.c b/example/reader_util.c
index 6c7dcdb46..2b9c6cdf4 100644
--- a/example/reader_util.c
+++ b/example/reader_util.c
@@ -1138,7 +1138,7 @@ static struct ndpi_proto packet_processing(struct ndpi_workflow * workflow,
}
ndpi_data_add_value(flow->pktlen_c_to_s, rawsize);
- flow->src2dst_packets++, flow->src2dst_bytes += rawsize;
+ flow->src2dst_packets++, flow->src2dst_bytes += rawsize, flow->src2dst_goodput_bytes += payload_len;
memcpy(&flow->entropy.src2dst_last_pkt_time, &when, sizeof(when));
} else {
if(flow->entropy.dst2src_last_pkt_time.tv_sec && (!begin_or_end_tcp)) {
@@ -1152,7 +1152,7 @@ static struct ndpi_proto packet_processing(struct ndpi_workflow * workflow,
}
ndpi_data_add_value(flow->pktlen_s_to_c, rawsize);
- flow->dst2src_packets++, flow->dst2src_bytes += rawsize;
+ flow->dst2src_packets++, flow->dst2src_bytes += rawsize, flow->dst2src_goodput_bytes += payload_len;
memcpy(&flow->entropy.dst2src_last_pkt_time, &when, sizeof(when));
}