From 6d7c70f3856810ee8ba082a042bdbea8c9d947a9 Mon Sep 17 00:00:00 2001 From: Chris Gioran Date: Mon, 15 Feb 2016 17:50:50 +0200 Subject: [PATCH] Fixes compilation errors from last merge --- .../java/org/neo4j/kernel/ha/TestFailover.java | 18 +++++++++++------- ...estFailoverWithAdditionalSlaveFailures.java | 15 +++++++++------ 2 files changed, 20 insertions(+), 13 deletions(-) diff --git a/enterprise/ha/src/test/java/org/neo4j/kernel/ha/TestFailover.java b/enterprise/ha/src/test/java/org/neo4j/kernel/ha/TestFailover.java index 40a65f2cf0c04..a6dc3ed37238d 100644 --- a/enterprise/ha/src/test/java/org/neo4j/kernel/ha/TestFailover.java +++ b/enterprise/ha/src/test/java/org/neo4j/kernel/ha/TestFailover.java @@ -41,7 +41,8 @@ public class TestFailover { @Rule public LoggerRule logger = new LoggerRule(); - public TargetDirectory dir = TargetDirectory.forTest( getClass() ); + @Rule + public TargetDirectory.TestDirectory dir = TargetDirectory.testDirForTest( getClass() ); // parameters private int clusterSize; @@ -65,10 +66,13 @@ public TestFailover( int clusterSize ) private void testFailOver( int clusterSize ) throws Throwable { // given - ClusterManager clusterManager = new ClusterManager( clusterOfSize( clusterSize ), dir.cleanDirectory( "failover" ), stringMap( - ClusterSettings.default_timeout.name(), "1", - ClusterSettings.heartbeat_interval.name(), "1", - ClusterSettings.heartbeat_timeout.name(), "2" ) ); + ClusterManager clusterManager = new ClusterManager.Builder().withRootDirectory( dir.cleanDirectory( "failover" ) ). + withProvider( ClusterManager.clusterOfSize( clusterSize ) ) + .withSharedConfig( stringMap( + ClusterSettings.default_timeout.name(), "1", + ClusterSettings.heartbeat_interval.name(), "1", + ClusterSettings.heartbeat_timeout.name(), "2" ) ) + .build(); clusterManager.start(); ClusterManager.ManagedCluster cluster = clusterManager.getDefaultCluster(); @@ -79,13 +83,13 @@ private void testFailOver( int clusterSize ) throws Throwable // When long start = System.nanoTime(); ClusterManager.RepairKit repairKit = cluster.fail( oldMaster ); - logger.getLogger().warn( "Shut down master" ); + logger.getLogger().warning( "Shut down master" ); // Then cluster.await( ClusterManager.masterAvailable( oldMaster ) ); long end = System.nanoTime(); - logger.getLogger().warn( "Failover took:" + (end - start) / 1000000 + "ms" ); + logger.getLogger().warning( "Failover took:" + (end - start) / 1000000 + "ms" ); repairKit.repair(); Thread.sleep( 3000 ); // give repaired instance chance to cleanly rejoin and exit faster diff --git a/enterprise/ha/src/test/java/org/neo4j/kernel/ha/TestFailoverWithAdditionalSlaveFailures.java b/enterprise/ha/src/test/java/org/neo4j/kernel/ha/TestFailoverWithAdditionalSlaveFailures.java index fb5f52af44930..78f1d89a62b04 100644 --- a/enterprise/ha/src/test/java/org/neo4j/kernel/ha/TestFailoverWithAdditionalSlaveFailures.java +++ b/enterprise/ha/src/test/java/org/neo4j/kernel/ha/TestFailoverWithAdditionalSlaveFailures.java @@ -45,7 +45,8 @@ public class TestFailoverWithAdditionalSlaveFailures { @Rule public LoggerRule logger = new LoggerRule(); - public TargetDirectory dir = TargetDirectory.forTest( getClass() ); + @Rule + public TargetDirectory.TestDirectory dir = TargetDirectory.testDirForTest( getClass() ); // parameters private int clusterSize; @@ -83,11 +84,13 @@ public void testFailoverWithAdditionalSlave() throws Throwable private void testFailoverWithAdditionalSlave( int clusterSize, int[] slaveIndexes ) throws Throwable { - ClusterManager manager = new ClusterManager( ClusterManager.clusterOfSize( clusterSize ), - TargetDirectory.forTest( getClass() ).cleanDirectory( "testCluster" ), stringMap( - ClusterSettings.default_timeout.name(), "1", - ClusterSettings.heartbeat_interval.name(), "1", - ClusterSettings.heartbeat_timeout.name(), "2" ) ); + ClusterManager manager = new ClusterManager.Builder().withRootDirectory( dir.cleanDirectory( "testcluster" ) ). + withProvider( ClusterManager.clusterOfSize( clusterSize ) ) + .withSharedConfig( stringMap( + ClusterSettings.default_timeout.name(), "1", + ClusterSettings.heartbeat_interval.name(), "1", + ClusterSettings.heartbeat_timeout.name(), "2" ) ) + .build(); try {