Febbweiss/logstash-forwarder-java
1
0
Fork 0
mirror of https://github.com/Febbweiss/logstash-forwarder-java.git synced 2026-03-04 22:25:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

FileWatcher debugging.

Browse Source
This commit is contained in:
didfet
2015-03-14 07:41:18 +01:00
parent 797f6f41bb
commit 8d7b0cd59d
1 changed files with 22 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
src/main/java/info/fetter/logstashforwarder/FileWatcher.java
View File

@@ -68,7 +68,8 @@ public class FileWatcher implements FileAlterationListener {
public void checkFiles() throws IOException {
logger.debug("Checking files");
//printWatchMap();
logger.trace("==============");
for(FileAlterationObserver observer : observerList) {
observer.checkAndNotify();
}
@@ -76,16 +77,23 @@ public class FileWatcher implements FileAlterationListener {
printWatchMap();
}
public void readFiles() {
logger.debug("Reading files");
logger.trace("==============");
}
private void processModifications() throws IOException {
for(File file : changedWatchMap.keySet()) {
FileState state = changedWatchMap.get(file);
logger.trace("Checking file : " + file.getCanonicalPath());
logger.trace("-- Last modified : " + state.getLastModified());
logger.trace("-- Size : " + state.getSize());
logger.trace("-- Directory : " + state.getDirectory());
logger.trace("-- Filename : " + state.getFileName());
if(logger.isTraceEnabled()) {
logger.trace("Checking file : " + file.getCanonicalPath());
logger.trace("-- Last modified : " + state.getLastModified());
logger.trace("-- Size : " + state.getSize());
logger.trace("-- Directory : " + state.getDirectory());
logger.trace("-- Filename : " + state.getFileName());
}
// Determine if file is still the same
logger.trace("Determine if file has just been written to");
@@ -125,7 +133,9 @@ public class FileWatcher implements FileAlterationListener {
for(File otherFile : watchMap.keySet()) {
FileState otherState = watchMap.get(otherFile);
if(otherState != null && state.getSize() >= otherState.getSize() && state.getDirectory().equals(otherState.getDirectory())) {
logger.trace("Comparing to : " + otherFile.getCanonicalPath());
if(logger.isTraceEnabled()) {
logger.trace("Comparing to : " + otherFile.getCanonicalPath());
}
// File in the same directory which was smaller
if(otherState.getSignatureLength() == state.getSignatureLength() && otherState.getSignature() == state.getSignature()) {
// File is the same
@@ -156,7 +166,9 @@ public class FileWatcher implements FileAlterationListener {
// Refresh file state
logger.trace("Refreshing file state");
for(File file : changedWatchMap.keySet()) {
logger.trace("Refreshing file : " + file.getCanonicalPath());
if(logger.isTraceEnabled()) {
logger.trace("Refreshing file : " + file.getCanonicalPath());
}
FileState state = changedWatchMap.get(file);
FileState oldState = state.getOldFileState();
if(oldState == null) {
@@ -178,7 +190,7 @@ public class FileWatcher implements FileAlterationListener {
// Truncating changedWatchMap
changedWatchMap.clear();
removeMarkedFilesFromWatchMap();
}
@@ -290,7 +302,7 @@ public class FileWatcher implements FileAlterationListener {
}
}
}
public void close() throws IOException {
logger.debug("Closing all files");
for(File file : watchMap.keySet()) {