X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fnetconf%2Fsal-netconf-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fconnect%2Fnetconf%2Flistener%2FNetconfSessionPreferences.java;fp=opendaylight%2Fnetconf%2Fsal-netconf-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fconnect%2Fnetconf%2Flistener%2FNetconfSessionPreferences.java;h=0000000000000000000000000000000000000000;hp=7ff48e35f8be253321ff35afaa9b3e90f5dae36d;hb=9ba2b4eca79bcc0e78099b133296801c8d45a6c4;hpb=b2e81149739c87f0ecc2ce7f06448d7a5d3162b8 diff --git a/opendaylight/netconf/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/listener/NetconfSessionPreferences.java b/opendaylight/netconf/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/listener/NetconfSessionPreferences.java deleted file mode 100644 index 7ff48e35f8..0000000000 --- a/opendaylight/netconf/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/listener/NetconfSessionPreferences.java +++ /dev/null @@ -1,205 +0,0 @@ -/* - * Copyright (c) 2015 Cisco Systems, Inc. and others. All rights reserved. - * - * This program and the accompanying materials are made available under the - * terms of the Eclipse Public License v1.0 which accompanies this distribution, - * and is available at http://www.eclipse.org/legal/epl-v10.html - */ - -package org.opendaylight.controller.sal.connect.netconf.listener; - -import com.google.common.base.MoreObjects; -import com.google.common.base.Optional; -import com.google.common.base.Preconditions; -import com.google.common.base.Predicate; -import com.google.common.base.Splitter; -import com.google.common.collect.ImmutableSet; -import com.google.common.collect.Iterables; -import com.google.common.collect.Sets; -import java.net.URI; -import java.util.Collection; -import java.util.HashSet; -import java.util.Set; -import org.opendaylight.controller.netconf.client.NetconfClientSession; -import org.opendaylight.controller.sal.connect.netconf.util.NetconfMessageTransformUtil; -import org.opendaylight.yangtools.yang.common.QName; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -public final class NetconfSessionPreferences { - - private static final class ParameterMatcher { - private final Predicate predicate; - private final int skipLength; - - ParameterMatcher(final String name) { - predicate = new Predicate() { - @Override - public boolean apply(final String input) { - return input.startsWith(name); - } - }; - - this.skipLength = name.length(); - } - - private String from(final Iterable params) { - final Optional o = Iterables.tryFind(params, predicate); - if (!o.isPresent()) { - return null; - } - - return o.get().substring(skipLength); - } - } - - private static final Logger LOG = LoggerFactory.getLogger(NetconfSessionPreferences.class); - private static final ParameterMatcher MODULE_PARAM = new ParameterMatcher("module="); - private static final ParameterMatcher REVISION_PARAM = new ParameterMatcher("revision="); - private static final ParameterMatcher BROKEN_REVISON_PARAM = new ParameterMatcher("amp;revision="); - private static final Splitter AMP_SPLITTER = Splitter.on('&'); - private static final Predicate CONTAINS_REVISION = new Predicate() { - @Override - public boolean apply(final String input) { - return input.contains("revision="); - } - }; - - private final Set moduleBasedCaps; - private final Set nonModuleCaps; - - private NetconfSessionPreferences(final Set nonModuleCaps, final Set moduleBasedCaps) { - this.nonModuleCaps = Preconditions.checkNotNull(nonModuleCaps); - this.moduleBasedCaps = Preconditions.checkNotNull(moduleBasedCaps); - } - - public Set getModuleBasedCaps() { - return moduleBasedCaps; - } - - public Set getNonModuleCaps() { - return nonModuleCaps; - } - - public boolean containsNonModuleCapability(final String capability) { - return nonModuleCaps.contains(capability); - } - - public boolean containsModuleCapability(final QName capability) { - return moduleBasedCaps.contains(capability); - } - - @Override - public String toString() { - return MoreObjects.toStringHelper(this) - .add("capabilities", nonModuleCaps) - .add("moduleBasedCapabilities", moduleBasedCaps) - .add("rollback", isRollbackSupported()) - .add("monitoring", isMonitoringSupported()) - .add("candidate", isCandidateSupported()) - .add("writableRunning", isRunningWritable()) - .toString(); - } - - public boolean isRollbackSupported() { - return containsNonModuleCapability(NetconfMessageTransformUtil.NETCONF_ROLLBACK_ON_ERROR_URI.toString()); - } - - public boolean isCandidateSupported() { - return containsNonModuleCapability(NetconfMessageTransformUtil.NETCONF_CANDIDATE_URI.toString()); - } - - public boolean isRunningWritable() { - return containsNonModuleCapability(NetconfMessageTransformUtil.NETCONF_RUNNING_WRITABLE_URI.toString()); - } - - public boolean isNotificationsSupported() { - return containsNonModuleCapability(NetconfMessageTransformUtil.NETCONF_NOTIFICATONS_URI.toString()) - || containsModuleCapability(NetconfMessageTransformUtil.IETF_NETCONF_NOTIFICATIONS); - } - - public boolean isMonitoringSupported() { - return containsModuleCapability(NetconfMessageTransformUtil.IETF_NETCONF_MONITORING) - || containsNonModuleCapability(NetconfMessageTransformUtil.IETF_NETCONF_MONITORING.getNamespace().toString()); - } - - public NetconfSessionPreferences addModuleCaps(final NetconfSessionPreferences netconfSessionModuleCapabilities) { - final HashSet mergedCaps = Sets.newHashSetWithExpectedSize(moduleBasedCaps.size() + netconfSessionModuleCapabilities.getModuleBasedCaps().size()); - mergedCaps.addAll(moduleBasedCaps); - mergedCaps.addAll(netconfSessionModuleCapabilities.getModuleBasedCaps()); - return new NetconfSessionPreferences(getNonModuleCaps(), mergedCaps); - } - - public static NetconfSessionPreferences fromNetconfSession(final NetconfClientSession session) { - return fromStrings(session.getServerCapabilities()); - } - - private static QName cachedQName(final String namespace, final String revision, final String moduleName) { - return QName.cachedReference(QName.create(namespace, revision, moduleName)); - } - - private static QName cachedQName(final String namespace, final String moduleName) { - return QName.cachedReference(QName.create(URI.create(namespace), null, moduleName).withoutRevision()); - } - - public static NetconfSessionPreferences fromStrings(final Collection capabilities) { - final Set moduleBasedCaps = new HashSet<>(); - final Set nonModuleCaps = Sets.newHashSet(capabilities); - - for (final String capability : capabilities) { - final int qmark = capability.indexOf('?'); - if (qmark == -1) { - continue; - } - - final String namespace = capability.substring(0, qmark); - final Iterable queryParams = AMP_SPLITTER.split(capability.substring(qmark + 1)); - final String moduleName = MODULE_PARAM.from(queryParams); - if (moduleName == null) { - continue; - } - - String revision = REVISION_PARAM.from(queryParams); - if (revision != null) { - addModuleQName(moduleBasedCaps, nonModuleCaps, capability, cachedQName(namespace, revision, moduleName)); - continue; - } - - /* - * We have seen devices which mis-escape revision, but the revision may not - * even be there. First check if there is a substring that matches revision. - */ - if (Iterables.any(queryParams, CONTAINS_REVISION)) { - - LOG.debug("Netconf device was not reporting revision correctly, trying to get amp;revision="); - revision = BROKEN_REVISON_PARAM.from(queryParams); - if (revision == null) { - LOG.warn("Netconf device returned revision incorrectly escaped for {}, ignoring it", capability); - addModuleQName(moduleBasedCaps, nonModuleCaps, capability, cachedQName(namespace, moduleName)); - } else { - addModuleQName(moduleBasedCaps, nonModuleCaps, capability, cachedQName(namespace, revision, moduleName)); - } - continue; - } - - // Fallback, no revision provided for module - addModuleQName(moduleBasedCaps, nonModuleCaps, capability, cachedQName(namespace, moduleName)); - } - - return new NetconfSessionPreferences(ImmutableSet.copyOf(nonModuleCaps), ImmutableSet.copyOf(moduleBasedCaps)); - } - - - private static void addModuleQName(final Set moduleBasedCaps, final Set nonModuleCaps, final String capability, final QName qName) { - moduleBasedCaps.add(qName); - nonModuleCaps.remove(capability); - } - - private NetconfDeviceCapabilities capabilities = new NetconfDeviceCapabilities(); - - public NetconfDeviceCapabilities getNetconfDeviceCapabilities() { - return capabilities; - } - - -}