Mercurial > hg > Members > nobuyasu > jungle-network
annotate src/jungle/test/codesegment/persistence/AliceJournal.java @ 53:f47a02368099
implemented timestamp in DefaultTreeOperationLogContainer
| author | one |
|---|---|
| date | Sun, 14 Jul 2013 16:13:37 +0900 |
| parents | 9e782b4eb06e |
| children | ccfe9b5e8f11 |
| rev | line source |
|---|---|
| 17 | 1 package jungle.test.codesegment.persistence; |
| 2 | |
| 3 import java.nio.ByteBuffer; | |
| 4 | |
| 31 | 5 import alice.jungle.datasegment.store.operations.DefaultNodeOperationContainer; |
| 6 import alice.jungle.datasegment.store.operations.DefaultTreeOperationContainer; | |
| 7 | |
| 17 | 8 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeList; |
| 9 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListReader; | |
| 10 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListWriter; | |
| 11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Journal; | |
| 12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Result; | |
| 13 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.Command; | |
| 14 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.NodePath; | |
| 15 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.NodeOperation; | |
| 16 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation; | |
| 17 | |
| 18 public class AliceJournal implements Journal { | |
| 19 | |
| 20 private static final AliceChangeListWriter ALICE_WRITER = new AliceChangeListWriter(); | |
| 21 private static final AliceChangeListReader ALICE_READER = new AliceChangeListReader(); | |
| 22 @Override | |
| 23 public ChangeListReader getReader() { | |
| 24 return ALICE_READER; | |
| 25 } | |
| 26 @Override | |
| 27 public ChangeListWriter getWriter() { | |
| 28 return ALICE_WRITER; | |
| 29 } | |
| 30 | |
| 31 private static class AliceChangeListWriter implements ChangeListWriter | |
| 32 { | |
| 33 @Override | |
| 34 public Result write(ChangeList _operations) | |
| 35 { | |
|
53
f47a02368099
implemented timestamp in DefaultTreeOperationLogContainer
one
parents:
51
diff
changeset
|
36 /* |
| 17 | 37 for(TreeOperation op : _operations){ |
| 38 NodePath p = op.getNodePath(); | |
| 39 NodeOperation nodeOp = op.getNodeOperation(); | |
| 40 Command c = nodeOp.getCommand(); | |
| 41 String args = ""; | |
| 42 switch(c){ | |
| 43 case PUT_ATTRIBUTE: | |
| 44 String key = nodeOp.getKey(); | |
| 45 ByteBuffer value = nodeOp.getValue(); | |
| 46 if(value.limit() < 100){ | |
| 47 args = String.format("key:%s,value:%s",key,new String(value.array())); | |
| 48 }else{ | |
| 49 args = String.format("key:%s,value:%d",key,value.limit()); | |
| 50 } | |
| 51 break; | |
| 52 case DELETE_ATTRIBUTE: | |
| 53 args = String.format("key:%s",nodeOp.getKey()); | |
| 54 break; | |
| 55 case APPEND_CHILD: | |
| 56 args = String.format("pos:%d",nodeOp.getPosition()); | |
| 57 break; | |
| 58 case DELETE_CHILD: | |
| 59 args = String.format("pos:%d",nodeOp.getPosition()); | |
| 60 break; | |
| 61 } | |
| 62 System.out.println(String.format("[%s:%s:%s]",c,p,args)); | |
| 63 } | |
|
53
f47a02368099
implemented timestamp in DefaultTreeOperationLogContainer
one
parents:
51
diff
changeset
|
64 */ |
| 17 | 65 return Result.SUCCESS; |
| 66 } | |
| 67 } | |
| 68 | |
| 69 private static class AliceChangeListReader implements ChangeListReader | |
| 70 { | |
| 71 @Override | |
| 72 public ChangeListReader newReader() | |
| 73 { | |
| 74 return this; | |
| 75 } | |
| 76 | |
| 77 @Override | |
| 78 public ChangeList read() | |
| 79 { | |
| 80 return null; | |
| 81 } | |
| 82 } | |
| 83 | |
| 84 | |
| 85 } |