# HG changeset patch # User one # Date 1372673664 -32400 # Node ID e968224ad0ceb0fc56bfaa60d2c1b1b5d6a64da8 # Parent 0493340583aba0b2cc516e5834f5e81697ed239a add jungle.test.core.practice diff -r 0493340583ab -r e968224ad0ce .classpath --- a/.classpath Mon Jul 01 04:27:11 2013 +0900 +++ b/.classpath Mon Jul 01 19:14:24 2013 +0900 @@ -3,10 +3,10 @@ - + diff -r 0493340583ab -r e968224ad0ce src/jungle/test/codesegment/persistence/AliceJournal.java --- a/src/jungle/test/codesegment/persistence/AliceJournal.java Mon Jul 01 04:27:11 2013 +0900 +++ b/src/jungle/test/codesegment/persistence/AliceJournal.java Mon Jul 01 19:14:24 2013 +0900 @@ -42,11 +42,7 @@ } -*/ - - - - +*/ for(TreeOperation op : _operations){ NodePath p = op.getNodePath(); NodeOperation nodeOp = op.getNodeOperation(); diff -r 0493340583ab -r e968224ad0ce src/jungle/test/core/NetworkDefaultJungle.java --- a/src/jungle/test/core/NetworkDefaultJungle.java Mon Jul 01 04:27:11 2013 +0900 +++ b/src/jungle/test/core/NetworkDefaultJungle.java Mon Jul 01 19:14:24 2013 +0900 @@ -26,7 +26,8 @@ public NetworkDefaultJungle(Journal _journal,String _uuid,TreeEditor _editor) { - journal = new AliceJournal(); +// journal = new AliceJournal(); + journal = new NullJournal(); trees = new ConcurrentHashMap(); uuid = _uuid; editor = _editor; @@ -48,7 +49,6 @@ return nil.iterator(); } }; - DefaultTreeNode root = new DefaultTreeNode(); ChangeSet set = new DefaultChangeSet(root.getAsNode(),null,list,uuid,0); DefaultTreeContext tc = new DefaultTreeContext(root,set); @@ -58,6 +58,4 @@ } return newTree; } - - } diff -r 0493340583ab -r e968224ad0ce src/jungle/test/core/practice/LogReadCodeSegment.java --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/jungle/test/core/practice/LogReadCodeSegment.java Mon Jul 01 19:14:24 2013 +0900 @@ -0,0 +1,51 @@ +package jungle.test.core.practice; + +import java.io.IOException; + +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.impl.logger.DefaultTreeOperationLog; +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.codesegment.operation.JungleManager; +import jungle.test.datasegment.store.operations.DefaultTreeOperationLogContainer; +import jungle.test.transaction.NetworkDefaultJungleTreeEditor; +import alice.codesegment.CodeSegment; +import alice.datasegment.CommandType; +import alice.datasegment.Receiver; + +public class LogReadCodeSegment extends CodeSegment { + + Receiver arg1 = ids.create(CommandType.TAKE); + + public LogReadCodeSegment() { + arg1.setKey("log"); + } + + public void run() { + System.out.println("--LogReadCodeSegment--"); + + DefaultTreeOperationLogContainer container = arg1.asClass(DefaultTreeOperationLogContainer.class); + DefaultTreeOperationLog log = null; + try { + log = container.convert(); + } catch (IOException e) { + e.printStackTrace(); + } + + JungleManager jm = new JungleManager(); + Jungle jungle = jm.getJungle(); + JungleTree tree = jungle.getTreeByName("tree"); + NetworkDefaultJungleTreeEditor nEditor = (NetworkDefaultJungleTreeEditor) tree.getTreeEditor(); + JungleTreeEditor editor = nEditor.setNewLogAndGetEditor(log); + Either either = editor.success(); + if(either.isA()) { + throw new IllegalStateException(); + } + new PrintChildrenAttribute("key1"); + ods.update("key1", "key1"); + + } + +} diff -r 0493340583ab -r e968224ad0ce src/jungle/test/core/practice/LogSendTest.java --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/jungle/test/core/practice/LogSendTest.java Mon Jul 01 19:14:24 2013 +0900 @@ -0,0 +1,47 @@ +package jungle.test.core.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.impl.logger.TreeOperationLog; +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.codesegment.operation.JungleManager; +import jungle.test.datasegment.store.operations.DefaultTreeOperationLogContainer; +import jungle.test.transaction.NetworkDefaultJungleTreeEditor; + +public class LogSendTest { + + public static void main(String[] args) { + System.out.println("Start LogSendTest"); + JungleManager jm = new JungleManager(); + JungleTree tree = jm.createNewTree("tree"); + JungleTreeEditor editor = tree.getTreeEditor(); + + DefaultNodePath root = new DefaultNodePath(); + Either either = editor.addNewChildAt(root, 0); + if(either.isA()) { + throw new IllegalStateException(); + } + editor = either.b(); + either = editor.putAttribute(root.add(0), "key1", ByteBuffer.wrap("first message".getBytes())); + if(either.isA()) { + throw new IllegalStateException(); + } + NetworkDefaultJungleTreeEditor nEditor = (NetworkDefaultJungleTreeEditor) either.b(); + TreeOperationLog log = nEditor.getTreeOperationLog(); + + DefaultTreeOperationLogContainer container = new DefaultTreeOperationLogContainer(); + try { + container.unconvert(log); + } catch (IOException e) { + e.printStackTrace(); + } + LogReadCodeSegment cs = new LogReadCodeSegment(); + cs.ods.update("log", container); + } + +} diff -r 0493340583ab -r e968224ad0ce src/jungle/test/core/practice/PrintChildrenAttribute.java --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/jungle/test/core/practice/PrintChildrenAttribute.java Mon Jul 01 19:14:24 2013 +0900 @@ -0,0 +1,46 @@ +package jungle.test.core.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.core.Children; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.core.Node; +import jungle.test.codesegment.operation.JungleManager; +import alice.codesegment.CodeSegment; +import alice.datasegment.CommandType; +import alice.datasegment.Receiver; + +public class PrintChildrenAttribute extends CodeSegment { + + Receiver key = ids.create(CommandType.TAKE); + + public PrintChildrenAttribute(String _key) { + key.setKey(_key); + } + + public void run() { + System.out.println("--PrintChildrenAttribute--"); + String k = key.asString(); + System.out.println("key : "+ k); + JungleManager jm = new JungleManager(); + Jungle jungle = jm.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(k); + System.out.println(new String(b.array())); + } + + System.exit(0); + + + + + + } + + +} diff -r 0493340583ab -r e968224ad0ce src/jungle/test/datasegment/store/operations/DefaultTreeOperationLogContainer.java --- a/src/jungle/test/datasegment/store/operations/DefaultTreeOperationLogContainer.java Mon Jul 01 04:27:11 2013 +0900 +++ b/src/jungle/test/datasegment/store/operations/DefaultTreeOperationLogContainer.java Mon Jul 01 19:14:24 2013 +0900 @@ -88,7 +88,7 @@ } - public void unconvert(DefaultTreeOperationLog _log) throws IOException { + public void unconvert(TreeOperationLog _log) throws IOException { MessagePack msgpack = new MessagePack(); List list = new LinkedList(); for(TreeOperation op : _log) { diff -r 0493340583ab -r e968224ad0ce src/jungle/test/transaction/NetworkDefaultJungleTreeEditor.java --- a/src/jungle/test/transaction/NetworkDefaultJungleTreeEditor.java Mon Jul 01 04:27:11 2013 +0900 +++ b/src/jungle/test/transaction/NetworkDefaultJungleTreeEditor.java Mon Jul 01 19:14:24 2013 +0900 @@ -143,7 +143,7 @@ return newEditor; } - public TreeOperationLog getLog() { + public TreeOperationLog getTreeOperationLog() { return log; }