X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2Fmessages%2FInstallSnapshotTest.java;fp=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2Fmessages%2FInstallSnapshotTest.java;h=a3da9594169af01290664a255e18d8d9e5fbd385;hp=b371ade4853d69ce8ad2b237fda815fa36098259;hb=9a091425d16dadf09a5be4e764785707f5253013;hpb=10e35192bf210eeadcba20bd0c17a61bc8fd9716 diff --git a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/messages/InstallSnapshotTest.java b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/messages/InstallSnapshotTest.java index b371ade485..a3da959416 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/messages/InstallSnapshotTest.java +++ b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/messages/InstallSnapshotTest.java @@ -10,8 +10,7 @@ package org.opendaylight.controller.cluster.raft.messages; import static org.junit.Assert.assertArrayEquals; import static org.junit.Assert.assertEquals; -import java.io.Serializable; -import java.util.Arrays; +import java.util.List; import java.util.Optional; import java.util.OptionalInt; import org.apache.commons.lang.SerializationUtils; @@ -26,7 +25,6 @@ import org.opendaylight.controller.cluster.raft.persisted.ServerInfo; * @author Thomas Pantelis */ public class InstallSnapshotTest { - @Test public void testSerialization() { byte[] data = new byte[1000]; @@ -37,25 +35,19 @@ public class InstallSnapshotTest { } } - ServerConfigurationPayload serverConfig = new ServerConfigurationPayload(Arrays.asList( + ServerConfigurationPayload serverConfig = new ServerConfigurationPayload(List.of( new ServerInfo("leader", true), new ServerInfo("follower", false))); - InstallSnapshot expected = new InstallSnapshot(3L, "leaderId", 11L, 2L, data, 5, 6, OptionalInt.of(54321), - Optional.of(serverConfig)); - - Object serialized = expected.toSerializable(RaftVersions.CURRENT_VERSION); - assertEquals("Serialized type", InstallSnapshot.class, serialized.getClass()); + assertInstallSnapshot(1302, new InstallSnapshot(3L, "leaderId", 11L, 2L, data, 5, 6, OptionalInt.of(54321), + Optional.of(serverConfig), RaftVersions.CURRENT_VERSION)); - var bytes = SerializationUtils.serialize((Serializable) serialized); - assertEquals(1302, bytes.length); - var actual = (InstallSnapshot) SerializationUtils.deserialize(bytes); - - verifyInstallSnapshot(expected, actual); + assertInstallSnapshot(1165, new InstallSnapshot(3L, "leaderId", 11L, 2L, data, 5, 6, OptionalInt.empty(), + Optional.empty(), RaftVersions.CURRENT_VERSION)); + } - expected = new InstallSnapshot(3L, "leaderId", 11L, 2L, data, 5, 6); - bytes = SerializationUtils.serialize((Serializable) expected.toSerializable(RaftVersions.CURRENT_VERSION)); - assertEquals(1165, bytes.length); - actual = (InstallSnapshot) SerializationUtils.deserialize(bytes); - verifyInstallSnapshot(expected, actual); + private static void assertInstallSnapshot(final int expectedSize, final InstallSnapshot expected) { + final var bytes = SerializationUtils.serialize(expected); + assertEquals(expectedSize, bytes.length); + verifyInstallSnapshot(expected, (InstallSnapshot) SerializationUtils.deserialize(bytes)); } private static void verifyInstallSnapshot(final InstallSnapshot expected, final InstallSnapshot actual) {