Mercurial > hg > Database > jungle-network

comparison src/main/java/alice/jungle/transaction/NetworkTransactionManager.java @ 179:2828205bdc3a

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fit JungleCore
author tatsuki
date Sat, 13 Sep 2014 12:54:02 +0900
parents d6944d788121
children 4493dd7692ce
comparison
equal deleted inserted replaced
178:d6944d788121 179:2828205bdc3a
1 package alice.jungle.transaction; 1 package alice.jungle.transaction;
2 2
3 import java.util.Iterator; 3 import java.util.Iterator;
4 4
5 import fj.data.List;
6 import fj.data.TreeMap;
5 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeList; 7 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeList;
6 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListWriter; 8 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListWriter;
7 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Result; 9 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Result;
8 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.ChangeSet; 10 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.ChangeSet;
9 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.TreeNode; 11 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.impl.TreeNode;
38 uuid = _uuid; 40 uuid = _uuid;
39 treeName = _treeName; 41 treeName = _treeName;
40 } 42 }
41 43
42 @Override 44 @Override
43 public Either<Error, TransactionManager> commit(TreeNode _newRoot,final TreeOperationLog _log) { 45 public Either<Error, TransactionManager> commit(TreeNode _newRoot,final TreeOperationLog _log, TreeMap<String,TreeMap<String, List<TreeNode>>> index) {
44 ChangeSet cs = tip.getChangeSet(); 46 ChangeSet cs = tip.getChangeSet();
45 long currentRevision = cs.revision(); 47 long currentRevision = cs.revision();
46 long nextRevision = currentRevision + 1; 48 long nextRevision = currentRevision + 1;
47 49
48 ChangeList list = new ChangeList() { 50 ChangeList list = new ChangeList() {
59 return treeName; 61 return treeName;
60 } 62 }
61 }; 63 };
62 64
63 TreeNode root = _newRoot; 65 TreeNode root = _newRoot;
64 DefaultChangeSet newCs = new DefaultChangeSet(root, cs, list, uuid, treeName, nextRevision); 66 DefaultChangeSet newCs = new DefaultChangeSet(root, cs, list, uuid, treeName, nextRevision, null);
65 DefaultTreeContext newContext = new DefaultTreeContext(_newRoot,newCs); 67 DefaultTreeContext newContext = new DefaultTreeContext(_newRoot,newCs);
66 68
67 @SuppressWarnings("rawtypes") 69 @SuppressWarnings("rawtypes")
68 Reservation reservation = repository.makeReservation(tip, newContext); 70 Reservation reservation = repository.makeReservation(tip, newContext);
69 if(reservation == null) { 71 if(reservation == null) {