stream: add util to get absolute right edge of data

diff --git a/src/stream-tcp-reassemble.c b/src/stream-tcp-reassemble.c
index e647aaa6ecda6664e1a85de9d402f6b3817ea87a..662045d8ad032452d867dfa4a26b76c531f37430 100644 (file)
--- a/src/stream-tcp-reassemble.c
+++ b/src/stream-tcp-reassemble.c
@@ -411,6 +411,16 @@ uint64_t StreamTcpGetAcked(const TcpStream *stream)
     return GetAbsLastAck(stream);
 }
 
+// may contain gaps
+uint64_t StreamDataRightEdge(const TcpStream *stream, const bool eof)
+{
+    uint64_t right_edge = STREAM_BASE_OFFSET(stream) + stream->segs_right_edge - stream->base_seq;
+    if (!eof && StreamTcpInlineMode() == FALSE) {
+        right_edge = MIN(GetAbsLastAck(stream), right_edge);
+    }
+    return right_edge;
+}
+
 uint64_t StreamTcpGetUsable(const TcpStream *stream, const bool eof)
 {
     uint64_t right_edge = StreamingBufferGetConsecutiveDataRightEdge(&stream->sb);

diff --git a/src/stream-tcp.h b/src/stream-tcp.h
index 3a4b0e9e57fc4927e7ebeb4c59d14a3e14d3ca2e..ad26779f6dbf76d22f76c8aa2ee543557b99ae78 100644 (file)
--- a/src/stream-tcp.h
+++ b/src/stream-tcp.h
@@ -212,6 +212,7 @@ void StreamTcpUpdateAppLayerProgress(TcpSession *ssn, char direction,
 
 uint64_t StreamTcpGetAcked(const TcpStream *stream);
 uint64_t StreamTcpGetUsable(const TcpStream *stream, const bool eof);
+uint64_t StreamDataRightEdge(const TcpStream *stream, const bool eof);
 
 void StreamTcpThreadCacheEnable(void);
 void StreamTcpThreadCacheCleanup(void);