net.jini.discovery

Class AbstractLookupLocatorDiscovery.DiscoveryTask

java.lang.Object

org.apache.river.thread.RetryTask

net.jini.discovery.AbstractLookupLocatorDiscovery.DiscoveryTask

All Implemented Interfaces:

Runnable, java.util.concurrent.Future, java.util.concurrent.RunnableFuture, TimeConstants, FutureObserver.ObservableFuture

Enclosing class:

AbstractLookupLocatorDiscovery

private class AbstractLookupLocatorDiscovery.DiscoveryTask
extends RetryTask

Task which retrieves elements from the set of undiscoveredLocators and attempts, through the unicast discovery protocol, to discover the lookup service having the LookupLocator referenced by the element. If a particular instance of this class fails to find the lookup service that it references, this task will be rescheduled to be executed again at a later time, using a "backoff strategy" as defined by the method org.apache.river.thread.RetryTask.retryTime.

See Also:

RetryTask, WakeupManager

Field Summary

Fields

Modifier and Type	Field and Description
private AbstractLookupLocatorDiscovery.LocatorReg	reg

Fields inherited from class org.apache.river.thread.RetryTask

logger

Fields inherited from interface org.apache.river.constants.TimeConstants

DAYS, HOURS, MINUTES, SECONDS

Constructor Summary

Constructors

Constructor and Description
DiscoveryTask(AbstractLookupLocatorDiscovery.LocatorReg reg, java.util.concurrent.ExecutorService executor, WakeupManager wakeupMgr)

Method Summary

Modifier and Type	Method and Description
long	retryTime() Returns the next absolute time (in milliseconds) at which another attempt to discover the lookup service referenced in this class should be made.
boolean	tryOnce() Executes the current instance of this task once, attempting to discover - through unicast discovery - the lookup service referenced in that instance.

Methods inherited from class org.apache.river.thread.RetryTask

addObserver, attempt, cancel, get, get, isCancelled, isDone, run, startTime, waitFor

Methods inherited from class java.lang.Object

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

Field Detail

reg

private final AbstractLookupLocatorDiscovery.LocatorReg reg

Constructor Detail

DiscoveryTask

public DiscoveryTask(AbstractLookupLocatorDiscovery.LocatorReg reg,
                     java.util.concurrent.ExecutorService executor,
                     WakeupManager wakeupMgr)

Method Detail

tryOnce

public boolean tryOnce()

Executes the current instance of this task once, attempting to discover - through unicast discovery - the lookup service referenced in that instance. Upon successfully discovering the indicated lookup service, this method returns true and the current instance of this task is not executed again. For each unsuccessful discovery attempt made by this method for the current instance of this task, this method returns false, which causes the task to be scheduled by the WakeupManager to be executed again at a later time as indicated by the value returned by retryTime.

Specified by:

tryOnce in class RetryTask

retryTime

public long retryTime()

Returns the next absolute time (in milliseconds) at which another attempt to discover the lookup service referenced in this class should be made. Overrides the version of this method in the parent class.

Overrides:

retryTime in class RetryTask