Mercurial > hg > Database > jungle-network

annotate src/main/java/alice/jungle/transaction/NetworkDefaultJungleTreeEditor.java @ 178:d6944d788121

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fit Junglecore
author tatsuki
date Thu, 04 Sep 2014 13:12:25 +0900
parents 6f104ab4eb81
children 2828205bdc3a
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
31
190f6a3bdab2 rename some packages
one
parents: 28
diff changeset
1 package alice.jungle.transaction;
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
2
66
29127ac788a6 move some files
one
parents: 65
diff changeset
3
93
75cf01a430a6 Added LocalTreeEditor
one
parents: 92
diff changeset
4 import java.io.IOException;
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
5 import java.nio.ByteBuffer;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
6
113
7d9b7fcb4d9a Add LogPutCodeSegment
one
parents: 112
diff changeset
7 import alice.codesegment.CodeSegment;
95
dcd767b76f8d Modified putDataSement for to use NetworkTreeOperationLog
one
parents: 93
diff changeset
8 import alice.jungle.operations.NetworkTreeOperationLog;
113
7d9b7fcb4d9a Add LogPutCodeSegment
one
parents: 112
diff changeset
9 import app.bbs.codesegment.LogPutCodeSegment;
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
10 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.JungleTreeEditor;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.NodePath;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.TreeEditor;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
13 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.TreeNode;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
14 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.DefaultTreeOperationLog;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
15 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.OperationLog;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
16 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.logger.TreeOperationLog;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
17 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.DefaultTreeOperation;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
18 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.NodeOperation;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
19 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
20 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.trasnformer.AppendChildAt;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
21 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.trasnformer.DeleteAttribute;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
22 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.trasnformer.DeleteChildAt;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
23 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.trasnformer.NodeEditor;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
24 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.trasnformer.PutAttribute;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
25 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction.TransactionManager;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
26 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.DefaultEither;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
27 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Either;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
28 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.Error;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
29 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.util.IterableConverter;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
30
178
d6944d788121 fit Junglecore
tatsuki
parents: 176
diff changeset
31 public class NetworkDefaultJungleTreeEditor implements JungleTreeEditor {
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
32
178
d6944d788121 fit Junglecore
tatsuki
parents: 176
diff changeset
33 private final TransactionManager txManager;
176
6f104ab4eb81 fit jungle core but editMessage is not work
tatsuki
parents: 113
diff changeset
34 private final TreeNode root;
92
e95faa202b4f Modified NetworkDefaultJungleTreeEditor class. Removed uuid and serverUpdater fields
one
parents: 91
diff changeset
35 private final TreeEditor editor;
32
2f1879e0acec modified to have tree name
one
parents: 31
diff changeset
36 private final String treeName;
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
37 private final TreeOperationLog log;
93
75cf01a430a6 Added LocalTreeEditor
one
parents: 92
diff changeset
38 private boolean exportLog;
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
39
178
d6944d788121 fit Junglecore
tatsuki
parents: 176
diff changeset
40 public NetworkDefaultJungleTreeEditor(String _treeName, TreeNode _root,TransactionManager _txManager,TreeEditor _editor)
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
41 {
92
e95faa202b4f Modified NetworkDefaultJungleTreeEditor class. Removed uuid and serverUpdater fields
one
parents: 91
diff changeset
42 this(_treeName, _root,_txManager,_editor,new DefaultTreeOperationLog());
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
43 }
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
44
178
d6944d788121 fit Junglecore
tatsuki
parents: 176
diff changeset
45 public NetworkDefaultJungleTreeEditor(String _treeName, TreeNode _root,TransactionManager _txManager,TreeEditor _editor, TreeOperationLog _log)
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
46 {
32
2f1879e0acec modified to have tree name
one
parents: 31
diff changeset
47 treeName = _treeName;
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
48 root = _root;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
49 txManager = _txManager;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
50 editor = _editor;
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
51 log = _log;
93
75cf01a430a6 Added LocalTreeEditor
one
parents: 92
diff changeset
52 exportLog = true;
75cf01a430a6 Added LocalTreeEditor
one
parents: 92
diff changeset
53 }
75cf01a430a6 Added LocalTreeEditor
one
parents: 92
diff changeset
54
178
d6944d788121 fit Junglecore
tatsuki
parents: 176
diff changeset
55 public static NetworkDefaultJungleTreeEditor NewLocalJungleTreeEditor(String _treeName, TreeNode _root,TransactionManager _txManager,TreeEditor _editor) {
d6944d788121 fit Junglecore
tatsuki
parents: 176
diff changeset
56 NetworkDefaultJungleTreeEditor treeEditor = new NetworkDefaultJungleTreeEditor(_treeName, _root,_txManager,_editor,new DefaultTreeOperationLog());
93
75cf01a430a6 Added LocalTreeEditor
one
parents: 92
diff changeset
57 treeEditor.exportLog = false;
75cf01a430a6 Added LocalTreeEditor
one
parents: 92
diff changeset
58 return treeEditor;
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
59 }
99
55a4f2bb44a8 Fixed bug NetworkDefaultJungle
one
parents: 97
diff changeset
60
178
d6944d788121 fit Junglecore
tatsuki
parents: 176
diff changeset
61 public static NetworkDefaultJungleTreeEditor NewLocalJungleTreeEditor(String _treeName, TreeNode _root,TransactionManager _txManager,TreeEditor _editor, TreeOperationLog _log) {
d6944d788121 fit Junglecore
tatsuki
parents: 176
diff changeset
62 NetworkDefaultJungleTreeEditor treeEditor = new NetworkDefaultJungleTreeEditor(_treeName, _root,_txManager,_editor,_log);
99
55a4f2bb44a8 Fixed bug NetworkDefaultJungle
one
parents: 97
diff changeset
63 treeEditor.exportLog = false;
55a4f2bb44a8 Fixed bug NetworkDefaultJungle
one
parents: 97
diff changeset
64 return treeEditor;
55a4f2bb44a8 Fixed bug NetworkDefaultJungle
one
parents: 97
diff changeset
65 }
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
66
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
67 private Either<Error,JungleTreeEditor> _edit(final NodePath _path,NodeEditor _e)
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
68 {
178
d6944d788121 fit Junglecore
tatsuki
parents: 176
diff changeset
69 //LoggingNodeHook hook = new LoggingNodeHook(_e);
d6944d788121 fit Junglecore
tatsuki
parents: 176
diff changeset
70 Either<Error,TreeNode> either = editor.edit(root,_path,_e);
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
71 if(either.isA()){
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
72 return DefaultEither.newA(either.a());
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
73 }
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
74
176
6f104ab4eb81 fit jungle core but editMessage is not work
tatsuki
parents: 113
diff changeset
75 TreeNode newNode = either.b();
178
d6944d788121 fit Junglecore
tatsuki
parents: 176
diff changeset
76 OperationLog newLog = newNode.getLog();
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
77
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
78 IterableConverter.Converter<TreeOperation,NodeOperation> converter = new IterableConverter.Converter<TreeOperation,NodeOperation>(){
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
79 @Override
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
80 public TreeOperation conv(NodeOperation _b){
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
81 return new DefaultTreeOperation(_path,_b);
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
82 }
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
83 };
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
84
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
85 Iterable<TreeOperation> iterable = new IterableConverter<TreeOperation,NodeOperation>(newLog,converter);
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
86 DefaultTreeOperationLog treeOperationLog = new DefaultTreeOperationLog(iterable,newLog.length());
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
87 TreeOperationLog newTreeOpLog = log.append(treeOperationLog);
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
88
99
55a4f2bb44a8 Fixed bug NetworkDefaultJungle
one
parents: 97
diff changeset
89 JungleTreeEditor newEditor;
55a4f2bb44a8 Fixed bug NetworkDefaultJungle
one
parents: 97
diff changeset
90 if(exportLog) {
178
d6944d788121 fit Junglecore
tatsuki
parents: 176
diff changeset
91 newEditor = new NetworkDefaultJungleTreeEditor(treeName, newNode,txManager,editor,newTreeOpLog);
99
55a4f2bb44a8 Fixed bug NetworkDefaultJungle
one
parents: 97
diff changeset
92 } else {
55a4f2bb44a8 Fixed bug NetworkDefaultJungle
one
parents: 97
diff changeset
93 newEditor = NetworkDefaultJungleTreeEditor.NewLocalJungleTreeEditor(treeName, newNode, txManager, editor, newTreeOpLog);
55a4f2bb44a8 Fixed bug NetworkDefaultJungle
one
parents: 97
diff changeset
94 }
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
95 return DefaultEither.newB(newEditor);
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
96 }
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
97
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
98 @Override
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
99 public Either<Error,JungleTreeEditor> addNewChildAt(NodePath _path, int _pos)
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
100 {
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
101 AppendChildAt appendChildAt = new AppendChildAt(_pos);
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
102 return _edit(_path,appendChildAt);
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
103 }
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
104
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
105 @Override
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
106 public Either<Error,JungleTreeEditor> deleteChildAt(NodePath _path, int _pos)
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
107 {
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
108 DeleteChildAt deleteChildAt = new DeleteChildAt(_pos);
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
109 return _edit(_path,deleteChildAt);
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
110 }
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
111
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
112 @Override
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
113 public Either<Error,JungleTreeEditor> putAttribute(NodePath _path,String _key,ByteBuffer _value)
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
114 {
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
115 PutAttribute putAttribute = new PutAttribute(_key,_value);
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
116 return _edit(_path,putAttribute);
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
117 }
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
118
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
119 @Override
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
120 public Either<Error,JungleTreeEditor> deleteAttribute(NodePath _path, String _key)
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
121 {
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
122 DeleteAttribute deleteAttribute = new DeleteAttribute(_key);
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
123 return _edit(_path,deleteAttribute);
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
124 }
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
125
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
126 @Override
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
127 public Either<Error,JungleTreeEditor> edit(NodePath _path,NodeEditor _editor)
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
128 {
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
129 return _edit(_path,_editor);
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
130 }
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
131
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
132 @Override
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
133 public Either<Error,JungleTreeEditor> success()
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
134 {
178
d6944d788121 fit Junglecore
tatsuki
parents: 176
diff changeset
135 Either<Error,TransactionManager> either = txManager.commit(root,log);
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
136 if(either.isA()){
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
137 return DefaultEither.newA(either.a());
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
138 }
97
11ad00323206 Removed unnecessary files. Modified NetworkDefaultJungleTreeEditor
one
parents: 95
diff changeset
139 if(exportLog) {
11ad00323206 Removed unnecessary files. Modified NetworkDefaultJungleTreeEditor
one
parents: 95
diff changeset
140 try {
11ad00323206 Removed unnecessary files. Modified NetworkDefaultJungleTreeEditor
one
parents: 95
diff changeset
141 putTreeOperationLog(log);
11ad00323206 Removed unnecessary files. Modified NetworkDefaultJungleTreeEditor
one
parents: 95
diff changeset
142 } catch (IOException e) {
11ad00323206 Removed unnecessary files. Modified NetworkDefaultJungleTreeEditor
one
parents: 95
diff changeset
143 return DefaultEither.newA(either.a());
11ad00323206 Removed unnecessary files. Modified NetworkDefaultJungleTreeEditor
one
parents: 95
diff changeset
144 }
11ad00323206 Removed unnecessary files. Modified NetworkDefaultJungleTreeEditor
one
parents: 95
diff changeset
145 }
11ad00323206 Removed unnecessary files. Modified NetworkDefaultJungleTreeEditor
one
parents: 95
diff changeset
146
178
d6944d788121 fit Junglecore
tatsuki
parents: 176
diff changeset
147 TransactionManager newTxManager = either.b();
d6944d788121 fit Junglecore
tatsuki
parents: 176
diff changeset
148 JungleTreeEditor newTreeEditor = new NetworkDefaultJungleTreeEditor(treeName, root,newTxManager,editor);
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
149
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
150 return DefaultEither.newB(newTreeEditor);
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
151 }
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
152
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
153 @Override
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
154 public String getID()
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
155 {
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
156 return txManager.getUUID();
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
157 }
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
158
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
159 @Override
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
160 public String getRevision()
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
161 {
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
162 return Long.toString(txManager.getRevision());
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
163 }
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
164
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
165 @Override
176
6f104ab4eb81 fit jungle core but editMessage is not work
tatsuki
parents: 113
diff changeset
166 public TreeNode getRoot()
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
167 {
176
6f104ab4eb81 fit jungle core but editMessage is not work
tatsuki
parents: 113
diff changeset
168 return root;
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
169 }
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
170
46
fd3643699f83 modified pom.xml. fix conflict log4j libraries
one
parents: 43
diff changeset
171 public String getTreeName() {
fd3643699f83 modified pom.xml. fix conflict log4j libraries
one
parents: 43
diff changeset
172 return treeName;
fd3643699f83 modified pom.xml. fix conflict log4j libraries
one
parents: 43
diff changeset
173 }
fd3643699f83 modified pom.xml. fix conflict log4j libraries
one
parents: 43
diff changeset
174
92
e95faa202b4f Modified NetworkDefaultJungleTreeEditor class. Removed uuid and serverUpdater fields
one
parents: 91
diff changeset
175 public TreeOperationLog getTreeOperationLog() {
e95faa202b4f Modified NetworkDefaultJungleTreeEditor class. Removed uuid and serverUpdater fields
one
parents: 91
diff changeset
176 return log;
46
fd3643699f83 modified pom.xml. fix conflict log4j libraries
one
parents: 43
diff changeset
177 }
93
75cf01a430a6 Added LocalTreeEditor
one
parents: 92
diff changeset
178
75cf01a430a6 Added LocalTreeEditor
one
parents: 92
diff changeset
179 public void putTreeOperationLog(Iterable<TreeOperation> newLog) throws IOException {
75cf01a430a6 Added LocalTreeEditor
one
parents: 92
diff changeset
180 String uuid = getID();
75cf01a430a6 Added LocalTreeEditor
one
parents: 92
diff changeset
181 String treeName = getTreeName();
75cf01a430a6 Added LocalTreeEditor
one
parents: 92
diff changeset
182 String updaterName = getID();
75cf01a430a6 Added LocalTreeEditor
one
parents: 92
diff changeset
183 String revision = getRevision();
75cf01a430a6 Added LocalTreeEditor
one
parents: 92
diff changeset
184 putDataSegment(uuid, treeName, updaterName, newLog, revision);
75cf01a430a6 Added LocalTreeEditor
one
parents: 92
diff changeset
185 }
75cf01a430a6 Added LocalTreeEditor
one
parents: 92
diff changeset
186
75cf01a430a6 Added LocalTreeEditor
one
parents: 92
diff changeset
187 public void putDataSegment(String _uuid, String _treeName, String _updaterName, Iterable<TreeOperation> newLog, String nextRevision) throws IOException {
95
dcd767b76f8d Modified putDataSement for to use NetworkTreeOperationLog
one
parents: 93
diff changeset
188 NetworkTreeOperationLog netLog = new NetworkTreeOperationLog(_uuid, _treeName,newLog);
113
7d9b7fcb4d9a Add LogPutCodeSegment
one
parents: 112
diff changeset
189 CodeSegment cs = new LogPutCodeSegment(netLog);
106
f42f2e6b31de Removed project reference and Added dependency in pom.xml
one
parents: 105
diff changeset
190 cs.execute();
93
75cf01a430a6 Added LocalTreeEditor
one
parents: 92
diff changeset
191 }
12
80680cfcfd3b add jungle/test/transaction, jungle/test/core/NetworkDefaultJungle
one
parents:
diff changeset
192 }