Merge pull request #13 from irstevenson/unittest-multiport

Change to unit test so that it doesn't require the setup of multiple loopback devices.
This commit is contained in:
edwardcapriolo
2016-01-29 23:33:07 -04:30
2 changed files with 11 additions and 2 deletions

View File

@ -47,6 +47,9 @@ public class GossipService {
} }
public void start() { public void start() {
String address = get_gossipManager().getMyself().getHost() + ":" + get_gossipManager().getMyself().getPort();
LOGGER.debug( "Starting: " + _gossipManager.getName() + " - " + address );
_gossipManager.start(); _gossipManager.start();
} }

View File

@ -9,6 +9,7 @@ import java.util.concurrent.Callable;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import org.apache.log4j.Logger;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Test; import org.junit.Test;
@ -20,6 +21,7 @@ import com.google.code.gossip.event.GossipListener;
import com.google.code.gossip.event.GossipState; import com.google.code.gossip.event.GossipState;
public class TenNodeThreeSeedTest { public class TenNodeThreeSeedTest {
private static final Logger log = Logger.getLogger( TenNodeThreeSeedTest.class );
@Test @Test
public void test() throws UnknownHostException, InterruptedException{ public void test() throws UnknownHostException, InterruptedException{
@ -33,15 +35,19 @@ public class TenNodeThreeSeedTest {
public void abc() throws InterruptedException, UnknownHostException{ public void abc() throws InterruptedException, UnknownHostException{
GossipSettings settings = new GossipSettings(); GossipSettings settings = new GossipSettings();
log.info( "Adding seed nodes" );
int seedNodes = 3; int seedNodes = 3;
List<GossipMember> startupMembers = new ArrayList<>(); List<GossipMember> startupMembers = new ArrayList<>();
for (int i = 1; i < seedNodes+1; ++i) { for (int i = 1; i < seedNodes+1; ++i) {
startupMembers.add(new RemoteGossipMember("127.0.0." + i, 2000, i + "")); startupMembers.add(new RemoteGossipMember("127.0.0.1", 50000 + i, i + ""));
} }
log.info( "Adding clients" );
final List<GossipService> clients = new ArrayList<>(); final List<GossipService> clients = new ArrayList<>();
final int clusterMembers = 5; final 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, i + "", GossipService gossipService = new GossipService("127.0.0.1", 50000 + i, i + "",
startupMembers, settings, startupMembers, settings,
new GossipListener(){ new GossipListener(){
@Override @Override