X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fnetconf%2Fconfig-netconf-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fnetconf%2Fconfignetconfconnector%2Fosgi%2FNetconfOperationServiceImpl.java;h=902be44fd9d78847d218fea620993d411b099314;hb=26b333ab642abbdda8ef0e3b570083b47af00255;hp=1069858b4777008a321b7021beb172ca951675df;hpb=386d8f0ac5fa09ee5514d48284f1a4012f408b52;p=controller.git diff --git a/opendaylight/netconf/config-netconf-connector/src/main/java/org/opendaylight/controller/netconf/confignetconfconnector/osgi/NetconfOperationServiceImpl.java b/opendaylight/netconf/config-netconf-connector/src/main/java/org/opendaylight/controller/netconf/confignetconfconnector/osgi/NetconfOperationServiceImpl.java index 1069858b47..902be44fd9 100644 --- a/opendaylight/netconf/config-netconf-connector/src/main/java/org/opendaylight/controller/netconf/confignetconfconnector/osgi/NetconfOperationServiceImpl.java +++ b/opendaylight/netconf/config-netconf-connector/src/main/java/org/opendaylight/controller/netconf/confignetconfconnector/osgi/NetconfOperationServiceImpl.java @@ -8,11 +8,15 @@ package org.opendaylight.controller.netconf.confignetconfconnector.osgi; +import com.google.common.annotations.VisibleForTesting; +import com.google.common.base.Optional; +import com.google.common.base.Preconditions; +import com.google.common.collect.Sets; +import java.util.Collection; +import java.util.Collections; import java.util.HashSet; -import java.util.List; import java.util.Map; import java.util.Set; - import org.opendaylight.controller.config.api.LookupRegistry; import org.opendaylight.controller.config.util.ConfigRegistryJMXClient; import org.opendaylight.controller.config.yangjmxgenerator.ModuleMXBeanEntry; @@ -23,11 +27,6 @@ import org.opendaylight.controller.netconf.mapping.api.NetconfOperation; import org.opendaylight.controller.netconf.mapping.api.NetconfOperationService; import org.opendaylight.yangtools.yang.model.api.Module; -import com.google.common.annotations.VisibleForTesting; -import com.google.common.base.Optional; -import com.google.common.base.Preconditions; -import com.google.common.collect.Sets; - /** * Manages life cycle of {@link YangStoreSnapshot}. */ @@ -38,8 +37,8 @@ public class NetconfOperationServiceImpl implements NetconfOperationService { private final Set capabilities; private final TransactionProvider transactionProvider; - public NetconfOperationServiceImpl(YangStoreService yangStoreService, ConfigRegistryJMXClient jmxClient, - String netconfSessionIdForReporting) throws YangStoreException { + public NetconfOperationServiceImpl(final YangStoreService yangStoreService, final ConfigRegistryJMXClient jmxClient, + final String netconfSessionIdForReporting) throws YangStoreException { yangStoreSnapshot = yangStoreService.getYangStoreSnapshot(); checkConsistencyBetweenYangStoreAndConfig(jmxClient, yangStoreSnapshot); @@ -52,7 +51,7 @@ public class NetconfOperationServiceImpl implements NetconfOperationService { @VisibleForTesting - static void checkConsistencyBetweenYangStoreAndConfig(LookupRegistry jmxClient, YangStoreSnapshot yangStoreSnapshot) { + static void checkConsistencyBetweenYangStoreAndConfig(final LookupRegistry jmxClient, final YangStoreSnapshot yangStoreSnapshot) { Set missingModulesFromConfig = Sets.newHashSet(); Set modulesSeenByConfig = jmxClient.getAvailableModuleFactoryQNames(); @@ -91,12 +90,14 @@ public class NetconfOperationServiceImpl implements NetconfOperationService { return operationProvider.getOperations(); } - private static Set setupCapabilities(YangStoreSnapshot yangStoreSnapshot) { + private static Set setupCapabilities(final YangStoreSnapshot yangStoreSnapshot) { Set capabilities = new HashSet<>(); // [RFC6241] 8.3. Candidate Configuration Capability capabilities.add(new BasicCapability("urn:ietf:params:netconf:capability:candidate:1.0")); + + // TODO rollback on error not supported EditConfigXmlParser:100 // [RFC6241] 8.5. Rollback-on-Error Capability - capabilities.add(new BasicCapability("urn:ietf:params:netconf:capability:rollback-on-error:1.0")); + // capabilities.add(new BasicCapability("urn:ietf:params:netconf:capability:rollback-on-error:1.0")); Set modules = yangStoreSnapshot.getModules(); for (Module module : modules) { @@ -110,7 +111,7 @@ public class NetconfOperationServiceImpl implements NetconfOperationService { private final String capability; - private BasicCapability(String capability) { + private BasicCapability(final String capability) { this.capability = capability; } @@ -140,8 +141,8 @@ public class NetconfOperationServiceImpl implements NetconfOperationService { } @Override - public Optional> getLocation() { - return Optional.absent(); + public Collection getLocation() { + return Collections.emptyList(); } @Override @@ -157,7 +158,7 @@ public class NetconfOperationServiceImpl implements NetconfOperationService { private final String moduleName; private final String moduleNamespace; - public YangStoreCapability(Module module, String moduleContent) { + public YangStoreCapability(final Module module, final String moduleContent) { super(toCapabilityURI(module)); this.content = moduleContent; this.moduleName = module.getName(); @@ -170,7 +171,7 @@ public class NetconfOperationServiceImpl implements NetconfOperationService { return Optional.of(content); } - private static String toCapabilityURI(Module module) { + private static String toCapabilityURI(final Module module) { return String.valueOf(module.getNamespace()) + "?module=" + module.getName() + "&revision=" + Util.writeDate(module.getRevision()); }