Package org.elasticsearch.discovery.zen

Class UnicastZenPing

java.lang.Object

org.elasticsearch.discovery.zen.UnicastZenPing

All Implemented Interfaces:

Closeable, AutoCloseable, org.elasticsearch.core.Releasable, ZenPing

public class UnicastZenPing
extends 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 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(Consumer<ZenPing.PingCollection> resultsConsumer, org.elasticsearch.core.TimeValue duration)	Sends three rounds of pings notifying the specified Consumer when pinging is complete.
protected void	ping(Consumer<ZenPing.PingCollection> resultsConsumer, org.elasticsearch.core.TimeValue scheduleDuration, org.elasticsearch.core.TimeValue requestDuration)	a variant of ping(Consumer, TimeValue), but allows separating the scheduling duration from the duration used for request level time outs.
protected void	sendPings(org.elasticsearch.core.TimeValue timeout, UnicastZenPing.PingingRound pingingRound)
void	start()
protected void	submitToExecutor(AbstractRunnable abstractRunnable)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

ACTION_NAME

public static final String ACTION_NAME

See Also:

Constant Field Values

unicastZenPingExecutorService

protected final EsThreadPoolExecutor unicastZenPingExecutorService

Constructor Details

UnicastZenPing

public UnicastZenPing(Settings settings,
 ThreadPool threadPool,
 TransportService transportService,
 SeedHostsProvider seedHostsProvider,
 PingContextProvider contextProvider)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.elasticsearch.core.Releasable

start

public void start()

Specified by:

start in interface ZenPing

clearTemporalResponses

public void clearTemporalResponses()

Clears the list of cached ping responses.

ping

public void ping(Consumer<ZenPing.PingCollection> resultsConsumer,
 org.elasticsearch.core.TimeValue duration)

Sends three rounds of pings notifying the specified Consumer 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 specified TimeValue, and then another batch of pings is sent at the specified TimeValue. The pings that are sent carry a timeout of 1.25 times the specified TimeValue. When pinging each node, a connection and handshake is performed, with a connection timeout of the specified TimeValue.

Specified by:

ping in interface ZenPing

Parameters:

resultsConsumer - the callback when pinging is complete

duration - the timeout for various components of the pings

ping

protected void ping(Consumer<ZenPing.PingCollection> resultsConsumer,
 org.elasticsearch.core.TimeValue scheduleDuration,
 org.elasticsearch.core.TimeValue requestDuration)

a variant of ping(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(org.elasticsearch.core.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()