seperate out out and err prints

Author: madhephaestus

src/main/java/com/neuronrobotics/sdk/common/Log.java

@@ -77,16 +77,17 @@ public class Log {
 	private static PrintStream outStream = System.out;
 	/** The out stream. */
 	private static PrintStream errStream = System.err;	
-	
+	/** The out stream. */
+	private static PrintStream mirrorStream = System.out;		
 	/** The use colored prints. */
 	private boolean useColoredPrints=false;
 
 	private Thread logFileThread = null;
 
 	private File log=null;
 
-	private ByteList incoming;
-	
+	private ByteList incomingErr;
+	private ByteList incomingOut;
 
 	/**
 	 * Instantiates a new log.
@@ -454,22 +455,44 @@ public static void setFile(File logfile) {
 
 		instance.log=logfile;
 		instance.logFileThread=new Thread(()->{
-			instance.incoming = new ByteList();
-			OutputStream stream =  new OutputStream() {
+			instance.incomingErr = new ByteList();
+			
+			OutputStream streamErr =  new OutputStream() {
+				@Override
+				public void write(int b) throws IOException {
+					instance.incomingErr.add(b);
+				}
+			};
+			instance.incomingOut = new ByteList();
+			
+			OutputStream streamOut =  new OutputStream() {
 				@Override
 				public void write(int b) throws IOException {
-					instance.incoming.add(b);
+					instance.incomingOut.add(b);
 				}
 			};
-			System.setOut(new PrintStream(stream));
-			System.setErr(new PrintStream(stream));
-			setOutStream(new PrintStream(stream));
+			System.setOut(new PrintStream(streamOut));
+			System.setErr(new PrintStream(streamErr));
+			setOutStream(new PrintStream(streamErr));
 			while (instance.log!=null) {
 				ThreadUtil.wait(150);
-				if (instance.incoming.size() > 0)
+				if (instance.incomingOut.size() > 0)
+					try {
+						String text = instance.incomingOut.asString();
+						instance.incomingOut.clear();
+						if (text != null && text.length() > 0){
+							//Files.writeString(logfile.toPath(), text, StandardCharsets.UTF_8, StandardOpenOption.APPEND); // java 11+
+							Files.write(logfile.toPath(), text.getBytes(StandardCharsets.UTF_8), StandardOpenOption.APPEND);
+							mirrorStream.println(text);
+						}
+						text = null;
+					} catch (Exception e) {
+						e.printStackTrace();
+					}
+				if (instance.incomingErr.size() > 0)
 					try {
-						String text = instance.incoming.asString();
-						instance.incoming.clear();
+						String text = instance.incomingErr.asString();
+						instance.incomingErr.clear();
 						if (text != null && text.length() > 0){
 							//Files.writeString(logfile.toPath(), text, StandardCharsets.UTF_8, StandardOpenOption.APPEND); // java 11+
 							Files.write(logfile.toPath(), text.getBytes(StandardCharsets.UTF_8), StandardOpenOption.APPEND);
@@ -488,7 +511,7 @@ public static void flush() {
 		System.setOut(outStream);
 		System.setErr(outStream);
 		instance.log=null;
-		while(instance.incoming.size() > 0) {
+		while(instance.incomingOut.size() > 0 ||instance.incomingErr.size() > 0 ) {
 			try {
 				Thread.sleep(10);
 			} catch (InterruptedException e) {
@@ -503,4 +526,12 @@ public static void flush() {
 			e.printStackTrace();
 		}
 	}
+
+	public static PrintStream getMirrorStream() {
+		return mirrorStream;
+	}
+
+	public static void setMirrorStream(PrintStream mirrorStream) {
+		Log.mirrorStream = mirrorStream;
+	}
 }