X-Git-Url: https://git.pterodactylus.net/?p=jSite.git;a=blobdiff_plain;f=src%2Fde%2Ftodesbaum%2Futil%2Ffreenet%2Ffcp2%2FConnection.java;h=9932d2558d5177a8f768734f976db1d04c56ae61;hp=848ee868e54b0666c9a0b5075f81ce1e5603ab4d;hb=85d5c89f25bed4fc3002eaaaa98e7ca4992fa2d6;hpb=8cc524061375237e2f5c01cfe605e3e74d50d785

diff --git a/src/de/todesbaum/util/freenet/fcp2/Connection.java b/src/de/todesbaum/util/freenet/fcp2/Connection.java
index 848ee86..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();
 		}
 	}