Mercurial > hg > Members > nobuyasu > jungle-network

comparison src/main/java/alice/jungle/persistent/PersistentJournal.java @ 158:cd4d64249931

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
minor fix
author Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date Sat, 12 Jul 2014 15:58:48 +0900
parents 2e8034524259
children 54d68cda84c4
comparison
equal deleted inserted replaced
157:47ca5d48c30f 158:cd4d64249931
12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListReader; 12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListReader;
13 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListWriter; 13 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListWriter;
14 14
15 public class PersistentJournal implements NetworkJournal { 15 public class PersistentJournal implements NetworkJournal {
16 16
17 private ChangeListWriter WRITER; 17 // private ChangeListWriter WRITER;
18 private ChangeListReader READER; 18 private ChangeListReader READER;
19 private OutputStream out; 19 private OutputStream out;
20 private InputStream in; 20 private InputStream in;
21 21
22 public PersistentJournal() { 22 public PersistentJournal() {
23 } 23 }
24 24
25 public PersistentJournal(File file) throws FileNotFoundException { 25 public PersistentJournal(File file) throws FileNotFoundException {
26 out = new FileOutputStream(file,true); 26 out = new FileOutputStream(file,true);
27 in = new FileInputStream(file); 27 in = new FileInputStream(file);
28 WRITER = new PersistentChangeListWriter(out); 28 // WRITER = new PersistentChangeListWriter(out);
29 READER = new PersistentChangeListReader(in); 29 READER = new PersistentChangeListReader(in);
30 } 30 }
31 31
32 @Override 32 @Override
33 public ChangeListReader getReader() { 33 public ChangeListReader getReader() {
56 setInputStream(new FileInputStream(file)); 56 setInputStream(new FileInputStream(file));
57 } 57 }
58 58
59 public void setOutputStream(OutputStream _out) { 59 public void setOutputStream(OutputStream _out) {
60 out = _out; 60 out = _out;
61 WRITER = new PersistentChangeListWriter(out); 61 // WRITER = new PersistentChangeListWriter(out);
62 } 62 }
63 63
64 public OutputStream getOutputStream() { 64 public OutputStream getOutputStream() {
65 return out; 65 return out;
66 } 66 }