blob: 7e10994496939290b3c7ed76967d2908a8ae025d (
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
|
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;
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) {
pool.execute(DERMSServer::new);
alive = true;
log.info(getClass().getSimpleName() + " started.");
log.config("Local address is "+localAddr.toString());
}
@Override
public void processRequest(Request request) {
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.");
startProcess(0, 0);
}
@Override
public int getId() {
return 1;
}
}
|