annotate src/main/java/christie/topology/manager/TopologyFinish.java @ 272:b592fe1d4a4e default tip

create example Attendance
author matac42 <matac@cr.ie.u-ryukyu.ac.jp>
date Thu, 01 Jul 2021 20:41:07 +0900
parents 6eb548c188e5
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
43
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
1 package christie.topology.manager;
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
2
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
3 import christie.annotation.Peek;
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
4 import christie.annotation.Take;
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
5 import christie.codegear.CodeGear;
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
6 import christie.codegear.CodeGearManager;
176
6eb548c188e5 update add Message
akahori
parents: 127
diff changeset
7 import christie.topology.Message;
43
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
8
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
9
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
10 public class TopologyFinish extends CodeGear {
64
f884c1bd0d36 fix IncomingHosts and RecordTopology. and refactor.
akahori
parents: 60
diff changeset
11 @Take
176
6eb548c188e5 update add Message
akahori
parents: 127
diff changeset
12 Message FINISHMESSAGE;
64
f884c1bd0d36 fix IncomingHosts and RecordTopology. and refactor.
akahori
parents: 60
diff changeset
13
43
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
14 @Peek
60
cfd79a71f9cd refactor topology manager
akahori
parents: 52
diff changeset
15 TopologyManagerConfig topologyManagerConfig;
43
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
16
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
17 @Take
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
18 Long startTime;
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
19
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
20 @Override
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
21 protected void run(CodeGearManager cgm) {
127
42f195de3152 fix topologyManager
akahori
parents: 99
diff changeset
22 if (topologyManagerConfig.showTime) {
42f195de3152 fix topologyManager
akahori
parents: 99
diff changeset
23 System.out.println("TopologymanagerTime = " + (System.currentTimeMillis() - startTime));
42f195de3152 fix topologyManager
akahori
parents: 99
diff changeset
24 }
43
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
25
127
42f195de3152 fix topologyManager
akahori
parents: 99
diff changeset
26
42f195de3152 fix topologyManager
akahori
parents: 99
diff changeset
27 for(String dgm : cgm.getDGMList().keySet()){
176
6eb548c188e5 update add Message
akahori
parents: 127
diff changeset
28 getDGM(dgm).put("_CLOSEMESSEAGE", new Message());
127
42f195de3152 fix topologyManager
akahori
parents: 99
diff changeset
29 getDGM(dgm).shutdown();
43
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
30 }
127
42f195de3152 fix topologyManager
akahori
parents: 99
diff changeset
31
42f195de3152 fix topologyManager
akahori
parents: 99
diff changeset
32 getLocalDGM().finish();
42f195de3152 fix topologyManager
akahori
parents: 99
diff changeset
33
43
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
34 }
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
35
ea9657dc8311 add CreateHash SearchHostName TopologyManager
akahori
parents:
diff changeset
36 }