stream: move state queue code into util func

diff --git a/src/stream-tcp.c b/src/stream-tcp.c
index 6fe7c61426171a4b4c935f3a228b4e1806ad093a..9d57789a410327369d1038bf2b7ee1a99f6ced3a 100644 (file)
--- a/src/stream-tcp.c
+++ b/src/stream-tcp.c
@@ -204,6 +204,20 @@ void StreamTcpStreamCleanup(TcpStream *stream)
     }
 }
 
+static void StreamTcp3wsFreeQueue(TcpSession *ssn)
+{
+    TcpStateQueue *q, *q_next;
+    q = ssn->queue;
+    while (q != NULL) {
+        q_next = q->next;
+        SCFree(q);
+        q = q_next;
+        StreamTcpDecrMemuse((uint64_t)sizeof(TcpStateQueue));
+    }
+    ssn->queue = NULL;
+    ssn->queue_len = 0;
+}
+
 /**
  *  \brief Session cleanup function. Does not free the ssn.
  *  \param ssn tcp session
@@ -211,23 +225,13 @@ void StreamTcpStreamCleanup(TcpStream *stream)
 void StreamTcpSessionCleanup(TcpSession *ssn)
 {
     SCEnter();
-    TcpStateQueue *q, *q_next;
 
     if (ssn == NULL)
         return;
 
     StreamTcpStreamCleanup(&ssn->client);
     StreamTcpStreamCleanup(&ssn->server);
-
-    q = ssn->queue;
-    while (q != NULL) {
-        q_next = q->next;
-        SCFree(q);
-        q = q_next;
-        StreamTcpDecrMemuse((uint64_t)sizeof(TcpStateQueue));
-    }
-    ssn->queue = NULL;
-    ssn->queue_len = 0;
+    StreamTcp3wsFreeQueue(ssn);
 
     SCReturn;
 }