package de.todesbaum.util.freenet.fcp2;
+import static java.util.logging.Level.FINE;
+import static java.util.logging.Logger.getLogger;
+
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.nio.charset.Charset;
import java.util.ArrayList;
import java.util.List;
+import java.util.logging.Logger;
import net.pterodactylus.util.io.Closer;
+import net.pterodactylus.util.io.StreamCopier;
+import net.pterodactylus.util.io.StreamCopier.ProgressListener;
import de.todesbaum.util.io.LineInputStream;
-import de.todesbaum.util.io.StreamCopier;
-import de.todesbaum.util.io.StreamCopier.ProgressListener;
import de.todesbaum.util.io.TempFileInputStream;
/**
*/
public class Connection {
+ private static final Logger logger = getLogger(Connection.class.getName());
+
/** The listeners that receive events from this connection. */
private List<ConnectionListener> connectionListeners = new ArrayList<ConnectionListener>();
synchronized (this) {
notify();
}
+ logger.log(FINE, "Connection terminated.", new Exception());
fireConnectionTerminated();
}
InputStream payloadInputStream = null;
try {
payloadInputStream = command.getPayload();
- StreamCopier.copy(payloadInputStream, nodeOutputStream, command.getPayloadLength(), progressListener);
+ StreamCopier.copy(payloadInputStream, nodeOutputStream, progressListener, command.getPayloadLength());
} finally {
Closer.close(payloadInputStream);
}
line = nodeReader.readLine();
// System.err.println("> " + line);
if (line == null) {
+ logger.fine("Connection was closed.");
break;
}
if (message == null) {
throw new IOException("Unexpected line: " + line);
}
} catch (IOException ioe1) {
- // ioe1.printStackTrace();
+ logger.log(FINE, "Exception while reading from node.", ioe1);
} finally {
if (nodeReader != null) {
try {