Merge pull request #9930 from klaren/3.3-stop-stream-on-dead

Test another hypothesis for serverStopsStreamingToDeadClient flakiness
neo4j · Aug 30, 2017 · e9a1b18 · e9a1b18
2 parents 5f075d5 + 328bdd8
commit e9a1b18
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/enterprise/com/src/test/java/org/neo4j/com/MadeUpServer.java b/enterprise/com/src/test/java/org/neo4j/com/MadeUpServer.java
@@ -38,7 +38,7 @@ public class MadeUpServer extends Server<MadeUpCommunicationInterface, Void>
     private volatile boolean responseWritten;
     private volatile boolean responseFailureEncountered;
     private final byte internalProtocolVersion;
-    public static final int FRAME_LENGTH = 1024 * 1024 * 1;
+    public static final int FRAME_LENGTH = 1024 * 1024;
 
     public MadeUpServer( MadeUpCommunicationInterface requestTarget, final int port, byte internalProtocolVersion,
                          byte applicationProtocolVersion, TxChecksumVerifier txVerifier, final int chunkSize )

diff --git a/enterprise/com/src/test/java/org/neo4j/com/TestCommunication.java b/enterprise/com/src/test/java/org/neo4j/com/TestCommunication.java
@@ -276,11 +276,11 @@ public void serverStopsStreamingToDeadClient() throws Throwable
         MadeUpClient client = builder.client();
         addToLifeAndStart( server, client );
 
-        int failAtSize = FRAME_LENGTH / 2;
+        int failAtSize = FRAME_LENGTH / 1024;
         ClientCrashingWriter writer = new ClientCrashingWriter( client, failAtSize );
         try
         {
-            client.fetchDataStream( writer, FRAME_LENGTH * 10 );
+            client.fetchDataStream( writer, FRAME_LENGTH * 100 );
             assertTrue( writer.getSizeRead() >= failAtSize );
             fail( "Should fail in the middle" );
         }