org.opendaylight.vtn.manager.internal.flow.reader

Class ReadSingleFlowFuture

java.lang.Object

org.opendaylight.vtn.manager.internal.util.concurrent.AbstractVTNFuture<T>

org.opendaylight.vtn.manager.internal.util.concurrent.SettableVTNFuture<T>

org.opendaylight.vtn.manager.internal.flow.reader.AbstractReadFlowFuture<List<DataFlowInfo>>

org.opendaylight.vtn.manager.internal.flow.reader.ReadFlowFuture

org.opendaylight.vtn.manager.internal.flow.reader.ReadSingleFlowFuture

All Implemented Interfaces:

com.google.common.util.concurrent.CheckedFuture<List<DataFlowInfo>,VTNException>, com.google.common.util.concurrent.FutureCallback<com.google.common.base.Optional<VtnDataFlow>>, com.google.common.util.concurrent.ListenableFuture<List<DataFlowInfo>>, Future<List<DataFlowInfo>>, VTNFuture<List<DataFlowInfo>>, RpcOutputGenerator<List<DataFlowInfo>,GetDataFlowOutput>

public final class ReadSingleFlowFuture
extends ReadFlowFuture
implements com.google.common.util.concurrent.FutureCallback<com.google.common.base.Optional<VtnDataFlow>>

ReadSingleFlowFuture describes a future associated with the task which reads a single data flow information.

Constructor Summary

Constructors

Constructor and Description
ReadSingleFlowFuture(TxContext ctx, TxQueue txq, StatsReaderService srs, GetDataFlowInput input) Construct a new instance.

Method Summary

Modifier and Type	Method and Description
void	onFailure(Throwable cause) Invoked when the read operation has failed.
void	onSuccess(com.google.common.base.Optional<VtnDataFlow> result) Invoked when the read operation has completed successfully.

Methods inherited from class org.opendaylight.vtn.manager.internal.flow.reader.ReadFlowFuture

clearFlowNode, clearFlowPort, clearSourceHost, create, createOutput, getFlowNode, getFlowPort, getOutputType, getSourceHost, getStatsReaderService, notFound, select, toDataFlowInfo

Methods inherited from class org.opendaylight.vtn.manager.internal.flow.reader.AbstractReadFlowFuture

checkTenant, getTenantName, getTxContext, setFailure, setResult

Methods inherited from class org.opendaylight.vtn.manager.internal.util.concurrent.SettableVTNFuture

cancel, get, get, isCancelled, isDone, maskCancel, onFutureFailed, onFutureSucceeded, set, setException, setThread, unmaskCancel

Methods inherited from class org.opendaylight.vtn.manager.internal.util.concurrent.AbstractVTNFuture

addListener, done, getCause, getException

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.opendaylight.vtn.manager.internal.util.concurrent.VTNFuture

checkedGet, checkedGet

Constructor Detail

ReadSingleFlowFuture

public ReadSingleFlowFuture(TxContext ctx,
                            TxQueue txq,
                            StatsReaderService srs,
                            GetDataFlowInput input)
                     throws VTNException

Construct a new instance.

Parameters:

ctx - A TxContext instance.

txq - A TxQueue instance used to update the MD-SAL datastore.

srs - The flow statistics reader service.

input - Input of the RPC call.

Throws:

VTNException - An error occurred.

Method Detail

onSuccess

public void onSuccess(@Nonnull
                      com.google.common.base.Optional<VtnDataFlow> result)

Invoked when the read operation has completed successfully.

Specified by:

onSuccess in interface com.google.common.util.concurrent.FutureCallback<com.google.common.base.Optional<VtnDataFlow>>

Parameters:

result - An Optional instance that contains the VTN data flow information.

onFailure

public void onFailure(Throwable cause)

Invoked when the read operation has failed.

Specified by:

onFailure in interface com.google.common.util.concurrent.FutureCallback<com.google.common.base.Optional<VtnDataFlow>>

Parameters:

cause - A Throwable that indicates the cause of failure.