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%2Fsal%2FNetconfDeviceRpc.java;h=48cbbb9dbc13d94bd12831dbc651478bcb94fe36;hb=68d52ef8ea8ee2ee6cda8bbc4a864c3fa897297e;hp=e34b885787709215c4c0777741c1c27c4262765d;hpb=e7abbe8b97f494030992ea8f9cc81a982695852b;p=netconf.git diff --git a/netconf/sal-netconf-connector/src/main/java/org/opendaylight/netconf/sal/connect/netconf/sal/NetconfDeviceRpc.java b/netconf/sal-netconf-connector/src/main/java/org/opendaylight/netconf/sal/connect/netconf/sal/NetconfDeviceRpc.java index e34b885787..48cbbb9dbc 100644 --- a/netconf/sal-netconf-connector/src/main/java/org/opendaylight/netconf/sal/connect/netconf/sal/NetconfDeviceRpc.java +++ b/netconf/sal-netconf-connector/src/main/java/org/opendaylight/netconf/sal/connect/netconf/sal/NetconfDeviceRpc.java @@ -7,92 +7,83 @@ */ package org.opendaylight.netconf.sal.connect.netconf.sal; -import com.google.common.base.Function; +import static java.util.Objects.requireNonNull; + import com.google.common.collect.Collections2; -import com.google.common.util.concurrent.CheckedFuture; +import com.google.common.util.concurrent.FutureCallback; import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.ListenableFuture; import com.google.common.util.concurrent.MoreExecutors; -import java.util.Collection; -import javax.annotation.Nonnull; -import javax.annotation.Nullable; -import org.opendaylight.controller.md.sal.dom.api.DOMRpcAvailabilityListener; -import org.opendaylight.controller.md.sal.dom.api.DOMRpcException; -import org.opendaylight.controller.md.sal.dom.api.DOMRpcIdentifier; -import org.opendaylight.controller.md.sal.dom.api.DOMRpcImplementationNotAvailableException; -import org.opendaylight.controller.md.sal.dom.api.DOMRpcResult; -import org.opendaylight.controller.md.sal.dom.api.DOMRpcService; -import org.opendaylight.controller.md.sal.dom.spi.DefaultDOMRpcResult; +import com.google.common.util.concurrent.SettableFuture; +import org.opendaylight.mdsal.dom.api.DOMRpcAvailabilityListener; +import org.opendaylight.mdsal.dom.api.DOMRpcIdentifier; +import org.opendaylight.mdsal.dom.api.DOMRpcImplementationNotAvailableException; +import org.opendaylight.mdsal.dom.api.DOMRpcResult; +import org.opendaylight.mdsal.dom.api.DefaultDOMRpcException; import org.opendaylight.netconf.api.NetconfMessage; -import org.opendaylight.netconf.sal.connect.api.MessageTransformer; import org.opendaylight.netconf.sal.connect.api.RemoteDeviceCommunicator; +import org.opendaylight.netconf.sal.connect.api.RemoteDeviceServices.Rpcs; +import org.opendaylight.netconf.sal.connect.api.RpcTransformer; import org.opendaylight.yangtools.concepts.ListenerRegistration; +import org.opendaylight.yangtools.concepts.NoOpListenerRegistration; +import org.opendaylight.yangtools.yang.common.QName; import org.opendaylight.yangtools.yang.common.RpcResult; -import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; -import org.opendaylight.yangtools.yang.model.api.SchemaContext; -import org.opendaylight.yangtools.yang.model.api.SchemaPath; +import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode; +import org.opendaylight.yangtools.yang.model.api.EffectiveModelContext; /** - * Invokes RPC by sending netconf message via listener. Also transforms result from NetconfMessage to CompositeNode. + * Invokes RPC by sending netconf message via listener. Also transforms result from NetconfMessage to + * {@link ContainerNode}. */ -public final class NetconfDeviceRpc implements DOMRpcService { - - private final RemoteDeviceCommunicator listener; - private final MessageTransformer transformer; - private final Collection availableRpcs; +public final class NetconfDeviceRpc implements Rpcs.Normalized { + private final RemoteDeviceCommunicator communicator; + private final RpcTransformer transformer; + private final EffectiveModelContext modelContext; - public NetconfDeviceRpc(final SchemaContext schemaContext, final RemoteDeviceCommunicator listener, - final MessageTransformer transformer) { - this.listener = listener; + public NetconfDeviceRpc(final EffectiveModelContext modelContext, final RemoteDeviceCommunicator communicator, + final RpcTransformer transformer) { + this.modelContext = requireNonNull(modelContext); + this.communicator = communicator; this.transformer = transformer; - - availableRpcs = Collections2.transform(schemaContext.getOperations(), - input -> DOMRpcIdentifier.create(input.getPath())); } - @Nonnull @Override - public CheckedFuture invokeRpc(@Nonnull final SchemaPath type, - @Nullable final NormalizedNode input) { - final NetconfMessage message = transformer.toRpcRequest(type, input); - final ListenableFuture> delegateFutureWithPureResult = - listener.sendRequest(message, type.getLastComponent()); + @SuppressWarnings("checkstyle:IllegalCatch") + public ListenableFuture invokeRpc(final QName type, final ContainerNode input) { + final ListenableFuture> delegateFuture = communicator.sendRequest( + transformer.toRpcRequest(type, input), type); - final ListenableFuture transformed = - Futures.transform(delegateFutureWithPureResult, input1 -> { - if (input1.isSuccessful()) { - return transformer.toRpcResult(input1.getResult(), type); - } else { - return new DefaultDOMRpcResult(input1.getErrors()); + final SettableFuture ret = SettableFuture.create(); + Futures.addCallback(delegateFuture, new FutureCallback>() { + @Override + public void onSuccess(final RpcResult result) { + final DOMRpcResult rpcResult; + try { + rpcResult = transformer.toRpcResult(result, type); + } catch (Exception cause) { + ret.setException(new DefaultDOMRpcException( + "Unable to parse rpc reply. type: " + type + " input: " + input, cause)); + return; } - }, MoreExecutors.directExecutor()); - return Futures.makeChecked(transformed, new Function() { - @Nullable + ret.set(rpcResult); + } + @Override - public DOMRpcException apply(@Nullable final Exception exception) { - return new DOMRpcImplementationNotAvailableException(exception, "Unable to invoke rpc %s", type); + public void onFailure(final Throwable cause) { + ret.setException(new DOMRpcImplementationNotAvailableException(cause, "Unable to invoke rpc %s", type)); } - }); + + }, MoreExecutors.directExecutor()); + return ret; } - @Nonnull @Override - public ListenerRegistration registerRpcListener( - @Nonnull final T listener) { + public ListenerRegistration registerRpcListener(final T listener) { + listener.onRpcAvailable(Collections2.transform(modelContext.getOperations(), + input -> DOMRpcIdentifier.create(input.getQName()))); - listener.onRpcAvailable(availableRpcs); - - return new ListenerRegistration() { - @Override - public void close() { - // NOOP, no rpcs appear and disappear in this implementation - } - - @Override - public T getInstance() { - return listener; - } - }; + // NOOP, no rpcs appear and disappear in this implementation + return NoOpListenerRegistration.of(listener); } }