rik/jlibredis
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix ClusterCommand tearDown as gossip may take some time to send data to nodes

Browse Source
This commit is contained in:
Marcos Nils
2014-01-14 17:58:21 -03:00
parent a09a682f09
commit ccf93714e6
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/test/java/redis/clients/jedis/tests/commands/ClusterCommandsTest.java
View File

@@ -9,6 +9,7 @@ import org.junit.Test;
import redis.clients.jedis.HostAndPort; import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.Jedis; import redis.clients.jedis.Jedis;
import redis.clients.jedis.exceptions.JedisDataException;
import redis.clients.jedis.tests.HostAndPortUtil; import redis.clients.jedis.tests.HostAndPortUtil;
import redis.clients.jedis.tests.JedisTestBase; import redis.clients.jedis.tests.JedisTestBase;
@@ -48,6 +49,11 @@ public class ClusterCommandsTest extends JedisTestBase {
node1.clusterDelSlots(5000, 10000); node1.clusterDelSlots(5000, 10000);
node1.clusterDelSlots(6000); node1.clusterDelSlots(6000);
node2.clusterDelSlots(6000,1,2,3,4,5,500,5000); node2.clusterDelSlots(6000,1,2,3,4,5,500,5000);
try {
node2.clusterDelSlots(10000);
} catch (JedisDataException jde) {
//Do nothing, slot may or may not be assigned depending on gossip
}
} }
private static void waitForEqualClusterSize() throws InterruptedException { private static void waitForEqualClusterSize() throws InterruptedException {