X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Ffcp%2FFcpConnection.java;h=cc13d4a6aac5a3d8214b68a724ddff1abcf8e982;hb=108820f7b62fea4b149574a978b163b9d509a13b;hp=484e7c3d0543e2a3a8c81fb0080975bcdeb3821e;hpb=f26076a082cc6a3f8d6ec20689e0dda1e2b264ef;p=jFCPlib.git

diff --git a/src/main/java/net/pterodactylus/fcp/FcpConnection.java b/src/main/java/net/pterodactylus/fcp/FcpConnection.java
index 484e7c3..cc13d4a 100644
--- a/src/main/java/net/pterodactylus/fcp/FcpConnection.java
+++ b/src/main/java/net/pterodactylus/fcp/FcpConnection.java
@@ -31,8 +31,6 @@ import java.util.HashMap;
 import java.util.Map;
 import java.util.logging.Logger;
 
-import net.pterodactylus.util.logging.Logging;
-
 /**
  * An FCP connection to a Freenet node.
  *
@@ -41,7 +39,7 @@ import net.pterodactylus.util.logging.Logging;
 public class FcpConnection implements Closeable {
 
 	/** Logger. */
-	private static final Logger logger = Logging.getLogger(FcpConnection.class.getName());
+	private static final Logger logger = Logger.getLogger(FcpConnection.class.getName());
 
 	/** The default port for FCP v2. */
 	public static final int DEFAULT_PORT = 9481;
@@ -134,6 +132,10 @@ public class FcpConnection implements Closeable {
 		this.port = port;
 	}
 
+	public synchronized boolean isClosed() {
+		return connectionHandler == null;
+	}
+
 	//
 	// LISTENER MANAGEMENT
 	//
@@ -193,9 +195,10 @@ public class FcpConnection implements Closeable {
 	}
 
 	/**
-	 * Closes the connection. If there is no connection to the node, this method
-	 * does nothing.
+	 * Closes the connection. If there is no connection to the node, this
+	 * method does nothing.
 	 */
+	@Override
 	public void close() {
 		handleDisconnect(null);
 	}
@@ -323,8 +326,8 @@ public class FcpConnection implements Closeable {
 	 * Handles a disconnect from the node.
 	 *
 	 * @param throwable
-	 *            The exception that caused the disconnect, or <code>null</code>
-	 *            if there was no exception
+	 *            The exception that caused the disconnect, or
+	 *            <code>null</code> if there was no exception
 	 */
 	synchronized void handleDisconnect(Throwable throwable) {
 		FcpUtils.close(remoteInputStream);
@@ -372,8 +375,8 @@ public class FcpConnection implements Closeable {
 	}
 
 	/**
-	 * A wrapper around an {@link InputStream} that only supplies a limit number
-	 * of bytes from the underlying input stream.
+	 * A wrapper around an {@link InputStream} that only supplies a limit
+	 * number of bytes from the underlying input stream.
 	 *
 	 * @author David ‘Bombe’ Roden &lt;bombe@freenetproject.org&gt;
 	 */