# 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;
}