Mercurial > hg > Members > nobuyasu > jungle-network

comparison src/jungle/test/core/practice/LogSendTest.java @ 28:e968224ad0ce

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add jungle.test.core.practice
author one
date Mon, 01 Jul 2013 19:14:24 +0900
parents
children 190f6a3bdab2
comparison
equal deleted inserted replaced
27:0493340583ab 28:e968224ad0ce
1 package jungle.test.core.practice;
2
3 import java.io.IOException;
4 import java.nio.ByteBuffer;
5
6 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTree;
7 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTreeEditor;
8 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultNodePath;
9 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.TreeOperationLog;
10 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either;
11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error;
12 import jungle.test.codesegment.operation.JungleManager;
13 import jungle.test.datasegment.store.operations.DefaultTreeOperationLogContainer;
14 import jungle.test.transaction.NetworkDefaultJungleTreeEditor;
15
16 public class LogSendTest {
17
18 public static void main(String[] args) {
19 System.out.println("Start LogSendTest");
20 JungleManager jm = new JungleManager();
21 JungleTree tree = jm.createNewTree("tree");
22 JungleTreeEditor editor = tree.getTreeEditor();
23
24 DefaultNodePath root = new DefaultNodePath();
25 Either<Error, JungleTreeEditor> either = editor.addNewChildAt(root, 0);
26 if(either.isA()) {
27 throw new IllegalStateException();
28 }
29 editor = either.b();
30 either = editor.putAttribute(root.add(0), "key1", ByteBuffer.wrap("first message".getBytes()));
31 if(either.isA()) {
32 throw new IllegalStateException();
33 }
34 NetworkDefaultJungleTreeEditor nEditor = (NetworkDefaultJungleTreeEditor) either.b();
35 TreeOperationLog log = nEditor.getTreeOperationLog();
36
37 DefaultTreeOperationLogContainer container = new DefaultTreeOperationLogContainer();
38 try {
39 container.unconvert(log);
40 } catch (IOException e) {
41 e.printStackTrace();
42 }
43 LogReadCodeSegment cs = new LogReadCodeSegment();
44 cs.ods.update("log", container);
45 }
46
47 }