summaryrefslogtreecommitdiffstats
path: root/src/main/java/derms/ReplicaManager.java
diff options
context:
space:
mode:
authorBMatajsz <90217645+BMatajsz@users.noreply.github.com>2024-12-03 09:34:00 -0500
committerBMatajsz <90217645+BMatajsz@users.noreply.github.com>2024-12-03 09:34:00 -0500
commit44df5df0b65df279aaf471fa8258da218ed7c522 (patch)
treee0b2bc04e5f68d08043fb36b43a80fba1e9e075f /src/main/java/derms/ReplicaManager.java
parentd6067d28ce2a22c64cb595af6bca48c81b1664da (diff)
downloadsoen423-44df5df0b65df279aaf471fa8258da218ed7c522.zip
Added expected test results
Diffstat (limited to 'src/main/java/derms/ReplicaManager.java')
-rw-r--r--src/main/java/derms/ReplicaManager.java7
1 files changed, 5 insertions, 2 deletions
diff --git a/src/main/java/derms/ReplicaManager.java b/src/main/java/derms/ReplicaManager.java
index 1e89969..64ceb04 100644
--- a/src/main/java/derms/ReplicaManager.java
+++ b/src/main/java/derms/ReplicaManager.java
@@ -112,7 +112,7 @@ public class ReplicaManager {
informFrontEndRmIsDown(replica.getId());
replica.restart();
- TestLogger.log("REPLICA " + replicaId + ": {RESTARTED}");
+ //TestLogger.log("REPLICA " + replicaId + ": {RESTARTED}");
}
try {
Thread.sleep(5000); // Example 5 seconds.
@@ -139,7 +139,7 @@ public class ReplicaManager {
replica.restart();
informFrontEndRmHasBug(replica.getId());
- TestLogger.log("REPLICA " + replicaId + ": {RESTARTED}");
+ //TestLogger.log("REPLICA " + replicaId + ": {RESTARTED}");
}
private void informFrontEndRmIsDown(int replicaId) {
@@ -148,6 +148,7 @@ public class ReplicaManager {
out.writeObject("RM_DOWN:" + replicaId);
} catch (IOException e) {
log.severe("Failed to inform FE that RM is down: " + e.getMessage());
+ TestLogger.log("[FAILED TO INFORM FE (RM IS DOWN)]");
}
}
@@ -157,6 +158,7 @@ public class ReplicaManager {
out.writeObject("RM_BUG:" + replicaId);
} catch (IOException e) {
log.severe("Failed to inform FE that RM has a bug: " + e.getMessage());
+ TestLogger.log("[FAILED TO INFORM FE (RM HAS A BUG)]");
}
}
@@ -176,6 +178,7 @@ public class ReplicaManager {
System.out.println("ReplicaManager " + replicaId + " is running.");
} catch (IOException e) {
System.err.println("Failed to start ReplicaManager: " + e.getMessage());
+ TestLogger.log("[FAILED TO START RM]");
e.printStackTrace();
}
}