X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fconfig%2Fconfig-manager-facade-xml%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Ffacade%2Fxml%2FConfigSubsystemFacade.java;fp=opendaylight%2Fconfig%2Fconfig-manager-facade-xml%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Ffacade%2Fxml%2FConfigSubsystemFacade.java;h=4ee3c7ae6eb055834b11b25e0da9977fe9d9750e;hp=0f9e6f3ac02661d96417d560ddaca1132d38af2d;hb=20a32e6459fd1e27e7669bf1ebc7742b96787b94;hpb=b95285098ab2090d36095c69fc838d4df4d61300 diff --git a/opendaylight/config/config-manager-facade-xml/src/main/java/org/opendaylight/controller/config/facade/xml/ConfigSubsystemFacade.java b/opendaylight/config/config-manager-facade-xml/src/main/java/org/opendaylight/controller/config/facade/xml/ConfigSubsystemFacade.java index 0f9e6f3ac0..4ee3c7ae6e 100644 --- a/opendaylight/config/config-manager-facade-xml/src/main/java/org/opendaylight/controller/config/facade/xml/ConfigSubsystemFacade.java +++ b/opendaylight/config/config-manager-facade-xml/src/main/java/org/opendaylight/controller/config/facade/xml/ConfigSubsystemFacade.java @@ -10,17 +10,13 @@ package org.opendaylight.controller.config.facade.xml; import com.google.common.base.Optional; import com.google.common.collect.Multimap; - import java.io.Closeable; -import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Set; - import javax.management.InstanceNotFoundException; import javax.management.ObjectName; - import org.opendaylight.controller.config.api.ConflictingVersionException; import org.opendaylight.controller.config.api.ValidationException; import org.opendaylight.controller.config.api.jmx.CommitStatus; @@ -53,6 +49,7 @@ import org.opendaylight.controller.config.util.xml.XmlMappingConstants; import org.opendaylight.controller.config.util.xml.XmlUtil; import org.opendaylight.controller.config.yangjmxgenerator.ModuleMXBeanEntry; import org.opendaylight.controller.config.yangjmxgenerator.RuntimeBeanEntry; +import org.opendaylight.yangtools.yang.common.Revision; import org.opendaylight.yangtools.yang.model.api.IdentitySchemaNode; import org.opendaylight.yangtools.yang.model.api.Module; import org.slf4j.Logger; @@ -205,7 +202,7 @@ public class ConfigSubsystemFacade implements Closeable { setOnTransaction(ta, configExecution); } - private void setServicesOnTransaction(final ConfigTransactionClient ta, final ConfigExecution execution) + private static void setServicesOnTransaction(final ConfigTransactionClient ta, final ConfigExecution execution) throws DocumentedException { Services services = execution.getServices(); @@ -244,11 +241,12 @@ public class ConfigSubsystemFacade implements Closeable { } } - private String getQname(final ConfigTransactionClient ta, final String namespace, final String serviceName) { + private static String getQname(final ConfigTransactionClient ta, final String namespace, + final String serviceName) { return ta.getServiceInterfaceName(namespace, serviceName); } - private void setOnTransaction(final ConfigTransactionClient ta, final ConfigExecution execution) + private static void setOnTransaction(final ConfigTransactionClient ta, final ConfigExecution execution) throws DocumentedException { for (Multimap modulesToResolved : execution.getResolvedXmlElements(ta) @@ -268,8 +266,8 @@ public class ConfigSubsystemFacade implements Closeable { } } - private void handleMisssingInstancesOnTransaction(final ConfigTransactionClient ta, final ConfigExecution execution) - throws DocumentedException { + private static void handleMisssingInstancesOnTransaction(final ConfigTransactionClient ta, + final ConfigExecution execution) throws DocumentedException { for (Multimap modulesToResolved : execution.getModulesDefinition(ta) .values()) { @@ -289,18 +287,20 @@ public class ConfigSubsystemFacade implements Closeable { final YangStoreContext snapshot = yangStoreService.getCurrentSnapshot(); Map> factories = transformMbeToModuleConfigs( snapshot.getModuleMXBeanEntryMap()); - Map> identitiesMap = transformIdentities(snapshot.getModules()); + Map, IdentityMapping>> identitiesMap = + transformIdentities(snapshot.getModules()); return new Config(factories, identitiesMap, snapshot.getEnumResolver()); } - private static Map> transformIdentities(final Set modules) { - Map> mappedIds = new HashMap<>(); + private static Map, IdentityMapping>> transformIdentities( + final Set modules) { + Map, IdentityMapping>> mappedIds = new HashMap<>(); for (Module module : modules) { String namespace = module.getNamespace().toString(); - Map revisionsByNamespace = mappedIds.computeIfAbsent(namespace, + Map, IdentityMapping> revisionsByNamespace = mappedIds.computeIfAbsent(namespace, k -> new HashMap<>()); - Date revision = module.getRevision(); + Optional revision = Optional.fromJavaUtil(module.getRevision()); IdentityMapping identityMapping = revisionsByNamespace.computeIfAbsent(revision, k -> new IdentityMapping());