Mercurial > hg > Database > Alice
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 |
rev | line source |
---|---|
470 | 1 package alice.topology.node; |
2 | |
3 import java.util.List; | |
4 | |
5 import alice.codesegment.CloseEventCodeSegment; | |
6 import alice.datasegment.CommandType; | |
7 import alice.datasegment.DataSegment; | |
8 import alice.datasegment.Receiver; | |
9 | |
10 public class DeleteConnection extends CloseEventCodeSegment { | |
11 | |
12 private Receiver info = ids.create(CommandType.TAKE); | |
13 | |
14 public DeleteConnection() { | |
15 info.setKey("_CLIST"); | |
16 } | |
17 | |
18 @Override | |
19 public void run() { | |
473 | 20 String name = getConnectionInfo().nodeName; |
470 | 21 @SuppressWarnings("unchecked") |
22 List<String> list = info.asClass(List.class); | |
23 | |
24 if (list.contains(name)) | |
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 | 28 ods.put(info.key, list); |
29 } | |
30 | |
31 } |