import org.apache.felix.service.command.CommandSession;
import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.config.rev160406.vtep.config.schemas.VtepConfigSchema;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.tunnels_state.StateTunnelList;
void remExternalEndpoint(java.lang.Class<? extends TunnelTypeBase> tunType, IpAddress dcgwIP);
boolean validateIP(String ip);
+
+ Interface getInterface(String tunnelName);
}
import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry;
import org.opendaylight.genius.itm.api.IITMProvider;
+import org.opendaylight.genius.itm.cache.DpnTepStateCache;
import org.opendaylight.genius.itm.cli.TepCommandHelper;
import org.opendaylight.genius.itm.cli.TepException;
import org.opendaylight.genius.itm.globals.ITMConstants;
import org.opendaylight.mdsal.eos.binding.api.EntityOwnershipService;
import org.opendaylight.mdsal.eos.common.api.CandidateAlreadyRegisteredException;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.CreateIdPoolInput;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.CreateIdPoolInputBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService;
static short flag = 0;
private final TunnelMonitoringConfig tunnelMonitoringConfig;
private EntityOwnershipCandidateRegistration registryCandidate;
+ private final DpnTepStateCache dpnTepStateCache;
@Inject
public ItmProvider(DataBroker dataBroker,
VtepConfigSchemaListener vtepConfigSchemaListener,
OvsdbNodeListener ovsdbNodeListener,
TunnelMonitoringConfig tunnelMonitoringConfig,
- EntityOwnershipService entityOwnershipService) {
+ EntityOwnershipService entityOwnershipService,
+ DpnTepStateCache dpnTepStateCache) {
LOG.info("ItmProvider Before register MBean");
this.dataBroker = dataBroker;
this.idManager = idManagerService;
this.ovsdbChangeListener = ovsdbNodeListener;
this.tunnelMonitoringConfig = tunnelMonitoringConfig;
this.entityOwnershipService = entityOwnershipService;
+ this.dpnTepStateCache = dpnTepStateCache;
ITMBatchingUtils.registerWithBatchManager(this.dataBroker);
}
Matcher matcher = pattern.matcher(ip);
return matcher.matches();
}
+
+ @Override
+ public Interface getInterface(String tunnelName) {
+ return dpnTepStateCache.getInterfaceFromCache(tunnelName);
+ }
}