diff --git a/src/stream-tcp.c b/src/stream-tcp.c index bfa15caf3d..c25978e079 100644 --- a/src/stream-tcp.c +++ b/src/stream-tcp.c @@ -921,6 +921,7 @@ static int StreamTcpPacketStateNone(ThreadVars *tv, Packet *p, return -1; } StatsIncr(tv, stt->counter_tcp_sessions); + StatsIncr(tv, stt->counter_tcp_midstream_pickups); } /* set the state */ StreamTcpPacketSetState(p, ssn, TCP_SYN_RECV); @@ -1065,6 +1066,7 @@ static int StreamTcpPacketStateNone(ThreadVars *tv, Packet *p, return -1; } StatsIncr(tv, stt->counter_tcp_sessions); + StatsIncr(tv, stt->counter_tcp_midstream_pickups); } /* set the state */ StreamTcpPacketSetState(p, ssn, TCP_ESTABLISHED); @@ -5040,6 +5042,7 @@ TmEcode StreamTcpThreadInit(ThreadVars *tv, void *initdata, void **data) stt->counter_tcp_syn = StatsRegisterCounter("tcp.syn", tv); stt->counter_tcp_synack = StatsRegisterCounter("tcp.synack", tv); stt->counter_tcp_rst = StatsRegisterCounter("tcp.rst", tv); + stt->counter_tcp_midstream_pickups = StatsRegisterCounter("tcp.midstream_pickups", tv); /* init reassembly ctx */ stt->ra_ctx = StreamTcpReassembleInitThreadCtx(tv); diff --git a/src/stream-tcp.h b/src/stream-tcp.h index 16c6b455b7..4c06d93b38 100644 --- a/src/stream-tcp.h +++ b/src/stream-tcp.h @@ -94,6 +94,8 @@ typedef struct StreamTcpThread_ { uint16_t counter_tcp_synack; /** rst pkts */ uint16_t counter_tcp_rst; + /** midstream pickups */ + uint16_t counter_tcp_midstream_pickups; /** tcp reassembly thread data */ TcpReassemblyThreadCtx *ra_ctx;