Reset ReplyStore on submit, not on message delivery (reception)

dgomezferro · Sep 28, 2012 · b4685bc · b4685bc
1 parent 32de19c
commit b4685bc
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/src/main/java/com/yahoo/pasc/paxos/client/handlers/ReplyHandler.java b/src/main/java/com/yahoo/pasc/paxos/client/handlers/ReplyHandler.java
@@ -53,7 +53,6 @@ public List<Received.Descriptor> processMessage(Reply reply, ClientState state)
             byte[] value = store.getStableReply(quorum);
             if (value != null) {
                 descriptors = Arrays.asList(new Received.Descriptor(value));
-                state.setReplyStore(new ReplyStore(state.getServers()));
             }
         }
         return descriptors;

diff --git a/src/main/java/com/yahoo/pasc/paxos/client/handlers/SubmitHandler.java b/src/main/java/com/yahoo/pasc/paxos/client/handlers/SubmitHandler.java
@@ -22,6 +22,7 @@
 import com.yahoo.pasc.Message;
 import com.yahoo.pasc.MessageHandler;
 import com.yahoo.pasc.paxos.client.ClientState;
+import com.yahoo.pasc.paxos.client.ReplyStore;
 import com.yahoo.pasc.paxos.client.messages.Submit;
 import com.yahoo.pasc.paxos.messages.InlineRequest;
 import com.yahoo.pasc.paxos.messages.Request;
@@ -45,6 +46,7 @@ public List<Request> processMessage(Submit submit, ClientState state) {
         }
         state.setPendingRequest(request);
         state.setTimestamp(timestamp);
+        state.setReplyStore(new ReplyStore(state.getServers()));
         return Arrays.asList(request);
     }