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%2Fmessages%2FInstallSnapshot.java;h=f2f9cd39d81e9d5dd5d8d342f3cc7f018f7b0973;hp=5a0cc95c21964168f305445d129b9dfe3f7d6bbb;hb=252ba03242407ee584c38fafdbfa1c322e66151d;hpb=b3bf00226d83387a060d97a4f573377f07e93b5a diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/messages/InstallSnapshot.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/messages/InstallSnapshot.java index 5a0cc95c21..f2f9cd39d8 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/messages/InstallSnapshot.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/messages/InstallSnapshot.java @@ -8,22 +8,35 @@ package org.opendaylight.controller.cluster.raft.messages; +import com.google.common.base.Optional; import com.google.protobuf.ByteString; +import java.io.Externalizable; +import java.io.IOException; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import org.opendaylight.controller.cluster.raft.RaftVersions; import org.opendaylight.controller.protobuff.messages.cluster.raft.InstallSnapshotMessages; -public class InstallSnapshot extends AbstractRaftRPC { - +public class InstallSnapshot extends AbstractRaftRPC implements Externalizable { + private static final long serialVersionUID = 1L; public static final Class SERIALIZABLE_CLASS = InstallSnapshotMessages.InstallSnapshot.class; - private final String leaderId; - private final long lastIncludedIndex; - private final long lastIncludedTerm; - private final ByteString data; - private final int chunkIndex; - private final int totalChunks; + private String leaderId; + private long lastIncludedIndex; + private long lastIncludedTerm; + private byte[] data; + private int chunkIndex; + private int totalChunks; + private Optional lastChunkHashCode; + + /** + * Empty constructor to satisfy Externalizable. + */ + public InstallSnapshot() { + } public InstallSnapshot(long term, String leaderId, long lastIncludedIndex, - long lastIncludedTerm, ByteString data, int chunkIndex, int totalChunks) { + long lastIncludedTerm, byte[] data, int chunkIndex, int totalChunks, Optional lastChunkHashCode) { super(term); this.leaderId = leaderId; this.lastIncludedIndex = lastIncludedIndex; @@ -31,6 +44,12 @@ public class InstallSnapshot extends AbstractRaftRPC { this.data = data; this.chunkIndex = chunkIndex; this.totalChunks = totalChunks; + this.lastChunkHashCode = lastChunkHashCode; + } + + public InstallSnapshot(long term, String leaderId, long lastIncludedIndex, + long lastIncludedTerm, byte[] data, int chunkIndex, int totalChunks) { + this(term, leaderId, lastIncludedIndex, lastIncludedTerm, data, chunkIndex, totalChunks, Optional.absent()); } public String getLeaderId() { @@ -45,7 +64,7 @@ public class InstallSnapshot extends AbstractRaftRPC { return lastIncludedTerm; } - public ByteString getData() { + public byte[] getData() { return data; } @@ -57,26 +76,96 @@ public class InstallSnapshot extends AbstractRaftRPC { return totalChunks; } - public Object toSerializable(){ - return InstallSnapshotMessages.InstallSnapshot.newBuilder() - .setLeaderId(this.getLeaderId()) - .setChunkIndex(this.getChunkIndex()) - .setData(this.getData()) - .setLastIncludedIndex(this.getLastIncludedIndex()) - .setLastIncludedTerm(this.getLastIncludedTerm()) - .setTotalChunks(this.getTotalChunks()).build(); + public Optional getLastChunkHashCode() { + return lastChunkHashCode; + } + @Override + public void writeExternal(ObjectOutput out) throws IOException { + out.writeShort(RaftVersions.CURRENT_VERSION); + out.writeLong(getTerm()); + out.writeUTF(leaderId); + out.writeLong(lastIncludedIndex); + out.writeLong(lastIncludedTerm); + out.writeInt(chunkIndex); + out.writeInt(totalChunks); + + out.writeByte(lastChunkHashCode.isPresent() ? 1 : 0); + if(lastChunkHashCode.isPresent()) { + out.writeInt(lastChunkHashCode.get().intValue()); + } + + out.writeObject(data); } - public static InstallSnapshot fromSerializable (Object o) { - InstallSnapshotMessages.InstallSnapshot from = - (InstallSnapshotMessages.InstallSnapshot) o; + @Override + public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { + in.readShort(); // raft version - not currently used + setTerm(in.readLong()); + leaderId = in.readUTF(); + lastIncludedIndex = in.readLong(); + lastIncludedTerm = in.readLong(); + chunkIndex = in.readInt(); + totalChunks = in.readInt(); + + lastChunkHashCode = Optional.absent(); + boolean chunkHashCodePresent = in.readByte() == 1; + if(chunkHashCodePresent) { + lastChunkHashCode = Optional.of(in.readInt()); + } + + data = (byte[])in.readObject(); + } + + public Object toSerializable(short version) { + if(version >= RaftVersions.BORON_VERSION) { + return this; + } else { + InstallSnapshotMessages.InstallSnapshot.Builder builder = InstallSnapshotMessages.InstallSnapshot.newBuilder() + .setTerm(this.getTerm()) + .setLeaderId(this.getLeaderId()) + .setChunkIndex(this.getChunkIndex()) + .setData(ByteString.copyFrom(getData())) + .setLastIncludedIndex(this.getLastIncludedIndex()) + .setLastIncludedTerm(this.getLastIncludedTerm()) + .setTotalChunks(this.getTotalChunks()); + + if(lastChunkHashCode.isPresent()){ + builder.setLastChunkHashCode(lastChunkHashCode.get()); + } + return builder.build(); + } + } - InstallSnapshot installSnapshot = new InstallSnapshot(from.getTerm(), - from.getLeaderId(), from.getLastIncludedIndex(), - from.getLastIncludedTerm(), from.getData(), - from.getChunkIndex(), from.getTotalChunks()); + @Override + public String toString() { + return "InstallSnapshot [term=" + getTerm() + ", leaderId=" + leaderId + ", lastIncludedIndex=" + + lastIncludedIndex + ", lastIncludedTerm=" + lastIncludedTerm + ", datasize=" + data.length + + ", Chunk=" + chunkIndex + "/" + totalChunks + ", lastChunkHashCode=" + lastChunkHashCode + "]"; + } + + public static InstallSnapshot fromSerializable (Object o) { + if(o instanceof InstallSnapshot) { + return (InstallSnapshot)o; + } else { + InstallSnapshotMessages.InstallSnapshot from = + (InstallSnapshotMessages.InstallSnapshot) o; + + Optional lastChunkHashCode = Optional.absent(); + if(from.hasLastChunkHashCode()){ + lastChunkHashCode = Optional.of(from.getLastChunkHashCode()); + } + + InstallSnapshot installSnapshot = new InstallSnapshot(from.getTerm(), + from.getLeaderId(), from.getLastIncludedIndex(), + from.getLastIncludedTerm(), from.getData().toByteArray(), + from.getChunkIndex(), from.getTotalChunks(), lastChunkHashCode); + + return installSnapshot; + } + } - return installSnapshot; + public static boolean isSerializedType(Object message) { + return message instanceof InstallSnapshot || message instanceof InstallSnapshotMessages.InstallSnapshot; } }