X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fpersisted%2FAbstractIdentifiablePayload.java;h=de9b0bba8a3acd6668fd8c0c54b7edb4d9998092;hb=1d5ca4009be6c61d7b61989799037ad8f1ab7a75;hp=4ca35098c5b4d6189adf006ec3444de689397001;hpb=e66759266dc43d5f58b2837aca5047b42c205e4a;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/AbstractIdentifiablePayload.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/AbstractIdentifiablePayload.java index 4ca35098c5..de9b0bba8a 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/AbstractIdentifiablePayload.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/AbstractIdentifiablePayload.java @@ -7,9 +7,9 @@ */ package org.opendaylight.controller.cluster.datastore.persisted; +import static com.google.common.base.Verify.verifyNotNull; import static java.util.Objects.requireNonNull; -import com.google.common.base.Verify; import com.google.common.io.ByteStreams; import java.io.DataInput; import java.io.Externalizable; @@ -18,6 +18,7 @@ import java.io.ObjectInput; import java.io.ObjectOutput; import java.io.Serializable; import org.eclipse.jdt.annotation.NonNull; +import org.opendaylight.controller.cluster.raft.protobuff.client.messages.IdentifiablePayload; import org.opendaylight.controller.cluster.raft.protobuff.client.messages.Payload; import org.opendaylight.yangtools.concepts.Identifiable; import org.opendaylight.yangtools.concepts.Identifier; @@ -27,10 +28,11 @@ import org.opendaylight.yangtools.concepts.Identifier; * * @author Robert Varga */ -public abstract class AbstractIdentifiablePayload - extends Payload implements Identifiable, Serializable { +public abstract class AbstractIdentifiablePayload extends IdentifiablePayload + implements Serializable { protected abstract static class AbstractProxy implements Externalizable { private static final long serialVersionUID = 1L; + private byte[] serialized; private T identifier; @@ -53,11 +55,11 @@ public abstract class AbstractIdentifiablePayload final int length = in.readInt(); serialized = new byte[length]; in.readFully(serialized); - identifier = Verify.verifyNotNull(readIdentifier(ByteStreams.newDataInput(serialized))); + identifier = verifyNotNull(readIdentifier(ByteStreams.newDataInput(serialized))); } protected final Object readResolve() { - return Verify.verifyNotNull(createObject(identifier, serialized)); + return verifyNotNull(createObject(identifier, serialized)); } protected abstract @NonNull T readIdentifier(@NonNull DataInput in) throws IOException; @@ -67,8 +69,9 @@ public abstract class AbstractIdentifiablePayload } private static final long serialVersionUID = 1L; - private final byte[] serialized; - private final T identifier; + + private final byte @NonNull [] serialized; + private final @NonNull T identifier; AbstractIdentifiablePayload(final @NonNull T identifier, final byte @NonNull[] serialized) { this.identifier = requireNonNull(identifier); @@ -86,7 +89,7 @@ public abstract class AbstractIdentifiablePayload } protected final Object writeReplace() { - return Verify.verifyNotNull(externalizableProxy(serialized)); + return verifyNotNull(externalizableProxy(serialized)); } @SuppressWarnings("checkstyle:hiddenField")