# HG changeset patch # User one # Date 1372620431 -32400 # Node ID 0493340583aba0b2cc516e5834f5e81697ed239a # Parent 1d7f52c3b3d9857a1d11fec88722af02c615feed move some files diff -r 1d7f52c3b3d9 -r 0493340583ab src/jungle/test/codesegment/operation/CodeSegmentJournal.java --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/jungle/test/codesegment/operation/CodeSegmentJournal.java Mon Jul 01 04:27:11 2013 +0900 @@ -0,0 +1,20 @@ +package jungle.test.codesegment.operation; + +import alice.codesegment.CodeSegment; +import alice.datasegment.CommandType; +import alice.datasegment.Receiver; + +public class CodeSegmentJournal extends CodeSegment { + + Receiver arg1 = ids.create(CommandType.PEEK); + + @Override + public void run() { + + + } + + + + +} diff -r 1d7f52c3b3d9 -r 0493340583ab src/jungle/test/codesegment/operation/JungleManager.java --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/jungle/test/codesegment/operation/JungleManager.java Mon Jul 01 04:27:11 2013 +0900 @@ -0,0 +1,26 @@ +package jungle.test.codesegment.operation; + +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.store.impl.DefaultTreeEditor; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.traverser.DefaultTraverser; +import jungle.test.core.NetworkDefaultJungle; + +public class JungleManager { + static Jungle jungle = new NetworkDefaultJungle(null,"hoge",new DefaultTreeEditor(new DefaultTraverser())); + + public JungleManager() { + + } + + public Jungle getJungle() { + return jungle; + } + + public JungleTree createNewTree(String name) { + return jungle.createNewTree(name); + } + + +} diff -r 1d7f52c3b3d9 -r 0493340583ab src/jungle/test/codesegment/operation/ShowAttribute.java --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/jungle/test/codesegment/operation/ShowAttribute.java Mon Jul 01 04:27:11 2013 +0900 @@ -0,0 +1,43 @@ +package jungle.test.codesegment.operation; + +import java.nio.ByteBuffer; + +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.Children; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.core.Node; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultNodePath; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error; +import alice.codesegment.CodeSegment; +import alice.datasegment.CommandType; +import alice.datasegment.Receiver; + +public class ShowAttribute extends CodeSegment { + + Receiver arg1 = ids.create(CommandType.TAKE); + + public ShowAttribute() { + arg1.setKey("show"); + } + + public void run() { + System.out.println("--ShowAttribute--"); + + Jungle jungle = new JungleManager().getJungle(); + JungleTree tree = jungle.getTreeByName("tree"); + Node node = tree.getRootNode(); + Children chs = node.getChildren(); + System.out.println("children size : "+chs.size()); + for(Node n : chs) { + ByteBuffer b = n.getAttributes().get("key1"); + System.out.println(new String(b.array())); + } + + System.exit(0); + + + } + +} diff -r 1d7f52c3b3d9 -r 0493340583ab src/jungle/test/codesegment/operation/StartJungleCodeSegment.java --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/jungle/test/codesegment/operation/StartJungleCodeSegment.java Mon Jul 01 04:27:11 2013 +0900 @@ -0,0 +1,38 @@ +package jungle.test.codesegment.operation; + +import java.io.IOException; +import java.nio.ByteBuffer; + +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.store.impl.DefaultNodePath; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.DefaultTreeOperation; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.PutAttributeOperation; +import jungle.test.datasegment.store.operations.DefaultTreeOperationContainer; +import alice.codesegment.CodeSegment; + +public class StartJungleCodeSegment { + + public static void main(String[] args) { + System.out.println("--StartJungleCodeSegment--"); + + JungleManager jm = new JungleManager(); + JungleTree tree = jm.createNewTree("tree"); + JungleTreeEditor editor = tree.getTreeEditor(); + DefaultNodePath path = new DefaultNodePath(); + path = path.add(0); + editor.addNewChildAt(path, 0); + editor.success(); + + TestPutAttributeCodeSegment cs = new TestPutAttributeCodeSegment(); + DefaultTreeOperation treeOp = cs.getSampleOperation("message0"); + DefaultTreeOperationContainer treeOperationContainer = new DefaultTreeOperationContainer(); + try { + treeOperationContainer.unconvert(treeOp); + } catch (IOException e) { + e.printStackTrace(); + } + cs.ods.update("local", "log", treeOperationContainer); + } + +} diff -r 1d7f52c3b3d9 -r 0493340583ab src/jungle/test/codesegment/operation/TestPutAttributeCodeSegment.java --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/jungle/test/codesegment/operation/TestPutAttributeCodeSegment.java Mon Jul 01 04:27:11 2013 +0900 @@ -0,0 +1,124 @@ +package jungle.test.codesegment.operation; + +import java.io.IOException; +import java.nio.ByteBuffer; + +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.store.Command; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.NodePath; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.TreeEditor; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultNodePath; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.TreeOperationLog; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.DefaultTreeOperation; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.NodeOperation; +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 jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error; +import jungle.test.datasegment.store.operations.DefaultTreeOperationContainer; +import jungle.test.datasegment.store.operations.DefaultTreeOperationLogContainer; +import jungle.test.transaction.NetworkDefaultJungleTreeEditor; + +import org.msgpack.type.Value; + +import alice.codesegment.CodeSegment; +import alice.datasegment.CommandType; +import alice.datasegment.Receiver; + +public class TestPutAttributeCodeSegment extends CodeSegment { + + Receiver arg1 = ids.create(CommandType.TAKE); + + public TestPutAttributeCodeSegment() { + arg1.setKey("log"); + } + + public void run() { + System.out.println("--TestPutAttributeCodeSegment--"); + DefaultTreeOperationContainer convertedOpContainer = arg1 + .asClass(DefaultTreeOperationContainer.class); + TreeOperation convertedOp = null; + try { + convertedOp = convertedOpContainer.convert(); + } catch (IOException e) { + e.printStackTrace(); + } + Jungle jungle = new JungleManager().getJungle(); + JungleTree tree = jungle.getTreeByName("tree"); + JungleTreeEditor editor = tree.getTreeEditor(); + DefaultNodePath root = new DefaultNodePath(); + Either either = editor.addNewChildAt(root, 0); + if (either.isA()) { + throw new IllegalStateException(); + } + editor = either.b(); + editor.success(); + NetworkDefaultJungleTreeEditor nEditor = (NetworkDefaultJungleTreeEditor) tree + .getTreeEditor(); + either = edit(nEditor, convertedOp); + if (either.isA()) { + throw new IllegalStateException(); + } + editor = either.b(); + editor.success(); + if (arg1.index >= 10) { + new ShowAttribute(); + ods.update("local", "show", 1); + return; + } + TestPutAttributeCodeSegment cs = new TestPutAttributeCodeSegment(); + DefaultTreeOperation treeOp = cs.getSampleOperation("message"+ arg1.index); + DefaultTreeOperationContainer treeOperationContainer = new DefaultTreeOperationContainer(); + try { + treeOperationContainer.unconvert(treeOp); + } catch (IOException e) { + e.printStackTrace(); + } + ods.update("local", "log", treeOperationContainer); + } + + public DefaultTreeOperation getSampleOperation(String message) { + /* Create TreeOperation */ + String key = "key1"; + ByteBuffer b = ByteBuffer.wrap(message.getBytes()); + PutAttributeOperation op = new PutAttributeOperation(key, b); + DefaultNodePath p = new DefaultNodePath(); + p = p.add(0); + DefaultTreeOperation treeOp = new DefaultTreeOperation(p, op); + return treeOp; + } + + public Either edit(JungleTreeEditor editor, + TreeOperation op) { + NodePath path = op.getNodePath(); + NodeOperation nodeOp = op.getNodeOperation(); + Command c = nodeOp.getCommand(); + String str = ""; + String key = ""; + switch (c) { + case PUT_ATTRIBUTE: + key = nodeOp.getKey(); + ByteBuffer value = nodeOp.getValue(); + if (value.limit() < 100) { + str = String.format("key:%s,value:%s", key, + new String(value.array())); + } else { + str = String.format("key:%s,value:%d", key, value.limit()); + } + return editor.putAttribute(path, key, value); + case DELETE_ATTRIBUTE: + key = nodeOp.getKey(); + str = String.format("key:%s", nodeOp.getKey()); + return editor.deleteAttribute(path, key); + case APPEND_CHILD: + str = String.format("pos:%d", nodeOp.getPosition()); + return editor.addNewChildAt(path, 0); + case DELETE_CHILD: + str = String.format("pos:%d", nodeOp.getPosition()); + return editor.deleteChildAt(path, 0); + } + return null; + } +} diff -r 1d7f52c3b3d9 -r 0493340583ab src/jungle/test/codesegment/persistence/TestJungle.java --- a/src/jungle/test/codesegment/persistence/TestJungle.java Mon Jul 01 04:16:03 2013 +0900 +++ b/src/jungle/test/codesegment/persistence/TestJungle.java Mon Jul 01 04:27:11 2013 +0900 @@ -4,8 +4,8 @@ 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.store.TreeEditor; -import jungle.test.codesegment.practice.JungleManager; -import jungle.test.codesegment.practice.TestPutAttributeCodeSegment; +import jungle.test.codesegment.operation.JungleManager; +import jungle.test.codesegment.operation.TestPutAttributeCodeSegment; public class TestJungle { diff -r 1d7f52c3b3d9 -r 0493340583ab src/jungle/test/codesegment/practice/CodeSegmentJournal.java --- a/src/jungle/test/codesegment/practice/CodeSegmentJournal.java Mon Jul 01 04:16:03 2013 +0900 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,20 +0,0 @@ -package jungle.test.codesegment.practice; - -import alice.codesegment.CodeSegment; -import alice.datasegment.CommandType; -import alice.datasegment.Receiver; - -public class CodeSegmentJournal extends CodeSegment { - - Receiver arg1 = ids.create(CommandType.PEEK); - - @Override - public void run() { - - - } - - - - -} diff -r 1d7f52c3b3d9 -r 0493340583ab src/jungle/test/codesegment/practice/JungleManager.java --- a/src/jungle/test/codesegment/practice/JungleManager.java Mon Jul 01 04:16:03 2013 +0900 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,26 +0,0 @@ -package jungle.test.codesegment.practice; - -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.store.impl.DefaultTreeEditor; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.traverser.DefaultTraverser; -import jungle.test.core.NetworkDefaultJungle; - -public class JungleManager { - static Jungle jungle = new NetworkDefaultJungle(null,"hoge",new DefaultTreeEditor(new DefaultTraverser())); - - public JungleManager() { - - } - - public Jungle getJungle() { - return jungle; - } - - public JungleTree createNewTree(String name) { - return jungle.createNewTree(name); - } - - -} diff -r 1d7f52c3b3d9 -r 0493340583ab src/jungle/test/codesegment/practice/ShowAttribute.java --- a/src/jungle/test/codesegment/practice/ShowAttribute.java Mon Jul 01 04:16:03 2013 +0900 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,43 +0,0 @@ -package jungle.test.codesegment.practice; - -import java.nio.ByteBuffer; - -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.Children; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.core.Node; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultNodePath; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error; -import alice.codesegment.CodeSegment; -import alice.datasegment.CommandType; -import alice.datasegment.Receiver; - -public class ShowAttribute extends CodeSegment { - - Receiver arg1 = ids.create(CommandType.TAKE); - - public ShowAttribute() { - arg1.setKey("show"); - } - - public void run() { - System.out.println("--ShowAttribute--"); - - Jungle jungle = new JungleManager().getJungle(); - JungleTree tree = jungle.getTreeByName("tree"); - Node node = tree.getRootNode(); - Children chs = node.getChildren(); - System.out.println("children size : "+chs.size()); - for(Node n : chs) { - ByteBuffer b = n.getAttributes().get("key1"); - System.out.println(new String(b.array())); - } - - System.exit(0); - - - } - -} diff -r 1d7f52c3b3d9 -r 0493340583ab src/jungle/test/codesegment/practice/StartJungleCodeSegment.java --- a/src/jungle/test/codesegment/practice/StartJungleCodeSegment.java Mon Jul 01 04:16:03 2013 +0900 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,38 +0,0 @@ -package jungle.test.codesegment.practice; - -import java.io.IOException; -import java.nio.ByteBuffer; - -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.store.impl.DefaultNodePath; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.DefaultTreeOperation; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.PutAttributeOperation; -import jungle.test.datasegment.store.operations.DefaultTreeOperationContainer; -import alice.codesegment.CodeSegment; - -public class StartJungleCodeSegment { - - public static void main(String[] args) { - System.out.println("--StartJungleCodeSegment--"); - - JungleManager jm = new JungleManager(); - JungleTree tree = jm.createNewTree("tree"); - JungleTreeEditor editor = tree.getTreeEditor(); - DefaultNodePath path = new DefaultNodePath(); - path = path.add(0); - editor.addNewChildAt(path, 0); - editor.success(); - - TestPutAttributeCodeSegment cs = new TestPutAttributeCodeSegment(); - DefaultTreeOperation treeOp = cs.getSampleOperation("message0"); - DefaultTreeOperationContainer treeOperationContainer = new DefaultTreeOperationContainer(); - try { - treeOperationContainer.unconvert(treeOp); - } catch (IOException e) { - e.printStackTrace(); - } - cs.ods.update("local", "log", treeOperationContainer); - } - -} diff -r 1d7f52c3b3d9 -r 0493340583ab src/jungle/test/codesegment/practice/TestPutAttributeCodeSegment.java --- a/src/jungle/test/codesegment/practice/TestPutAttributeCodeSegment.java Mon Jul 01 04:16:03 2013 +0900 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,122 +0,0 @@ -package jungle.test.codesegment.practice; - -import java.io.IOException; -import java.nio.ByteBuffer; - -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.store.Command; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.NodePath; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.TreeEditor; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultNodePath; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.TreeOperationLog; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.DefaultTreeOperation; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.NodeOperation; -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 jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either; -import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error; -import jungle.test.datasegment.store.operations.DefaultTreeOperationContainer; -import jungle.test.datasegment.store.operations.DefaultTreeOperationLogContainer; -import jungle.test.transaction.NetworkDefaultJungleTreeEditor; - -import org.msgpack.type.Value; - -import alice.codesegment.CodeSegment; -import alice.datasegment.CommandType; -import alice.datasegment.Receiver; - -public class TestPutAttributeCodeSegment extends CodeSegment { - - Receiver arg1 = ids.create(CommandType.TAKE); - - public TestPutAttributeCodeSegment() { - arg1.setKey("log"); - } - - - public void run() { - System.out.println("--TestPutAttributeCodeSegment--"); - DefaultTreeOperationContainer convertedOpContainer = arg1.asClass(DefaultTreeOperationContainer.class); - TreeOperation convertedOp = null; - try { - convertedOp = convertedOpContainer.convert(); - } catch (IOException e) { - e.printStackTrace(); - } - Jungle jungle = new JungleManager().getJungle(); - JungleTree tree = jungle.getTreeByName("tree"); - JungleTreeEditor editor = tree.getTreeEditor(); - DefaultNodePath root = new DefaultNodePath(); - Either either = editor.addNewChildAt(root, 0); - if(either.isA()) { - throw new IllegalStateException(); - } - editor = either.b(); - editor.success(); - NetworkDefaultJungleTreeEditor nEditor = (NetworkDefaultJungleTreeEditor) tree.getTreeEditor(); - either = edit(nEditor, convertedOp); - if(either.isA()) { - throw new IllegalStateException(); - } - editor = either.b(); - editor.success(); - if (arg1.index >= 10) { - new ShowAttribute(); - ods.update("local","show",1); - } else { - TestPutAttributeCodeSegment cs = new TestPutAttributeCodeSegment(); - DefaultTreeOperation treeOp = cs.getSampleOperation("message"+arg1.index); - DefaultTreeOperationContainer treeOperationContainer = new DefaultTreeOperationContainer(); - try { - treeOperationContainer.unconvert(treeOp); - } catch (IOException e) { - e.printStackTrace(); - } - ods.update("local", "log", treeOperationContainer); - } - } - - public DefaultTreeOperation getSampleOperation(String message) { - /* Create TreeOperation */ - String key = "key1"; - ByteBuffer b = ByteBuffer.wrap(message.getBytes()); - PutAttributeOperation op = new PutAttributeOperation(key, b); - DefaultNodePath p = new DefaultNodePath(); - p = p.add(0); - DefaultTreeOperation treeOp = new DefaultTreeOperation(p, op); - return treeOp; - } - - public Either edit(JungleTreeEditor editor, TreeOperation op) { - NodePath path = op.getNodePath(); - NodeOperation nodeOp = op.getNodeOperation(); - Command c = nodeOp.getCommand(); - String str = ""; - String key = ""; - switch (c) { - case PUT_ATTRIBUTE: - key = nodeOp.getKey(); - ByteBuffer value = nodeOp.getValue(); - if (value.limit() < 100) { - str = String.format("key:%s,value:%s", key, - new String(value.array())); - } else { - str = String.format("key:%s,value:%d", key, value.limit()); - } - return editor.putAttribute(path, key, value); - case DELETE_ATTRIBUTE: - key = nodeOp.getKey(); - str = String.format("key:%s", nodeOp.getKey()); - return editor.deleteAttribute(path, key); - case APPEND_CHILD: - str = String.format("pos:%d", nodeOp.getPosition()); - return editor.addNewChildAt(path, 0); - case DELETE_CHILD: - str = String.format("pos:%d", nodeOp.getPosition()); - return editor.deleteChildAt(path, 0); - } - return null; - } -} diff -r 1d7f52c3b3d9 -r 0493340583ab src/jungle/test/transaction/NetworkDefaultJungleTreeEditor.java --- a/src/jungle/test/transaction/NetworkDefaultJungleTreeEditor.java Mon Jul 01 04:16:03 2013 +0900 +++ b/src/jungle/test/transaction/NetworkDefaultJungleTreeEditor.java Mon Jul 01 04:27:11 2013 +0900 @@ -143,7 +143,9 @@ return newEditor; } - + public TreeOperationLog getLog() { + return log; + } }