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

annotate src/main/java/jp/ac/u_ryukyu/ie/cr/shoshi/jungle/transaction/DefaultTransactionManager.java @ 127:b2c1fd513feb

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
push index thread add read log
author one
date Mon, 13 Oct 2014 03:22:16 +0900
parents 5df5505e1c1e
children 6e9a8d26e0cf
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
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
3 import java.util.Iterator;
103
bed3afd5c2e2 add Index but Not use
one
parents: 100
diff changeset
4
bed3afd5c2e2 add Index but Not use
one
parents: 100
diff changeset
5 import fj.data.List;
bed3afd5c2e2 add Index but Not use
one
parents: 100
diff changeset
6 import fj.data.TreeMap;
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
7 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeList;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
8 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListWriter;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
9 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Result;
54
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 53
diff changeset
10 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.ChangeSet;
110
cf17350a2415 traverse find args change Query
one
parents: 107
diff changeset
11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.NodePath;
54
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 53
diff changeset
12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.TreeNode;
53
ed890dcb673e modified JungleTreeEditor
Shoshi TAMAKI
parents: 45
diff changeset
13 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.TreeOperationLog;
ed890dcb673e modified JungleTreeEditor
Shoshi TAMAKI
parents: 45
diff changeset
14 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation;
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
15 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction.AtomicReservableReference.Reservation;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
16 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.DefaultEither;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
17 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
18 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
19 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error;
110
cf17350a2415 traverse find args change Query
one
parents: 107
diff changeset
20 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Pair;
38
cb9fabaedfd4 added tests and changed testing provider to junit47
Shoshi TAMAKI
parents:
diff changeset
21
86
fb1dc448ac8c delete <T extends TreeNode>
one
parents: 82
diff changeset
22 public class DefaultTransactionManager implements TransactionManager
38
cb9fabaedfd4 added tests and changed testing provider to junit47
Shoshi TAMAKI
parents:
diff changeset
23 {
86
fb1dc448ac8c delete <T extends TreeNode>
one
parents: 82
diff changeset
24 private final AtomicReservableReference<TreeContext> repository;
fb1dc448ac8c delete <T extends TreeNode>
one
parents: 82
diff changeset
25 private final TreeContext tip;
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
26 private final ChangeListWriter writer;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
27 private final String uuid;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
28
86
fb1dc448ac8c delete <T extends TreeNode>
one
parents: 82
diff changeset
29 public DefaultTransactionManager(ChangeListWriter _writer,TreeContext _tip,
fb1dc448ac8c delete <T extends TreeNode>
one
parents: 82
diff changeset
30 AtomicReservableReference<TreeContext> _repository,String _uuid)
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
31 {
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
32 repository = _repository;
54
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 53
diff changeset
33 tip = _tip;
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
34 writer = _writer;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
35 uuid = _uuid;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
36 }
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
37
38
cb9fabaedfd4 added tests and changed testing provider to junit47
Shoshi TAMAKI
parents:
diff changeset
38 @Override
111
5df5505e1c1e change Index type
one
parents: 110
diff changeset
39 public Either<Error,TransactionManager> commit(TreeNode _newRoot,final TreeOperationLog _log, TreeMap<String, TreeMap<String, List<Pair<TreeNode, NodePath>>>> index)
38
cb9fabaedfd4 added tests and changed testing provider to junit47
Shoshi TAMAKI
parents:
diff changeset
40 {
81
715a9fbf02fc remove <T> many source
one
parents: 74
diff changeset
41 ChangeSet cs = tip.getChangeSet();
54
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 53
diff changeset
42 long currentRevision = cs.revision();
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
43 long nextRevision = currentRevision + 1;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
44
59
57e965b73c9e Implement getTreeName method in ChangeSet and ChangeList interface.
one
parents: 54
diff changeset
45 final String _treeName = cs.getTreeName();
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
46 ChangeList list = new ChangeList(){
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
47 @Override
53
ed890dcb673e modified JungleTreeEditor
Shoshi TAMAKI
parents: 45
diff changeset
48 public Iterator<TreeOperation> iterator(){
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
49 return _log.iterator();
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
50 }
59
57e965b73c9e Implement getTreeName method in ChangeSet and ChangeList interface.
one
parents: 54
diff changeset
51 @Override
57e965b73c9e Implement getTreeName method in ChangeSet and ChangeList interface.
one
parents: 54
diff changeset
52 public String getTreeName(){
57e965b73c9e Implement getTreeName method in ChangeSet and ChangeList interface.
one
parents: 54
diff changeset
53 return _treeName;
57e965b73c9e Implement getTreeName method in ChangeSet and ChangeList interface.
one
parents: 54
diff changeset
54 }
57e965b73c9e Implement getTreeName method in ChangeSet and ChangeList interface.
one
parents: 54
diff changeset
55 @Override
57e965b73c9e Implement getTreeName method in ChangeSet and ChangeList interface.
one
parents: 54
diff changeset
56 public String uuid(){
57e965b73c9e Implement getTreeName method in ChangeSet and ChangeList interface.
one
parents: 54
diff changeset
57 return uuid;
57e965b73c9e Implement getTreeName method in ChangeSet and ChangeList interface.
one
parents: 54
diff changeset
58 }
127
b2c1fd513feb push index thread add read log
one
parents: 111
diff changeset
59 @Override
b2c1fd513feb push index thread add read log
one
parents: 111
diff changeset
60 public int getLogSize() {
b2c1fd513feb push index thread add read log
one
parents: 111
diff changeset
61 return _log.length();
b2c1fd513feb push index thread add read log
one
parents: 111
diff changeset
62 }
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
63 };
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
64
103
bed3afd5c2e2 add Index but Not use
one
parents: 100
diff changeset
65 DefaultChangeSet newCs = new DefaultChangeSet(_newRoot,cs,list,uuid, _treeName, nextRevision,index);
86
fb1dc448ac8c delete <T extends TreeNode>
one
parents: 82
diff changeset
66 DefaultTreeContext newContext = new DefaultTreeContext(_newRoot,newCs);
54
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 53
diff changeset
67
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 53
diff changeset
68 @SuppressWarnings("rawtypes")
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 53
diff changeset
69 Reservation reservation = repository.makeReservation(tip,newContext);
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
70 if(reservation == null){
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
71 return DefaultEither.newA((Error)new DefaultError());
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
72 }
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
73 Result r = writer.write(list);
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
74 if(r == Result.SUCCESS){
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
75 reservation.confirm();
86
fb1dc448ac8c delete <T extends TreeNode>
one
parents: 82
diff changeset
76 TransactionManager txManager = new DefaultTransactionManager(writer,newContext,repository,uuid);
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
77 return DefaultEither.newB(txManager);
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
78 }
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
79 return DefaultEither.newA((Error)new DefaultError());
38
cb9fabaedfd4 added tests and changed testing provider to junit47
Shoshi TAMAKI
parents:
diff changeset
80 }
cb9fabaedfd4 added tests and changed testing provider to junit47
Shoshi TAMAKI
parents:
diff changeset
81
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
82 @Override
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
83 public String getUUID()
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
84 {
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
85 return uuid;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
86 }
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
87
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
88 @Override
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
89 public long getRevision()
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
90 {
81
715a9fbf02fc remove <T> many source
one
parents: 74
diff changeset
91 ChangeSet cs = tip.getChangeSet();
54
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 53
diff changeset
92 return cs.revision();
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents: 38
diff changeset
93 }
38
cb9fabaedfd4 added tests and changed testing provider to junit47
Shoshi TAMAKI
parents:
diff changeset
94 }