Mercurial > hg > Database > jungle-network

annotate src/jungle/app/bbs/JungleManager.java @ 95:dcd767b76f8d

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Modified putDataSement for to use NetworkTreeOperationLog
author one
date Mon, 18 Nov 2013 17:08:17 +0900
parents 75cf01a430a6
children fcce7ca4adb9
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
66
29127ac788a6 move some files
one
parents: 65
diff changeset
1 package jungle.app.bbs;
39
10359a815068 add alice.jungle.codesegment.remote
one
parents: 31
diff changeset
2
59
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
3 import java.io.IOException;
39
10359a815068 add alice.jungle.codesegment.remote
one
parents: 31
diff changeset
4 import java.nio.ByteBuffer;
59
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
5 import java.util.Iterator;
15
bf4a7f899c4e add some files
one
parents:
diff changeset
6
75
87ec5dd0dc27 Rename from alice.jungle.datasegment.store.operation to alice.jungle.datasegment.store.container
one
parents: 67
diff changeset
7 import alice.jungle.datasegment.store.container.DefaultTreeOperationLogContainer;
93
75cf01a430a6 Added LocalTreeEditor
one
parents: 90
diff changeset
8 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.DefaultJungle;
15
bf4a7f899c4e add some files
one
parents:
diff changeset
9 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.Jungle;
bf4a7f899c4e add some files
one
parents:
diff changeset
10 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTree;
39
10359a815068 add alice.jungle.codesegment.remote
one
parents: 31
diff changeset
11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTreeEditor;
59
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.core.Node;
39
10359a815068 add alice.jungle.codesegment.remote
one
parents: 31
diff changeset
13 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.Command;
90
eef737ab3b2c Modified JungleManager class
one
parents: 75
diff changeset
14 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.NodePath;
56
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
15 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultNodePath;
93
75cf01a430a6 Added LocalTreeEditor
one
parents: 90
diff changeset
16 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.DefaultTreeEditor;
59
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
17 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.DefaultTreeOperationLog;
39
10359a815068 add alice.jungle.codesegment.remote
one
parents: 31
diff changeset
18 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.TreeOperationLog;
10359a815068 add alice.jungle.codesegment.remote
one
parents: 31
diff changeset
19 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.NodeOperation;
10359a815068 add alice.jungle.codesegment.remote
one
parents: 31
diff changeset
20 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation;
93
75cf01a430a6 Added LocalTreeEditor
one
parents: 90
diff changeset
21 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.traverser.DefaultTraverser;
39
10359a815068 add alice.jungle.codesegment.remote
one
parents: 31
diff changeset
22 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either;
10359a815068 add alice.jungle.codesegment.remote
one
parents: 31
diff changeset
23 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error;
15
bf4a7f899c4e add some files
one
parents:
diff changeset
24
bf4a7f899c4e add some files
one
parents:
diff changeset
25 public class JungleManager {
45
bf3dc481cc9b modified JungleManager to singleton
one
parents: 43
diff changeset
26 private static JungleManager jm = new JungleManager();
43
12d87bb4b84d modified LogUpdateCodeSegment
one
parents: 42
diff changeset
27 private Jungle jungle;
90
eef737ab3b2c Modified JungleManager class
one
parents: 75
diff changeset
28 private static int NOT_CHANGE_POSITION = 0;
43
12d87bb4b84d modified LogUpdateCodeSegment
one
parents: 42
diff changeset
29
45
bf3dc481cc9b modified JungleManager to singleton
one
parents: 43
diff changeset
30 private JungleManager() {
93
75cf01a430a6 Added LocalTreeEditor
one
parents: 90
diff changeset
31 jungle = new DefaultJungle(null,"hogehoge",new DefaultTreeEditor(new DefaultTraverser()));
15
bf4a7f899c4e add some files
one
parents:
diff changeset
32 }
bf4a7f899c4e add some files
one
parents:
diff changeset
33
45
bf3dc481cc9b modified JungleManager to singleton
one
parents: 43
diff changeset
34 public static void setJungle(Jungle _j) {
bf3dc481cc9b modified JungleManager to singleton
one
parents: 43
diff changeset
35 jm.jungle = _j;
15
bf4a7f899c4e add some files
one
parents:
diff changeset
36 }
bf4a7f899c4e add some files
one
parents:
diff changeset
37
43
12d87bb4b84d modified LogUpdateCodeSegment
one
parents: 42
diff changeset
38 public static Jungle getJungle() {
12d87bb4b84d modified LogUpdateCodeSegment
one
parents: 42
diff changeset
39 return jm.jungle;
12d87bb4b84d modified LogUpdateCodeSegment
one
parents: 42
diff changeset
40 }
12d87bb4b84d modified LogUpdateCodeSegment
one
parents: 42
diff changeset
41
12d87bb4b84d modified LogUpdateCodeSegment
one
parents: 42
diff changeset
42 public static JungleTree createNewTree(String name) {
12d87bb4b84d modified LogUpdateCodeSegment
one
parents: 42
diff changeset
43 return jm.jungle.createNewTree(name);
15
bf4a7f899c4e add some files
one
parents:
diff changeset
44 }
bf4a7f899c4e add some files
one
parents:
diff changeset
45
56
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
46 public static Either<Error, JungleTreeEditor> edit(JungleTreeEditor _editor ,TreeOperationLog _log, int pos) {
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
47 JungleTreeEditor editor = _editor;
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
48 Either<Error, JungleTreeEditor> either = null;
90
eef737ab3b2c Modified JungleManager class
one
parents: 75
diff changeset
49 for (TreeOperation op : _log) {
56
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
50 either = _edit(editor, op, pos);
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
51 if(either.isA()) {
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
52 return either;
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
53 }
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
54 editor = either.b();
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
55 }
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
56 return either;
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
57 }
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
58
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
59 private static Either<Error, JungleTreeEditor> _edit(JungleTreeEditor editor,
90
eef737ab3b2c Modified JungleManager class
one
parents: 75
diff changeset
60 TreeOperation op, int _pos) {
eef737ab3b2c Modified JungleManager class
one
parents: 75
diff changeset
61 NodePath path = new DefaultNodePath();
56
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
62 NodeOperation nodeOp = op.getNodeOperation();
90
eef737ab3b2c Modified JungleManager class
one
parents: 75
diff changeset
63 int pos = _pos;
eef737ab3b2c Modified JungleManager class
one
parents: 75
diff changeset
64 if (_pos == NOT_CHANGE_POSITION ) {
eef737ab3b2c Modified JungleManager class
one
parents: 75
diff changeset
65 pos = nodeOp.getPosition();
eef737ab3b2c Modified JungleManager class
one
parents: 75
diff changeset
66 }
56
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
67 Command c = nodeOp.getCommand();
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
68 String key = "";
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
69 switch (c) {
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
70 case PUT_ATTRIBUTE:
90
eef737ab3b2c Modified JungleManager class
one
parents: 75
diff changeset
71 path = op.getNodePath();
56
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
72 key = nodeOp.getKey();
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
73 ByteBuffer value = nodeOp.getValue();
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
74 return editor.putAttribute(path, key, value);
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
75 case DELETE_ATTRIBUTE:
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
76 key = nodeOp.getKey();
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
77 return editor.deleteAttribute(path, key);
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
78 case APPEND_CHILD:
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
79 return editor.addNewChildAt(path, pos);
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
80 case DELETE_CHILD:
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
81 return editor.deleteChildAt(path, 0);
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
82 }
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
83 return null;
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
84 }
ccfe9b5e8f11 bug LogUpdateCodeSegment
one
parents: 45
diff changeset
85
59
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
86 public static Either<Error, JungleTreeEditor> update(DefaultTreeOperationLogContainer container) {
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
87 DefaultTreeOperationLog log = null;
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
88 try {
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
89 log = container.convert();
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
90 } catch (IOException e) {
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
91 e.printStackTrace();
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
92 }
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
93 String treeName = container.getTreeName();
93
75cf01a430a6 Added LocalTreeEditor
one
parents: 90
diff changeset
94 Jungle jungle = JungleManager.getJungle();
75cf01a430a6 Added LocalTreeEditor
one
parents: 90
diff changeset
95 if (jungle.getTreeByName(treeName) == null) {
75cf01a430a6 Added LocalTreeEditor
one
parents: 90
diff changeset
96 if(null == jungle.createNewTree(treeName)){
59
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
97 throw new IllegalStateException();
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
98 }
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
99 }
93
75cf01a430a6 Added LocalTreeEditor
one
parents: 90
diff changeset
100 JungleTree tree = jungle.getTreeByName(treeName);
95
dcd767b76f8d Modified putDataSement for to use NetworkTreeOperationLog
one
parents: 93
diff changeset
101 JungleTreeEditor editor = tree.getLocalTreeEditor();
90
eef737ab3b2c Modified JungleManager class
one
parents: 75
diff changeset
102 int pos = calculatePosition(tree.getRootNode(), container.getTimeStamp());
59
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
103 Either<Error, JungleTreeEditor> either = JungleManager.edit(editor, log, pos);
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
104 if(either.isA()) {
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
105 throw new IllegalStateException();
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
106 }
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
107 editor = either.b();
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
108 either = editor.success();
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
109 if(either.isA()) {
67
89e39301ccaa remove some warning
one
parents: 66
diff changeset
110 throw new IllegalStateException();
59
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
111 }
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
112 return either;
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
113 }
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
114
90
eef737ab3b2c Modified JungleManager class
one
parents: 75
diff changeset
115 private static int calculatePosition(Node node, long newNodeTimeStamp) {
59
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
116 int count = 0;
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
117 long childTimeStamp = 0;
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
118 for(Iterator<Node> iter = node.getChildren().iterator();iter.hasNext();) {
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
119 Node n = iter.next();
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
120 if(n.getAttributes().get("timestamp") == null) {
90
eef737ab3b2c Modified JungleManager class
one
parents: 75
diff changeset
121 return NOT_CHANGE_POSITION;
59
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
122 }
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
123 if(n.getAttributes().get("timestamp") != null) {
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
124 childTimeStamp = n.getAttributes().get("timestamp").getLong();
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
125 if (newNodeTimeStamp < childTimeStamp) {
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
126 break;
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
127 }
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
128 }
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
129 count++;
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
130 }
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
131 return count;
8a532ca5df80 refactoring LogUpdateCodeSegment and ChildLogCheckCodeSegment
one
parents: 56
diff changeset
132 }
15
bf4a7f899c4e add some files
one
parents:
diff changeset
133 }