|
45
|
1 package jp.ac.u_ryukyu.ie.cr.shoshi.jungle;
|
|
|
2
|
|
|
3 import java.util.Iterator;
|
|
|
4 import java.util.concurrent.ConcurrentHashMap;
|
|
|
5 import fj.data.List;
|
|
|
6 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeList;
|
|
|
7 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Journal;
|
|
|
8 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.NullJournal;
|
|
54
|
9 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.ChangeSet;
|
|
|
10 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.TreeEditor;
|
|
|
11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultNodePath;
|
|
|
12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultTreeEditor;
|
|
|
13 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation;
|
|
45
|
14 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction.DefaultChangeSet;
|
|
54
|
15 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction.DefaultTreeContext;
|
|
|
16 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction.DefaultTreeNode;
|
|
|
17 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.traverser.DefaultTraverser;
|
|
|
18 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either;
|
|
|
19 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error;
|
|
45
|
20
|
|
|
21 public class DefaultJungle implements Jungle
|
|
|
22 {
|
|
|
23 private Journal journal;
|
|
|
24 private ConcurrentHashMap<String,JungleTree> trees;
|
|
|
25 private String uuid;
|
|
54
|
26 private TreeEditor editor;
|
|
45
|
27
|
|
54
|
28 public static void main(String _args[])
|
|
|
29 {
|
|
|
30 DefaultJungle j = new DefaultJungle(null,"hoge",new DefaultTreeEditor(new DefaultTraverser()));
|
|
|
31 JungleTree t = j.createNewTree("fuga");
|
|
|
32
|
|
|
33 JungleTreeEditor e1 = t.getTreeEditor();
|
|
|
34 JungleTreeEditor e2 = t.getTreeEditor();
|
|
|
35
|
|
|
36 DefaultNodePath root = new DefaultNodePath();
|
|
|
37
|
|
|
38 Either<Error,JungleTreeEditor> either = e1.addNewChildAt(root,0);
|
|
|
39 e1 = either.b();
|
|
|
40 either = e1.addNewChildAt(root.add(0),0);
|
|
|
41 e1 = either.b();
|
|
|
42 e1.success();
|
|
|
43 }
|
|
|
44
|
|
|
45 public DefaultJungle(Journal _journal,String _uuid,TreeEditor _editor)
|
|
45
|
46 {
|
|
|
47 journal = new NullJournal();
|
|
|
48 trees = new ConcurrentHashMap<String,JungleTree>();
|
|
|
49 uuid = _uuid;
|
|
54
|
50 editor = _editor;
|
|
45
|
51 }
|
|
|
52
|
|
|
53 @Override
|
|
|
54 public JungleTree getTreeByName(String _name)
|
|
|
55 {
|
|
|
56 return trees.get(_name);
|
|
|
57 }
|
|
|
58
|
|
|
59 @Override
|
|
|
60 public JungleTree createNewTree(String _name)
|
|
|
61 {
|
|
|
62 ChangeList list = new ChangeList(){
|
|
|
63 @Override
|
|
54
|
64 public Iterator<TreeOperation> iterator() {
|
|
|
65 List<TreeOperation> nil = List.nil();
|
|
45
|
66 return nil.iterator();
|
|
|
67 }
|
|
|
68 };
|
|
54
|
69
|
|
|
70 DefaultTreeNode root = new DefaultTreeNode();
|
|
|
71 ChangeSet set = new DefaultChangeSet(root.getAsNode(),null,list,uuid,0);
|
|
|
72 DefaultTreeContext<DefaultTreeNode> tc = new DefaultTreeContext<DefaultTreeNode>(root,set);
|
|
|
73 JungleTree newTree = new DefaultJungleTree<DefaultTreeNode>(tc,uuid,journal.getWriter(),editor);
|
|
46
|
74 if(trees.putIfAbsent(_name,newTree) != null){
|
|
|
75 return null;
|
|
|
76 }
|
|
45
|
77 return newTree;
|
|
|
78 }
|
|
|
79 }
|
