Mercurial > hg > Members > tatsuki > bench > jungle-core
annotate src/main/java/jp/ac/u_ryukyu/ie/cr/shoshi/jungle/transaction/DefaultTransactionManager.java @ 169:3cd075a445bf
create parent index order o(n^2) → log(n)
author | one |
---|---|
date | Fri, 26 Dec 2014 01:43:54 +0900 |
parents | 6615db346bf5 |
children | 809f813d1083 |
rev | line source |
---|---|
38
cb9fabaedfd4
added tests and changed testing provider to junit47
Shoshi TAMAKI
parents:
diff
changeset
|
1 package jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction; |
cb9fabaedfd4
added tests and changed testing provider to junit47
Shoshi TAMAKI
parents:
diff
changeset
|
2 |
169 | 3 |
45 | 4 import java.util.Iterator; |
103 | 5 |
45 | 6 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeList; |
7 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListWriter; | |
8 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Result; | |
54 | 9 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.ChangeSet; |
10 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.TreeNode; | |
53 | 11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.TreeOperationLog; |
12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation; | |
45 | 13 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction.AtomicReservableReference.Reservation; |
154 | 14 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.traverser.InterfaceTraverser; |
45 | 15 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.DefaultEither; |
16 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.DefaultError; | |
38
cb9fabaedfd4
added tests and changed testing provider to junit47
Shoshi TAMAKI
parents:
diff
changeset
|
17 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either; |
cb9fabaedfd4
added tests and changed testing provider to junit47
Shoshi TAMAKI
parents:
diff
changeset
|
18 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error; |
151 | 19 import jp.ac.u_ryukyu.ie.cr.tatsuki.jungle.store.index.Index; |
154 | 20 import jp.ac.u_ryukyu.ie.cr.tatsuki.jungle.store.index.IndexManager; |
149 | 21 import jp.ac.u_ryukyu.ie.cr.tatsuki.jungle.store.index.ParentIndex; |
38
cb9fabaedfd4
added tests and changed testing provider to junit47
Shoshi TAMAKI
parents:
diff
changeset
|
22 |
154 | 23 public class DefaultTransactionManager implements TransactionManager { |
24 private final AtomicReservableReference<TreeContext> repository; | |
25 private final TreeContext tip; | |
26 private final ChangeListWriter writer; | |
27 private final String uuid; | |
28 | |
29 public DefaultTransactionManager(ChangeListWriter _writer, TreeContext _tip, | |
30 AtomicReservableReference<TreeContext> _repository, String _uuid) { | |
31 repository = _repository; | |
32 tip = _tip; | |
33 writer = _writer; | |
34 uuid = _uuid; | |
35 } | |
36 | |
37 @Override | |
38 public Either<Error, TransactionManager> commit(TreeNode _newRoot, final TreeOperationLog _log) { | |
39 ChangeSet cs = tip.getChangeSet(); | |
40 long currentRevision = cs.revision(); | |
41 long nextRevision = currentRevision + 1; | |
42 | |
43 final String _treeName = cs.getTreeName(); | |
44 ChangeList list = new ChangeList() { | |
45 @Override | |
46 public Iterator<TreeOperation> iterator() { | |
47 return _log.iterator(); | |
48 } | |
49 | |
50 @Override | |
51 public String getTreeName() { | |
52 return _treeName; | |
53 } | |
54 | |
55 @Override | |
56 public String uuid() { | |
57 return uuid; | |
58 } | |
135 | 59 |
154 | 60 }; |
61 | |
62 IndexManager indexManager = new IndexManager(repository.getReservation()); | |
166 | 63 InterfaceTraverser traverser = new InterfaceTraverser(_newRoot, indexManager, false); |
169 | 64 System.out.println("not use Index"); |
154 | 65 traverser.createIndex(); |
163 | 66 Index index = traverser.getIndex(); |
67 ParentIndex parentIndex = traverser.getParentIndex(); | |
68 DefaultChangeSet newCs = new DefaultChangeSet(_newRoot, cs, list, uuid, _treeName, nextRevision, index.getIndex(), | |
69 parentIndex.getParentIndex()); | |
154 | 70 DefaultTreeContext newContext = new DefaultTreeContext(_newRoot, newCs); |
38
cb9fabaedfd4
added tests and changed testing provider to junit47
Shoshi TAMAKI
parents:
diff
changeset
|
71 |
154 | 72 @SuppressWarnings("rawtypes") |
73 Reservation reservation = repository.makeReservation(tip, newContext); | |
74 if (reservation == null) { | |
75 return DefaultEither.newA((Error) new DefaultError()); | |
76 } | |
77 Result r = writer.write(list); | |
78 if (r == Result.SUCCESS) { | |
79 reservation.confirm(); | |
80 TransactionManager txManager = new DefaultTransactionManager(writer, newContext, repository, uuid); | |
81 return DefaultEither.newB(txManager); | |
82 } | |
83 return DefaultEither.newA((Error) new DefaultError()); | |
84 } | |
45 | 85 |
154 | 86 @Override |
87 public String getUUID() { | |
88 return uuid; | |
89 } | |
90 | |
91 @Override | |
92 public long getRevision() { | |
93 ChangeSet cs = tip.getChangeSet(); | |
94 return cs.revision(); | |
95 } | |
38
cb9fabaedfd4
added tests and changed testing provider to junit47
Shoshi TAMAKI
parents:
diff
changeset
|
96 } |