Mercurial > hg > Members > nobuyasu > jungle-network

annotate src/jungle/app/bbs/JungleManager.java @ 92:e95faa202b4f

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