annotate src/main/java/alice/topology/node/ClosedEventManager.java @ 647:e321c5ec9b58

fix toplogy manager; ring worked
author suruga
date Sun, 31 Dec 2017 19:32:27 +0900
parents 145c425db88d
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
469
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
1 package alice.topology.node;
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
2
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
3 import java.util.ArrayList;
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
4
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
5 import alice.codesegment.CodeSegment;
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
6 import alice.datasegment.CommandType;
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
7 import alice.datasegment.Receiver;
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
8
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 523
diff changeset
9 public class ClosedEventManager extends CodeSegment {
469
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
10
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
11 private Receiver info = ids.create(CommandType.PEEK);
506
sugi
parents: 470
diff changeset
12 private static ClosedEventManager instance = new ClosedEventManager();
469
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
13
506
sugi
parents: 470
diff changeset
14 private <T> ClosedEventManager() {
469
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
15 ods.put("_DEVENTLIST", new ArrayList<Class<T>>());
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
16 }
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
17
506
sugi
parents: 470
diff changeset
18 public static ClosedEventManager getInstance() {
469
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
19 return instance;
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
20 }
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
21
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 523
diff changeset
22 public void ceSetKey() {
469
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
23 ids.init();
470
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents: 469
diff changeset
24 info.setKey("_DISCONNECT");
469
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
25 }
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
26
523
145c425db88d add CompressedLDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 518
diff changeset
27 @SuppressWarnings("rawtypes")
469
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
28 @Override
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
29 public void run() {
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
30 new ExecuteEvent();
647
e321c5ec9b58 fix toplogy manager; ring worked
suruga
parents: 523
diff changeset
31 ceSetKey();
469
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
32 }
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
33
523
145c425db88d add CompressedLDSM
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents: 518
diff changeset
34 @SuppressWarnings("rawtypes")
469
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
35 public synchronized <T> void register(Class<T> clazz) {
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
36 ods.put("_REGISTERDEVENT", clazz);
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
37 new RegisterEvent();
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
38 }
b31b1d197c42 Add Disconnect Event Manager
sugi
parents:
diff changeset
39 }