annotate src/main/java/jp/ac/u_ryukyu/ie/cr/shoshi/jungle/DefaultJungle.java @ 179:817febd9c69b

change transaction
author tatsuki
date Tue, 17 Mar 2015 11:19:04 +0900
parents 550f51183d8a
children 066d9c5758dc
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
1 package jp.ac.u_ryukyu.ie.cr.shoshi.jungle;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
2
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
3 import java.util.Iterator;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
4 import java.util.concurrent.ConcurrentHashMap;
74
3a3622cf2eef remove error but have a error test program
one
parents: 59
diff changeset
5
174
one
parents: 170
diff changeset
6 import fj.Ord;
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
7 import fj.data.List;
163
7be56a1be5d9 modification index
one
parents: 153
diff changeset
8 import fj.data.TreeMap;
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
9 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeList;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
10 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Journal;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.NullJournal;
179
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.TreeContext;
54
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
13 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.TreeEditor;
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
14 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultNodePath;
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
15 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultTreeEditor;
163
7be56a1be5d9 modification index
one
parents: 153
diff changeset
16 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.TreeNode;
54
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
17 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation;
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
18 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction.DefaultTreeContext;
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
19 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction.DefaultTreeNode;
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
20 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.traverser.DefaultTraverser;
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
21 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either;
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
22 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error;
149
feb2346ace19 refactor ParentIndex
one
parents: 146
diff changeset
23 import jp.ac.u_ryukyu.ie.cr.tatsuki.jungle.store.index.ParentIndex;
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
24
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
25 public class DefaultJungle implements Jungle
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
26 {
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
27 private Journal journal;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
28 private ConcurrentHashMap<String,JungleTree> trees;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
29 private String uuid;
54
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
30 private TreeEditor editor;
104
f9a0e7069811 delete worning halfway
one
parents: 100
diff changeset
31 public static void main(String args[])
54
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
32 {
153
20af7f25ef32 miner change
one
parents: 152
diff changeset
33 DefaultJungle j = new DefaultJungle(null,"hoge",new DefaultTreeEditor(new DefaultTraverser()));
54
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
34 JungleTree t = j.createNewTree("fuga");
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
35
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
36 JungleTreeEditor e1 = t.getTreeEditor();
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
37
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
38 DefaultNodePath root = new DefaultNodePath();
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
39
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
40 Either<Error,JungleTreeEditor> either = e1.addNewChildAt(root,0);
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
41 e1 = either.b();
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
42 either = e1.addNewChildAt(root.add(0),0);
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
43 e1 = either.b();
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
44 e1.success();
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
45 }
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
46
175
e26462a38ce0 add push pop
tatsuki
parents: 170
diff changeset
47 public DefaultJungle(Journal journal,String uuid,TreeEditor editor)
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
48 {
104
f9a0e7069811 delete worning halfway
one
parents: 100
diff changeset
49 this.journal = new NullJournal();
f9a0e7069811 delete worning halfway
one
parents: 100
diff changeset
50 this.trees = new ConcurrentHashMap<String,JungleTree>();
f9a0e7069811 delete worning halfway
one
parents: 100
diff changeset
51 this.uuid = uuid;
153
20af7f25ef32 miner change
one
parents: 152
diff changeset
52 this.editor = editor;
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
53 }
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
54
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
55 @Override
104
f9a0e7069811 delete worning halfway
one
parents: 100
diff changeset
56 public JungleTree getTreeByName(String name)
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
57 {
104
f9a0e7069811 delete worning halfway
one
parents: 100
diff changeset
58 return trees.get(name);
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
59 }
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
60
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
61 @Override
104
f9a0e7069811 delete worning halfway
one
parents: 100
diff changeset
62 public JungleTree createNewTree(final String name)
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
63 {
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
64 ChangeList list = new ChangeList(){
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
65 @Override
54
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
66 public Iterator<TreeOperation> iterator() {
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
67 List<TreeOperation> nil = List.nil();
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
68 return nil.iterator();
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
69 }
59
57e965b73c9e Implement getTreeName method in ChangeSet and ChangeList interface.
one
parents: 54
diff changeset
70 @Override
57e965b73c9e Implement getTreeName method in ChangeSet and ChangeList interface.
one
parents: 54
diff changeset
71 public String uuid() {
57e965b73c9e Implement getTreeName method in ChangeSet and ChangeList interface.
one
parents: 54
diff changeset
72 return uuid;
57e965b73c9e Implement getTreeName method in ChangeSet and ChangeList interface.
one
parents: 54
diff changeset
73 }
57e965b73c9e Implement getTreeName method in ChangeSet and ChangeList interface.
one
parents: 54
diff changeset
74 @Override
57e965b73c9e Implement getTreeName method in ChangeSet and ChangeList interface.
one
parents: 54
diff changeset
75 public String getTreeName() {
104
f9a0e7069811 delete worning halfway
one
parents: 100
diff changeset
76 return name;
59
57e965b73c9e Implement getTreeName method in ChangeSet and ChangeList interface.
one
parents: 54
diff changeset
77 }
127
b2c1fd513feb push index thread add read log
one
parents: 111
diff changeset
78
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
79 };
54
650fe2a0dccc modified tests
Shoshi TAMAKI
parents: 46
diff changeset
80 DefaultTreeNode root = new DefaultTreeNode();
174
one
parents: 170
diff changeset
81 TreeMap<String, TreeMap<String, TreeMap<TreeNode, TreeNode>>> indexList = TreeMap.empty(Ord.stringOrd);
175
e26462a38ce0 add push pop
tatsuki
parents: 170
diff changeset
82 TreeMap<TreeNode, TreeNode> parentIndex = new ParentIndex().getParentIndex();
179
817febd9c69b change transaction
tatsuki
parents: 176
diff changeset
83 TreeContext tc = new DefaultTreeContext(root,null,list,uuid,name,0,indexList,parentIndex);
153
20af7f25ef32 miner change
one
parents: 152
diff changeset
84 JungleTree newTree = new DefaultJungleTree(tc,uuid,journal.getWriter(),editor);
104
f9a0e7069811 delete worning halfway
one
parents: 100
diff changeset
85 if(trees.putIfAbsent(name,newTree) != null){
46
e7d94437ca2f added sample
Shoshi TAMAKI
parents: 45
diff changeset
86 return null;
e7d94437ca2f added sample
Shoshi TAMAKI
parents: 45
diff changeset
87 }
45
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
88 return newTree;
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
89 }
fb00d7b147c8 added JungleTree service
Shoshi TAMAKI
parents:
diff changeset
90 }