X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fnetconf%2Fnetconf-util%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fnetconf%2Futil%2Fmapping%2FAbstractNetconfOperation.java;h=6b12a1999270608264053c7edbf9ab1cc5bc6b55;hp=ba6364662cc5aae73bd0701e5084d263221c4575;hb=0692e55fe3536ab24a3f6c20e6f96dcd04315d9a;hpb=d6bcfc09131a675cdf198a3fb9b4fac653daf19b diff --git a/opendaylight/netconf/netconf-util/src/main/java/org/opendaylight/controller/netconf/util/mapping/AbstractNetconfOperation.java b/opendaylight/netconf/netconf-util/src/main/java/org/opendaylight/controller/netconf/util/mapping/AbstractNetconfOperation.java index ba6364662c..6b12a19992 100644 --- a/opendaylight/netconf/netconf-util/src/main/java/org/opendaylight/controller/netconf/util/mapping/AbstractNetconfOperation.java +++ b/opendaylight/netconf/netconf-util/src/main/java/org/opendaylight/controller/netconf/util/mapping/AbstractNetconfOperation.java @@ -8,12 +8,10 @@ package org.opendaylight.controller.netconf.util.mapping; -import java.util.Map; - import org.opendaylight.controller.netconf.api.NetconfDocumentedException; -import org.opendaylight.controller.netconf.api.NetconfOperationRouter; import org.opendaylight.controller.netconf.mapping.api.HandlingPriority; import org.opendaylight.controller.netconf.mapping.api.NetconfOperation; +import org.opendaylight.controller.netconf.mapping.api.NetconfOperationChainedExecution; import org.opendaylight.controller.netconf.util.xml.XmlElement; import org.opendaylight.controller.netconf.util.xml.XmlNetconfConstants; import org.opendaylight.controller.netconf.util.xml.XmlUtil; @@ -22,6 +20,8 @@ import org.w3c.dom.Document; import org.w3c.dom.Element; import org.w3c.dom.NodeList; +import java.util.Map; + public abstract class AbstractNetconfOperation implements NetconfOperation { private final String netconfSessionIdForReporting; @@ -64,19 +64,34 @@ public abstract class AbstractNetconfOperation implements NetconfOperation { XmlNetconfConstants.URN_IETF_PARAMS_XML_NS_NETCONF_BASE_1_0); } - protected abstract HandlingPriority canHandle(String operationName, String netconfOperationNamespace); + protected HandlingPriority canHandle(String operationName, String operationNamespace) { + return operationName.equals(getOperationName()) && operationNamespace.equals(getOperationNamespace()) + ? getHandlingPriority() + : HandlingPriority.CANNOT_HANDLE; + } + + protected HandlingPriority getHandlingPriority() { + return HandlingPriority.HANDLE_WITH_DEFAULT_PRIORITY; + } + + protected String getOperationNamespace() { + return XmlNetconfConstants.URN_IETF_PARAMS_XML_NS_NETCONF_BASE_1_0; + } + + protected abstract String getOperationName(); @Override - public final Document handle(Document message, NetconfOperationRouter opRouter) throws NetconfDocumentedException { + public Document handle(Document requestMessage, + NetconfOperationChainedExecution subsequentOperation) throws NetconfDocumentedException { - XmlElement requestElement = getRequestElementWithCheck(message); + XmlElement requestElement = getRequestElementWithCheck(requestMessage); Document document = XmlUtil.newDocument(); XmlElement operationElement = requestElement.getOnlyChildElement(); Map attributes = requestElement.getAttributes(); - Element response = handle(document, operationElement, opRouter); + Element response = handle(document, operationElement, subsequentOperation); Element rpcReply = document.createElementNS(XmlNetconfConstants.URN_IETF_PARAMS_XML_NS_NETCONF_BASE_1_0, XmlNetconfConstants.RPC_REPLY_KEY); @@ -98,11 +113,20 @@ public abstract class AbstractNetconfOperation implements NetconfOperation { return document; } - protected abstract Element handle(Document document, XmlElement operationElement, NetconfOperationRouter opRouter) + protected abstract Element handle(Document document, XmlElement message, NetconfOperationChainedExecution subsequentOperation) throws NetconfDocumentedException; @Override public String toString() { - return getClass() + "{" + netconfSessionIdForReporting + '}'; + final StringBuffer sb = new StringBuffer(getClass().getName()); + try { + sb.append("{name=").append(getOperationName()); + } catch(UnsupportedOperationException e) { + // no problem + } + sb.append(", namespace=").append(getOperationNamespace()); + sb.append(", session=").append(netconfSessionIdForReporting); + sb.append('}'); + return sb.toString(); } }