X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fde%2Ftodesbaum%2Futil%2Ffreenet%2Ffcp2%2FConnection.java;h=9932d2558d5177a8f768734f976db1d04c56ae61;hb=bc7e254592c6a8d509e5d3b78866f425c75d6ac3;hp=1109aec38ea60d056017c14f8e25829b1960ab9d;hpb=e4f461213da0e30faf9e9eb2e97626abff320618;p=jSite.git

diff --git a/src/de/todesbaum/util/freenet/fcp2/Connection.java b/src/de/todesbaum/util/freenet/fcp2/Connection.java
index 1109aec..9932d25 100644
--- a/src/de/todesbaum/util/freenet/fcp2/Connection.java
+++ b/src/de/todesbaum/util/freenet/fcp2/Connection.java
@@ -31,6 +31,7 @@ import java.nio.charset.Charset;
 import java.util.ArrayList;
 import java.util.List;
 
+import de.todesbaum.util.io.Closer;
 import de.todesbaum.util.io.LineInputStream;
 import de.todesbaum.util.io.StreamCopier;
 import de.todesbaum.util.io.TempFileInputStream;
@@ -253,7 +254,13 @@ public class Connection {
 		nodeWriter.write("EndMessage" + Command.LINEFEED);
 		nodeWriter.flush();
 		if (command.hasPayload()) {
-			StreamCopier.copy(command.getPayload(), nodeOutputStream, command.getPayloadLength());
+			InputStream payloadInputStream = null;
+			try {
+				payloadInputStream = command.getPayload();
+				StreamCopier.copy(payloadInputStream, nodeOutputStream, command.getPayloadLength());
+			} finally {
+				Closer.close(payloadInputStream);
+			}
 			nodeOutputStream.flush();
 		}
 	}
@@ -294,7 +301,7 @@ public class Connection {
 				Message message = null;
 				while (line != null) {
 					line = nodeReader.readLine();
-					 System.err.println("> " + line);
+					// System.err.println("> " + line);
 					if (line == null) {
 						break;
 					}