You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gossip.apache.org by ec...@apache.org on 2016/06/11 00:16:42 UTC
[05/12] incubator-gossip git commit: Final final
Final final
Project: http://git-wip-us.apache.org/repos/asf/incubator-gossip/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gossip/commit/3366f636
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gossip/tree/3366f636
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gossip/diff/3366f636
Branch: refs/heads/master
Commit: 3366f6364142ad8460c7899fff5a90b67b81976d
Parents: 266e039
Author: Edward Capriolo <ed...@gmail.com>
Authored: Mon May 16 19:10:53 2016 -0400
Committer: Edward Capriolo <ed...@gmail.com>
Committed: Tue Jun 7 22:52:53 2016 -0400
----------------------------------------------------------------------
.../google/code/gossip/manager/PassiveGossipThread.java | 10 +++-------
1 file changed, 3 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-gossip/blob/3366f636/src/main/java/com/google/code/gossip/manager/PassiveGossipThread.java
----------------------------------------------------------------------
diff --git a/src/main/java/com/google/code/gossip/manager/PassiveGossipThread.java b/src/main/java/com/google/code/gossip/manager/PassiveGossipThread.java
index ec11cfe..6bf1494 100644
--- a/src/main/java/com/google/code/gossip/manager/PassiveGossipThread.java
+++ b/src/main/java/com/google/code/gossip/manager/PassiveGossipThread.java
@@ -29,10 +29,6 @@ import java.util.concurrent.atomic.AtomicBoolean;
import org.apache.log4j.Logger;
import org.codehaus.jackson.map.ObjectMapper;
-import org.json.JSONArray;
-import org.json.JSONException;
-import org.json.JSONObject;
-
import com.google.code.gossip.GossipMember;
import com.google.code.gossip.GossipService;
import com.google.code.gossip.RemoteGossipMember;
@@ -49,15 +45,15 @@ abstract public class PassiveGossipThread implements Runnable {
public static final Logger LOGGER = Logger.getLogger(PassiveGossipThread.class);
/** The socket used for the passive thread of the gossip service. */
- private DatagramSocket server;
+ private final DatagramSocket server;
private final GossipManager gossipManager;
- private AtomicBoolean keepRunning;
+ private final AtomicBoolean keepRunning;
private final String cluster;
- private ObjectMapper MAPPER = new ObjectMapper();
+ private final ObjectMapper MAPPER = new ObjectMapper();
public PassiveGossipThread(GossipManager gossipManager) {
this.gossipManager = gossipManager;