X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fpersisted%2FAbstractVersionedShardDataTreeSnapshot.java;h=5e85434e4aa38bba477a3b64bc470a961be317f8;hb=99f80f27bee37bb23e345420bf14bb7bb4793c28;hp=96ab0ca5e6cb21c6342b4284c5ea7964b3880217;hpb=3f2f311927a45635339201f400652c145318e632;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/AbstractVersionedShardDataTreeSnapshot.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/AbstractVersionedShardDataTreeSnapshot.java index 96ab0ca5e6..5e85434e4a 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/AbstractVersionedShardDataTreeSnapshot.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/AbstractVersionedShardDataTreeSnapshot.java @@ -7,7 +7,8 @@ */ package org.opendaylight.controller.cluster.datastore.persisted; -import com.google.common.base.Verify; +import static com.google.common.base.Verify.verifyNotNull; + import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; @@ -30,17 +31,16 @@ abstract class AbstractVersionedShardDataTreeSnapshot extends ShardDataTreeSnaps static @NonNull ShardSnapshotState versionedDeserialize(final ObjectInput in) throws IOException { final PayloadVersion version = PayloadVersion.readFrom(in); switch (version) { - case BORON: - return new ShardSnapshotState(readSnapshot(in), true); - case NEON_SR2: case SODIUM_SR1: + return new ShardSnapshotState(readSnapshot(in), true); + case MAGNESIUM: return new ShardSnapshotState(readSnapshot(in), false); case TEST_FUTURE_VERSION: case TEST_PAST_VERSION: // These versions are never returned and this code is effectively dead default: // Not included as default in above switch to ensure we get warnings when new versions are added - throw new IOException("Encountered unhandled version" + version); + throw new IOException("Encountered unhandled version " + version); } } @@ -55,8 +55,8 @@ abstract class AbstractVersionedShardDataTreeSnapshot extends ShardDataTreeSnaps } @Override - public final Optional> getRootNode() { - return Optional.of(Verify.verifyNotNull(rootNode(), "Snapshot %s returned non-present root node", getClass())); + public final Optional getRootNode() { + return Optional.of(verifyNotNull(rootNode(), "Snapshot %s returned non-present root node", getClass())); } /** @@ -64,7 +64,7 @@ abstract class AbstractVersionedShardDataTreeSnapshot extends ShardDataTreeSnaps * * @return The root node. */ - abstract @NonNull NormalizedNode rootNode(); + abstract @NonNull NormalizedNode rootNode(); /** * Return the snapshot payload version. Implementations of this method should return a constant. @@ -75,10 +75,9 @@ abstract class AbstractVersionedShardDataTreeSnapshot extends ShardDataTreeSnaps private void versionedSerialize(final ObjectOutput out, final PayloadVersion version) throws IOException { switch (version) { - case BORON: - case NEON_SR2: case SODIUM_SR1: - // Boron, NeonSR2 and Sodium snapshots use Java Serialization, but differ in stream format + case MAGNESIUM: + // Sodium and Magnesium snapshots use Java Serialization, but differ in stream format out.writeObject(this); return; case TEST_FUTURE_VERSION: