X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=netconf%2Fsal-netconf-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fnetconf%2Fsal%2Fconnect%2Fnetconf%2Futil%2FNetconfBaseOps.java;h=7564e755e72e4c32c1fb1565921fd7d3ec0f39aa;hb=f9b44acb9f0d688448fe1a4c19d792bfc5b059ab;hp=ac4033cbfcc9c97b3328d1f3aeb6c172e388ee3f;hpb=cc52b439ea3ef9c7663eacc700540de9312127c2;p=netconf.git diff --git a/netconf/sal-netconf-connector/src/main/java/org/opendaylight/netconf/sal/connect/netconf/util/NetconfBaseOps.java b/netconf/sal-netconf-connector/src/main/java/org/opendaylight/netconf/sal/connect/netconf/util/NetconfBaseOps.java index ac4033cbfc..7564e755e7 100644 --- a/netconf/sal-netconf-connector/src/main/java/org/opendaylight/netconf/sal/connect/netconf/util/NetconfBaseOps.java +++ b/netconf/sal-netconf-connector/src/main/java/org/opendaylight/netconf/sal/connect/netconf/util/NetconfBaseOps.java @@ -47,6 +47,8 @@ import org.opendaylight.netconf.sal.connect.netconf.sal.KeepaliveSalFacade.Keepa import org.opendaylight.netconf.sal.connect.netconf.sal.SchemalessNetconfDeviceRpc; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.netconf.base._1._0.rev110601.copy.config.input.target.ConfigTarget; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.netconf.base._1._0.rev110601.get.config.input.source.ConfigSource; +import org.opendaylight.yangtools.rcf8528.data.util.EmptyMountPointContext; +import org.opendaylight.yangtools.rfc8528.data.api.MountPointContext; import org.opendaylight.yangtools.yang.common.Empty; import org.opendaylight.yangtools.yang.common.QName; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; @@ -68,18 +70,23 @@ public final class NetconfBaseOps { private static final NodeIdentifier CONFIG_TARGET_NODEID = NodeIdentifier.create(ConfigTarget.QNAME); private final DOMRpcService rpc; - private final SchemaContext schemaContext; + private final MountPointContext mountContext; private final RpcStructureTransformer transformer; + @Deprecated public NetconfBaseOps(final DOMRpcService rpc, final SchemaContext schemaContext) { + this(rpc, new EmptyMountPointContext(schemaContext)); + } + + public NetconfBaseOps(final DOMRpcService rpc, final MountPointContext mountContext) { this.rpc = rpc; - this.schemaContext = schemaContext; + this.mountContext = mountContext; if (rpc instanceof KeepaliveDOMRpcService && ((KeepaliveDOMRpcService) rpc).getDeviceRpc() instanceof SchemalessNetconfDeviceRpc) { this.transformer = new SchemalessRpcStructureTransformer(); } else { - this.transformer = new NetconfRpcStructureTransformer(schemaContext); + this.transformer = new NetconfRpcStructureTransformer(mountContext); } } @@ -235,7 +242,8 @@ public final class NetconfBaseOps { requireNonNull(callback); final ListenableFuture future = rpc.invokeRpc(NETCONF_GET_PATH, isFilterPresent(filterPath) - ? NetconfMessageTransformUtil.wrap(NETCONF_GET_NODEID, toFilterStructure(filterPath.get(), schemaContext)) + ? NetconfMessageTransformUtil.wrap(NETCONF_GET_NODEID, + toFilterStructure(filterPath.get(), mountContext.getSchemaContext())) : NetconfMessageTransformUtil.GET_RPC_CONTENT); Futures.addCallback(future, callback, MoreExecutors.directExecutor()); return future;