Mercurial > hg > Members > nobuyasu > jungle-network

annotate 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
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
105
f9e29a52efd3 Move some files
one
parents: 89
diff changeset
1 package alice.jungle.persistent;
85
e641f559559c Added some files for persistent
one
parents:
diff changeset
2
e641f559559c Added some files for persistent
one
parents:
diff changeset
3 import java.io.File;
e641f559559c Added some files for persistent
one
parents:
diff changeset
4 import java.io.FileInputStream;
e641f559559c Added some files for persistent
one
parents:
diff changeset
5 import java.io.FileNotFoundException;
e641f559559c Added some files for persistent
one
parents:
diff changeset
6 import java.io.FileOutputStream;
e641f559559c Added some files for persistent
one
parents:
diff changeset
7 import java.io.IOException;
e641f559559c Added some files for persistent
one
parents:
diff changeset
8 import java.io.InputStream;
e641f559559c Added some files for persistent
one
parents:
diff changeset
9 import java.io.OutputStream;
e641f559559c Added some files for persistent
one
parents:
diff changeset
10
e641f559559c Added some files for persistent
one
parents:
diff changeset
11
e641f559559c Added some files for persistent
one
parents:
diff changeset
12 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListReader;
e641f559559c Added some files for persistent
one
parents:
diff changeset
13 import jp.ac.u_ryukyu.ie.cr.shoshi.jungle.persistent.ChangeListWriter;
e641f559559c Added some files for persistent
one
parents:
diff changeset
14
135
2e8034524259 Added NetworkJournal and SingletonMessageFromAlice class
Nobuyasu Oshiro <dimolto@cr.ie.u-ryukyu.ac.jp>
parents: 118
diff changeset
15 public class PersistentJournal implements NetworkJournal {
85
e641f559559c Added some files for persistent
one
parents:
diff changeset
16
158
cd4d64249931 minor fix
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 135
diff changeset
17 // private ChangeListWriter WRITER;
118
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
18 private ChangeListReader READER;
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
19 private OutputStream out;
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
20 private InputStream in;
135
2e8034524259 Added NetworkJournal and SingletonMessageFromAlice class
Nobuyasu Oshiro <dimolto@cr.ie.u-ryukyu.ac.jp>
parents: 118
diff changeset
21
86
bcaf28f8244d Added PersistentChageList and PersistentJournalTest
one
parents: 85
diff changeset
22 public PersistentJournal() {
bcaf28f8244d Added PersistentChageList and PersistentJournalTest
one
parents: 85
diff changeset
23 }
85
e641f559559c Added some files for persistent
one
parents:
diff changeset
24
e641f559559c Added some files for persistent
one
parents:
diff changeset
25 public PersistentJournal(File file) throws FileNotFoundException {
118
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
26 out = new FileOutputStream(file,true);
85
e641f559559c Added some files for persistent
one
parents:
diff changeset
27 in = new FileInputStream(file);
158
cd4d64249931 minor fix
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 135
diff changeset
28 // WRITER = new PersistentChangeListWriter(out);
85
e641f559559c Added some files for persistent
one
parents:
diff changeset
29 READER = new PersistentChangeListReader(in);
e641f559559c Added some files for persistent
one
parents:
diff changeset
30 }
e641f559559c Added some files for persistent
one
parents:
diff changeset
31
e641f559559c Added some files for persistent
one
parents:
diff changeset
32 @Override
e641f559559c Added some files for persistent
one
parents:
diff changeset
33 public ChangeListReader getReader() {
e641f559559c Added some files for persistent
one
parents:
diff changeset
34 return READER;
e641f559559c Added some files for persistent
one
parents:
diff changeset
35 }
e641f559559c Added some files for persistent
one
parents:
diff changeset
36
e641f559559c Added some files for persistent
one
parents:
diff changeset
37 @Override
e641f559559c Added some files for persistent
one
parents:
diff changeset
38 public ChangeListWriter getWriter() {
118
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
39 String timeStamp = Long.toString(System.currentTimeMillis());
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
40 String logFileName = timeStamp + ".log";
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
41 OutputStream outStream = null;
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
42 try {
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
43 outStream = new FileOutputStream(new File("./log/"+logFileName));
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
44 } catch (FileNotFoundException e) {
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
45 e.printStackTrace();
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
46 }
135
2e8034524259 Added NetworkJournal and SingletonMessageFromAlice class
Nobuyasu Oshiro <dimolto@cr.ie.u-ryukyu.ac.jp>
parents: 118
diff changeset
47 ChangeListWriter writer = new PersistentChangeListWriter(outStream);
118
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
48 return writer;
85
e641f559559c Added some files for persistent
one
parents:
diff changeset
49 }
e641f559559c Added some files for persistent
one
parents:
diff changeset
50
86
bcaf28f8244d Added PersistentChageList and PersistentJournalTest
one
parents: 85
diff changeset
51 public void setOutputFile(File file) throws FileNotFoundException {
118
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
52 setOutputStream(new FileOutputStream(file, true));
86
bcaf28f8244d Added PersistentChageList and PersistentJournalTest
one
parents: 85
diff changeset
53 }
bcaf28f8244d Added PersistentChageList and PersistentJournalTest
one
parents: 85
diff changeset
54
bcaf28f8244d Added PersistentChageList and PersistentJournalTest
one
parents: 85
diff changeset
55 public void setInputFile(File file) throws FileNotFoundException {
118
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
56 setInputStream(new FileInputStream(file));
85
e641f559559c Added some files for persistent
one
parents:
diff changeset
57 }
e641f559559c Added some files for persistent
one
parents:
diff changeset
58
e641f559559c Added some files for persistent
one
parents:
diff changeset
59 public void setOutputStream(OutputStream _out) {
e641f559559c Added some files for persistent
one
parents:
diff changeset
60 out = _out;
158
cd4d64249931 minor fix
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents: 135
diff changeset
61 // WRITER = new PersistentChangeListWriter(out);
85
e641f559559c Added some files for persistent
one
parents:
diff changeset
62 }
e641f559559c Added some files for persistent
one
parents:
diff changeset
63
e641f559559c Added some files for persistent
one
parents:
diff changeset
64 public OutputStream getOutputStream() {
e641f559559c Added some files for persistent
one
parents:
diff changeset
65 return out;
e641f559559c Added some files for persistent
one
parents:
diff changeset
66 }
e641f559559c Added some files for persistent
one
parents:
diff changeset
67
e641f559559c Added some files for persistent
one
parents:
diff changeset
68 public void setInputStream(InputStream _in) {
e641f559559c Added some files for persistent
one
parents:
diff changeset
69 in = _in;
118
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
70 READER = new PersistentChangeListReader(in);
85
e641f559559c Added some files for persistent
one
parents:
diff changeset
71 }
118
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
72
85
e641f559559c Added some files for persistent
one
parents:
diff changeset
73 public InputStream getInputStream() {
e641f559559c Added some files for persistent
one
parents:
diff changeset
74 return in;
e641f559559c Added some files for persistent
one
parents:
diff changeset
75 }
e641f559559c Added some files for persistent
one
parents:
diff changeset
76
118
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
77 public void close() throws IOException {
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
78 out.close();
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
79 in.close();
f64ff5bd66f5 Implements persistent for bbs app and Fixed bug JungleUpdater
one
parents: 116
diff changeset
80 }
85
e641f559559c Added some files for persistent
one
parents:
diff changeset
81 }