Voomra/trader
Archived
0
Fork 0
Code Activity

seek to end file on change file

Browse Source
This commit is contained in:
iMoHax
2016-06-03 12:56:16 +03:00
parent a8d5deb5a9
commit 2e1571a3ed
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
utils/src/main/java/ru/trader/edlog/LogReader.java
View File

@@ -31,16 +31,19 @@ public class LogReader implements LogHandler {
} }
} }
private void readFile(){ private void seekToEnd(){
readFile(false); try {
reader.seek(file.length());
} catch (IOException e) {
LOG.error("Error on read log file",e);
}
} }
private void readFile(boolean skip){ private void readFile(){
LOG.trace("Read file {}", file); LOG.trace("Read file {}", file);
String line; String line;
try { try {
while ((line = reader.readLine()) != null){ while ((line = reader.readLine()) != null){
if (skip) continue;
outLine(line); outLine(line);
} }
} catch (IOException e) { } catch (IOException e) {
@@ -56,7 +59,7 @@ public class LogReader implements LogHandler {
public void createFile(Path file) { public void createFile(Path file) {
if (file.toString().matches(pattern)){ if (file.toString().matches(pattern)){
changeFile(file.toFile()); changeFile(file.toFile());
readFile(true); seekToEnd();
} else { } else {
LOG.trace("{} Is not log file, skip", file); LOG.trace("{} Is not log file, skip", file);
} }
@@ -68,7 +71,7 @@ public class LogReader implements LogHandler {
File f = file.toFile(); File f = file.toFile();
if (this.file == null){ if (this.file == null){
changeFile(f); changeFile(f);
readFile(true); seekToEnd();
} else { } else {
if (this.file.equals(f)){ if (this.file.equals(f)){
readFile(); readFile();