Mercurial > hg > Database > jungle-network

comparison src/jungle/test/codesegment/practice/TestCodeSegment.java @ 11:c9ff68c4d82f

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
modified TestCodeSegment
author one
date Wed, 26 Jun 2013 19:02:40 +0900
parents 5376ac62ac08
children f3c0a65c3f12
comparison
equal deleted inserted replaced
10:5376ac62ac08 11:c9ff68c4d82f
1 package jungle.test.codesegment.practice; 1 package jungle.test.codesegment.practice;
2 2
3 import java.io.IOException; 3 import java.io.IOException;
4 import java.nio.ByteBuffer; 4 import java.nio.ByteBuffer;
5 5
6 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.DefaultJungle;
7 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.Jungle;
8 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTree;
9 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTreeEditor;
10 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.core.Node;
6 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.Command; 11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.Command;
7 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.NodePath; 12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.NodePath;
8 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultNodePath; 13 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultNodePath;
14 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultTreeEditor;
9 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.TreeOperationLog; 15 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.TreeOperationLog;
10 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.NodeOperation; 16 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.NodeOperation;
11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation; 17 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation;
18 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.traverser.DefaultTraverser;
19 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either;
20 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error;
21 import jungle.test.core.NetworkDefaultJungle;
12 import jungle.test.datasegment.store.operations.DefaultTreeOperationLogContainer; 22 import jungle.test.datasegment.store.operations.DefaultTreeOperationLogContainer;
23 import jungle.test.transaction.NetworkDefaultJungleTreeEditor;
13 import alice.codesegment.CodeSegment; 24 import alice.codesegment.CodeSegment;
14 import alice.datasegment.CommandType; 25 import alice.datasegment.CommandType;
15 import alice.datasegment.Receiver; 26 import alice.datasegment.Receiver;
16 27
17 import org.msgpack.MessagePack; 28 import org.msgpack.MessagePack;
18 import org.msgpack.type.Value; 29 import org.msgpack.type.Value;
19 30
20 public class TestCodeSegment extends CodeSegment { 31 public class TestCodeSegment extends CodeSegment {
21 32
33 static Jungle jungle = new NetworkDefaultJungle(null,"hoge",new DefaultTreeEditor(new DefaultTraverser()));
34
22 // create input datasegment arg1 35 // create input datasegment arg1
23 Receiver arg1 = ids.create(CommandType.PEEK); 36 Receiver arg1 = ids.create(CommandType.PEEK);
37
38 public TestCodeSegment() {
39 jungle.createNewTree("tree");
40 }
24 41
25 @Override 42 @Override
26 public void run() { 43 public void run() {
27 System.out.println("type = " + arg1.type); 44 System.out.println("type = " + arg1.type);
28 System.out.println("index = " + arg1.index); 45 System.out.println("index = " + arg1.index);
36 DefaultTreeOperationLogContainer convertedLogContainer = msgpack.convert(logContainerValue, DefaultTreeOperationLogContainer.class); 53 DefaultTreeOperationLogContainer convertedLogContainer = msgpack.convert(logContainerValue, DefaultTreeOperationLogContainer.class);
37 convertedLog = convertedLogContainer.convert(); 54 convertedLog = convertedLogContainer.convert();
38 } catch (IOException e) { 55 } catch (IOException e) {
39 e.printStackTrace(); 56 e.printStackTrace();
40 } 57 }
41 58 printLog(convertedLog);
42 for (TreeOperation treeOp : convertedLog) { 59
60 JungleTree tree = jungle.getTreeByName("tree");
61 NetworkDefaultJungleTreeEditor editor = (NetworkDefaultJungleTreeEditor) tree.getTreeEditor();
62 JungleTreeEditor tEditor = editor.setNewLogAndGetEditor(convertedLog);
63 Either<Error,JungleTreeEditor> either = tEditor.success();
64 if (either.isA()) {
65 throw new IllegalStateException();
66 }
67 System.exit(0);
68 }
69
70 public void printLog(TreeOperationLog log) {
71 for (TreeOperation treeOp : log) {
43 NodePath path = treeOp.getNodePath(); 72 NodePath path = treeOp.getNodePath();
44 NodeOperation nodeOp = treeOp.getNodeOperation(); 73 NodeOperation nodeOp = treeOp.getNodeOperation();
45 Command c = nodeOp.getCommand(); 74 Command c = nodeOp.getCommand();
46 String str = ""; 75 String str = "";
47 switch (c) { 76 switch (c) {
68 System.out.println(String.format("[%s:%s]", c, str)); 97 System.out.println(String.format("[%s:%s]", c, str));
69 System.out.println("path:"); 98 System.out.println("path:");
70 for (int i: path ) { 99 for (int i: path ) {
71 System.out.println(i); 100 System.out.println(i);
72 } 101 }
73 } 102 }
74
75
76
77
78 System.exit(0);
79
80 /*
81 TestCodeSegment cs = new TestCodeSegment();
82 cs.arg1.setKey("key1", arg1.index);
83
84 // DataSegment.get("local").update
85 ods.update("local", "key1", "String data");
86 */
87 } 103 }
88 104
89 } 105 }