org.corfudb.runtime.view

Class QuorumFuturesFactory.CompositeFuture<R>

java.lang.Object

org.corfudb.runtime.view.QuorumFuturesFactory.CompositeFuture<R>

All Implemented Interfaces:

Future<R>

Enclosing class:

QuorumFuturesFactory

public static class QuorumFuturesFactory.CompositeFuture<R>
extends Object
implements Future<R>

Method Summary

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
boolean	containsThrowableFrom(Class<? extends Throwable> check) Checks whether one of the exceptions is throwable from the given type.
R	get()
R	get(long timeout, TimeUnit unit)
Set<Throwable>	getThrowables() Returns a set of Throwable classes from all futures that completed in any exceptional fashion.
boolean	isCancelled()
boolean	isConflict() Returns true if there were two successful results with different values, otherwise false.
boolean	isDone()

Methods inherited from class java.lang.Object

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

Method Detail

get

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

Specified by:

get in interface Future<R>

Throws:

InterruptedException

ExecutionException

TimeoutException

get

public R get()
      throws InterruptedException,
             ExecutionException

Specified by:

get in interface Future<R>

Throws:

InterruptedException

ExecutionException

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<R>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<R>

Returns:

true the future was canceled explicitly, or if the future was unable to reach quorum due to conflicts, canceled futures or futures that have thrown exception.

isDone

public boolean isDone()

Specified by:

isDone in interface Future<R>

isConflict

public boolean isConflict()

Returns true if there were two successful results with different values, otherwise false.

getThrowables

public Set<Throwable> getThrowables()

Returns a set of Throwable classes from all futures that completed in any exceptional fashion.

Returns:

Read-only set containing the Throwable classes

containsThrowableFrom

public boolean containsThrowableFrom(Class<? extends Throwable> check)

Checks whether one of the exceptions is throwable from the given type.

Parameters:

check - - the throwable to search for

Returns:

true if there is a throwable from the given type, otherwise false