X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2Fpersisted%2FAJE.java;fp=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2Fpersisted%2FAJE.java;h=4e39e9884c24bdae6b3e441a6bdd87a945c24c4b;hp=0000000000000000000000000000000000000000;hb=9a091425d16dadf09a5be4e764785707f5253013;hpb=10e35192bf210eeadcba20bd0c17a61bc8fd9716;ds=sidebyside diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/persisted/AJE.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/persisted/AJE.java new file mode 100644 index 0000000000..4e39e9884c --- /dev/null +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/persisted/AJE.java @@ -0,0 +1,51 @@ +/* + * Copyright (c) 2022 PANTHEON.tech, s.r.o. 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 com.google.common.base.Verify.verifyNotNull; +import static java.util.Objects.requireNonNull; + +import java.io.Externalizable; +import java.io.IOException; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import org.opendaylight.yangtools.concepts.WritableObjects; + +/** + * Serialization proxy for {@link ApplyJournalEntries}. + */ +final class AJE implements Externalizable { + @java.io.Serial + private static final long serialVersionUID = 1L; + + private ApplyJournalEntries applyEntries; + + @SuppressWarnings("checkstyle:RedundantModifier") + public AJE() { + // For Externalizable + } + + AJE(final ApplyJournalEntries applyEntries) { + this.applyEntries = requireNonNull(applyEntries); + } + + @Override + public void writeExternal(final ObjectOutput out) throws IOException { + WritableObjects.writeLong(out, applyEntries.getToIndex()); + } + + @Override + public void readExternal(final ObjectInput in) throws IOException { + applyEntries = new ApplyJournalEntries(WritableObjects.readLong(in)); + } + + @java.io.Serial + private Object readResolve() { + return verifyNotNull(applyEntries); + } +}