org.opendaylight.vtn.manager.internal.util.flow

Class SendBarrierRpc

java.lang.Object

org.opendaylight.vtn.manager.internal.util.rpc.RpcInvocation<I,O>

org.opendaylight.vtn.manager.internal.util.inventory.NodeRpcInvocation<org.opendaylight.yang.gen.v1.urn.opendaylight.flow.transaction.rev150304.SendBarrierInput,Void>

org.opendaylight.vtn.manager.internal.util.flow.SendBarrierRpc

All Implemented Interfaces:

com.google.common.util.concurrent.FutureCallback<org.opendaylight.yangtools.yang.common.RpcResult<Void>>, RpcRequest

public final class SendBarrierRpc
extends NodeRpcInvocation<org.opendaylight.yang.gen.v1.urn.opendaylight.flow.transaction.rev150304.SendBarrierInput,Void>
implements com.google.common.util.concurrent.FutureCallback<org.opendaylight.yangtools.yang.common.RpcResult<Void>>

SendBarrierRpc describes an invocation of send-barrier RPC provided by the flow-capable-transaction service.

Constructor Summary

Constructors

Constructor and Description
SendBarrierRpc(NodeRpcWatcher w, org.opendaylight.yang.gen.v1.urn.opendaylight.flow.transaction.rev150304.FlowCapableTransactionService fcts, org.opendaylight.yang.gen.v1.urn.opendaylight.flow.transaction.rev150304.SendBarrierInput in) Issue a send-barrier RPC request.

Method Summary

Modifier and Type	Method and Description
static SendBarrierRpc	create(NodeRpcWatcher w, org.opendaylight.yang.gen.v1.urn.opendaylight.flow.transaction.rev150304.FlowCapableTransactionService fcts, org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef node) Send a barrier request to the specified node.
String	getName() Return the name of the RPC.
void	onFailure(Throwable t) Invoked when a barrier request has failed.
void	onSuccess(org.opendaylight.yangtools.yang.common.RpcResult<Void> result) Invoked when a barrier request has been processed successfully.

Methods inherited from class org.opendaylight.vtn.manager.internal.util.inventory.NodeRpcInvocation

complete, getNode, getNodeRpcWatcher, getResult, isDisconnected, isNodeRemoved, needErrorLog, needErrorLog, onNodeRemoved, start

Methods inherited from class org.opendaylight.vtn.manager.internal.util.rpc.RpcInvocation

getFuture, getInput, getInputForLog

Methods inherited from class java.lang.Object

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

Constructor Detail

SendBarrierRpc

public SendBarrierRpc(NodeRpcWatcher w,
                      org.opendaylight.yang.gen.v1.urn.opendaylight.flow.transaction.rev150304.FlowCapableTransactionService fcts,
                      org.opendaylight.yang.gen.v1.urn.opendaylight.flow.transaction.rev150304.SendBarrierInput in)

Issue a send-barrier RPC request.

Parameters:

w - The node RPC watcher.

fcts - MD-SAL flow-capable-transaction service.

in - The RPC input.

Method Detail

create

public static SendBarrierRpc create(NodeRpcWatcher w,
                                    org.opendaylight.yang.gen.v1.urn.opendaylight.flow.transaction.rev150304.FlowCapableTransactionService fcts,
                                    org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef node)

Send a barrier request to the specified node.

Parameters:

w - The node RPC watcher.

fcts - MD-SAL flow-capable-transaction service.

node - Reference to the target node.

Returns:

A SendBarrierRpc instance.

getName

public String getName()

Return the name of the RPC.

Specified by:

getName in interface RpcRequest

Returns:

"send-barrier".

onSuccess

public void onSuccess(org.opendaylight.yangtools.yang.common.RpcResult<Void> result)

Invoked when a barrier request has been processed successfully.

Specified by:

onSuccess in interface com.google.common.util.concurrent.FutureCallback<org.opendaylight.yangtools.yang.common.RpcResult<Void>>

Parameters:

result - The result of the send-barrier RPC.

onFailure

public void onFailure(Throwable t)

Invoked when a barrier request has failed.

Specified by:

onFailure in interface com.google.common.util.concurrent.FutureCallback<org.opendaylight.yangtools.yang.common.RpcResult<Void>>

Parameters:

t - A throwable that indicates the cause of failure.