com.pervasive.datarush.cal.dr

Class RemoteMonitoredFuture<R>

java.lang.Object

com.pervasive.datarush.cal.dr.RemoteMonitoredFuture<R>

All Implemented Interfaces:

MonitoredFuture<R>, Future<R>

Direct Known Subclasses:

FaultTolerantFuture

public class RemoteMonitoredFuture<R>
extends Object
implements MonitoredFuture<R>

Field Summary

Fields

Modifier and Type	Field and Description
protected List<CommandHandleInfo>	handles
protected ResultMerger<R>	merger
protected Object	MUTEX

Constructor Summary

Constructors

Constructor and Description
RemoteMonitoredFuture(CommandHandleInfo handle)
RemoteMonitoredFuture(ResultMerger<R> merger, List<CommandHandleInfo> handles)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
R	get()
R	get(long duration, TimeUnit unit)
R	getStatus() Returns the partial status of the MonitoredCallable or the final result if the command has completed successfully.
protected List<CommandHandleInfo>	handleFailed(CommandHandleInfo handle, RMIException e)
boolean	isCancelled()
boolean	isDone()

Methods inherited from class java.lang.Object

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

Field Detail

merger

protected final ResultMerger<R> merger

MUTEX

protected final Object MUTEX

handles

protected List<CommandHandleInfo> handles

Constructor Detail

RemoteMonitoredFuture

public RemoteMonitoredFuture(CommandHandleInfo handle)

RemoteMonitoredFuture

public RemoteMonitoredFuture(ResultMerger<R> merger,
                     List<CommandHandleInfo> handles)

Method Detail

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<R>

get

public final R get()
            throws InterruptedException,
                   ExecutionException

Specified by:

get in interface Future<R>

Throws:

InterruptedException

ExecutionException

get

public final R get(long duration,
    TimeUnit unit)
            throws InterruptedException,
                   ExecutionException,
                   TimeoutException

Specified by:

get in interface Future<R>

Throws:

InterruptedException

ExecutionException

TimeoutException

isCancelled

public final boolean isCancelled()

Specified by:

isCancelled in interface Future<R>

isDone

public final boolean isDone()

Specified by:

isDone in interface Future<R>

getStatus

public final R getStatus()
                  throws ExecutionException,
                         InterruptedException

Description copied from interface: MonitoredFuture

Returns the partial status of the MonitoredCallable or the final result if the command has completed successfully. In the event that the command fails, this will return a status of the command following the exception. In the case where it is a DistributedCallable, the result returned by the future will be the result of calling DistributedCallable.merge(java.util.List) on the status's or final results.

Specified by:

getStatus in interface MonitoredFuture<R>

Returns:

the partial status

Throws:

ExecutionException - if there was an (I/O) error fetching the status.

InterruptedException - if interrupted while waiting for the status. Note that getStatus does not block in the end-to-end sense, but does block waiting for network IO so it can potentially throw InterruptedException

handleFailed

protected List<CommandHandleInfo> handleFailed(CommandHandleInfo handle,
                                   RMIException e)
                                        throws ExecutionException

Parameters:

handle -

e -

Returns:

nothing

Throws:

ExecutionException