Sync cluster before asserting

neo4j · Sep 5, 2016 · b0ef390 · b0ef390
1 parent b9689b4
commit b0ef390
Showing 1 changed file with 11 additions and 12 deletions.
diff --git a/enterprise/ha/src/test/java/org/neo4j/kernel/ha/TestBasicHaOperations.java b/enterprise/ha/src/test/java/org/neo4j/kernel/ha/TestBasicHaOperations.java
@@ -42,8 +42,7 @@ public class TestBasicHaOperations
     @ClassRule
     public static LoggerRule logger = new LoggerRule( Level.OFF );
     @Rule
-    public ClusterRule clusterRule = new ClusterRule( getClass() )
-            .withSharedSetting( HaSettings.tx_push_factor, "2" );
+    public ClusterRule clusterRule = new ClusterRule( getClass() ).withSharedSetting( HaSettings.tx_push_factor, "2" );
 
     @Test
     public void testBasicFailover() throws Throwable
@@ -134,21 +133,21 @@ public void testBasicPropagationFromMasterToSlave() throws Throwable
             tx.success();
         }
 
+        cluster.sync();
+
         // No need to wait, the push factor is 2
         HighlyAvailableGraphDatabase slave1 = cluster.getAnySlave();
-        String value;
-        try ( Transaction tx = slave1.beginTx() )
-        {
-            value = slave1.getNodeById( nodeId ).getProperty( "Hello" ).toString();
-            logger.getLogger().info( "Hello=" + value );
-            assertEquals( "World", value );
-            tx.success();
-        }
+        checkNodeOnSlave( nodeId, slave1 );
 
-        HighlyAvailableGraphDatabase slave2 = cluster.getAnySlave(slave1);
+        HighlyAvailableGraphDatabase slave2 = cluster.getAnySlave( slave1 );
+        checkNodeOnSlave( nodeId, slave2 );
+    }
+
+    private void checkNodeOnSlave( long nodeId, HighlyAvailableGraphDatabase slave2 )
+    {
         try ( Transaction tx = slave2.beginTx() )
         {
-            value = slave2.getNodeById( nodeId ).getProperty( "Hello" ).toString();
+            String value = slave2.getNodeById( nodeId ).getProperty( "Hello" ).toString();
             logger.getLogger().info( "Hello=" + value );
             assertEquals( "World", value );
             tx.success();