diff options
| author | Sam Anthony <sam@samanthony.xyz> | 2024-11-28 10:37:30 -0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-11-28 10:37:30 -0500 |
| commit | 0cae203edc71b0285d2971f9124f24cb543b8e39 (patch) | |
| tree | a16d0137d60d813c6ff06f2029ad8a935d2a804e /src/main/java/derms/ReplicaRunner.java | |
| parent | b7dabf61e2f4deea23c9a4cbf33da419d031c5e8 (diff) | |
| parent | fe384df239711ad0990e39d585e64292816bf24f (diff) | |
| download | soen423-0cae203edc71b0285d2971f9124f24cb543b8e39.zip | |
Merge pull request #1 from sam-rba/ReplicaManager
merge replicas
Diffstat (limited to 'src/main/java/derms/ReplicaRunner.java')
| -rw-r--r-- | src/main/java/derms/ReplicaRunner.java | 28 |
1 files changed, 28 insertions, 0 deletions
diff --git a/src/main/java/derms/ReplicaRunner.java b/src/main/java/derms/ReplicaRunner.java new file mode 100644 index 0000000..a17fbf1 --- /dev/null +++ b/src/main/java/derms/ReplicaRunner.java @@ -0,0 +1,28 @@ +package derms; +import derms.frontend.FEInterface; + +import java.io.IOException; + +public class ReplicaRunner { + public static void main(String[] args) { + if (args.length != 1) { + System.err.println("Usage: ReplicaManagerRunner <replica_id>"); + System.exit(1); + } + + int replicaId = Integer.parseInt(args[0]); + System.out.println("Starting ReplicaManager for Replica " + replicaId); + + try { + FEInterface frontEnd = new FE(); // Assume FE implements FEInterface + ReplicaManager replicaManager = new ReplicaManager(replicaId, frontEnd); + + // Simulate receiving and handling client requests + // Add logic to listen for client requests and forward them to replicaManager + + } catch (IOException e) { + System.err.println("Failed to start ReplicaManager: " + e.getMessage()); + e.printStackTrace(); + } + } +}
\ No newline at end of file |