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

Why set to null

Browse Source
This commit is contained in:
Edward Capriolo
2016-04-20 14:17:39 -04:00
parent 611b53b475
commit e91d4af3bf
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -64,7 +64,6 @@ abstract public class PassiveGossipThread implements Runnable {
GossipService.LOGGER.debug("I am " + _gossipManager.getMyself()); GossipService.LOGGER.debug("I am " + _gossipManager.getMyself());
} catch (SocketException ex) { } catch (SocketException ex) {
GossipService.LOGGER.warn(ex); GossipService.LOGGER.warn(ex);
_server = null;
throw new RuntimeException(ex); throw new RuntimeException(ex);
} }
_keepRunning = new AtomicBoolean(true); _keepRunning = new AtomicBoolean(true);
@ -139,7 +138,9 @@ abstract public class PassiveGossipThread implements Runnable {
} }
public void shutdown() { public void shutdown() {
try {
_server.close(); _server.close();
} catch (RuntimeException ex){ }
} }
/** /**