X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-dom-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Fdom%2Fbroker%2FBackwardsCompatibleMountPoint.java;h=9e1134ece2b1a1b7888d0b5663ed4229ceb1302e;hp=fb72b5a99a130efbcfcd0ea04056ef61978f2e06;hb=33c9769f6dd0dadd68e460c8f6d76a06b43bf146;hpb=a3ff4b68093e6d675a92159e0efa2525af32d644 diff --git a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/BackwardsCompatibleMountPoint.java b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/BackwardsCompatibleMountPoint.java index fb72b5a99a..9e1134ece2 100644 --- a/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/BackwardsCompatibleMountPoint.java +++ b/opendaylight/md-sal/sal-dom-broker/src/main/java/org/opendaylight/controller/sal/dom/broker/BackwardsCompatibleMountPoint.java @@ -11,10 +11,15 @@ import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Function; import com.google.common.base.Optional; import com.google.common.base.Preconditions; +import com.google.common.collect.Iterables; import com.google.common.util.concurrent.CheckedFuture; import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.JdkFutureAdapters; import com.google.common.util.concurrent.ListenableFuture; +import java.util.Map; +import java.util.Set; +import java.util.concurrent.ExecutionException; +import javax.annotation.Nullable; import org.opendaylight.controller.md.sal.common.api.RegistrationListener; import org.opendaylight.controller.md.sal.common.api.TransactionStatus; import org.opendaylight.controller.md.sal.common.api.data.DataCommitHandler; @@ -56,7 +61,6 @@ import org.opendaylight.controller.sal.core.api.notify.NotificationListener; import org.opendaylight.controller.sal.core.api.notify.NotificationPublishService; import org.opendaylight.controller.sal.dom.broker.impl.NotificationRouterImpl; import org.opendaylight.controller.sal.dom.broker.impl.SchemaAwareRpcBroker; -import org.opendaylight.controller.sal.dom.broker.impl.SchemaContextProvider; import org.opendaylight.controller.sal.dom.broker.spi.NotificationRouter; import org.opendaylight.controller.sal.dom.broker.util.ProxySchemaContext; import org.opendaylight.yangtools.concepts.ListenerRegistration; @@ -65,18 +69,13 @@ import org.opendaylight.yangtools.yang.common.QName; import org.opendaylight.yangtools.yang.common.RpcResult; import org.opendaylight.yangtools.yang.data.api.CompositeNode; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; -import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier.PathArgument; import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; import org.opendaylight.yangtools.yang.model.api.Module; import org.opendaylight.yangtools.yang.model.api.SchemaContext; import org.opendaylight.yangtools.yang.model.api.SchemaContextListener; +import org.opendaylight.yangtools.yang.model.api.SchemaContextProvider; -import javax.annotation.Nullable; -import java.util.List; -import java.util.Map; -import java.util.Set; -import java.util.concurrent.ExecutionException; - +@Deprecated public class BackwardsCompatibleMountPoint implements MountProvisionInstance, SchemaContextProvider, SchemaService { private final DataProviderService dataReader; @@ -285,12 +284,10 @@ public class BackwardsCompatibleMountPoint implements MountProvisionInstance, Sc class ReadWrapper implements DataReader { private YangInstanceIdentifier shortenPath(final YangInstanceIdentifier path) { - YangInstanceIdentifier ret = null; - if(mountPath.contains(path)) { - final List newArgs = path.getPath().subList(mountPath.getPath().size(), path.getPath().size()); - ret = YangInstanceIdentifier.create(newArgs); + if (!mountPath.contains(path)) { + return null; } - return ret; + return YangInstanceIdentifier.create(Iterables.skip(path.getPathArguments(), Iterables.size(mountPath.getPathArguments()))); } @Override @@ -405,8 +402,8 @@ public class BackwardsCompatibleMountPoint implements MountProvisionInstance, Sc return Futures.immediateCheckedFuture(normalizedNodeOptional); } - @Override public CheckedFuture exists(LogicalDatastoreType store, - YangInstanceIdentifier path) { + @Override public CheckedFuture exists(final LogicalDatastoreType store, + final YangInstanceIdentifier path) { try { return Futures.immediateCheckedFuture(read(store, path).get().isPresent()); @@ -527,8 +524,8 @@ public class BackwardsCompatibleMountPoint implements MountProvisionInstance, Sc return new BackwardsCompatibleReadTransaction(dataReader, dataNormalizer).read(store, path); } - @Override public CheckedFuture exists(LogicalDatastoreType store, - YangInstanceIdentifier path) { + @Override public CheckedFuture exists(final LogicalDatastoreType store, + final YangInstanceIdentifier path) { try { return Futures.immediateCheckedFuture(read(store, path).get().isPresent());