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

Correcting gossipper so it only binds to a single host/port rather than all

Browse Source
This commit is contained in:
Edward Capriolo
2015-01-09 12:27:55 -05:00
parent 961d93d13b
commit 844b827dc6
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/com/google/code/gossip/manager/PassiveGossipThread.java
View File

@ -3,6 +3,8 @@ package com.google.code.gossip.manager;
import java.io.IOException; import java.io.IOException;
import java.net.DatagramPacket; import java.net.DatagramPacket;
import java.net.DatagramSocket; import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.net.SocketException; import java.net.SocketException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicBoolean;
@ -37,17 +39,22 @@ abstract public class PassiveGossipThread implements Runnable {
// Start the service on the given port number. // Start the service on the given port number.
try { try {
_server = new DatagramSocket(_gossipManager.getMyself().getPort()); //_server = new DatagramSocket( _gossipManager.getMyself().getPort());
SocketAddress socketAddress = new InetSocketAddress(_gossipManager.getMyself().getHost(), _gossipManager.getMyself().getPort());
_server = new DatagramSocket(socketAddress);
// The server successfully started on the current port. // The server successfully started on the current port.
GossipService.info("Gossip service successfully initialized on port " + _gossipManager.getMyself().getPort()); GossipService.info("Gossip service successfully initialized on port " + _gossipManager.getMyself().getPort());
GossipService.debug("I am " + _gossipManager.getMyself()); GossipService.debug("I am " + _gossipManager.getMyself());
} catch (SocketException ex) { } catch (SocketException ex) {
// The port is probably already in use. System.err.println(ex);
_server = null; _server = null;
// Let's communicate this to the user. // Let's communicate this to the user.
/*
GossipService.error("Error while starting the gossip service on port " + _gossipManager.getMyself().getPort() + ": " + ex.getMessage()); GossipService.error("Error while starting the gossip service on port " + _gossipManager.getMyself().getPort() + ": " + ex.getMessage());
System.exit(-1); System.exit(-1);*/
throw new RuntimeException(ex);
} }
_keepRunning = new AtomicBoolean(true); _keepRunning = new AtomicBoolean(true);