# HG changeset patch # User one # Date 1372334673 -32400 # Node ID 6dc6b25021a3eacbcc7beaf60a9b178c34c84f33 # Parent f3c0a65c3f124408ed26d0c7285229354770b503 move some files diff -r f3c0a65c3f12 -r 6dc6b25021a3 src/jungle/test/codesegment/log/practice/StartCodeSegment.java --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/jungle/test/codesegment/log/practice/StartCodeSegment.java Thu Jun 27 21:04:33 2013 +0900 @@ -0,0 +1,60 @@ +package jungle.test.codesegment.log.practice; + +import java.io.IOException; +import java.nio.ByteBuffer; +import java.util.LinkedList; +import java.util.List; + +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultNodePath; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.DefaultTreeOperationLog; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.AppendChildAtOperation; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.DefaultTreeOperation; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.DeleteAttributeOperation; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.DeleteChildAtOperation; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.PutAttributeOperation; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation; +import jungle.test.datasegment.store.operations.DefaultTreeOperationLogContainer; +import alice.codesegment.CodeSegment; + +public class StartCodeSegment extends CodeSegment { + + @Override + public void run() { + System.out.println("run StartCodeSegment"); + + TestCodeSegment cs = new TestCodeSegment(); + cs.arg1.setKey("log"); + System.out.println("create TestCodeSegment"); + + DefaultTreeOperationLog log = getSampleOperationLog(); + DefaultTreeOperationLogContainer logContainer = new DefaultTreeOperationLogContainer(); + try { + logContainer.unconvert(log); + ods.update("local", "log", logContainer); + } catch (IOException e) { + e.printStackTrace(); + } + } + + public DefaultTreeOperationLog getSampleOperationLog() { + String key = "hoge"; + ByteBuffer b = ByteBuffer.wrap("messagepack value".getBytes()); + DefaultNodePath nodePath1 = new DefaultNodePath(); + nodePath1 = nodePath1.add(1); + DefaultNodePath nodePath2 = nodePath1.add(2); + AppendChildAtOperation appendChildOp1 = new AppendChildAtOperation(1); + AppendChildAtOperation appendChildOp2 = new AppendChildAtOperation(2); + PutAttributeOperation putOp = new PutAttributeOperation(key, b); + DeleteAttributeOperation deleteOp = new DeleteAttributeOperation("hoge"); + DeleteChildAtOperation deleteChild = new DeleteChildAtOperation(2); + List list = new LinkedList(); + list.add(new DefaultTreeOperation(new DefaultNodePath(), appendChildOp1)); + list.add(new DefaultTreeOperation(nodePath1, appendChildOp2)); + list.add(new DefaultTreeOperation(nodePath2, putOp)); + list.add(new DefaultTreeOperation(nodePath2, deleteOp)); + list.add(new DefaultTreeOperation(nodePath1, deleteChild)); + DefaultTreeOperationLog log = new DefaultTreeOperationLog(list, list.size()); + return log; + } + +} diff -r f3c0a65c3f12 -r 6dc6b25021a3 src/jungle/test/codesegment/log/practice/TestCodeSegment.java --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/jungle/test/codesegment/log/practice/TestCodeSegment.java Thu Jun 27 21:04:33 2013 +0900 @@ -0,0 +1,106 @@ +package jungle.test.codesegment.log.practice; + +import java.io.IOException; +import java.nio.ByteBuffer; + +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.DefaultJungle; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.Jungle; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTree; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTreeEditor; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.core.Node; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.Command; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.NodePath; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultNodePath; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultTreeEditor; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.DefaultTreeOperationLog; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.TreeOperationLog; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.NodeOperation; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.traverser.DefaultTraverser; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error; +import jungle.test.core.NetworkDefaultJungle; +import jungle.test.datasegment.store.operations.DefaultTreeOperationLogContainer; +import jungle.test.transaction.NetworkDefaultJungleTreeEditor; +import alice.codesegment.CodeSegment; +import alice.datasegment.CommandType; +import alice.datasegment.Receiver; +import alice.test.topology.aquarium.FishPoint; + +import org.msgpack.MessagePack; +import org.msgpack.type.Value; + +public class TestCodeSegment extends CodeSegment { + + static Jungle jungle = new NetworkDefaultJungle(null,"hoge",new DefaultTreeEditor(new DefaultTraverser())); + + // create input datasegment arg1 + Receiver arg1 = ids.create(CommandType.PEEK); + + public TestCodeSegment() { + arg1.setKey("log"); + jungle.createNewTree("tree"); + } + + @Override + public void run() { + System.out.println("type = " + arg1.type); + System.out.println("index = " + arg1.index); + System.out.println("data = " + arg1.getVal()); + System.out.println(((Value)arg1.getVal()).getType()); + + DefaultTreeOperationLogContainer convertedLogContainer = arg1.asClass(DefaultTreeOperationLogContainer.class); + TreeOperationLog convertedLog = null; + try { + convertedLog = convertedLogContainer.convert(); + } catch (IOException e) { + e.printStackTrace(); + } + printLog(convertedLog); + + JungleTree tree = jungle.getTreeByName("tree"); + NetworkDefaultJungleTreeEditor editor = (NetworkDefaultJungleTreeEditor) tree.getTreeEditor(); + JungleTreeEditor tEditor = editor.setNewLogAndGetEditor(convertedLog); + Either either = tEditor.success(); + if (either.isA()) { + throw new IllegalStateException(); + } + System.exit(0); + } + + public void printLog(TreeOperationLog log) { + for (TreeOperation treeOp : log) { + NodePath path = treeOp.getNodePath(); + NodeOperation nodeOp = treeOp.getNodeOperation(); + Command c = nodeOp.getCommand(); + String str = ""; + switch (c) { + case PUT_ATTRIBUTE: + String k = nodeOp.getKey(); + ByteBuffer value = nodeOp.getValue(); + if (value.limit() < 100) { + str = String.format("key:%s,value:%s", k, + new String(value.array())); + } else { + str = String.format("key:%s,value:%d", k, value.limit()); + } + break; + case DELETE_ATTRIBUTE: + str = String.format("key:%s", nodeOp.getKey()); + break; + case APPEND_CHILD: + str = String.format("pos:%d", nodeOp.getPosition()); + break; + case DELETE_CHILD: + str = String.format("pos:%d", nodeOp.getPosition()); + break; + } + System.out.println(String.format("[%s:%s]", c, str)); + System.out.println("path:"); + for (int i: path ) { + System.out.println(i); + } + } + } + +} diff -r f3c0a65c3f12 -r 6dc6b25021a3 src/jungle/test/codesegment/log/practice/TestLocalAlice.java --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/jungle/test/codesegment/log/practice/TestLocalAlice.java Thu Jun 27 21:04:33 2013 +0900 @@ -0,0 +1,12 @@ +package jungle.test.codesegment.log.practice; + +import alice.daemon.AliceDaemon; +import alice.daemon.Config; + +public class TestLocalAlice { + public static void main(String args[]) { + new AliceDaemon(new Config(args)).listen(); // logger off + new StartCodeSegment().execute(); + } + +} diff -r f3c0a65c3f12 -r 6dc6b25021a3 src/jungle/test/codesegment/practice/StartCodeSegment.java --- a/src/jungle/test/codesegment/practice/StartCodeSegment.java Thu Jun 27 21:02:58 2013 +0900 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,60 +0,0 @@ -package jungle.test.codesegment.practice; - -import java.io.IOException; -import java.nio.ByteBuffer; -import java.util.LinkedList; -import java.util.List; - -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultNodePath; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.DefaultTreeOperationLog; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.AppendChildAtOperation; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.DefaultTreeOperation; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.DeleteAttributeOperation; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.DeleteChildAtOperation; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.PutAttributeOperation; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation; -import jungle.test.datasegment.store.operations.DefaultTreeOperationLogContainer; -import alice.codesegment.CodeSegment; - -public class StartCodeSegment extends CodeSegment { - - @Override - public void run() { - System.out.println("run StartCodeSegment"); - - TestCodeSegment cs = new TestCodeSegment(); - cs.arg1.setKey("log"); - System.out.println("create TestCodeSegment"); - - DefaultTreeOperationLog log = getSampleOperationLog(); - DefaultTreeOperationLogContainer logContainer = new DefaultTreeOperationLogContainer(); - try { - logContainer.unconvert(log); - ods.update("local", "log", logContainer); - } catch (IOException e) { - e.printStackTrace(); - } - } - - public DefaultTreeOperationLog getSampleOperationLog() { - String key = "hoge"; - ByteBuffer b = ByteBuffer.wrap("messagepack value".getBytes()); - DefaultNodePath nodePath1 = new DefaultNodePath(); - nodePath1 = nodePath1.add(1); - DefaultNodePath nodePath2 = nodePath1.add(2); - AppendChildAtOperation appendChildOp1 = new AppendChildAtOperation(1); - AppendChildAtOperation appendChildOp2 = new AppendChildAtOperation(2); - PutAttributeOperation putOp = new PutAttributeOperation(key, b); - DeleteAttributeOperation deleteOp = new DeleteAttributeOperation("hoge"); - DeleteChildAtOperation deleteChild = new DeleteChildAtOperation(2); - List list = new LinkedList(); - list.add(new DefaultTreeOperation(new DefaultNodePath(), appendChildOp1)); - list.add(new DefaultTreeOperation(nodePath1, appendChildOp2)); - list.add(new DefaultTreeOperation(nodePath2, putOp)); - list.add(new DefaultTreeOperation(nodePath2, deleteOp)); - list.add(new DefaultTreeOperation(nodePath1, deleteChild)); - DefaultTreeOperationLog log = new DefaultTreeOperationLog(list, list.size()); - return log; - } - -} diff -r f3c0a65c3f12 -r 6dc6b25021a3 src/jungle/test/codesegment/practice/TestCodeSegment.java --- a/src/jungle/test/codesegment/practice/TestCodeSegment.java Thu Jun 27 21:02:58 2013 +0900 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,106 +0,0 @@ -package jungle.test.codesegment.practice; - -import java.io.IOException; -import java.nio.ByteBuffer; - -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.DefaultJungle; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.Jungle; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTree; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTreeEditor; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.core.Node; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.Command; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.NodePath; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultNodePath; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultTreeEditor; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.DefaultTreeOperationLog; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.TreeOperationLog; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.NodeOperation; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.traverser.DefaultTraverser; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error; -import jungle.test.core.NetworkDefaultJungle; -import jungle.test.datasegment.store.operations.DefaultTreeOperationLogContainer; -import jungle.test.transaction.NetworkDefaultJungleTreeEditor; -import alice.codesegment.CodeSegment; -import alice.datasegment.CommandType; -import alice.datasegment.Receiver; -import alice.test.topology.aquarium.FishPoint; - -import org.msgpack.MessagePack; -import org.msgpack.type.Value; - -public class TestCodeSegment extends CodeSegment { - - static Jungle jungle = new NetworkDefaultJungle(null,"hoge",new DefaultTreeEditor(new DefaultTraverser())); - - // create input datasegment arg1 - Receiver arg1 = ids.create(CommandType.PEEK); - - public TestCodeSegment() { - arg1.setKey("log"); - jungle.createNewTree("tree"); - } - - @Override - public void run() { - System.out.println("type = " + arg1.type); - System.out.println("index = " + arg1.index); - System.out.println("data = " + arg1.getVal()); - System.out.println(arg1.getVal().getType()); - - DefaultTreeOperationLogContainer convertedLogContainer = arg1.asClass(DefaultTreeOperationLogContainer.class); - TreeOperationLog convertedLog = null; - try { - convertedLog = convertedLogContainer.convert(); - } catch (IOException e) { - e.printStackTrace(); - } - printLog(convertedLog); - - JungleTree tree = jungle.getTreeByName("tree"); - NetworkDefaultJungleTreeEditor editor = (NetworkDefaultJungleTreeEditor) tree.getTreeEditor(); - JungleTreeEditor tEditor = editor.setNewLogAndGetEditor(convertedLog); - Either either = tEditor.success(); - if (either.isA()) { - throw new IllegalStateException(); - } - System.exit(0); - } - - public void printLog(TreeOperationLog log) { - for (TreeOperation treeOp : log) { - NodePath path = treeOp.getNodePath(); - NodeOperation nodeOp = treeOp.getNodeOperation(); - Command c = nodeOp.getCommand(); - String str = ""; - switch (c) { - case PUT_ATTRIBUTE: - String k = nodeOp.getKey(); - ByteBuffer value = nodeOp.getValue(); - if (value.limit() < 100) { - str = String.format("key:%s,value:%s", k, - new String(value.array())); - } else { - str = String.format("key:%s,value:%d", k, value.limit()); - } - break; - case DELETE_ATTRIBUTE: - str = String.format("key:%s", nodeOp.getKey()); - break; - case APPEND_CHILD: - str = String.format("pos:%d", nodeOp.getPosition()); - break; - case DELETE_CHILD: - str = String.format("pos:%d", nodeOp.getPosition()); - break; - } - System.out.println(String.format("[%s:%s]", c, str)); - System.out.println("path:"); - for (int i: path ) { - System.out.println(i); - } - } - } - -} diff -r f3c0a65c3f12 -r 6dc6b25021a3 src/jungle/test/codesegment/practice/TestLocalAlice.java --- a/src/jungle/test/codesegment/practice/TestLocalAlice.java Thu Jun 27 21:02:58 2013 +0900 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,12 +0,0 @@ -package jungle.test.codesegment.practice; - -import alice.daemon.AliceDaemon; -import alice.daemon.Config; - -public class TestLocalAlice { - public static void main(String args[]) { - new AliceDaemon(new Config(args)).listen(); // logger off - new StartCodeSegment().execute(); - } - -}