mstoeck3/autopsy-flatpak
1
0
Fork 0
mirror of https://github.com/overcuriousity/autopsy-flatpak.git synced 2025-07-06 21:00:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

Send solr logs to separate log files

Browse Source
This commit is contained in:
Dick Fickling 2012-01-24 14:06:16 -05:00
parent a161f8a27d
commit 1501ae2af1
1 changed files with 32 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
KeywordSearch/src/org/sleuthkit/autopsy/keywordsearch/Server.java
View File

@ -21,10 +21,14 @@ package org.sleuthkit.autopsy.keywordsearch;
import java.awt.event.ActionEvent; import java.awt.event.ActionEvent;
import java.beans.PropertyChangeListener; import java.beans.PropertyChangeListener;
import java.io.BufferedReader; import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File; import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException; import java.io.IOException;
import java.io.InputStream; import java.io.InputStream;
import java.io.InputStreamReader; import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.ConnectException; import java.net.ConnectException;
import java.net.MalformedURLException; import java.net.MalformedURLException;
import java.net.SocketException; import java.net.SocketException;
@ -97,19 +101,41 @@ class Server {
private static class InputStreamPrinterThread extends Thread { private static class InputStreamPrinterThread extends Thread {
InputStream stream; InputStream stream;
OutputStream out;
InputStreamPrinterThread(InputStream stream) { InputStreamPrinterThread(InputStream stream, String type) {
this.stream = stream; this.stream = stream;
try{
String log = System.getProperty("netbeans.user") + "/var/log/solr.log." + type;
File outputFile = new File(log.concat(".0"));
File first = new File(log.concat(".1"));
File second = new File(log.concat(".2"));
if(second.exists())
second.delete();
if(first.exists())
first.renameTo(second);
if(outputFile.exists())
outputFile.renameTo(first);
else
outputFile.createNewFile();
out = new FileOutputStream(outputFile);
} catch(Exception ex){
logger.log(Level.WARNING, "Failed to create solr log file", ex);
}
} }
@Override @Override
public void run() { public void run() {
InputStreamReader isr = new InputStreamReader(stream); InputStreamReader isr = new InputStreamReader(stream);
BufferedReader br = new BufferedReader(isr); BufferedReader br = new BufferedReader(isr);
String line = null; try{
try { OutputStreamWriter osw = new OutputStreamWriter(out);
BufferedWriter bw = new BufferedWriter(osw);
String line = null;
while ((line = br.readLine()) != null) { while ((line = br.readLine()) != null) {
logger.log(Level.INFO, "SOLR OUTPUT: " + line.trim()); bw.write(line);
bw.newLine();
} }
} catch (IOException ex) { } catch (IOException ex) {
Exceptions.printStackTrace(ex); Exceptions.printStackTrace(ex);
@ -128,8 +154,8 @@ class Server {
Process start = Runtime.getRuntime().exec("java -DSTOP.PORT=8079 -DSTOP.KEY=mysecret -jar start.jar", null, solrFolder); Process start = Runtime.getRuntime().exec("java -DSTOP.PORT=8079 -DSTOP.KEY=mysecret -jar start.jar", null, solrFolder);
// Handle output to prevent process from blocking // Handle output to prevent process from blocking
(new InputStreamPrinterThread(start.getInputStream())).start(); (new InputStreamPrinterThread(start.getInputStream(), "input")).start();
(new InputStreamPrinterThread(start.getErrorStream())).start(); (new InputStreamPrinterThread(start.getErrorStream(), "error")).start();
} catch (IOException ex) { } catch (IOException ex) {
throw new RuntimeException(ex); throw new RuntimeException(ex);