summaryrefslogtreecommitdiff
path: root/src/main/java/protocols
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/protocols')
-rw-r--r--src/main/java/protocols/VSAbstractProtocol.java31
-rw-r--r--src/main/java/protocols/implementations/VSRaftProtocol.java14
2 files changed, 43 insertions, 2 deletions
diff --git a/src/main/java/protocols/VSAbstractProtocol.java b/src/main/java/protocols/VSAbstractProtocol.java
index da12d31..ee0d6c2 100644
--- a/src/main/java/protocols/VSAbstractProtocol.java
+++ b/src/main/java/protocols/VSAbstractProtocol.java
@@ -180,8 +180,8 @@ abstract public class VSAbstractProtocol extends VSAbstractEvent {
* This method:
* <ul>
* <li>Filters out messages for other protocols</li>
- * <li>Ensures server/client initialization</li>
- * <li>Delegates to onServerRecv() or onClientRecv() based on context</li>
+ * <li>Routes messages to the active role(s) without double-delivering
+ * to dual-role peers</li>
* </ul>
*
* @param message the received message
@@ -192,6 +192,21 @@ abstract public class VSAbstractProtocol extends VSAbstractEvent {
if (isIncorrectProtocol(message))
return;
+ if (isServer && isClient) {
+ if (message.isServerMessage()) {
+ currentContextIsServer(false);
+ if (!isClientInitialized)
+ onInit();
+ onClientRecv(message);
+ } else {
+ currentContextIsServer(true);
+ if (!isServerInitialized)
+ onInit();
+ onServerRecv(message);
+ }
+ return;
+ }
+
if (isServer) {
currentContextIsServer(true);
if (!isServerInitialized)
@@ -226,6 +241,18 @@ abstract public class VSAbstractProtocol extends VSAbstractEvent {
if (isIncorrectProtocol(message))
return false;
+ return isRelevantMessageForContext(message);
+ }
+
+ /**
+ * Checks whether a message is relevant for this protocol instance.
+ * Subclasses can relax or specialize the default server/client routing
+ * rules while keeping the protocol-name filter intact.
+ *
+ * @param message the message to check
+ * @return true if the message should be processed by this protocol instance
+ */
+ protected boolean isRelevantMessageForContext(VSMessage message) {
if (message.isServerMessage()) {
if (!isClient)
return false;
diff --git a/src/main/java/protocols/implementations/VSRaftProtocol.java b/src/main/java/protocols/implementations/VSRaftProtocol.java
index c75628d..bad893c 100644
--- a/src/main/java/protocols/implementations/VSRaftProtocol.java
+++ b/src/main/java/protocols/implementations/VSRaftProtocol.java
@@ -103,6 +103,11 @@ public class VSRaftProtocol extends VSAbstractProtocol {
handleMessage(recvMessage);
}
+ @Override
+ protected boolean isRelevantMessageForContext(VSMessage message) {
+ return isServer() || isClient();
+ }
+
/* (non-Javadoc)
* @see protocols.VSAbstractProtocol#onServerSchedule()
*/
@@ -366,7 +371,10 @@ public class VSRaftProtocol extends VSAbstractProtocol {
heartbeatAck.setInteger("term", currentTerm);
heartbeatAck.setInteger("pid", process.getProcessID());
heartbeatAck.setInteger("targetPid", messageLeaderId);
+ boolean previousContextIsServer = currentContextIsServer();
+ currentContextIsServer(true);
sendMessage(heartbeatAck);
+ currentContextIsServer(previousContextIsServer);
}
/**
@@ -417,7 +425,10 @@ public class VSRaftProtocol extends VSAbstractProtocol {
voteResponse.setInteger("pid", process.getProcessID());
voteResponse.setBoolean("voteGranted", voteGranted);
voteResponse.setInteger("targetPid", candidateId);
+ boolean previousContextIsServer = currentContextIsServer();
+ currentContextIsServer(true);
sendMessage(voteResponse);
+ currentContextIsServer(previousContextIsServer);
}
/**
@@ -487,7 +498,10 @@ public class VSRaftProtocol extends VSAbstractProtocol {
appendAck.setInteger("pid", process.getProcessID());
appendAck.setInteger("logIndex", messageLogIndex);
appendAck.setInteger("targetPid", messageLeaderId);
+ boolean previousContextIsServer = currentContextIsServer();
+ currentContextIsServer(true);
sendMessage(appendAck);
+ currentContextIsServer(previousContextIsServer);
}
/**