Snapshot work

allengeorge · Apr 30, 2014 · f42996b · f42996b
1 parent a814e32
commit f42996b
Show file tree

Hide file tree

Showing 5 changed files with 107 additions and 103 deletions.
diff --git a/libraft-agent/src/main/java/io/libraft/agent/rpc/RaftNetworkClient.java b/libraft-agent/src/main/java/io/libraft/agent/rpc/RaftNetworkClient.java
@@ -472,7 +472,7 @@ public void snapshotChunk(String server, long term, long snapshotTerm, long snap
     }
 
     @Override
-    public void snapshotChunkReply(String server, long term, long snapshotTerm, long snapshotIndex, int nextExpectedSeqnum) throws RPCException {
+    public void snapshotChunkReply(String server, long term, long snapshotTerm, long snapshotIndex, int nextSeqnum) throws RPCException {
         // FIXME (AG): noop
     }
 }
diff --git a/libraft-core/src/main/java/io/libraft/algorithm/RPCReceiver.java b/libraft-core/src/main/java/io/libraft/algorithm/RPCReceiver.java
@@ -114,5 +114,5 @@ public interface RPCReceiver {
 
     void onSnapshotChunk(String server, long term, long snapshotTerm, long snapshotIndex, int seqnum, @Nullable InputStream chunkInputStream);
 
-    void onSnapshotChunkReply(String server, long term, long snapshotTerm, long snapshotIndex, int nextExpectedSeqnum);
+    void onSnapshotChunkReply(String server, long term, long snapshotTerm, long snapshotIndex, int nextSeqnum);
 }
diff --git a/libraft-core/src/main/java/io/libraft/algorithm/RPCSender.java b/libraft-core/src/main/java/io/libraft/algorithm/RPCSender.java
@@ -114,5 +114,5 @@ public interface RPCSender {
 
     void snapshotChunk(String server, long term, long snapshotTerm, long snapshotIndex, int seqnum, @Nullable InputStream chunkInputStream) throws RPCException;
 
-    void snapshotChunkReply(String server, long term, long snapshotTerm, long snapshotIndex, int nextExpectedSeqnum) throws RPCException;
+    void snapshotChunkReply(String server, long term, long snapshotTerm, long snapshotIndex, int nextSeqnum) throws RPCException;
 }