|
105
|
1 package alice.jungle.log.example;
|
|
28
|
2
|
|
|
3 import java.io.IOException;
|
|
|
4 import java.nio.ByteBuffer;
|
|
|
5
|
|
105
|
6 import alice.jungle.datasegment.container.DefaultTreeOperationLogContainer;
|
|
31
|
7 import alice.jungle.transaction.NetworkDefaultJungleTreeEditor;
|
|
28
|
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.store.impl.DefaultNodePath;
|
|
|
11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.TreeOperationLog;
|
|
|
12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either;
|
|
|
13 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error;
|
|
66
|
14 import jungle.app.bbs.JungleManager;
|
|
28
|
15
|
|
|
16 public class LogSendTest {
|
|
|
17
|
|
|
18 public static void main(String[] args) {
|
|
|
19 System.out.println("Start LogSendTest");
|
|
47
|
20 JungleTree tree = JungleManager.createNewTree("tree");
|
|
28
|
21 JungleTreeEditor editor = tree.getTreeEditor();
|
|
|
22
|
|
|
23 DefaultNodePath root = new DefaultNodePath();
|
|
|
24 Either<Error, JungleTreeEditor> either = editor.addNewChildAt(root, 0);
|
|
|
25 if(either.isA()) {
|
|
|
26 throw new IllegalStateException();
|
|
|
27 }
|
|
|
28 editor = either.b();
|
|
|
29 either = editor.putAttribute(root.add(0), "key1", ByteBuffer.wrap("first message".getBytes()));
|
|
|
30 if(either.isA()) {
|
|
|
31 throw new IllegalStateException();
|
|
|
32 }
|
|
|
33 NetworkDefaultJungleTreeEditor nEditor = (NetworkDefaultJungleTreeEditor) either.b();
|
|
|
34 TreeOperationLog log = nEditor.getTreeOperationLog();
|
|
|
35
|
|
|
36 DefaultTreeOperationLogContainer container = new DefaultTreeOperationLogContainer();
|
|
|
37 try {
|
|
|
38 container.unconvert(log);
|
|
|
39 } catch (IOException e) {
|
|
|
40 e.printStackTrace();
|
|
|
41 }
|
|
|
42 LogReadCodeSegment cs = new LogReadCodeSegment();
|
|
|
43 cs.ods.update("log", container);
|
|
|
44 }
|
|
|
45
|
|
|
46 }
|
