Mercurial > hg > Members > tatsuki > bench > jungle-core
annotate src/main/java/jp/ac/u_ryukyu/ie/cr/shoshi/jungle/DefaultJungleTree.java @ 148:a2c374a2686b
Merge with 0854f9a9e81db5db639f02a126ebabf1d004b98e
| author | one |
|---|---|
| date | Fri, 21 Nov 2014 12:49:28 +0900 |
| parents | 371b6ddb78f2 afbe19c98f53 |
| children | 8a0aa8fc137c |
| rev | line source |
|---|---|
| 45 | 1 package jp.ac.u_ryukyu.ie.cr.shoshi.jungle; |
| 2 | |
| 104 | 3 import fj.data.List; |
| 100 | 4 import fj.data.TreeMap; |
| 45 | 5 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListWriter; |
| 6 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.ChangeSet; | |
| 54 | 7 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.TreeEditor; |
| 145 | 8 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.IndexTreeEditor; |
| 54 | 9 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.TreeNode; |
| 127 | 10 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation; |
| 45 | 11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction.AtomicReservableReference; |
| 12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction.DefaultJungleTreeEditor; | |
| 13 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction.DefaultTransactionManager; | |
| 142 | 14 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction.DefaultTreeContext; |
|
117
74723b26ad96
add IndexJungleTreeEditr and remove DefaultJungleIndexTreeEditor
one
parents:
111
diff
changeset
|
15 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction.IndexJungleTreeEditor; |
| 54 | 16 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction.TreeContext; |
| 100 | 17 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.traverser.InterfaceTraverser; |
| 142 | 18 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.DefaultEither; |
| 19 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either; | |
| 20 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error; | |
| 21 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.GetOldTreeError; | |
| 134 | 22 import jp.ac.u_ryukyu.ie.cr.tatsuki.jungle.store.index.IndexManager; |
| 45 | 23 |
| 142 | 24 public class DefaultJungleTree implements JungleTree { |
| 25 private final AtomicReservableReference<TreeContext> repository; | |
| 26 private final String uuid; | |
| 27 private final ChangeListWriter writer; | |
| 145 | 28 private final TreeEditor treeEditor; |
| 29 private final IndexTreeEditor indexTreeEditor; | |
| 30 | |
| 31 public DefaultJungleTree(TreeContext tc, String uuid, ChangeListWriter writer, TreeEditor editor, IndexTreeEditor indexTreeEditor) { | |
| 142 | 32 this.repository = new AtomicReservableReference<TreeContext>(tc); |
| 33 this.uuid = uuid; | |
| 34 this.writer = writer; | |
| 145 | 35 this.treeEditor = editor; |
| 36 this.indexTreeEditor = indexTreeEditor; | |
| 142 | 37 } |
| 45 | 38 |
| 142 | 39 @Override |
| 40 public JungleTreeEditor getTreeEditor() { | |
| 41 TreeContext tc = repository.get(); | |
| 42 DefaultTransactionManager txManager = new DefaultTransactionManager(writer, tc, repository, uuid); | |
| 43 TreeNode root = tc.getTreeNode(); | |
| 146 | 44 TreeMap<String, TreeMap<String, List<TreeNode>>>index = getIndex(); |
| 145 | 45 TreeMap<TreeNode, TreeNode> parentIndex = getParentIndex(); |
| 46 return new DefaultJungleTreeEditor(root, txManager, treeEditor, index,parentIndex); | |
| 142 | 47 } |
| 48 | |
| 49 @Override | |
| 50 public IndexJungleTreeEditor getIndexTreeEditor() { | |
| 51 TreeContext tc = repository.get(); | |
| 52 DefaultTransactionManager txManager = new DefaultTransactionManager(writer, tc, repository, uuid); | |
| 53 TreeNode root = tc.getTreeNode(); | |
| 146 | 54 TreeMap<String, TreeMap<String, List<TreeNode>>> index = getIndex(); |
| 145 | 55 TreeMap<TreeNode, TreeNode> parentIndex = getParentIndex(); |
| 56 return new IndexJungleTreeEditor(root, txManager, indexTreeEditor, index, parentIndex); | |
| 57 } | |
| 58 | |
| 59 @Override | |
| 60 public TreeMap<TreeNode, TreeNode> getParentIndex() { | |
| 61 TreeContext tc = repository.get(); | |
| 62 ChangeSet cs = tc.getChangeSet(); | |
| 63 return cs.getParentIndex(); | |
| 142 | 64 } |
| 65 | |
| 66 @Override | |
| 67 public JungleTreeEditor getLocalTreeEditor() { | |
| 68 return getTreeEditor(); | |
| 69 } | |
| 70 | |
| 71 @Override | |
| 72 public TreeNode getRootNode() { | |
| 73 TreeContext tc = repository.get(); | |
| 74 ChangeSet cs = tc.getChangeSet(); | |
| 75 return cs.getRoot(); | |
| 76 } | |
| 45 | 77 |
| 142 | 78 @Override |
| 79 public InterfaceTraverser getTraverser() { | |
| 80 AtomicReservableReference<TreeContext>.Reservation reservation = repository.getReservation(); | |
| 81 IndexManager indexManager = new IndexManager(reservation); | |
| 146 | 82 TreeMap<String, TreeMap<String, List<TreeNode>>> index = getIndex(); |
| 142 | 83 if (index != null) |
| 84 return new InterfaceTraverser(getRootNode(), index, indexManager); | |
| 85 return new InterfaceTraverser(getRootNode(), indexManager); | |
| 86 } | |
| 87 | |
| 88 @Override | |
| 146 | 89 public TreeMap<String, TreeMap<String, List<TreeNode>>> getIndex() { |
| 142 | 90 TreeContext tc = repository.get(); |
| 91 ChangeSet cs = tc.getChangeSet(); | |
| 92 return cs.getIndex(); | |
| 93 } | |
| 94 | |
| 95 @Override | |
| 96 public Iterable<TreeOperation> getLog() { | |
| 97 TreeContext tc = repository.get(); | |
| 98 ChangeSet cs = tc.getChangeSet(); | |
| 99 return cs.getOperations(); | |
| 100 } | |
| 100 | 101 |
| 142 | 102 @Override |
| 103 public long revision() { | |
| 104 TreeContext tc = repository.get(); | |
| 105 ChangeSet cs = tc.getChangeSet(); | |
| 106 return cs.revision(); | |
| 107 } | |
| 108 | |
| 109 @Override | |
| 110 public Either<Error, JungleTree> getOldTree(long revision) { | |
| 111 TreeContext tc = repository.get(); | |
| 112 ChangeSet cs = tc.getChangeSet(); | |
| 113 | |
| 114 for (;cs.revision() != revision;) { | |
| 115 cs = cs.prev(); | |
| 116 if (cs == null) | |
| 117 return DefaultEither.newA(GetOldTreeError.OLD_TREE_NOT_FOUND); | |
| 118 } | |
| 119 | |
| 120 TreeNode root = cs.getRoot(); | |
| 121 | |
| 122 TreeContext oldTc = new DefaultTreeContext(root, cs); | |
| 123 String oldTreeUuid = uuid + revision; | |
| 145 | 124 JungleTree oldTree = new DefaultJungleTree(oldTc,oldTreeUuid,writer,treeEditor,indexTreeEditor); |
| 142 | 125 return DefaultEither.newB(oldTree); |
| 126 } | |
| 127 | |
| 128 | |
| 45 | 129 } |