diff --git a/src/detect-engine.c b/src/detect-engine.c
index ce2d319d52..23341087fd 100644
--- a/src/detect-engine.c
+++ b/src/detect-engine.c
@@ -2278,7 +2278,7 @@ retry:
         if (SC_ATOMIC_GET(new_det_ctx[i]->so_far_used_by_detect) == 1) {
             SCLogDebug("new_det_ctx - %p used by detect engine", new_det_ctx[i]);
             threads_done++;
-        } else if (detect_tvs[i]->break_loop) {
+        } else {
             TmThreadsCaptureBreakLoop(detect_tvs[i]);
         }
     }
diff --git a/src/tm-threads.h b/src/tm-threads.h
index e547064bc4..76b1ce221e 100644
--- a/src/tm-threads.h
+++ b/src/tm-threads.h
@@ -255,9 +255,6 @@ static inline void TmThreadsCaptureHandleTimeout(ThreadVars *tv, Packet *p)
 
 static inline void TmThreadsCaptureBreakLoop(ThreadVars *tv)
 {
-    if (unlikely(!tv->break_loop))
-        return;
-
     if ((tv->tmm_flags & TM_FLAG_RECEIVE_TM) == 0) {
         return;
     }