blob: 64565e6352b7e4929d0d016f09a3837f0a7ee224 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
|
package derms.replica1;
import derms.Replica;
import derms.ReplicaManager;
import derms.Request;
import derms.Response;
import derms.replica2.DermsLogger;
import derms.util.ThreadPool;
import java.io.IOException;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.logging.Logger;
public class Replica1 implements Replica {
private boolean alive = false;
private final ExecutorService pool;
private final Logger log;
private final InetAddress localAddr;
private final ResponderClient responderClient;
private final ReplicaManager replicaManager;
private boolean byzFailure;
public Replica1(ReplicaManager replicaManager) {
this.replicaManager = replicaManager;
pool = Executors.newFixedThreadPool(5);
try {
localAddr = InetAddress.getLocalHost();
} catch (UnknownHostException e) {
throw new RuntimeException(e);
}
responderClient = new ResponderClient("MTL");
try {
this.log = DermsLogger.getLogger(getClass());
} catch (IOException e) {
throw new RuntimeException(e);
}
}
@Override
public boolean isAlive() {
return alive;
}
@Override
public void startProcess(int byzantine, int crash) {
// [TEST] Detect crash
if (crash == 1) {
alive = false;
} else {
alive = true;
}
// [TEST] Detect byzantine failure
if (byzantine == 1) {
byzFailure = true;
} else {
byzFailure = false;
}
pool.execute(DERMSServer::new);
//alive = true;
log.info(getClass().getSimpleName() + " started.");
log.config("Local address is "+localAddr.toString());
}
@Override
public void processRequest(Request request) {
// [TEST] Simulate byzantine failure (return incorrect value)
if (byzFailure == true) {
Response response = new Response(request, replicaManager.getReplicaId(), "BYZANTINE FAILURE", false);
replicaManager.sendResponseToFE(response);
return;
}
String status = responderClient.addResource(
request.getResourceID(),
request.getResourceType(),
request.getDuration()
);
Response response = new Response(request.getSequenceNumber(), status);
log.info("Processed request " + request + "; response: " + response);
replicaManager.sendResponseToFE(response);
}
@Override
public void restart() {
log.info("Shutting down...");
ThreadPool.shutdown(pool, log);
alive = false;
log.info("Finished shutting down.");
// [TEST] Restart process without byzantine failure or crash
startProcess(0, 0);
}
@Override
public int getId() {
return 1;
}
}
|