X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fnetconf%2Fconfig-netconf-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fnetconf%2Fconfignetconfconnector%2Fmapping%2Fconfig%2FServiceRegistryWrapper.java;h=f86d641112585515198e9cbad18cce3c62a89389;hp=1f63555e83d93b57565ec44027114bd801eea0e1;hb=8720a3f3498bbc6fab675431f4200d26641a8ec8;hpb=7e0e35596dde2a0cbcf077b26f9797b6e0cdfa43 diff --git a/opendaylight/netconf/config-netconf-connector/src/main/java/org/opendaylight/controller/netconf/confignetconfconnector/mapping/config/ServiceRegistryWrapper.java b/opendaylight/netconf/config-netconf-connector/src/main/java/org/opendaylight/controller/netconf/confignetconfconnector/mapping/config/ServiceRegistryWrapper.java index 1f63555e83..f86d641112 100644 --- a/opendaylight/netconf/config-netconf-connector/src/main/java/org/opendaylight/controller/netconf/confignetconfconnector/mapping/config/ServiceRegistryWrapper.java +++ b/opendaylight/netconf/config-netconf-connector/src/main/java/org/opendaylight/controller/netconf/confignetconfconnector/mapping/config/ServiceRegistryWrapper.java @@ -7,47 +7,30 @@ */ package org.opendaylight.controller.netconf.confignetconfconnector.mapping.config; -import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Preconditions; import com.google.common.collect.Maps; -import com.google.common.collect.Sets; -import org.opendaylight.controller.config.api.ServiceReferenceReadableRegistry; -import org.opendaylight.yangtools.yang.common.QName; - +import java.util.Map; import javax.management.InstanceNotFoundException; import javax.management.ObjectName; -import java.util.Collection; -import java.util.Collections; -import java.util.Map; -import java.util.Set; +import org.opendaylight.controller.config.api.ServiceReferenceReadableRegistry; +import org.opendaylight.yangtools.yang.common.QName; public class ServiceRegistryWrapper { private ServiceReferenceReadableRegistry configServiceRefRegistry; - private long suffix = 1; - public ServiceRegistryWrapper(ServiceReferenceReadableRegistry configServiceRefRegistry) { this.configServiceRefRegistry = configServiceRefRegistry; } - public boolean hasRefName(String namespace, String serviceName, ObjectName on) { - String qname = configServiceRefRegistry.getServiceInterfaceName(namespace, serviceName); - Map forQName = configServiceRefRegistry.getServiceMapping().get(qname); - if(forQName==null){ - return false; - } - return forQName.values().contains(on); - } - public ObjectName getByServiceAndRefName(String namespace, String serviceName, String refName) { Map> serviceNameToRefNameToInstance = getMappedServices().get(namespace); - Preconditions.checkArgument(serviceNameToRefNameToInstance != null, "No serviceInstances mapped to " + namespace); + Preconditions.checkNotNull(serviceNameToRefNameToInstance, "No serviceInstances mapped to " + namespace); Map refNameToInstance = serviceNameToRefNameToInstance.get(serviceName); - Preconditions.checkArgument(refNameToInstance != null, "No serviceInstances mapped to " + serviceName + " , " + Preconditions.checkNotNull(refNameToInstance, "No serviceInstances mapped to " + serviceName + " , " + serviceNameToRefNameToInstance.keySet()); String instanceId = refNameToInstance.get(refName); @@ -102,50 +85,4 @@ public class ServiceRegistryWrapper { return retVal; } - - @VisibleForTesting - public String getNewDefaultRefName(String namespace, String serviceName, String moduleName, String instanceName) { - String refName; - refName = "ref_" + instanceName; - - Map> serviceNameToRefNameToInstance = getMappedServices().get(namespace); - - Map refNameToInstance; - if(serviceNameToRefNameToInstance == null || !serviceNameToRefNameToInstance.containsKey(serviceName)) { - refNameToInstance = Collections.emptyMap(); - } else { - refNameToInstance = serviceNameToRefNameToInstance.get(serviceName); - } - - final Set refNamesAsSet = toSet(refNameToInstance.keySet()); - if (refNamesAsSet.contains(refName)) { - refName = findAvailableRefName(refName, refNamesAsSet); - } - - return refName; - } - - - private Set toSet(Collection values) { - Set refNamesAsSet = Sets.newHashSet(); - - for (String refName : values) { - boolean resultAdd = refNamesAsSet.add(refName); - Preconditions.checkState(resultAdd, - "Error occurred building services element, reference name {} was present twice", refName); - } - - return refNamesAsSet; - } - - private String findAvailableRefName(String refName, Set refNamesAsSet) { - String availableRefName = ""; - - while (true) { - availableRefName = refName + "_" + suffix++; - if (!refNamesAsSet.contains(availableRefName)){ - return availableRefName; - } - } - } }