Handle failure in ReplicaManager

1 files changed, 6 insertions, 1 deletions

diff --git a/src/main/java/derms/ReplicaManager.java b/src/main/java/derms/ReplicaManager.java
index 83c1897..6ff5de2 100644
--- a/src/main/java/derms/ReplicaManager.java
+++ b/src/main/java/derms/ReplicaManager.java
@@ -18,6 +18,7 @@ import java.net.NetworkInterface;
 import java.net.Socket;
 import java.io.ObjectOutputStream;
 import java.io.ObjectInputStream;
+import java.util.Objects;
 import java.util.logging.Logger;
 
 public class ReplicaManager {
@@ -77,7 +78,11 @@ public class ReplicaManager {
                     MessagePayload receivedPayload = multicastReceiver.receive();
                     Request request = (Request) receivedPayload;
                     log.info("Received request: " + request);
-                    replica.processRequest(request);
+                    if (Objects.equals(request.getMessageType(), "1" + replicaId)) {
+                        handleByzantineFailure();
+                    } else {
+                        replica.processRequest(request);
+                    }
                 } catch (InterruptedException e) {
                     log.severe("Failed to receive request: " + e.getMessage());
                     Thread.currentThread().interrupt();