Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

Rename getOutputMessages()

  • Loading branch information...
commit ab193a0bb20b6641584595c4d0d4d77695a22fd1 1 parent b7887b2
@dgomezferro authored
View
2  src/main/java/com/yahoo/pasc/paxos/client/handlers/AsyncMessageHandler.java
@@ -64,7 +64,7 @@ public boolean guardPredicate(AsyncMessage receivedMessage) {
}
@Override
- public List<Message> getSendMessages(ClientState state, List<Received.Descriptor> descriptors) {
+ public List<Message> getOutputMessages(ClientState state, List<Received.Descriptor> descriptors) {
if (descriptors != null && descriptors.size() > 0) {
return Arrays.<Message> asList(new Received(descriptors.get(0).getValue()));
}
View
2  src/main/java/com/yahoo/pasc/paxos/client/handlers/HelloHandler.java
@@ -46,7 +46,7 @@ public boolean guardPredicate(Hello receivedMessage) {
}
@Override
- public List<Message> getSendMessages(ClientState state, List<Connected> descriptors) {
+ public List<Message> getOutputMessages(ClientState state, List<Connected> descriptors) {
if (descriptors != null && descriptors.size() > 0) {
return Arrays.<Message> asList(new Connected());
}
View
2  src/main/java/com/yahoo/pasc/paxos/client/handlers/ReplyHandler.java
@@ -65,7 +65,7 @@ public boolean guardPredicate(Reply receivedMessage) {
}
@Override
- public List<Message> getSendMessages(ClientState state, List<Received.Descriptor> descriptors) {
+ public List<Message> getOutputMessages(ClientState state, List<Received.Descriptor> descriptors) {
if (descriptors != null && descriptors.size() > 0) {
return Arrays.<Message> asList(new Received(descriptors.get(0).getValue()));
}
View
2  src/main/java/com/yahoo/pasc/paxos/client/handlers/SubmitHandler.java
@@ -49,7 +49,7 @@ public boolean guardPredicate(Submit receivedMessage) {
}
@Override
- public List<Message> getSendMessages(ClientState state, List<Request> messages) {
+ public List<Message> getOutputMessages(ClientState state, List<Request> messages) {
return Arrays.<Message>asList(messages.get(0));
}
}
View
2  src/main/java/com/yahoo/pasc/paxos/client/handlers/TimeoutHandler.java
@@ -42,7 +42,7 @@ public boolean guardPredicate(Timeout receivedMessage) {
}
@Override
- public List<Message> getSendMessages(ClientState state, List<Request> messages) {
+ public List<Message> getOutputMessages(ClientState state, List<Request> messages) {
if (messages != null && messages.size() > 0) {
return Arrays.<Message>asList(messages.get(0));
}
View
2  src/main/java/com/yahoo/pasc/paxos/handlers/PaxosHandler.java
@@ -34,7 +34,7 @@ public boolean guardPredicate(M receivedMessage) {
};
@Override
- public List<Message> getSendMessages(PaxosState state, List<PaxosDescriptor> descriptors) {
+ public List<Message> getOutputMessages(PaxosState state, List<PaxosDescriptor> descriptors) {
if (descriptors == null)
return null;
Please sign in to comment.
Something went wrong with that request. Please try again.