Mercurial > hg > Database > Christie

annotate src/main/java/christie/test/Paxos/ProposerCodeGear.java @ 107:825e01825ad3

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
update java11
author akahori
date Wed, 31 Oct 2018 11:04:55 +0900
parents b9dd655a54b9
children e1e919f12ed9
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
37
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
1 package christie.test.Paxos;
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
2
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
3
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
4 import christie.codegear.CodeGear;
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
5 import christie.codegear.CodeGearManager;
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
6 import christie.datagear.DataGearManager;
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
7 import java.util.concurrent.ConcurrentHashMap;
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
8
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
9 public class ProposerCodeGear extends CodeGear {
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
10
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
11 ConcurrentHashMap<String, DataGearManager> acceptors;
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
12
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
13 @Override
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
14 protected void run(CodeGearManager cgm) {
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
15
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
16 cgm.setup(new SendPrepareRequestCodeGear());
107
825e01825ad3 update java11
akahori
parents: 37
diff changeset
17 //put("acceptors", cgm.getRemoteDgmList());
37
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
18 put("sendProposal", new Proposal(cgm,cgm.cgmID));
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
19 put("promiseCount", 0);
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
20
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
21 }
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
22 }
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
23
b9dd655a54b9 add paxos Code
akahori
parents:
diff changeset
24