X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2Fmessages%2FRequestVote.java;h=2b33a12950620accf369300b23074710c8b5b3c2;hb=HEAD;hp=b23c76d06f9213d516f0f2a7345f85034c157333;hpb=4a3ba6c6695119ba041f358fca281b582c7665f1;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/messages/RequestVote.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/messages/RequestVote.java index b23c76d06f..2b33a12950 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/messages/RequestVote.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/messages/RequestVote.java @@ -7,15 +7,11 @@ */ package org.opendaylight.controller.cluster.raft.messages; -import java.io.Externalizable; -import java.io.IOException; -import java.io.ObjectInput; -import java.io.ObjectOutput; - /** * Invoked by candidates to gather votes (§5.2). */ public final class RequestVote extends AbstractRaftRPC { + @java.io.Serial private static final long serialVersionUID = -6967509186297108657L; // candidate requesting vote @@ -57,44 +53,6 @@ public final class RequestVote extends AbstractRaftRPC { @Override Object writeReplace() { - return new Proxy(this); - } - - private static class Proxy implements Externalizable { - private static final long serialVersionUID = 1L; - - private RequestVote requestVote; - - // checkstyle flags the public modifier as redundant which really doesn't make sense since it clearly isn't - // redundant. It is explicitly needed for Java serialization to be able to create instances via reflection. - @SuppressWarnings("checkstyle:RedundantModifier") - public Proxy() { - } - - Proxy(final RequestVote requestVote) { - this.requestVote = requestVote; - } - - @Override - public void writeExternal(final ObjectOutput out) throws IOException { - out.writeLong(requestVote.getTerm()); - out.writeObject(requestVote.candidateId); - out.writeLong(requestVote.lastLogIndex); - out.writeLong(requestVote.lastLogTerm); - } - - @Override - public void readExternal(final ObjectInput in) throws IOException, ClassNotFoundException { - long term = in.readLong(); - String candidateId = (String) in.readObject(); - long lastLogIndex = in.readLong(); - long lastLogTerm = in.readLong(); - - requestVote = new RequestVote(term, candidateId, lastLogIndex, lastLogTerm); - } - - private Object readResolve() { - return requestVote; - } + return new RV(this); } }