X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-netconf-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fconnect%2Fnetconf%2Futil%2FNetconfBaseOps.java;fp=opendaylight%2Fmd-sal%2Fsal-netconf-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fconnect%2Fnetconf%2Futil%2FNetconfBaseOps.java;h=40e890e80cc4c5636ccfc0bec8855537d001bb9d;hb=3190d3dbe9438f94724a0296a9f0cb937491a094;hp=8ac8a48b45d7ad0b98717c93aa223a697ba55b6c;hpb=46c06195fd4c2ad4b1a2d26de3891e2459598410;p=controller.git diff --git a/opendaylight/md-sal/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/util/NetconfBaseOps.java b/opendaylight/md-sal/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/util/NetconfBaseOps.java index 8ac8a48b45..40e890e80c 100644 --- a/opendaylight/md-sal/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/util/NetconfBaseOps.java +++ b/opendaylight/md-sal/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/util/NetconfBaseOps.java @@ -174,33 +174,17 @@ public final class NetconfBaseOps { return getConfig(callback, NETCONF_CANDIDATE_QNAME, filterPath); } - public ListenableFuture> get(final FutureCallback> callback, final QName datastore, final Optional filterPath) { + public ListenableFuture> get(final FutureCallback> callback, final Optional filterPath) { Preconditions.checkNotNull(callback); - Preconditions.checkNotNull(datastore); final ListenableFuture> future; - if (filterPath.isPresent()) { - final Node node = toFilterStructure(filterPath.get()); - future = rpc.invokeRpc(NETCONF_GET_QNAME, - NetconfMessageTransformUtil.wrap(NETCONF_GET_QNAME, getSourceNode(datastore), node)); - } else { - future = rpc.invokeRpc(NETCONF_GET_QNAME, - NetconfMessageTransformUtil.wrap(NETCONF_GET_QNAME, getSourceNode(datastore))); - } + final Node node = filterPath.isPresent() ? toFilterStructure(filterPath.get()) : NetconfMessageTransformUtil.GET_RPC_CONTENT; + future = rpc.invokeRpc(NETCONF_GET_QNAME, NetconfMessageTransformUtil.wrap(NETCONF_GET_QNAME, node)); Futures.addCallback(future, callback); return future; } - public ListenableFuture> getRunning(final FutureCallback> callback, final Optional filterPath) { - return get(callback, NETCONF_RUNNING_QNAME, filterPath); - } - - public ListenableFuture> getCandidate(final FutureCallback> callback, final Optional filterPath) { - return get(callback, NETCONF_CANDIDATE_QNAME, filterPath); - } - - public ListenableFuture> editConfigCandidate(final FutureCallback> callback, final CompositeNode editStructure, final ModifyAction modifyAction, final boolean rollback) { return editConfig(callback, NETCONF_CANDIDATE_QNAME, editStructure, Optional.of(modifyAction), rollback); }