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