Switch current {ABI,DataStore,Payload}Version to Sodium SR1 09/84709/4
authorRobert Varga <robert.varga@pantheon.tech>
Wed, 25 Sep 2019 14:25:08 +0000 (16:25 +0200)
committerRobert Varga <robert.varga@pantheon.tech>
Wed, 25 Sep 2019 15:40:19 +0000 (17:40 +0200)
This mass-switches versioned resources to use Sodium SR1 streaming
format.

JIRA: CONTROLLER-1919
Change-Id: Ic712fa04e16c68481eeecccc61d8e6a7dfabac52
Signed-off-by: Robert Varga <robert.varga@pantheon.tech>
opendaylight/md-sal/cds-access-api/src/main/java/org/opendaylight/controller/cluster/access/ABIVersion.java
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DataStoreVersions.java
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/AbstractVersionedShardDataTreeSnapshot.java
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/MetadataShardDataTreeSnapshot.java
opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/persisted/PayloadVersion.java
opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/persisted/CommitTransactionPayloadTest.java
opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/persisted/ShardDataTreeSnapshotTest.java

index 90949db842bd6755ff13bd6331e83f99517d87ec..26093c1b23d36982079f3197b60b33aa1f665251 100644 (file)
@@ -117,7 +117,7 @@ public enum ABIVersion implements WritableObject {
      * @return Current {@link ABIVersion}
      */
     public static @NonNull ABIVersion current() {
      * @return Current {@link ABIVersion}
      */
     public static @NonNull ABIVersion current() {
-        return NEON_SR2;
+        return SODIUM_SR1;
     }
 
     /**
     }
 
     /**
index 40f06d10ac90df46d8fbaa74cc0933ac6069d077..79eedd3ef3e7511166b5dd4c9c00b0436ed6db95 100644 (file)
@@ -26,7 +26,7 @@ public final class DataStoreVersions {
     public static final short NEON_SR2_VERSION = 10;
     public static final short SODIUM_SR1_VERSION = 11;
     public static final short MAGNESIUM_VERSION = 12;
     public static final short NEON_SR2_VERSION = 10;
     public static final short SODIUM_SR1_VERSION = 11;
     public static final short MAGNESIUM_VERSION = 12;
-    public static final short CURRENT_VERSION = NEON_SR2_VERSION;
+    public static final short CURRENT_VERSION = SODIUM_SR1_VERSION;
 
     private DataStoreVersions() {
 
 
     private DataStoreVersions() {
 
index 9e6402cda96f32a8bbd822bcbab26cc84a3798c0..2712b24fa7933160d483031d8fbe065f188656dc 100644 (file)
@@ -31,8 +31,8 @@ abstract class AbstractVersionedShardDataTreeSnapshot extends ShardDataTreeSnaps
         final PayloadVersion version = PayloadVersion.readFrom(in);
         switch (version) {
             case BORON:
         final PayloadVersion version = PayloadVersion.readFrom(in);
         switch (version) {
             case BORON:
-                return new ShardSnapshotState(readSnapshot(in), true);
             case NEON_SR2:
             case NEON_SR2:
+                return new ShardSnapshotState(readSnapshot(in), true);
             case SODIUM_SR1:
             case MAGNESIUM:
                 return new ShardSnapshotState(readSnapshot(in), false);
             case SODIUM_SR1:
             case MAGNESIUM:
                 return new ShardSnapshotState(readSnapshot(in), false);
index 4af3bf77f78d0c78964e41bb373b5f41dd871129..2feb7b78a9ee7b56320195a1347b421f6db67ee5 100644 (file)
@@ -135,7 +135,7 @@ public final class MetadataShardDataTreeSnapshot extends AbstractVersionedShardD
 
     @Override
     PayloadVersion version() {
 
     @Override
     PayloadVersion version() {
-        return PayloadVersion.NEON_SR2;
+        return PayloadVersion.SODIUM_SR1;
     }
 
     private Object writeReplace() {
     }
 
     private Object writeReplace() {
index 921c9fca96cfc505f17a6b3be25564f3cad69163..af85a1336f4bf4b57772486dc4b129ba39eea963 100644 (file)
@@ -134,7 +134,7 @@ public enum PayloadVersion implements WritableObject {
      * @return Current {@link PayloadVersion}
      */
     public static @NonNull PayloadVersion current() {
      * @return Current {@link PayloadVersion}
      */
     public static @NonNull PayloadVersion current() {
-        return NEON_SR2;
+        return SODIUM_SR1;
     }
 
     /**
     }
 
     /**
index 0886d94fee0286ab0234cd4269e85794a00e0e8a..e0518a791bc0051f379cafc0b908c62c95518e05 100644 (file)
@@ -107,7 +107,7 @@ public class CommitTransactionPayloadTest extends AbstractTest {
     @Test
     public void testCandidateSerialization() throws IOException {
         final CommitTransactionPayload payload = CommitTransactionPayload.create(nextTransactionId(), candidate);
     @Test
     public void testCandidateSerialization() throws IOException {
         final CommitTransactionPayload payload = CommitTransactionPayload.create(nextTransactionId(), candidate);
-        assertEquals("payload size", 169, payload.size());
+        assertEquals("payload size", 156, payload.size());
     }
 
     @Test
     }
 
     @Test
index 9327f6262fea5d000e0692c33c728ac2d2afd23b..5adf2cb6bd1a0a3da93ebdecb234c0a8f62dc56c 100644 (file)
@@ -48,7 +48,7 @@ public class ShardDataTreeSnapshotTest {
         }
 
         final byte[] bytes = bos.toByteArray();
         }
 
         final byte[] bytes = bos.toByteArray();
-        assertEquals(242, bytes.length);
+        assertEquals(236, bytes.length);
 
         ShardDataTreeSnapshot deserialized;
         try (ObjectInputStream in = new ObjectInputStream(new ByteArrayInputStream(bytes))) {
 
         ShardDataTreeSnapshot deserialized;
         try (ObjectInputStream in = new ObjectInputStream(new ByteArrayInputStream(bytes))) {
@@ -77,7 +77,7 @@ public class ShardDataTreeSnapshotTest {
         }
 
         final byte[] bytes = bos.toByteArray();
         }
 
         final byte[] bytes = bos.toByteArray();
-        assertEquals(390, bytes.length);
+        assertEquals(384, bytes.length);
 
         ShardDataTreeSnapshot deserialized;
         try (ObjectInputStream in = new ObjectInputStream(new ByteArrayInputStream(bytes))) {
 
         ShardDataTreeSnapshot deserialized;
         try (ObjectInputStream in = new ObjectInputStream(new ByteArrayInputStream(bytes))) {