Mercurial > hg > Members > nobuyasu > jungle-network

annotate src/jungle/test/codesegment/persistence/AliceJournal.java @ 30:8593c2525aa7

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add NeworkTransactionManager
author one
date Mon, 01 Jul 2013 20:31:29 +0900
parents e968224ad0ce
children 190f6a3bdab2
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
17
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
1 package jungle.test.codesegment.persistence;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
2
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
3 import java.nio.ByteBuffer;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
4
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
5 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeList;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
6 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListReader;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
7 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListWriter;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
8 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Journal;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
9 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Result;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
10 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.Command;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.NodePath;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.NodeOperation;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
13 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
14 import jungle.test.datasegment.store.operations.DefaultNodeOperationContainer;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
15 import jungle.test.datasegment.store.operations.DefaultTreeOperationContainer;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
16
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
17 public class AliceJournal implements Journal {
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
18
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
19 private static final AliceChangeListWriter ALICE_WRITER = new AliceChangeListWriter();
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
20 private static final AliceChangeListReader ALICE_READER = new AliceChangeListReader();
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
21 @Override
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
22 public ChangeListReader getReader() {
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
23 return ALICE_READER;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
24 }
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
25 @Override
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
26 public ChangeListWriter getWriter() {
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
27 return ALICE_WRITER;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
28 }
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
29
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
30 private static class AliceChangeListWriter implements ChangeListWriter
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
31 {
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
32 @Override
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
33 public Result write(ChangeList _operations)
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
34 {
30
8593c2525aa7 add NeworkTransactionManager
one
parents: 28
diff changeset
35 /*
17
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
36 for(TreeOperation op : _operations){
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
37 DefaultTreeOperationContainer container = new DefaultTreeOperationContainer();
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
38 container.unconvert(op);
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
39 cs.ods.update("local", "op", op);
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
40 }
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
41
28
e968224ad0ce add jungle.test.core.practice
one
parents: 17
diff changeset
42 */
17
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
43 for(TreeOperation op : _operations){
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
44 NodePath p = op.getNodePath();
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
45 NodeOperation nodeOp = op.getNodeOperation();
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
46 Command c = nodeOp.getCommand();
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
47 String args = "";
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
48 switch(c){
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
49 case PUT_ATTRIBUTE:
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
50 String key = nodeOp.getKey();
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
51 ByteBuffer value = nodeOp.getValue();
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
52 if(value.limit() < 100){
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
53 args = String.format("key:%s,value:%s",key,new String(value.array()));
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
54 }else{
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
55 args = String.format("key:%s,value:%d",key,value.limit());
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
56 }
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
57 break;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
58 case DELETE_ATTRIBUTE:
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
59 args = String.format("key:%s",nodeOp.getKey());
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
60 break;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
61 case APPEND_CHILD:
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
62 args = String.format("pos:%d",nodeOp.getPosition());
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
63 break;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
64 case DELETE_CHILD:
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
65 args = String.format("pos:%d",nodeOp.getPosition());
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
66 break;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
67 }
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
68 System.out.println(String.format("[%s:%s:%s]",c,p,args));
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
69 }
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
70 return Result.SUCCESS;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
71 }
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
72 }
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
73
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
74 private static class AliceChangeListReader implements ChangeListReader
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
75 {
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
76 @Override
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
77 public ChangeListReader newReader()
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
78 {
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
79 return this;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
80 }
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
81
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
82 @Override
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
83 public ChangeList read()
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
84 {
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
85 return null;
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
86 }
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
87 }
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
88
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
89
c767e7af4d88 add TestPutAttributeCodeSegmnet and StartJungleCodeSegment
one
parents:
diff changeset
90 }