Package org.elasticsearch.discovery.zen
Class UnicastZenPing
- java.lang.Object
-
- org.elasticsearch.discovery.zen.UnicastZenPing
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,Releasable
,ZenPing
public class UnicastZenPing extends java.lang.Object implements ZenPing
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description protected class
UnicastZenPing.PingingRound
static class
UnicastZenPing.UnicastPingRequest
static class
UnicastZenPing.UnicastPingResponse
-
Nested classes/interfaces inherited from interface org.elasticsearch.discovery.zen.ZenPing
ZenPing.PingCollection, ZenPing.PingResponse
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
ACTION_NAME
protected EsThreadPoolExecutor
unicastZenPingExecutorService
-
Constructor Summary
Constructors Constructor Description UnicastZenPing(Settings settings, ThreadPool threadPool, TransportService transportService, SeedHostsProvider seedHostsProvider, PingContextProvider contextProvider)
-
Method Summary
Modifier and Type Method Description void
clearTemporalResponses()
Clears the list of cached ping responses.void
close()
protected void
finishPingingRound(UnicastZenPing.PingingRound pingingRound)
protected TransportResponseHandler<UnicastZenPing.UnicastPingResponse>
getPingResponseHandler(UnicastZenPing.PingingRound pingingRound, DiscoveryNode node)
protected Version
getVersion()
void
ping(java.util.function.Consumer<ZenPing.PingCollection> resultsConsumer, TimeValue duration)
Sends three rounds of pings notifying the specifiedConsumer
when pinging is complete.protected void
ping(java.util.function.Consumer<ZenPing.PingCollection> resultsConsumer, TimeValue scheduleDuration, TimeValue requestDuration)
a variant ofping(Consumer, TimeValue)
, but allows separating the scheduling duration from the duration used for request level time outs.protected void
sendPings(TimeValue timeout, UnicastZenPing.PingingRound pingingRound)
void
start()
protected void
submitToExecutor(AbstractRunnable abstractRunnable)
-
-
-
Field Detail
-
ACTION_NAME
public static final java.lang.String ACTION_NAME
- See Also:
- Constant Field Values
-
unicastZenPingExecutorService
protected final EsThreadPoolExecutor unicastZenPingExecutorService
-
-
Constructor Detail
-
UnicastZenPing
public UnicastZenPing(Settings settings, ThreadPool threadPool, TransportService transportService, SeedHostsProvider seedHostsProvider, PingContextProvider contextProvider)
-
-
Method Detail
-
close
public void close()
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Specified by:
close
in interfaceReleasable
-
clearTemporalResponses
public void clearTemporalResponses()
Clears the list of cached ping responses.
-
ping
public void ping(java.util.function.Consumer<ZenPing.PingCollection> resultsConsumer, TimeValue duration)
Sends three rounds of pings notifying the specifiedConsumer
when pinging is complete. Pings are sent after resolving configured unicast hosts to their IP address (subject to DNS caching within the JVM). A batch of pings is sent, then another batch of pings is sent at half the specifiedTimeValue
, and then another batch of pings is sent at the specifiedTimeValue
. The pings that are sent carry a timeout of 1.25 times the specifiedTimeValue
. When pinging each node, a connection and handshake is performed, with a connection timeout of the specifiedTimeValue
.
-
ping
protected void ping(java.util.function.Consumer<ZenPing.PingCollection> resultsConsumer, TimeValue scheduleDuration, TimeValue requestDuration)
a variant ofping(Consumer, TimeValue)
, but allows separating the scheduling duration from the duration used for request level time outs. This is useful for testing
-
finishPingingRound
protected void finishPingingRound(UnicastZenPing.PingingRound pingingRound)
-
sendPings
protected void sendPings(TimeValue timeout, UnicastZenPing.PingingRound pingingRound)
-
submitToExecutor
protected void submitToExecutor(AbstractRunnable abstractRunnable)
-
getPingResponseHandler
protected TransportResponseHandler<UnicastZenPing.UnicastPingResponse> getPingResponseHandler(UnicastZenPing.PingingRound pingingRound, DiscoveryNode node)
-
getVersion
protected Version getVersion()
-
-