Mercurial > hg > Database > jungle-network
diff src/test/java/alice/jungle/log/example/LogSendTest.java @ 82:60d28fedcbf2
Remove unnecessary files and move some files
author | one |
---|---|
date | Wed, 16 Oct 2013 20:53:44 +0900 |
parents | src/jungle/test/core/practice/LogSendTest.java@87ec5dd0dc27 |
children | f9e29a52efd3 |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/test/java/alice/jungle/log/example/LogSendTest.java Wed Oct 16 20:53:44 2013 +0900 @@ -0,0 +1,47 @@ +package test.java.alice.jungle.log.example; + +import java.io.IOException; +import java.nio.ByteBuffer; + +import alice.jungle.datasegment.store.container.DefaultTreeOperationLogContainer; +import alice.jungle.transaction.NetworkDefaultJungleTreeEditor; + +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.app.bbs.JungleManager; + +public class LogSendTest { + + public static void main(String[] args) { + System.out.println("Start LogSendTest"); + JungleTree tree = JungleManager.createNewTree("tree"); + JungleTreeEditor editor = tree.getTreeEditor(); + + DefaultNodePath root = new DefaultNodePath(); + Either<Error, JungleTreeEditor> 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); + } + +}