Mercurial > hg > Database > Alice
diff src/main/java/alice/test/topology/share/CheckLocalIndex.java @ 419:aefbe41fcf12 dispose
change tab to space
author | sugi |
---|---|
date | Tue, 15 Jul 2014 16:00:22 +0900 |
parents | 8f71c3e6f11d |
children | 15eeb439830c 767d93626b88 |
line wrap: on
line diff
--- a/src/main/java/alice/test/topology/share/CheckLocalIndex.java Tue Jul 15 06:15:53 2014 +0900 +++ b/src/main/java/alice/test/topology/share/CheckLocalIndex.java Tue Jul 15 16:00:22 2014 +0900 @@ -8,37 +8,37 @@ public class CheckLocalIndex extends CodeSegment { - private Receiver data = ids.create(CommandType.PEEK); - private Receiver list = ids.create(CommandType.PEEK); - private Receiver host = ids.create(CommandType.PEEK); + private Receiver data = ids.create(CommandType.PEEK); + private Receiver list = ids.create(CommandType.PEEK); + private Receiver host = ids.create(CommandType.PEEK); + + + public CheckLocalIndex(String key, int index) { + this.host.setKey("host"); + this.list.setKey("_CLIST"); + this.data.setKey(key, index); + } - - public CheckLocalIndex(String key, int index) { - this.host.setKey("host"); - this.list.setKey("_CLIST"); - this.data.setKey(key, index); - } - - @Override - public void run() { - @SuppressWarnings("unchecked") - List<String> r = list.asClass(List.class); - int count = 0; - boolean flag = false; - for (String node : r) { - if (node.equals("parent")) { - flag = true; - } - if (!node.equals(this.data.from)) { - ods.update(node, data.key, data.getVal()); - count++; - } - } - if (count == 0 && flag) { - ods.put("parent", "data", data.getVal()); - } - new CheckLocalIndex(data.key, data.index); - - } + @Override + public void run() { + @SuppressWarnings("unchecked") + List<String> r = list.asClass(List.class); + int count = 0; + boolean flag = false; + for (String node : r) { + if (node.equals("parent")) { + flag = true; + } + if (!node.equals(this.data.from)) { + ods.update(node, data.key, data.getVal()); + count++; + } + } + if (count == 0 && flag) { + ods.put("parent", "data", data.getVal()); + } + new CheckLocalIndex(data.key, data.index); + + } }