X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fcds-access-api%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Faccess%2Fcommands%2FReadTransactionSuccess.java;fp=opendaylight%2Fmd-sal%2Fcds-access-api%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Faccess%2Fcommands%2FReadTransactionSuccess.java;h=4f9734f060d4e51272366ed22c7bdec95e0d8b7e;hp=b65473aa381516f7fafc3d53af00113ea239d161;hb=f7833ed068d6fc7e5a38ede8c4edd6f371a5acfd;hpb=cd05b148126134dc5ed4f037f203ff260c1afa1a diff --git a/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/ReadTransactionSuccess.java b/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/ReadTransactionSuccess.java index b65473aa38..4f9734f060 100644 --- a/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/ReadTransactionSuccess.java +++ b/opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/commands/ReadTransactionSuccess.java @@ -10,15 +10,11 @@ package org.opendaylight.controller.cluster.access.commands; import static java.util.Objects.requireNonNull; import edu.umd.cs.findbugs.annotations.SuppressFBWarnings; -import java.io.IOException; -import java.io.ObjectInput; -import java.io.ObjectOutput; import java.util.Optional; import org.opendaylight.controller.cluster.access.ABIVersion; import org.opendaylight.controller.cluster.access.concepts.SliceableMessage; import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier; import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode; -import org.opendaylight.yangtools.yang.data.codec.binfmt.NormalizedNodeDataInput; /** * Successful reply to an {@link ReadTransactionRequest}. It indicates presence of requested data via @@ -26,35 +22,6 @@ import org.opendaylight.yangtools.yang.data.codec.binfmt.NormalizedNodeDataInput */ public final class ReadTransactionSuccess extends TransactionSuccess implements SliceableMessage { - interface SerialForm extends TransactionSuccess.SerialForm { - @Override - default ReadTransactionSuccess readExternal(final ObjectInput in, final TransactionIdentifier target, - final long sequence) throws IOException { - final Optional data; - if (in.readBoolean()) { - data = Optional.of(NormalizedNodeDataInput.newDataInput(in).readNormalizedNode()); - } else { - data = Optional.empty(); - } - return new ReadTransactionSuccess(target, sequence, data); - } - - @Override - default void writeExternal(final ObjectOutput out, final ReadTransactionSuccess msg) throws IOException { - TransactionSuccess.SerialForm.super.writeExternal(out, msg); - - final var data = msg.getData(); - if (data.isPresent()) { - out.writeBoolean(true); - try (var nnout = msg.getVersion().getStreamVersion().newDataOutput(out)) { - nnout.writeNormalizedNode(data.orElseThrow()); - } - } else { - out.writeBoolean(false); - } - } - } - @java.io.Serial private static final long serialVersionUID = 1L; @@ -77,8 +44,8 @@ public final class ReadTransactionSuccess extends TransactionSuccess