Mercurial > hg > Members > tatsuki > bench > jungle-core

annotate src/main/java/jp/ac/u_ryukyu/ie/cr/shoshi/jungle/transaction/DefaultTransactionManager.java @ 181:7282ee629af3

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add miss
author tatsuki
date Tue, 17 Mar 2015 15:38:27 +0900
parents 817febd9c69b
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
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
3cd075a445bf create parent index order o(n^2) → log(n)
one
parents: 166
diff changeset
3
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
4 import java.util.Iterator;
179
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
5 import java.util.concurrent.atomic.AtomicReference;
103
bed3afd5c2e2 add Index but Not use
one
parents: 100
diff changeset
6
174
one
parents: 172
diff changeset
7 import fj.data.TreeMap;
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
8 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeList;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
9 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListWriter;
179
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
10 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.TreeContext;
54
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 53
diff changeset
11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.TreeNode;
53
ed890dcb673e modified JungleTreeEditor
Shoshi TAMAKI
parents: 45
diff changeset
12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.TreeOperationLog;
ed890dcb673e modified JungleTreeEditor
Shoshi TAMAKI
parents: 45
diff changeset
13 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation;
154
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
14 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.traverser.InterfaceTraverser;
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
15 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.DefaultEither;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
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;
149
feb2346ace19 refactor ParentIndex
one
parents: 146
diff changeset
19 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
20
154
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
21 public class DefaultTransactionManager implements TransactionManager {
179
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
22 private final AtomicReference<TreeContext> repository;
154
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
23 private final TreeContext tip;
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
24 private final ChangeListWriter writer;
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
25 private final String uuid;
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
26
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
27 public DefaultTransactionManager(ChangeListWriter _writer, TreeContext _tip,
179
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
28 AtomicReference<TreeContext> _repository, String _uuid) {
154
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
29 repository = _repository;
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
30 tip = _tip;
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
31 writer = _writer;
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
32 uuid = _uuid;
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
33 }
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
34
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
35 @Override
179
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
36 public Either<Error, TransactionManager> commit(TreeNode newRoot, final TreeOperationLog _log) {
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
37 long currentRevision = tip.revision();
154
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
38 long nextRevision = currentRevision + 1;
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
39
179
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
40 final String _treeName = tip.getTreeName();
154
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
41 ChangeList list = new ChangeList() {
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
42 @Override
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
43 public Iterator<TreeOperation> iterator() {
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
44 return _log.iterator();
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
45 }
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
46
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
47 @Override
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
48 public String getTreeName() {
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
49 return _treeName;
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
50 }
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
51
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
52 @Override
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
53 public String uuid() {
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
54 return uuid;
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
55 }
135
6e9a8d26e0cf refactor
one
parents: 127
diff changeset
56
154
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
57 };
181
7282ee629af3 add miss
tatsuki
parents: 179
diff changeset
58
179
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
59 InterfaceTraverser traverser = new InterfaceTraverser(newRoot, true);
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
60 traverser.createIndex();
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
61 TreeMap<String, TreeMap<String, TreeMap<TreeNode, TreeNode>>> index = traverser.getIndex();
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
62 ParentIndex parentIndex = traverser.getParentIndex();
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
63 TreeContext newTreeContext = new DefaultTreeContext(newRoot , tip, list, uuid, _treeName, nextRevision,index,parentIndex.getParentIndex());
38
cb9fabaedfd4 added tests and changed testing provider to junit47
Shoshi TAMAKI
parents:
diff changeset
64
179
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
65 if (repository.compareAndSet(newTreeContext.prev(),newTreeContext)) {
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
66 TransactionManager txManager = new DefaultTransactionManager(writer, newTreeContext, repository, uuid);
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
67 return DefaultEither.newB(txManager);
154
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
68 }
179
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
69
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
70 return DefaultEither.newA((Error) new DefaultError());
154
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
71 }
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
72
154
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
73 @Override
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
74 public String getUUID() {
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
75 return uuid;
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
76 }
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
77
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
78 @Override
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
79 public long getRevision() {
179
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
80 return tip.revision();
154
b8cef4b640a3 update index for commit
one
parents: 153
diff changeset
81 }
38
cb9fabaedfd4 added tests and changed testing provider to junit47
Shoshi TAMAKI
parents:
diff changeset
82 }