X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2Fmessages%2FAppendEntriesReplyTest.java;h=8452a71c24a1b14faf5525b9513eebf80bda1722;hb=refs%2Fchanges%2F09%2F83009%2F6;hp=4469c8ed16720a3b513bb681ee3d465b518e8a63;hpb=baa92613648863a7d839be36f89cc30431d5a66a;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/messages/AppendEntriesReplyTest.java b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/messages/AppendEntriesReplyTest.java index 4469c8ed16..8452a71c24 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/messages/AppendEntriesReplyTest.java +++ b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/messages/AppendEntriesReplyTest.java @@ -8,8 +8,10 @@ package org.opendaylight.controller.cluster.raft.messages; import static org.junit.Assert.assertEquals; + import org.apache.commons.lang.SerializationUtils; import org.junit.Test; +import org.opendaylight.controller.cluster.raft.RaftVersions; /** * Unit tests for AppendEntriesReply. @@ -20,7 +22,25 @@ public class AppendEntriesReplyTest { @Test public void testSerialization() { - AppendEntriesReply expected = new AppendEntriesReply("follower", 5, true, 100, 4, (short)6); + AppendEntriesReply expected = new AppendEntriesReply("follower", 5, true, 100, 4, (short)6, true, true, + RaftVersions.CURRENT_VERSION); + AppendEntriesReply cloned = (AppendEntriesReply) SerializationUtils.clone(expected); + + assertEquals("getTerm", expected.getTerm(), cloned.getTerm()); + assertEquals("getFollowerId", expected.getFollowerId(), cloned.getFollowerId()); + assertEquals("getLogLastTerm", expected.getLogLastTerm(), cloned.getLogLastTerm()); + assertEquals("getLogLastIndex", expected.getLogLastIndex(), cloned.getLogLastIndex()); + assertEquals("getPayloadVersion", expected.getPayloadVersion(), cloned.getPayloadVersion()); + assertEquals("getRaftVersion", expected.getRaftVersion(), cloned.getRaftVersion()); + assertEquals("isForceInstallSnapshot", expected.isForceInstallSnapshot(), cloned.isForceInstallSnapshot()); + assertEquals("isNeedsLeaderAddress", expected.isNeedsLeaderAddress(), cloned.isNeedsLeaderAddress()); + } + + @Test + @Deprecated + public void testPreFluorineSerialization() { + AppendEntriesReply expected = new AppendEntriesReply("follower", 5, true, 100, 4, (short)6, true, true, + RaftVersions.BORON_VERSION); AppendEntriesReply cloned = (AppendEntriesReply) SerializationUtils.clone(expected); assertEquals("getTerm", expected.getTerm(), cloned.getTerm()); @@ -29,5 +49,7 @@ public class AppendEntriesReplyTest { assertEquals("getLogLastIndex", expected.getLogLastIndex(), cloned.getLogLastIndex()); assertEquals("getPayloadVersion", expected.getPayloadVersion(), cloned.getPayloadVersion()); assertEquals("getRaftVersion", expected.getRaftVersion(), cloned.getRaftVersion()); + assertEquals("isForceInstallSnapshot", expected.isForceInstallSnapshot(), cloned.isForceInstallSnapshot()); + assertEquals("isNeedsLeaderAddress", false, cloned.isNeedsLeaderAddress()); } }