Class UnicastZenPing

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, Releasable, ZenPing

    public class UnicastZenPing
    extends java.lang.Object
    implements ZenPing
    • Method Detail

      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Specified by:
        close in interface 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​(java.util.function.Consumer<ZenPing.PingCollection> resultsConsumer,
                         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
      • submitToExecutor

        protected void submitToExecutor​(AbstractRunnable abstractRunnable)
      • getVersion

        protected Version getVersion()