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-endpointRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddL2GwDeviceOutput>>addL2GwDevice(AddL2GwDeviceInput input)Invokeadd-l2-gw-deviceRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddL2GwMlagDeviceOutput>>addL2GwMlagDevice(AddL2GwMlagDeviceInput input)Invokeadd-l2-gw-mlag-deviceRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<BuildExternalTunnelFromDpnsOutput>>buildExternalTunnelFromDpns(BuildExternalTunnelFromDpnsInput input)Invokebuild-external-tunnel-from-dpnsRPC.voidclose()com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<CreateTerminatingServiceActionsOutput>>createTerminatingServiceActions(CreateTerminatingServiceActionsInput input)Invokecreate-terminating-service-actionsRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<DeleteL2GwDeviceOutput>>deleteL2GwDevice(DeleteL2GwDeviceInput input)Invokedelete-l2-gw-deviceRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<DeleteL2GwMlagDeviceOutput>>deleteL2GwMlagDevice(DeleteL2GwMlagDeviceInput input)Invokedelete-l2-gw-mlag-deviceRPC.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-ipsRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetDpnInfoOutput>>getDpnInfo(GetDpnInfoInput input)Invokeget-dpn-infoRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetEgressActionsForTunnelOutput>>getEgressActionsForTunnel(GetEgressActionsForTunnelInput input)Invokeget-egress-actions-for-tunnelRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetExternalTunnelInterfaceNameOutput>>getExternalTunnelInterfaceName(GetExternalTunnelInterfaceNameInput input)Invokeget-external-tunnel-interface-nameRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetInternalOrExternalInterfaceNameOutput>>getInternalOrExternalInterfaceName(GetInternalOrExternalInterfaceNameInput input)Invokeget-internal-or-external-interface-nameRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetTepIpOutput>>getTepIp(GetTepIpInput input)Invokeget-tep-ipRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetTunnelInterfaceNameOutput>>getTunnelInterfaceName(GetTunnelInterfaceNameInput input)Invokeget-tunnel-interface-nameRPC.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-typeRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetWatchPortForTunnelOutput>>getWatchPortForTunnel(GetWatchPortForTunnelInput input)Invokeget-watch-port-for-tunnelRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<IsDcgwPresentOutput>>isDcgwPresent(IsDcgwPresentInput input)Invokeis-dcgw-presentRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<IsTunnelInternalOrExternalOutput>>isTunnelInternalOrExternal(IsTunnelInternalOrExternalInput input)Invokeis-tunnel-internal-or-externalRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveExternalTunnelEndpointOutput>>removeExternalTunnelEndpoint(RemoveExternalTunnelEndpointInput input)Invokeremove-external-tunnel-endpointRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveExternalTunnelFromDpnsOutput>>removeExternalTunnelFromDpns(RemoveExternalTunnelFromDpnsInput input)Invokeremove-external-tunnel-from-dpnsRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveTerminatingServiceActionsOutput>>removeTerminatingServiceActions(RemoveTerminatingServiceActionsInput input)Invokeremove-terminating-service-actionsRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<SetBfdParamOnTunnelOutput>>setBfdParamOnTunnel(SetBfdParamOnTunnelInput input)Invokeset-bfd-param-on-tunnelRPC.voidstart()
-
-
-
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:ItmRpcServiceInvokeget-tunnel-interface-nameRPC.used to retrieve tunnel interface id between Dpns- Specified by:
getTunnelInterfaceNamein 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:ItmRpcServiceInvokeget-egress-actions-for-tunnelRPC.used to retrieve group actions to use from interface name- Specified by:
getEgressActionsForTunnelin 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:ItmRpcServiceInvokeget-tunnel-typeRPC.to get the type of the tunnel interface(vxlan, vxlan-gpe, gre, etc.)- Specified by:
getTunnelTypein 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:ItmRpcServiceInvokeset-bfd-param-on-tunnelRPC.used for turning ON/OFF to monitor individual tunnels- Specified by:
setBfdParamOnTunnelin 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:ItmRpcServiceInvokeremove-external-tunnel-endpointRPC.used for building tunnels between teps on all Dpns and external node- Specified by:
removeExternalTunnelEndpointin 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:ItmRpcServiceInvokeremove-external-tunnel-from-dpnsRPC.used for building tunnels between a Dpn and external node- Specified by:
removeExternalTunnelFromDpnsin 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:ItmRpcServiceInvokebuild-external-tunnel-from-dpnsRPC.used for building tunnels between a Dpn and external node- Specified by:
buildExternalTunnelFromDpnsin 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:ItmRpcServiceInvokeadd-external-tunnel-endpointRPC.used for building tunnels between teps on all Dpns and external node- Specified by:
addExternalTunnelEndpointin 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:ItmRpcServiceInvokeget-external-tunnel-interface-nameRPC.used to retrieve external tunnel interface id between Dpns/TORs- Specified by:
getExternalTunnelInterfaceNamein 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:ItmRpcServiceInvokecreate-terminating-service-actionsRPC.used for programming the terminating service actions- Specified by:
createTerminatingServiceActionsin 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:ItmRpcServiceInvokeremove-terminating-service-actionsRPC.used for removing the terminating service actions- Specified by:
removeTerminatingServiceActionsin 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:ItmRpcServiceInvokeget-internal-or-external-interface-nameRPC.used to retrieve tunnel interface id with src Dpn and destination ip/dpn- Specified by:
getInternalOrExternalInterfaceNamein 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:ItmRpcServiceInvokedelete-l2-gw-deviceRPC.used for deleting tunnels between teps on all Dpns and hwVtep- Specified by:
deleteL2GwDevicein 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:ItmRpcServiceInvokeadd-l2-gw-deviceRPC.used for building tunnels between teps on all Dpns and hwVtep- Specified by:
addL2GwDevicein 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:ItmRpcServiceInvokeget-watch-port-for-tunnelRPC.retrieve the watch port for the BFD enabled point to point tunnel- Specified by:
getWatchPortForTunnelin 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:ItmRpcServiceInvokeget-tep-ipRPC.used to retrieve local tep ip to use from DPNID- Specified by:
getTepIpin 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:ItmRpcServiceInvokeadd-l2-gw-mlag-deviceRPC.used for building tunnels between teps on all Dpns and hwVtep- Specified by:
addL2GwMlagDevicein 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:ItmRpcServiceInvokedelete-l2-gw-mlag-deviceRPC.used for deleting tunnels between teps on all Dpns and hwVtep- Specified by:
deleteL2GwMlagDevicein 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:ItmRpcServiceInvokeis-tunnel-internal-or-externalRPC.Used for determining whether tunnel is an internal or an external tunnel- Specified by:
isTunnelInternalOrExternalin 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:ItmRpcServiceInvokeis-dcgw-presentRPC.Used for determining whether tunnel is an internal or an external tunnel- Specified by:
isDcgwPresentin 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:ItmRpcServiceInvokeget-dpn-endpoint-ipsRPC.used to retrieve tunnel end point IPs of a Dpn- Specified by:
getDpnEndpointIpsin 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:ItmRpcServiceInvokeget-dpn-infoRPC.Gets the dpn id and tep ip information of compute nodes- Specified by:
getDpnInfoin 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.ExecutionExceptionjava.lang.InterruptedException
-
-