integration_cluster.rb - term_closes_listeners - add interleave asserts

test/test_integration_cluster.rb

@@ -147,8 +147,23 @@ def term_closes_listeners(unix: false)
     threads.each(&:join)
 
     responses = replies.count { |r| r[/\ASlept 1/] }
-    resets    = replies.count { |r| r == :reset    }
-    refused   = replies.count { |r| r == :refused  }
+    resets    = replies.count(:reset)
+    refused   = replies.count(:refused)
+
+    r_responses = replies.rindex { |i| i[/\ASlept 1/] }
+    l_resets    = replies.index(:reset)
+    r_resets    = replies.rindex(:reset)
+    l_refused   = replies.index(:refused)
+
+    if l_resets
+      assert_equal(r_responses + 1, l_resets, "Interleaved responses & resets")
+      if l_refused
+        assert_equal(r_resets + 1, l_refused, "Interleaved resets & refused")
+      end
+    else
+      assert_equal(r_responses + 1, l_refused, "Interleaved responses & refused")
+    end
+
     msg = "#{responses} responses, #{resets} resets, #{refused} refused"
 
     $debugging_info << "#{full_name}\n    #{msg}\n"