# HG changeset patch # User one # Date 1382871953 -32400 # Node ID 82d1d3dac7bc8b42f5f46c4c2ec9d9b87aa08239 # Parent b3ccefdf2b43e73c4f9cc2a266bf72c507a7d54e Modfied NetworkTransactionManager diff -r b3ccefdf2b43 -r 82d1d3dac7bc src/alice/jungle/operations/NetworkTreeOperationLog.java --- a/src/alice/jungle/operations/NetworkTreeOperationLog.java Fri Oct 25 18:44:29 2013 +0900 +++ b/src/alice/jungle/operations/NetworkTreeOperationLog.java Sun Oct 27 20:05:53 2013 +0900 @@ -15,10 +15,23 @@ { public LinkedList list; public int size; + String treeName; public NetworkTreeOperationLog() { list = new LinkedList(); size = 0; + treeName = ""; + } + + public NetworkTreeOperationLog(String _treeName, Iterable _list) + { + treeName = _treeName; + list = new LinkedList(); + for(TreeOperation op: _list) { + NetworkTreeOperation nOp = new NetworkTreeOperation(op); + list.add(nOp); + } + size = list.size(); } public NetworkTreeOperationLog(Iterable _list) @@ -29,17 +42,9 @@ list.add(nOp); } size = list.size(); + treeName = ""; } - public NetworkTreeOperationLog(Iterable _list, int _size) - { - list = new LinkedList(); - for(TreeOperation op: _list) { - NetworkTreeOperation nOp = new NetworkTreeOperation(op); - list.add(nOp); - } - size = _size; - } @Override public Iterator iterator() { @@ -73,5 +78,9 @@ { return size; } + + public String getTreeName() { + return treeName; + } } diff -r b3ccefdf2b43 -r 82d1d3dac7bc src/alice/jungle/persistence/NetworkJournal.java --- a/src/alice/jungle/persistence/NetworkJournal.java Fri Oct 25 18:44:29 2013 +0900 +++ b/src/alice/jungle/persistence/NetworkJournal.java Sun Oct 27 20:05:53 2013 +0900 @@ -19,6 +19,7 @@ import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListWriter; import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Journal; import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Result; +import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.ChangeSet; import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation; public class NetworkJournal implements Journal { @@ -82,9 +83,22 @@ } return Result.SUCCESS; } + + public Result write(ChangeSet cs) + { + NetworkTreeOperationLog log = new NetworkTreeOperationLog(cs.uuid(),cs.getChangeList()); + try { + msgpack.write(out, log); + out.flush(); + } catch (IOException e) { + return null; + } + return Result.SUCCESS; + } + } - public MessagePack getMessagePack() { + public static MessagePack getMessagePack() { return msgpack; }