diff --git a/src/main/java/org/elasticsearch/discovery/zen/ping/multicast/MulticastZenPing.java b/src/main/java/org/elasticsearch/discovery/zen/ping/multicast/MulticastZenPing.java index 2c77cd5ccdd..f6f8c2fe62d 100644 --- a/src/main/java/org/elasticsearch/discovery/zen/ping/multicast/MulticastZenPing.java +++ b/src/main/java/org/elasticsearch/discovery/zen/ping/multicast/MulticastZenPing.java @@ -62,44 +62,29 @@ public class MulticastZenPing extends AbstractLifecycleComponent implem private static final byte[] INTERNAL_HEADER = new byte[]{1, 9, 8, 4}; private final String address; - private final int port; - private final String group; - private final int bufferSize; - private final int ttl; private final ThreadPool threadPool; - private final TransportService transportService; - private final ClusterName clusterName; - private final NetworkService networkService; + private volatile DiscoveryNodesProvider nodesProvider; private final boolean pingEnabled; - - private volatile DiscoveryNodesProvider nodesProvider; - private volatile Receiver receiver; - private volatile Thread receiverThread; - - private MulticastSocket multicastSocket; - + private volatile MulticastSocket multicastSocket; private DatagramPacket datagramPacketSend; - private DatagramPacket datagramPacketReceive; private final AtomicInteger pingIdGenerator = new AtomicInteger(); - private final Map> receivedResponses = newConcurrentMap(); private final Object sendMutex = new Object(); - private final Object receiveMutex = new Object(); public MulticastZenPing(ThreadPool threadPool, TransportService transportService, ClusterName clusterName) {