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.mdsal.binding.api.DataBroker dataBroker, IMdsalApiManager mdsalManager, ItmConfig itmConfig, DPNTEPsInfoCache dpnTEPsInfoCache, IInterfaceManager interfaceManager, DpnTepStateCache dpnTepStateCache, TunnelStateCache tunnelStateCache, InterfaceManagerService interfaceManagerService, OvsBridgeRefEntryCache ovsBridgeRefEntryCache, DirectTunnelUtils directTunnelUtils, OfDpnTepConfigCache ofDpnTepConfigCache, OfTepStateCache ofTepStateCache)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddExternalTunnelEndpointOutput>>
addExternalTunnelEndpoint(AddExternalTunnelEndpointInput input)
Invokeadd-external-tunnel-endpoint
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddL2GwDeviceOutput>>
addL2GwDevice(AddL2GwDeviceInput input)
Invokeadd-l2-gw-device
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddL2GwMlagDeviceOutput>>
addL2GwMlagDevice(AddL2GwMlagDeviceInput input)
Invokeadd-l2-gw-mlag-device
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<BuildExternalTunnelFromDpnsOutput>>
buildExternalTunnelFromDpns(BuildExternalTunnelFromDpnsInput input)
Invokebuild-external-tunnel-from-dpns
RPC.void
close()
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<CreateTerminatingServiceActionsOutput>>
createTerminatingServiceActions(CreateTerminatingServiceActionsInput input)
Invokecreate-terminating-service-actions
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<DeleteL2GwDeviceOutput>>
deleteL2GwDevice(DeleteL2GwDeviceInput input)
Invokedelete-l2-gw-device
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<DeleteL2GwMlagDeviceOutput>>
deleteL2GwMlagDevice(DeleteL2GwMlagDeviceInput input)
Invokedelete-l2-gw-mlag-device
RPC.static java.util.Map<DcGatewayIpKey,DcGatewayIp>
getDcGatewayIpList(org.opendaylight.mdsal.binding.util.TypedReadWriteTransaction<org.opendaylight.mdsal.binding.util.Datastore.Configuration> tx)
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetDpnEndpointIpsOutput>>
getDpnEndpointIps(GetDpnEndpointIpsInput input)
Invokeget-dpn-endpoint-ips
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetDpnInfoOutput>>
getDpnInfo(GetDpnInfoInput input)
Invokeget-dpn-info
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetEgressActionsForTunnelOutput>>
getEgressActionsForTunnel(GetEgressActionsForTunnelInput input)
Invokeget-egress-actions-for-tunnel
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetExternalTunnelInterfaceNameOutput>>
getExternalTunnelInterfaceName(GetExternalTunnelInterfaceNameInput input)
Invokeget-external-tunnel-interface-name
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetInternalOrExternalInterfaceNameOutput>>
getInternalOrExternalInterfaceName(GetInternalOrExternalInterfaceNameInput input)
Invokeget-internal-or-external-interface-name
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetTepIpOutput>>
getTepIp(GetTepIpInput input)
Invokeget-tep-ip
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetTunnelInterfaceNameOutput>>
getTunnelInterfaceName(GetTunnelInterfaceNameInput input)
Invokeget-tunnel-interface-name
RPC.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)
Invokeget-tunnel-type
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetWatchPortForTunnelOutput>>
getWatchPortForTunnel(GetWatchPortForTunnelInput input)
Invokeget-watch-port-for-tunnel
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<IsDcgwPresentOutput>>
isDcgwPresent(IsDcgwPresentInput input)
Invokeis-dcgw-present
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<IsTunnelInternalOrExternalOutput>>
isTunnelInternalOrExternal(IsTunnelInternalOrExternalInput input)
Invokeis-tunnel-internal-or-external
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveExternalTunnelEndpointOutput>>
removeExternalTunnelEndpoint(RemoveExternalTunnelEndpointInput input)
Invokeremove-external-tunnel-endpoint
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveExternalTunnelFromDpnsOutput>>
removeExternalTunnelFromDpns(RemoveExternalTunnelFromDpnsInput input)
Invokeremove-external-tunnel-from-dpns
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveTerminatingServiceActionsOutput>>
removeTerminatingServiceActions(RemoveTerminatingServiceActionsInput input)
Invokeremove-terminating-service-actions
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<SetBfdParamOnTunnelOutput>>
setBfdParamOnTunnel(SetBfdParamOnTunnelInput input)
Invokeset-bfd-param-on-tunnel
RPC.void
start()
-
-
-
Constructor Detail
-
ItmManagerRpcService
@Inject public ItmManagerRpcService(org.opendaylight.mdsal.binding.api.DataBroker dataBroker, IMdsalApiManager mdsalManager, ItmConfig itmConfig, DPNTEPsInfoCache dpnTEPsInfoCache, IInterfaceManager interfaceManager, DpnTepStateCache dpnTepStateCache, TunnelStateCache tunnelStateCache, InterfaceManagerService interfaceManagerService, OvsBridgeRefEntryCache ovsBridgeRefEntryCache, DirectTunnelUtils directTunnelUtils, OfDpnTepConfigCache ofDpnTepConfigCache, OfTepStateCache ofTepStateCache)
-
-
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
Invokeget-tunnel-interface-name
RPC.used to retrieve tunnel interface id between Dpns
- Specified by:
getTunnelInterfaceName
in interfaceItmRpcService
- Parameters:
input
- ofget-tunnel-interface-name
- Returns:
- output of
get-tunnel-interface-name
-
getEgressActionsForTunnel
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetEgressActionsForTunnelOutput>> getEgressActionsForTunnel(GetEgressActionsForTunnelInput input)
Description copied from interface:ItmRpcService
Invokeget-egress-actions-for-tunnel
RPC.used to retrieve group actions to use from interface name
- Specified by:
getEgressActionsForTunnel
in interfaceItmRpcService
- Parameters:
input
- ofget-egress-actions-for-tunnel
- Returns:
- output of
get-egress-actions-for-tunnel
-
getTunnelType
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetTunnelTypeOutput>> getTunnelType(GetTunnelTypeInput input)
Description copied from interface:ItmRpcService
Invokeget-tunnel-type
RPC.to get the type of the tunnel interface(vxlan, vxlan-gpe, gre, etc.)
- Specified by:
getTunnelType
in interfaceItmRpcService
- Parameters:
input
- ofget-tunnel-type
- Returns:
- output of
get-tunnel-type
-
setBfdParamOnTunnel
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<SetBfdParamOnTunnelOutput>> setBfdParamOnTunnel(SetBfdParamOnTunnelInput input)
Description copied from interface:ItmRpcService
Invokeset-bfd-param-on-tunnel
RPC.used for turning ON/OFF to monitor individual tunnels
- Specified by:
setBfdParamOnTunnel
in interfaceItmRpcService
- Parameters:
input
- ofset-bfd-param-on-tunnel
- Returns:
- output of
set-bfd-param-on-tunnel
-
removeExternalTunnelEndpoint
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveExternalTunnelEndpointOutput>> removeExternalTunnelEndpoint(RemoveExternalTunnelEndpointInput input)
Description copied from interface:ItmRpcService
Invokeremove-external-tunnel-endpoint
RPC.used for building tunnels between teps on all Dpns and external node
- Specified by:
removeExternalTunnelEndpoint
in interfaceItmRpcService
- Parameters:
input
- ofremove-external-tunnel-endpoint
- Returns:
- output of
remove-external-tunnel-endpoint
-
removeExternalTunnelFromDpns
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveExternalTunnelFromDpnsOutput>> removeExternalTunnelFromDpns(RemoveExternalTunnelFromDpnsInput input)
Description copied from interface:ItmRpcService
Invokeremove-external-tunnel-from-dpns
RPC.used for building tunnels between a Dpn and external node
- Specified by:
removeExternalTunnelFromDpns
in interfaceItmRpcService
- Parameters:
input
- ofremove-external-tunnel-from-dpns
- Returns:
- output of
remove-external-tunnel-from-dpns
-
buildExternalTunnelFromDpns
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<BuildExternalTunnelFromDpnsOutput>> buildExternalTunnelFromDpns(BuildExternalTunnelFromDpnsInput input)
Description copied from interface:ItmRpcService
Invokebuild-external-tunnel-from-dpns
RPC.used for building tunnels between a Dpn and external node
- Specified by:
buildExternalTunnelFromDpns
in interfaceItmRpcService
- Parameters:
input
- ofbuild-external-tunnel-from-dpns
- Returns:
- output of
build-external-tunnel-from-dpns
-
addExternalTunnelEndpoint
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddExternalTunnelEndpointOutput>> addExternalTunnelEndpoint(AddExternalTunnelEndpointInput input)
Description copied from interface:ItmRpcService
Invokeadd-external-tunnel-endpoint
RPC.used for building tunnels between teps on all Dpns and external node
- Specified by:
addExternalTunnelEndpoint
in interfaceItmRpcService
- Parameters:
input
- ofadd-external-tunnel-endpoint
- Returns:
- output of
add-external-tunnel-endpoint
-
getExternalTunnelInterfaceName
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetExternalTunnelInterfaceNameOutput>> getExternalTunnelInterfaceName(GetExternalTunnelInterfaceNameInput input)
Description copied from interface:ItmRpcService
Invokeget-external-tunnel-interface-name
RPC.used to retrieve external tunnel interface id between Dpns/TORs
- Specified by:
getExternalTunnelInterfaceName
in interfaceItmRpcService
- Parameters:
input
- ofget-external-tunnel-interface-name
- Returns:
- output of
get-external-tunnel-interface-name
-
createTerminatingServiceActions
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<CreateTerminatingServiceActionsOutput>> createTerminatingServiceActions(CreateTerminatingServiceActionsInput input)
Description copied from interface:ItmRpcService
Invokecreate-terminating-service-actions
RPC.used for programming the terminating service actions
- Specified by:
createTerminatingServiceActions
in interfaceItmRpcService
- Parameters:
input
- ofcreate-terminating-service-actions
- Returns:
- output of
create-terminating-service-actions
-
removeTerminatingServiceActions
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveTerminatingServiceActionsOutput>> removeTerminatingServiceActions(RemoveTerminatingServiceActionsInput input)
Description copied from interface:ItmRpcService
Invokeremove-terminating-service-actions
RPC.used for removing the terminating service actions
- Specified by:
removeTerminatingServiceActions
in interfaceItmRpcService
- Parameters:
input
- ofremove-terminating-service-actions
- Returns:
- output of
remove-terminating-service-actions
-
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
Invokeget-internal-or-external-interface-name
RPC.used to retrieve tunnel interface id with src Dpn and destination ip/dpn
- Specified by:
getInternalOrExternalInterfaceName
in interfaceItmRpcService
- Parameters:
input
- ofget-internal-or-external-interface-name
- Returns:
- output of
get-internal-or-external-interface-name
-
deleteL2GwDevice
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<DeleteL2GwDeviceOutput>> deleteL2GwDevice(DeleteL2GwDeviceInput input)
Description copied from interface:ItmRpcService
Invokedelete-l2-gw-device
RPC.used for deleting tunnels between teps on all Dpns and hwVtep
- Specified by:
deleteL2GwDevice
in interfaceItmRpcService
- Parameters:
input
- ofdelete-l2-gw-device
- Returns:
- output of
delete-l2-gw-device
-
addL2GwDevice
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddL2GwDeviceOutput>> addL2GwDevice(AddL2GwDeviceInput input)
Description copied from interface:ItmRpcService
Invokeadd-l2-gw-device
RPC.used for building tunnels between teps on all Dpns and hwVtep
- Specified by:
addL2GwDevice
in interfaceItmRpcService
- Parameters:
input
- ofadd-l2-gw-device
- Returns:
- output of
add-l2-gw-device
-
getWatchPortForTunnel
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetWatchPortForTunnelOutput>> getWatchPortForTunnel(GetWatchPortForTunnelInput input)
Description copied from interface:ItmRpcService
Invokeget-watch-port-for-tunnel
RPC.retrieve the watch port for the BFD enabled point to point tunnel
- Specified by:
getWatchPortForTunnel
in interfaceItmRpcService
- Parameters:
input
- ofget-watch-port-for-tunnel
- Returns:
- output of
get-watch-port-for-tunnel
-
getTepIp
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetTepIpOutput>> getTepIp(GetTepIpInput input)
Description copied from interface:ItmRpcService
Invokeget-tep-ip
RPC.used to retrieve local tep ip to use from DPNID
- Specified by:
getTepIp
in interfaceItmRpcService
- Parameters:
input
- ofget-tep-ip
- Returns:
- output of
get-tep-ip
-
addL2GwMlagDevice
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddL2GwMlagDeviceOutput>> addL2GwMlagDevice(AddL2GwMlagDeviceInput input)
Description copied from interface:ItmRpcService
Invokeadd-l2-gw-mlag-device
RPC.used for building tunnels between teps on all Dpns and hwVtep
- Specified by:
addL2GwMlagDevice
in interfaceItmRpcService
- Parameters:
input
- ofadd-l2-gw-mlag-device
- Returns:
- output of
add-l2-gw-mlag-device
-
deleteL2GwMlagDevice
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<DeleteL2GwMlagDeviceOutput>> deleteL2GwMlagDevice(DeleteL2GwMlagDeviceInput input)
Description copied from interface:ItmRpcService
Invokedelete-l2-gw-mlag-device
RPC.used for deleting tunnels between teps on all Dpns and hwVtep
- Specified by:
deleteL2GwMlagDevice
in interfaceItmRpcService
- Parameters:
input
- ofdelete-l2-gw-mlag-device
- Returns:
- output of
delete-l2-gw-mlag-device
-
isTunnelInternalOrExternal
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<IsTunnelInternalOrExternalOutput>> isTunnelInternalOrExternal(IsTunnelInternalOrExternalInput input)
Description copied from interface:ItmRpcService
Invokeis-tunnel-internal-or-external
RPC.Used for determining whether tunnel is an internal or an external tunnel
- Specified by:
isTunnelInternalOrExternal
in interfaceItmRpcService
- Parameters:
input
- ofis-tunnel-internal-or-external
- Returns:
- output of
is-tunnel-internal-or-external
-
isDcgwPresent
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<IsDcgwPresentOutput>> isDcgwPresent(IsDcgwPresentInput input)
Description copied from interface:ItmRpcService
Invokeis-dcgw-present
RPC.Used for determining whether tunnel is an internal or an external tunnel
- Specified by:
isDcgwPresent
in interfaceItmRpcService
- Parameters:
input
- ofis-dcgw-present
- Returns:
- output of
is-dcgw-present
-
getDpnEndpointIps
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetDpnEndpointIpsOutput>> getDpnEndpointIps(GetDpnEndpointIpsInput input)
Description copied from interface:ItmRpcService
Invokeget-dpn-endpoint-ips
RPC.used to retrieve tunnel end point IPs of a Dpn
- Specified by:
getDpnEndpointIps
in interfaceItmRpcService
- Parameters:
input
- ofget-dpn-endpoint-ips
- Returns:
- output of
get-dpn-endpoint-ips
-
getDpnInfo
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetDpnInfoOutput>> getDpnInfo(GetDpnInfoInput input)
Description copied from interface:ItmRpcService
Invokeget-dpn-info
RPC.Gets the dpn id and tep ip information of compute nodes
- Specified by:
getDpnInfo
in interfaceItmRpcService
- Parameters:
input
- ofget-dpn-info
- Returns:
- output of
get-dpn-info
-
getDcGatewayIpList
public static java.util.Map<DcGatewayIpKey,DcGatewayIp> getDcGatewayIpList(org.opendaylight.mdsal.binding.util.TypedReadWriteTransaction<org.opendaylight.mdsal.binding.util.Datastore.Configuration> tx) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
- Throws:
java.util.concurrent.ExecutionException
java.lang.InterruptedException
-
-