Mercurial > hg > Database > jungle-network

comparison src/alice/jungle/persistence/NetworkJournal.java @ 84:82d1d3dac7bc

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Modfied NetworkTransactionManager
author one
date Sun, 27 Oct 2013 20:05:53 +0900
parents b3ccefdf2b43
children e641f559559c
comparison
equal deleted inserted replaced
83:b3ccefdf2b43 84:82d1d3dac7bc
17 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeList; 17 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeList;
18 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListReader; 18 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListReader;
19 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListWriter; 19 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListWriter;
20 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Journal; 20 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Journal;
21 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Result; 21 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.Result;
22 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.ChangeSet;
22 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation; 23 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.store.operations.TreeOperation;
23 24
24 public class NetworkJournal implements Journal { 25 public class NetworkJournal implements Journal {
25 26
26 private static final NetworkChangeListWriter WRITER = new NetworkChangeListWriter(); 27 private static final NetworkChangeListWriter WRITER = new NetworkChangeListWriter();
80 } catch (IOException e) { 81 } catch (IOException e) {
81 return null; 82 return null;
82 } 83 }
83 return Result.SUCCESS; 84 return Result.SUCCESS;
84 } 85 }
86
87 public Result write(ChangeSet cs)
88 {
89 NetworkTreeOperationLog log = new NetworkTreeOperationLog(cs.uuid(),cs.getChangeList());
90 try {
91 msgpack.write(out, log);
92 out.flush();
93 } catch (IOException e) {
94 return null;
95 }
96 return Result.SUCCESS;
97 }
98
85 } 99 }
86 100
87 public MessagePack getMessagePack() { 101 public static MessagePack getMessagePack() {
88 return msgpack; 102 return msgpack;
89 } 103 }
90 104
91 private static class NetworkChangeListReader implements ChangeListReader 105 private static class NetworkChangeListReader implements ChangeListReader
92 { 106 {