X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=netconf%2Fnetconf-topology-singleton%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fnetconf%2Ftopology%2Fsingleton%2Fimpl%2Fnetconf%2FProxyNetconfService.java;h=bfb6d295a6bf9229ec8b4d0a26b683398cb4d5e1;hb=1dba5b2651d7fc60af0263cc0640d5ebeda8e454;hp=7ecc5e0d2b46cd27834a4b19d6f740ca5dca9ab1;hpb=4f8fe6ca68115fecdb9ce43573af5a2e26c50b50;p=netconf.git diff --git a/netconf/netconf-topology-singleton/src/main/java/org/opendaylight/netconf/topology/singleton/impl/netconf/ProxyNetconfService.java b/netconf/netconf-topology-singleton/src/main/java/org/opendaylight/netconf/topology/singleton/impl/netconf/ProxyNetconfService.java index 7ecc5e0d2b..bfb6d295a6 100644 --- a/netconf/netconf-topology-singleton/src/main/java/org/opendaylight/netconf/topology/singleton/impl/netconf/ProxyNetconfService.java +++ b/netconf/netconf-topology-singleton/src/main/java/org/opendaylight/netconf/topology/singleton/impl/netconf/ProxyNetconfService.java @@ -15,7 +15,6 @@ import akka.dispatch.OnComplete; import akka.util.Timeout; import com.google.common.util.concurrent.ListenableFuture; import com.google.common.util.concurrent.SettableFuture; -import edu.umd.cs.findbugs.annotations.SuppressFBWarnings; import java.util.ArrayList; import java.util.Collection; import java.util.List; @@ -25,9 +24,9 @@ import org.checkerframework.checker.lock.qual.GuardedBy; import org.eclipse.jdt.annotation.NonNull; import org.opendaylight.mdsal.common.api.LogicalDatastoreType; import org.opendaylight.mdsal.dom.api.DOMRpcResult; -import org.opendaylight.netconf.api.ModifyAction; +import org.opendaylight.netconf.api.EffectiveOperation; import org.opendaylight.netconf.dom.api.NetconfDataTreeService; -import org.opendaylight.netconf.sal.connect.util.RemoteDeviceId; +import org.opendaylight.netconf.sal.connect.api.RemoteDeviceId; import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier; import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; import org.slf4j.Logger; @@ -129,7 +128,7 @@ public class ProxyNetconfService implements NetconfDataTreeService { @Override public ListenableFuture merge(final LogicalDatastoreType store, final YangInstanceIdentifier path, final NormalizedNode data, - final Optional defaultOperation) { + final Optional defaultOperation) { LOG.debug("{}: Merge {} {}", id, store, path); final SettableFuture returnFuture = SettableFuture.create(); processNetconfOperation(facade -> returnFuture.setFuture(facade.merge(store, path, data, defaultOperation))); @@ -139,7 +138,7 @@ public class ProxyNetconfService implements NetconfDataTreeService { @Override public ListenableFuture replace(final LogicalDatastoreType store, final YangInstanceIdentifier path, final NormalizedNode data, - final Optional defaultOperation) { + final Optional defaultOperation) { LOG.debug("{}: Replace {} {}", id, store, path); final SettableFuture returnFuture = SettableFuture.create(); processNetconfOperation(facade -> returnFuture.setFuture(facade.replace(store, path, data, defaultOperation))); @@ -149,7 +148,7 @@ public class ProxyNetconfService implements NetconfDataTreeService { @Override public ListenableFuture create(final LogicalDatastoreType store, final YangInstanceIdentifier path, final NormalizedNode data, - final Optional defaultOperation) { + final Optional defaultOperation) { LOG.debug("{}: Create {} {}", id, store, path); final SettableFuture returnFuture = SettableFuture.create(); processNetconfOperation(facade -> returnFuture.setFuture(facade.create(store, path, data, defaultOperation))); @@ -205,8 +204,6 @@ public class ProxyNetconfService implements NetconfDataTreeService { } } - @SuppressFBWarnings(value = "UPM_UNCALLED_PRIVATE_METHOD", - justification = "https://github.com/spotbugs/spotbugs/issues/811") private void executePriorNetconfOperations(final ProxyNetconfServiceFacade newNetconfFacade) { while (true) { // Access to queuedOperations and netconfFacade must be protected and atomic