annotate src/main/java/alice/topology/node/DeleteConnection.java @ 473:041ec04d4d45 dispose

refactor
author sugi
date Sun, 30 Nov 2014 00:00:48 +0900 (2014-11-29)
parents be0b61986ff7
children cf345b10a21a
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
470
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
1 package alice.topology.node;
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
2
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
3 import java.util.List;
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
4
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
5 import alice.codesegment.CloseEventCodeSegment;
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
6 import alice.datasegment.CommandType;
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
7 import alice.datasegment.DataSegment;
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
8 import alice.datasegment.Receiver;
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
9
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
10 public class DeleteConnection extends CloseEventCodeSegment {
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
11
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
12 private Receiver info = ids.create(CommandType.TAKE);
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
13
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
14 public DeleteConnection() {
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
15 info.setKey("_CLIST");
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
16 }
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
17
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
18 @Override
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
19 public void run() {
473
041ec04d4d45 refactor
sugi
parents: 471
diff changeset
20 String name = getConnectionInfo().nodeName;
470
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
21 @SuppressWarnings("unchecked")
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
22 List<String> list = info.asClass(List.class);
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
23
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
24 if (list.contains(name))
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
25 list.remove(name);
471
be0b61986ff7 checking having DataSegmentManger before get DataSegmentManager
sugi
parents: 470
diff changeset
26 if (DataSegment.contains(name))
be0b61986ff7 checking having DataSegmentManger before get DataSegmentManager
sugi
parents: 470
diff changeset
27 DataSegment.get(name).shutdown();
470
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
28 ods.put(info.key, list);
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
29 }
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
30
780ae843cdac Delete disconnect managerKey from connection list
sugi
parents:
diff changeset
31 }