rdev/gossip-revisited
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Lower test time

Browse Source
This commit is contained in:
Edward Capriolo
2015-01-10 15:11:40 -05:00
parent 980e3f51e9
commit d2ad190b93
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/test/java/io/teknek/gossip/TenNodeThreeSeedTest.java
View File

@ -25,17 +25,17 @@ public class TenNodeThreeSeedTest {
startupMembers.add(new RemoteGossipMember("127.0.0." + i, 2000)); startupMembers.add(new RemoteGossipMember("127.0.0." + i, 2000));
} }
ArrayList<GossipService> clients = new ArrayList<GossipService>(); ArrayList<GossipService> clients = new ArrayList<GossipService>();
int clusterMembers = 10; int clusterMembers = 5;
for (int i = 1; i < clusterMembers+1; ++i) { for (int i = 1; i < clusterMembers+1; ++i) {
GossipService gossipService = new GossipService("127.0.0."+i, 2000, LogLevel.DEBUG, startupMembers, settings); GossipService gossipService = new GossipService("127.0.0."+i, 2000, LogLevel.DEBUG, startupMembers, settings);
clients.add(gossipService); clients.add(gossipService);
gossipService.start(); gossipService.start();
Thread.sleep(settings.getCleanupInterval() + 1000); Thread.sleep(1000);
} }
Thread.sleep(10000); Thread.sleep(10000);
for (int i = 0; i < clusterMembers; ++i) { for (int i = 0; i < clusterMembers; ++i) {
System.out.println(clients.get(i).get_gossipManager().getMemberList()); System.out.println(clients.get(i).get_gossipManager().getMemberList());
Assert.assertEquals(9, clients.get(i).get_gossipManager().getMemberList().size()); Assert.assertEquals(4, clients.get(i).get_gossipManager().getMemberList().size());
} }
for (int i = 0; i < clusterMembers; ++i) { for (int i = 0; i < clusterMembers; ++i) {
clients.get(i).shutdown(); clients.get(i).shutdown();