From 4a4768b1d2dca39c9a31decb7206ef72c7332e4e Mon Sep 17 00:00:00 2001 From: Jonathan Leibiusky Date: Tue, 3 Dec 2013 19:03:19 -0500 Subject: [PATCH] speed up JedisSentinelTest --- Makefile | 1 + .../jedis/tests/JedisSentinelTest.java | 33 +++++++------------ .../tests/commands/ListCommandsTest.java | 2 -- 3 files changed, 13 insertions(+), 23 deletions(-) diff --git a/Makefile b/Makefile index 6df68af..da91267 100644 --- a/Makefile +++ b/Makefile @@ -60,6 +60,7 @@ pidfile /tmp/redis6.pid logfile /tmp/redis6.log save "" appendonly no +slaveof localhost 6379 endef define REDIS_SENTINEL1 diff --git a/src/test/java/redis/clients/jedis/tests/JedisSentinelTest.java b/src/test/java/redis/clients/jedis/tests/JedisSentinelTest.java index 8912a1c..f8267c8 100644 --- a/src/test/java/redis/clients/jedis/tests/JedisSentinelTest.java +++ b/src/test/java/redis/clients/jedis/tests/JedisSentinelTest.java @@ -1,6 +1,5 @@ package redis.clients.jedis.tests; -import java.util.ArrayList; import java.util.List; import java.util.Map; @@ -10,15 +9,14 @@ import org.junit.Test; import redis.clients.jedis.HostAndPort; import redis.clients.jedis.Jedis; -import redis.clients.jedis.tests.utils.JedisSentinelTestUtil; public class JedisSentinelTest extends JedisTestBase { private static final String MASTER_NAME = "mymaster"; protected static HostAndPort master = HostAndPortUtil.getRedisServers() .get(0); - protected static HostAndPort slave = HostAndPortUtil.getRedisServers() - .get(5); + protected static HostAndPort slave = HostAndPortUtil.getRedisServers().get( + 5); protected static HostAndPort sentinel = HostAndPortUtil .getSentinelServers().get(0); @@ -28,25 +26,16 @@ public class JedisSentinelTest extends JedisTestBase { @Before public void setup() throws InterruptedException { - masterJedis = new Jedis(master.getHost(), master.getPort()); - slaveJedis = new Jedis(slave.getHost(), slave.getPort()); - slaveJedis.auth("foobared"); - slaveJedis.configSet("masterauth", "foobared"); - slaveJedis.slaveof(master.getHost(), master.getPort()); - - List slaves = new ArrayList(); - slaves.add(slave); - - JedisSentinelTestUtil.waitForSentinelRecognizeRedisReplication( - sentinel, MASTER_NAME, master, slaves); } @After public void clear() throws InterruptedException { - // New Sentinel (after 2.8.1) - // when slave promoted to master (slave of no one), New Sentinel force to restore it (demote) - // so, promote(slaveof) slave to master has no effect, not same to old Sentinel's behavior + // New Sentinel (after 2.8.1) + // when slave promoted to master (slave of no one), New Sentinel force + // to restore it (demote) + // so, promote(slaveof) slave to master has no effect, not same to old + // Sentinel's behavior } @Test @@ -59,13 +48,15 @@ public class JedisSentinelTest extends JedisTestBase { List masterHostAndPort = j .sentinelGetMasterAddrByName(masterName); - HostAndPort masterFromSentinel = new HostAndPort(masterHostAndPort.get(0), - Integer.parseInt(masterHostAndPort.get(1))); + HostAndPort masterFromSentinel = new HostAndPort( + masterHostAndPort.get(0), Integer.parseInt(masterHostAndPort + .get(1))); assertEquals(master, masterFromSentinel); List> slaves = j.sentinelSlaves(masterName); assertTrue(slaves.size() > 0); - assertEquals(master.getPort(), Integer.parseInt(slaves.get(0).get("master-port"))); + assertEquals(master.getPort(), + Integer.parseInt(slaves.get(0).get("master-port"))); // DO NOT RE-RUN TEST TOO FAST, RESET TAKES SOME TIME TO... RESET assertEquals(Long.valueOf(1), j.sentinelReset(masterName)); diff --git a/src/test/java/redis/clients/jedis/tests/commands/ListCommandsTest.java b/src/test/java/redis/clients/jedis/tests/commands/ListCommandsTest.java index d5fa0b6..296877b 100644 --- a/src/test/java/redis/clients/jedis/tests/commands/ListCommandsTest.java +++ b/src/test/java/redis/clients/jedis/tests/commands/ListCommandsTest.java @@ -423,7 +423,6 @@ public class ListCommandsTest extends JedisCommandTestBase { jedis.lpush("foo", "bar"); result = jedis.blpop(1, "foo"); - System.out.println("lalalala"); assertNotNull(result); assertEquals(2, result.size()); @@ -433,7 +432,6 @@ public class ListCommandsTest extends JedisCommandTestBase { // Binary jedis.lpush(bfoo, bbar); List bresult = jedis.blpop(1, bfoo); - System.out.println("lalalala"); assertNotNull(bresult); assertEquals(2, bresult.size());