X-Git-Url: https://git.pterodactylus.net/?p=sonitus.git;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsonitus%2Fdata%2Ffilter%2FPipelineFilter.java;fp=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsonitus%2Fdata%2Ffilter%2FPipelineFilter.java;h=9bc86e9b846107a30720c7d9b71095524c71689b;hp=e4c2d81742e8abdba77730aa692e5ee2197e3a5f;hb=4f8cd2e68db8026dd0cd1fb2b6827d19d15e5f1d;hpb=a0057669de4cb82f613d0a2a765f145279cf2233

diff --git a/src/main/java/net/pterodactylus/sonitus/data/filter/PipelineFilter.java b/src/main/java/net/pterodactylus/sonitus/data/filter/PipelineFilter.java
index e4c2d81..9bc86e9 100644
--- a/src/main/java/net/pterodactylus/sonitus/data/filter/PipelineFilter.java
+++ b/src/main/java/net/pterodactylus/sonitus/data/filter/PipelineFilter.java
@@ -22,6 +22,7 @@ import java.util.Arrays;
 import java.util.Collection;
 import java.util.List;
 import java.util.Map;
+import java.util.logging.Logger;
 
 import net.pterodactylus.sonitus.data.AbstractFilter;
 import net.pterodactylus.sonitus.data.DataPacket;
@@ -39,6 +40,9 @@ import com.google.common.collect.Maps;
  */
 public class PipelineFilter extends AbstractFilter implements Filter {
 
+	/** The logger. */
+	private static final Logger logger = Logger.getLogger(PipelineFilter.class.getName());
+
 	/** The first filter. */
 	private final Filter source;
 
@@ -89,6 +93,7 @@ public class PipelineFilter extends AbstractFilter implements Filter {
 			Connection connection = new Connection(currentSource, Arrays.asList(filter));
 			filterConnections.put(filter, connection);
 			String threadName = String.format("%s → %s", connection.source().name(), filter.name());
+			logger.info(String.format("Starting Thread: %s.", threadName));
 			new Thread(connection, threadName).start();
 			currentSource = filter;
 		}
@@ -98,8 +103,10 @@ public class PipelineFilter extends AbstractFilter implements Filter {
 	@Override
 	public DataPacket get(int bufferSize) throws IOException {
 		if (filterConnections.get(lastFilter).ioException().isPresent()) {
+			logger.info(String.format("Rethrowing exception from %s: %s", lastFilter.name(), filterConnections.get(lastFilter).ioException().get().getMessage()));
 			throw filterConnections.get(lastFilter).ioException().get();
 		}
+		logger.info(String.format("Requesting %d bytes from %s...", bufferSize, lastFilter.name()));
 		return lastFilter.get(bufferSize);
 	}