Package org.opendaylight.genius.itm.rpc

Class ItmManagerRpcService

java.lang.Object

org.opendaylight.genius.itm.rpc.ItmManagerRpcService

All Implemented Interfaces:

ItmRpcService, org.opendaylight.yangtools.yang.binding.RpcService

@Singleton
public class ItmManagerRpcService
extends java.lang.Object
implements ItmRpcService

Constructor Summary

Constructors

Constructor

Description

ItmManagerRpcService(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker, IMdsalApiManager mdsalManager, ItmConfig itmConfig, DPNTEPsInfoCache dpnTEPsInfoCache, IInterfaceManager interfaceManager, DpnTepStateCache dpnTepStateCache, TunnelStateCache tunnelStateCache, InterfaceManagerService interfaceManagerService, OvsBridgeRefEntryCache ovsBridgeRefEntryCache, DirectTunnelUtils directTunnelUtils)

Method Summary

Modifier and Type	Method	Description
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddExternalTunnelEndpointOutput>>	addExternalTunnelEndpoint(AddExternalTunnelEndpointInput input)	used for building tunnels between teps on all Dpns and external node
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddL2GwDeviceOutput>>	addL2GwDevice(AddL2GwDeviceInput input)	used for building tunnels between teps on all Dpns and hwVtep
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddL2GwMlagDeviceOutput>>	addL2GwMlagDevice(AddL2GwMlagDeviceInput input)	used for building tunnels between teps on all Dpns and hwVtep
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<BuildExternalTunnelFromDpnsOutput>>	buildExternalTunnelFromDpns(BuildExternalTunnelFromDpnsInput input)	used for building tunnels between a Dpn and external node
void	close()
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<CreateTerminatingServiceActionsOutput>>	createTerminatingServiceActions(CreateTerminatingServiceActionsInput input)	used for programming the terminating service actions
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<DeleteL2GwDeviceOutput>>	deleteL2GwDevice(DeleteL2GwDeviceInput input)	used for deleting tunnels between teps on all Dpns and hwVtep
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<DeleteL2GwMlagDeviceOutput>>	deleteL2GwMlagDevice(DeleteL2GwMlagDeviceInput input)	used for deleting tunnels between teps on all Dpns and hwVtep
static java.util.List<DcGatewayIp>	getDcGatewayIpList(TypedReadWriteTransaction<Datastore.Configuration> tx)
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetDpnEndpointIpsOutput>>	getDpnEndpointIps(GetDpnEndpointIpsInput input)	used to retrieve tunnel end point IPs of a Dpn
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetDpnInfoOutput>>	getDpnInfo(GetDpnInfoInput input)	Gets the dpn id and tep ip information of compute nodes
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetEgressActionsForTunnelOutput>>	getEgressActionsForTunnel(GetEgressActionsForTunnelInput input)	used to retrieve group actions to use from interface name
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetExternalTunnelInterfaceNameOutput>>	getExternalTunnelInterfaceName(GetExternalTunnelInterfaceNameInput input)	used to retrieve external tunnel interface id between Dpns/TORs
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetInternalOrExternalInterfaceNameOutput>>	getInternalOrExternalInterfaceName(GetInternalOrExternalInterfaceNameInput input)	used to retrieve tunnel interface id with src Dpn and destination ip/dpn
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetTunnelInterfaceNameOutput>>	getTunnelInterfaceName(GetTunnelInterfaceNameInput input)	used to retrieve tunnel interface id between Dpns
java.util.List<MatchInfo>	getTunnelMatchesForServiceId(org.opendaylight.yangtools.yang.common.Uint16 serviceId)
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetTunnelTypeOutput>>	getTunnelType(GetTunnelTypeInput input)	to get the type of the tunnel interface(vxlan, vxlan-gpe, gre, etc.)
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetWatchPortForTunnelOutput>>	getWatchPortForTunnel(GetWatchPortForTunnelInput input)	retrieve the watch port for the BFD enabled point to point tunnel
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<IsDcgwPresentOutput>>	isDcgwPresent(IsDcgwPresentInput input)	Used for determining whether tunnel is an internal or an external tunnel
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<IsTunnelInternalOrExternalOutput>>	isTunnelInternalOrExternal(IsTunnelInternalOrExternalInput input)	Used for determining whether tunnel is an internal or an external tunnel
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveExternalTunnelEndpointOutput>>	removeExternalTunnelEndpoint(RemoveExternalTunnelEndpointInput input)	used for building tunnels between teps on all Dpns and external node
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveExternalTunnelFromDpnsOutput>>	removeExternalTunnelFromDpns(RemoveExternalTunnelFromDpnsInput input)	used for building tunnels between a Dpn and external node
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveTerminatingServiceActionsOutput>>	removeTerminatingServiceActions(RemoveTerminatingServiceActionsInput input)	used for removing the terminating service actions
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<SetBfdParamOnTunnelOutput>>	setBfdParamOnTunnel(SetBfdParamOnTunnelInput input)	used for turning ON/OFF to monitor individual tunnels
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

ItmManagerRpcService

@Inject
public ItmManagerRpcService(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker,
                            IMdsalApiManager mdsalManager,
                            ItmConfig itmConfig,
                            DPNTEPsInfoCache dpnTEPsInfoCache,
                            IInterfaceManager interfaceManager,
                            DpnTepStateCache dpnTepStateCache,
                            TunnelStateCache tunnelStateCache,
                            InterfaceManagerService interfaceManagerService,
                            OvsBridgeRefEntryCache ovsBridgeRefEntryCache,
                            DirectTunnelUtils directTunnelUtils)

Method Detail

start

@PostConstruct
public void start()

close

@PreDestroy
public void close()

getTunnelInterfaceName

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetTunnelInterfaceNameOutput>> getTunnelInterfaceName(GetTunnelInterfaceNameInput input)

Description copied from interface: ItmRpcService

used to retrieve tunnel interface id between Dpns

Specified by:

getTunnelInterfaceName in interface ItmRpcService

getEgressActionsForTunnel

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetEgressActionsForTunnelOutput>> getEgressActionsForTunnel(GetEgressActionsForTunnelInput input)

Description copied from interface: ItmRpcService

used to retrieve group actions to use from interface name

Specified by:

getEgressActionsForTunnel in interface ItmRpcService

getTunnelType

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetTunnelTypeOutput>> getTunnelType(GetTunnelTypeInput input)

Description copied from interface: ItmRpcService

to get the type of the tunnel interface(vxlan, vxlan-gpe, gre, etc.)

Specified by:

getTunnelType in interface ItmRpcService

setBfdParamOnTunnel

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<SetBfdParamOnTunnelOutput>> setBfdParamOnTunnel(SetBfdParamOnTunnelInput input)

Description copied from interface: ItmRpcService

used for turning ON/OFF to monitor individual tunnels

Specified by:

setBfdParamOnTunnel in interface ItmRpcService

removeExternalTunnelEndpoint

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveExternalTunnelEndpointOutput>> removeExternalTunnelEndpoint(RemoveExternalTunnelEndpointInput input)

Description copied from interface: ItmRpcService

used for building tunnels between teps on all Dpns and external node

Specified by:

removeExternalTunnelEndpoint in interface ItmRpcService

removeExternalTunnelFromDpns

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveExternalTunnelFromDpnsOutput>> removeExternalTunnelFromDpns(RemoveExternalTunnelFromDpnsInput input)

Description copied from interface: ItmRpcService

used for building tunnels between a Dpn and external node

Specified by:

removeExternalTunnelFromDpns in interface ItmRpcService

buildExternalTunnelFromDpns

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<BuildExternalTunnelFromDpnsOutput>> buildExternalTunnelFromDpns(BuildExternalTunnelFromDpnsInput input)

Description copied from interface: ItmRpcService

used for building tunnels between a Dpn and external node

Specified by:

buildExternalTunnelFromDpns in interface ItmRpcService

addExternalTunnelEndpoint

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddExternalTunnelEndpointOutput>> addExternalTunnelEndpoint(AddExternalTunnelEndpointInput input)

Description copied from interface: ItmRpcService

used for building tunnels between teps on all Dpns and external node

Specified by:

addExternalTunnelEndpoint in interface ItmRpcService

getExternalTunnelInterfaceName

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetExternalTunnelInterfaceNameOutput>> getExternalTunnelInterfaceName(GetExternalTunnelInterfaceNameInput input)

Description copied from interface: ItmRpcService

used to retrieve external tunnel interface id between Dpns/TORs

Specified by:

getExternalTunnelInterfaceName in interface ItmRpcService

createTerminatingServiceActions

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<CreateTerminatingServiceActionsOutput>> createTerminatingServiceActions(CreateTerminatingServiceActionsInput input)

Description copied from interface: ItmRpcService

used for programming the terminating service actions

Specified by:

createTerminatingServiceActions in interface ItmRpcService

removeTerminatingServiceActions

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveTerminatingServiceActionsOutput>> removeTerminatingServiceActions(RemoveTerminatingServiceActionsInput input)

Description copied from interface: ItmRpcService

used for removing the terminating service actions

Specified by:

removeTerminatingServiceActions in interface ItmRpcService

getTunnelMatchesForServiceId

public java.util.List<MatchInfo> getTunnelMatchesForServiceId(org.opendaylight.yangtools.yang.common.Uint16 serviceId)

getInternalOrExternalInterfaceName

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetInternalOrExternalInterfaceNameOutput>> getInternalOrExternalInterfaceName(GetInternalOrExternalInterfaceNameInput input)

Description copied from interface: ItmRpcService

used to retrieve tunnel interface id with src Dpn and destination ip/dpn

Specified by:

getInternalOrExternalInterfaceName in interface ItmRpcService

deleteL2GwDevice

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<DeleteL2GwDeviceOutput>> deleteL2GwDevice(DeleteL2GwDeviceInput input)

Description copied from interface: ItmRpcService

used for deleting tunnels between teps on all Dpns and hwVtep

Specified by:

deleteL2GwDevice in interface ItmRpcService

addL2GwDevice

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddL2GwDeviceOutput>> addL2GwDevice(AddL2GwDeviceInput input)

Description copied from interface: ItmRpcService

used for building tunnels between teps on all Dpns and hwVtep

Specified by:

addL2GwDevice in interface ItmRpcService

getWatchPortForTunnel

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetWatchPortForTunnelOutput>> getWatchPortForTunnel(GetWatchPortForTunnelInput input)

Description copied from interface: ItmRpcService

retrieve the watch port for the BFD enabled point to point tunnel

Specified by:

getWatchPortForTunnel in interface ItmRpcService

addL2GwMlagDevice

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddL2GwMlagDeviceOutput>> addL2GwMlagDevice(AddL2GwMlagDeviceInput input)

Description copied from interface: ItmRpcService

used for building tunnels between teps on all Dpns and hwVtep

Specified by:

addL2GwMlagDevice in interface ItmRpcService

deleteL2GwMlagDevice

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<DeleteL2GwMlagDeviceOutput>> deleteL2GwMlagDevice(DeleteL2GwMlagDeviceInput input)

Description copied from interface: ItmRpcService

used for deleting tunnels between teps on all Dpns and hwVtep

Specified by:

deleteL2GwMlagDevice in interface ItmRpcService

isTunnelInternalOrExternal

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<IsTunnelInternalOrExternalOutput>> isTunnelInternalOrExternal(IsTunnelInternalOrExternalInput input)

Description copied from interface: ItmRpcService

Used for determining whether tunnel is an internal or an external tunnel

Specified by:

isTunnelInternalOrExternal in interface ItmRpcService

isDcgwPresent

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<IsDcgwPresentOutput>> isDcgwPresent(IsDcgwPresentInput input)

Description copied from interface: ItmRpcService

Used for determining whether tunnel is an internal or an external tunnel

Specified by:

isDcgwPresent in interface ItmRpcService

getDpnEndpointIps

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetDpnEndpointIpsOutput>> getDpnEndpointIps(GetDpnEndpointIpsInput input)

Description copied from interface: ItmRpcService

used to retrieve tunnel end point IPs of a Dpn

Specified by:

getDpnEndpointIps in interface ItmRpcService

getDpnInfo

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetDpnInfoOutput>> getDpnInfo(GetDpnInfoInput input)

Description copied from interface: ItmRpcService

Gets the dpn id and tep ip information of compute nodes

Specified by:

getDpnInfo in interface ItmRpcService

getDcGatewayIpList

public static java.util.List<DcGatewayIp> getDcGatewayIpList(TypedReadWriteTransaction<Datastore.Configuration> tx)
                                                      throws java.util.concurrent.ExecutionException,
                                                             java.lang.InterruptedException

Throws:

java.util.concurrent.ExecutionException

java.lang.InterruptedException