/* * Copyright (c) 2017 Brocade Communications Systems, Inc. and others. All rights reserved. * * This program and the accompanying materials are made available under the * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ package org.opendaylight.controller.cluster.raft.persisted; import static org.junit.Assert.assertEquals; import java.util.List; import org.apache.commons.lang3.SerializationUtils; import org.junit.Test; import org.opendaylight.controller.cluster.raft.MockRaftActorContext.MockPayload; import org.opendaylight.controller.cluster.raft.ReplicatedLogEntry; /** * Unit tests for Snapshot. * * @author Thomas Pantelis */ public class SnapshotTest { @Test public void testSerialization() { testSerialization(new byte[]{1, 2, 3, 4, 5, 6, 7}, List.of( new SimpleReplicatedLogEntry(6, 2, new MockPayload("payload"))), 491); testSerialization(new byte[]{1, 2, 3, 4, 5, 6, 7, 8, 9}, List.of(), 345); } private static void testSerialization(final byte[] state, final List unapplied, final int expectedSize) { long lastIndex = 6; long lastTerm = 2; long lastAppliedIndex = 5; long lastAppliedTerm = 1; long electionTerm = 3; String electionVotedFor = "member-1"; ServerConfigurationPayload serverConfig = new ServerConfigurationPayload(List.of( new ServerInfo("1", true), new ServerInfo("2", false))); final var expected = Snapshot.create(ByteState.of(state), unapplied, lastIndex, lastTerm, lastAppliedIndex, lastAppliedTerm, electionTerm, electionVotedFor, serverConfig); final var bytes = SerializationUtils.serialize(expected); assertEquals(expectedSize, bytes.length); final var cloned = (Snapshot) SerializationUtils.deserialize(bytes); assertEquals("lastIndex", expected.getLastIndex(), cloned.getLastIndex()); assertEquals("lastTerm", expected.getLastTerm(), cloned.getLastTerm()); assertEquals("lastAppliedIndex", expected.getLastAppliedIndex(), cloned.getLastAppliedIndex()); assertEquals("lastAppliedTerm", expected.getLastAppliedTerm(), cloned.getLastAppliedTerm()); assertEquals("unAppliedEntries", expected.getUnAppliedEntries(), cloned.getUnAppliedEntries()); assertEquals("electionTerm", expected.getElectionTerm(), cloned.getElectionTerm()); assertEquals("electionVotedFor", expected.getElectionVotedFor(), cloned.getElectionVotedFor()); assertEquals("state", expected.getState(), cloned.getState()); assertEquals("serverConfig", expected.getServerConfiguration().getServerConfig(), cloned.getServerConfiguration().getServerConfig()); } }