temporary workaround for an intermittent test

real-logic · Sep 14, 2023 · 95fc44a · 95fc44a
1 parent f7bcea7
commit 95fc44a
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/...ests/src/test/java/uk/co/real_logic/artio/system_tests/ConnectAfterTimeoutSystemTest.java b/...ests/src/test/java/uk/co/real_logic/artio/system_tests/ConnectAfterTimeoutSystemTest.java
@@ -98,7 +98,7 @@ public void testConnectingAfterConnectionTimeouts()
         assertEquals(Reply.State.TIMED_OUT, secondConnectReply.state());
 
         // Make connections work again
-        debugTcpChannelSupplier.unpauseConnects();
+        debugTcpChannelSupplier.unpauseAndDiscardConnects();
 
         // Now it should connect
         connectSessions();

diff --git a/...stem-tests/src/test/java/uk/co/real_logic/artio/system_tests/DebugTcpChannelSupplier.java b/...stem-tests/src/test/java/uk/co/real_logic/artio/system_tests/DebugTcpChannelSupplier.java
@@ -108,6 +108,12 @@ public synchronized void unpauseConnects()
         connectsPaused = false;
     }
 
+    public synchronized void unpauseAndDiscardConnects()
+    {
+        connectsPaused = false;
+        pausedOperations.clear();
+    }
+
     protected void onFinishConnect(
         final InitiatedChannelHandler channelHandler, final SocketChannel channel) throws IOException
     {