threading: fix flow timeout loop race

diff --git a/src/tm-threads.c b/src/tm-threads.c
index 9d5105a6ef5d6685f72d841a6afd0eb961f1d606..bd1a856988d06b49731fc716dbcd57e91bc92909 100644 (file)
--- a/src/tm-threads.c
+++ b/src/tm-threads.c
@@ -217,12 +217,11 @@ static int TmThreadTimeoutLoop(ThreadVars *tv, TmSlot *s)
                 }
             }
         } else {
+            if (TmThreadsCheckFlag(tv, THV_KILL)) {
+                break;
+            }
             SleepUsec(1);
         }
-
-        if (tv->stream_pq->len == 0 && TmThreadsCheckFlag(tv, THV_KILL)) {
-            break;
-        }
     }
     SCLogDebug("flow end loop complete");