X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;ds=sidebyside;f=src%2Fnet%2Fpterodactylus%2Ffcp%2FFcpConnection.java;h=05d8815daf4ff7046d58761c7539aab7f64e7424;hb=bf0b6fe3af98f1c31895190bc54d017b623acd2e;hp=d7ed4bc2438fd88c45d69692502b2888bc08b5b9;hpb=930a13cd3640422a0fd23e2952cacf798286f0bc;p=jFCPlib.git
diff --git a/src/net/pterodactylus/fcp/FcpConnection.java b/src/net/pterodactylus/fcp/FcpConnection.java
index d7ed4bc..05d8815 100644
--- a/src/net/pterodactylus/fcp/FcpConnection.java
+++ b/src/net/pterodactylus/fcp/FcpConnection.java
@@ -36,9 +36,8 @@ import java.util.logging.Logger;
/**
* An FCP connection to a Freenet node.
- *
+ *
* @author David âBombeâ Roden <bombe@freenetproject.org>
- * @version $Id$
*/
public class FcpConnection implements Closeable {
@@ -75,7 +74,7 @@ public class FcpConnection implements Closeable {
/**
* Creates a new FCP connection to the freenet node running on localhost,
* using the default port.
- *
+ *
* @throws UnknownHostException
* if the hostname can not be resolved
*/
@@ -86,7 +85,7 @@ public class FcpConnection implements Closeable {
/**
* Creates a new FCP connection to the Freenet node running on the given
* host, listening on the default port.
- *
+ *
* @param host
* The hostname of the Freenet node
* @throws UnknownHostException
@@ -99,7 +98,7 @@ public class FcpConnection implements Closeable {
/**
* Creates a new FCP connection to the Freenet node running on the given
* host, listening on the given port.
- *
+ *
* @param host
* The hostname of the Freenet node
* @param port
@@ -114,7 +113,7 @@ public class FcpConnection implements Closeable {
/**
* Creates a new FCP connection to the Freenet node running at the given
* address, listening on the default port.
- *
+ *
* @param address
* The address of the Freenet node
*/
@@ -125,7 +124,7 @@ public class FcpConnection implements Closeable {
/**
* Creates a new FCP connection to the Freenet node running at the given
* address, listening on the given port.
- *
+ *
* @param address
* The address of the Freenet node
* @param port
@@ -142,7 +141,7 @@ public class FcpConnection implements Closeable {
/**
* Adds the given listener to the list of listeners.
- *
+ *
* @param fcpListener
* The listener to add
*/
@@ -152,7 +151,7 @@ public class FcpConnection implements Closeable {
/**
* Removes the given listener from the list of listeners.
- *
+ *
* @param fcpListener
* The listener to remove
*/
@@ -162,13 +161,13 @@ public class FcpConnection implements Closeable {
/**
* Notifies listeners that a âNodeHelloâ message was received.
- *
+ *
* @see FcpListener#receivedNodeHello(FcpConnection, NodeHello)
* @param nodeHello
* The âNodeHelloâ message
*/
private void fireReceivedNodeHello(NodeHello nodeHello) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedNodeHello(this, nodeHello);
}
}
@@ -176,157 +175,157 @@ public class FcpConnection implements Closeable {
/**
* Notifies listeners that a âCloseConnectionDuplicateClientNameâ message
* was received.
- *
+ *
* @see FcpListener#receivedCloseConnectionDuplicateClientName(FcpConnection,
* CloseConnectionDuplicateClientName)
* @param closeConnectionDuplicateClientName
* The âCloseConnectionDuplicateClientNameâ message
*/
private void fireReceivedCloseConnectionDuplicateClientName(CloseConnectionDuplicateClientName closeConnectionDuplicateClientName) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedCloseConnectionDuplicateClientName(this, closeConnectionDuplicateClientName);
}
}
/**
* Notifies listeners that a âSSKKeypairâ message was received.
- *
+ *
* @see FcpListener#receivedSSKKeypair(FcpConnection, SSKKeypair)
* @param sskKeypair
* The âSSKKeypairâ message
*/
private void fireReceivedSSKKeypair(SSKKeypair sskKeypair) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedSSKKeypair(this, sskKeypair);
}
}
/**
* Notifies listeners that a âPeerâ message was received.
- *
+ *
* @see FcpListener#receivedPeer(FcpConnection, Peer)
* @param peer
* The âPeerâ message
*/
private void fireReceivedPeer(Peer peer) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedPeer(this, peer);
}
}
/**
* Notifies all listeners that an âEndListPeersâ message was received.
- *
+ *
* @see FcpListener#receivedEndListPeers(FcpConnection, EndListPeers)
* @param endListPeers
* The âEndListPeersâ message
*/
private void fireReceivedEndListPeers(EndListPeers endListPeers) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedEndListPeers(this, endListPeers);
}
}
/**
* Notifies all listeners that a âPeerNoteâ message was received.
- *
+ *
* @see FcpListener#receivedPeerNote(FcpConnection, PeerNote)
* @param peerNote
*/
private void fireReceivedPeerNote(PeerNote peerNote) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedPeerNote(this, peerNote);
}
}
/**
* Notifies all listeners that an âEndListPeerNotesâ message was received.
- *
+ *
* @see FcpListener#receivedEndListPeerNotes(FcpConnection,
* EndListPeerNotes)
* @param endListPeerNotes
* The âEndListPeerNotesâ message
*/
private void fireReceivedEndListPeerNotes(EndListPeerNotes endListPeerNotes) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedEndListPeerNotes(this, endListPeerNotes);
}
}
/**
* Notifies all listeners that a âPeerRemovedâ message was received.
- *
+ *
* @see FcpListener#receivedPeerRemoved(FcpConnection, PeerRemoved)
* @param peerRemoved
* The âPeerRemovedâ message
*/
private void fireReceivedPeerRemoved(PeerRemoved peerRemoved) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedPeerRemoved(this, peerRemoved);
}
}
/**
* Notifies all listeners that a âNodeDataâ message was received.
- *
+ *
* @see FcpListener#receivedNodeData(FcpConnection, NodeData)
* @param nodeData
* The âNodeDataâ message
*/
private void fireReceivedNodeData(NodeData nodeData) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedNodeData(this, nodeData);
}
}
/**
* Notifies all listeners that a âTestDDAReplyâ message was received.
- *
+ *
* @see FcpListener#receivedTestDDAReply(FcpConnection, TestDDAReply)
* @param testDDAReply
* The âTestDDAReplyâ message
*/
private void fireReceivedTestDDAReply(TestDDAReply testDDAReply) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedTestDDAReply(this, testDDAReply);
}
}
/**
* Notifies all listeners that a âTestDDACompleteâ message was received.
- *
+ *
* @see FcpListener#receivedTestDDAComplete(FcpConnection, TestDDAComplete)
* @param testDDAComplete
* The âTestDDACompleteâ message
*/
private void fireReceivedTestDDAComplete(TestDDAComplete testDDAComplete) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedTestDDAComplete(this, testDDAComplete);
}
}
/**
* Notifies all listeners that a âPersistentGetâ message was received.
- *
+ *
* @see FcpListener#receivedPersistentGet(FcpConnection, PersistentGet)
* @param persistentGet
* The âPersistentGetâ message
*/
private void fireReceivedPersistentGet(PersistentGet persistentGet) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedPersistentGet(this, persistentGet);
}
}
/**
* Notifies all listeners that a âPersistentPutâ message was received.
- *
+ *
* @see FcpListener#receivedPersistentPut(FcpConnection, PersistentPut)
* @param persistentPut
* The âPersistentPutâ message
*/
private void fireReceivedPersistentPut(PersistentPut persistentPut) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedPersistentPut(this, persistentPut);
}
}
@@ -334,94 +333,94 @@ public class FcpConnection implements Closeable {
/**
* Notifies all listeners that a âEndListPersistentRequestsâ message was
* received.
- *
+ *
* @see FcpListener#receivedEndListPersistentRequests(FcpConnection,
* EndListPersistentRequests)
* @param endListPersistentRequests
* The âEndListPersistentRequestsâ message
*/
private void fireReceivedEndListPersistentRequests(EndListPersistentRequests endListPersistentRequests) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedEndListPersistentRequests(this, endListPersistentRequests);
}
}
/**
* Notifies all listeners that a âURIGeneratedâ message was received.
- *
+ *
* @see FcpListener#receivedURIGenerated(FcpConnection, URIGenerated)
* @param uriGenerated
* The âURIGeneratedâ message
*/
private void fireReceivedURIGenerated(URIGenerated uriGenerated) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedURIGenerated(this, uriGenerated);
}
}
/**
* Notifies all listeners that a âDataFoundâ message was received.
- *
+ *
* @see FcpListener#receivedDataFound(FcpConnection, DataFound)
* @param dataFound
* The âDataFoundâ message
*/
private void fireReceivedDataFound(DataFound dataFound) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedDataFound(this, dataFound);
}
}
/**
* Notifies all listeners that an âAllDataâ message was received.
- *
+ *
* @see FcpListener#receivedAllData(FcpConnection, AllData)
* @param allData
* The âAllDataâ message
*/
private void fireReceivedAllData(AllData allData) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedAllData(this, allData);
}
}
/**
* Notifies all listeners that a âSimpleProgressâ message was received.
- *
+ *
* @see FcpListener#receivedSimpleProgress(FcpConnection, SimpleProgress)
* @param simpleProgress
* The âSimpleProgressâ message
*/
private void fireReceivedSimpleProgress(SimpleProgress simpleProgress) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedSimpleProgress(this, simpleProgress);
}
}
/**
* Notifies all listeners that a âStartedCompressionâ message was received.
- *
+ *
* @see FcpListener#receivedStartedCompression(FcpConnection,
* StartedCompression)
* @param startedCompression
* The âStartedCompressionâ message
*/
private void fireReceivedStartedCompression(StartedCompression startedCompression) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedStartedCompression(this, startedCompression);
}
}
/**
* Notifies all listeners that a âFinishedCompressionâ message was received.
- *
+ *
* @see FcpListener#receviedFinishedCompression(FcpConnection,
* FinishedCompression)
* @param finishedCompression
* The âFinishedCompressionâ message
*/
private void fireReceivedFinishedCompression(FinishedCompression finishedCompression) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receviedFinishedCompression(this, finishedCompression);
}
}
@@ -429,14 +428,14 @@ public class FcpConnection implements Closeable {
/**
* Notifies all listeners that an âUnknownPeerNoteTypeâ message was
* received.
- *
+ *
* @see FcpListener#receivedUnknownPeerNoteType(FcpConnection,
* UnknownPeerNoteType)
* @param unknownPeerNoteType
* The âUnknownPeerNoteTypeâ message
*/
private void fireReceivedUnknownPeerNoteType(UnknownPeerNoteType unknownPeerNoteType) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedUnknownPeerNoteType(this, unknownPeerNoteType);
}
}
@@ -444,53 +443,53 @@ public class FcpConnection implements Closeable {
/**
* Notifies all listeners that an âUnknownNodeIdentifierâ message was
* received.
- *
+ *
* @see FcpListener#receivedUnknownNodeIdentifier(FcpConnection,
* UnknownNodeIdentifier)
* @param unknownNodeIdentifier
* The âUnknownNodeIdentifierâ message
*/
private void fireReceivedUnknownNodeIdentifier(UnknownNodeIdentifier unknownNodeIdentifier) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedUnknownNodeIdentifier(this, unknownNodeIdentifier);
}
}
/**
* Notifies all listeners that a âConfigDataâ message was received.
- *
+ *
* @see FcpListener#receivedConfigData(FcpConnection, ConfigData)
* @param configData
* The âConfigDataâ message
*/
private void fireReceivedConfigData(ConfigData configData) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedConfigData(this, configData);
}
}
/**
* Notifies all listeners that a âGetFailedâ message was received.
- *
+ *
* @see FcpListener#receivedGetFailed(FcpConnection, GetFailed)
* @param getFailed
* The âGetFailedâ message
*/
private void fireReceivedGetFailed(GetFailed getFailed) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedGetFailed(this, getFailed);
}
}
/**
* Notifies all listeners that a âPutFailedâ message was received.
- *
+ *
* @see FcpListener#receivedPutFailed(FcpConnection, PutFailed)
* @param putFailed
* The âPutFailedâ message
*/
private void fireReceivedPutFailed(PutFailed putFailed) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedPutFailed(this, putFailed);
}
}
@@ -498,28 +497,28 @@ public class FcpConnection implements Closeable {
/**
* Notifies all listeners that an âIdentifierCollisionâ message was
* received.
- *
+ *
* @see FcpListener#receivedIdentifierCollision(FcpConnection,
* IdentifierCollision)
* @param identifierCollision
* The âIdentifierCollisionâ message
*/
private void fireReceivedIdentifierCollision(IdentifierCollision identifierCollision) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedIdentifierCollision(this, identifierCollision);
}
}
/**
* Notifies all listeners that an âPersistentPutDirâ message was received.
- *
+ *
* @see FcpListener#receivedPersistentPutDir(FcpConnection,
* PersistentPutDir)
* @param persistentPutDir
* The âPersistentPutDirâ message
*/
private void fireReceivedPersistentPutDir(PersistentPutDir persistentPutDir) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedPersistentPutDir(this, persistentPutDir);
}
}
@@ -527,54 +526,54 @@ public class FcpConnection implements Closeable {
/**
* Notifies all listeners that a âPersistentRequestRemovedâ message was
* received.
- *
+ *
* @see FcpListener#receivedPersistentRequestRemoved(FcpConnection,
* PersistentRequestRemoved)
* @param persistentRequestRemoved
* The âPersistentRequestRemovedâ message
*/
private void fireReceivedPersistentRequestRemoved(PersistentRequestRemoved persistentRequestRemoved) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedPersistentRequestRemoved(this, persistentRequestRemoved);
}
}
/**
* Notifies all listeners that a âSubscribedUSKUpdateâ message was received.
- *
+ *
* @see FcpListener#receivedSubscribedUSKUpdate(FcpConnection,
* SubscribedUSKUpdate)
* @param subscribedUSKUpdate
* The âSubscribedUSKUpdateâ message
*/
private void fireReceivedSubscribedUSKUpdate(SubscribedUSKUpdate subscribedUSKUpdate) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedSubscribedUSKUpdate(this, subscribedUSKUpdate);
}
}
/**
* Notifies all listeners that a âPluginInfoâ message was received.
- *
+ *
* @see FcpListener#receivedPluginInfo(FcpConnection, PluginInfo)
* @param pluginInfo
* The âPluginInfoâ message
*/
private void fireReceivedPluginInfo(PluginInfo pluginInfo) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedPluginInfo(this, pluginInfo);
}
}
/**
* Notifies all listeners that an âFCPPluginReplyâ message was received.
- *
+ *
* @see FcpListener#receivedFCPPluginReply(FcpConnection, FCPPluginReply)
* @param fcpPluginReply
* The âFCPPluginReplyâ message
*/
private void fireReceivedFCPPluginReply(FCPPluginReply fcpPluginReply) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedFCPPluginReply(this, fcpPluginReply);
}
}
@@ -582,80 +581,80 @@ public class FcpConnection implements Closeable {
/**
* Notifies all listeners that a âPersistentRequestModifiedâ message was
* received.
- *
+ *
* @see FcpListener#receivedPersistentRequestModified(FcpConnection,
* PersistentRequestModified)
* @param persistentRequestModified
* The âPersistentRequestModifiedâ message
*/
private void fireReceivedPersistentRequestModified(PersistentRequestModified persistentRequestModified) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedPersistentRequestModified(this, persistentRequestModified);
}
}
/**
* Notifies all listeners that a âPutSuccessfulâ message was received.
- *
+ *
* @see FcpListener#receivedPutSuccessful(FcpConnection, PutSuccessful)
* @param putSuccessful
* The âPutSuccessfulâ message
*/
private void fireReceivedPutSuccessful(PutSuccessful putSuccessful) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedPutSuccessful(this, putSuccessful);
}
}
/**
* Notifies all listeners that a âPutFetchableâ message was received.
- *
+ *
* @see FcpListener#receivedPutFetchable(FcpConnection, PutFetchable)
* @param putFetchable
* The âPutFetchableâ message
*/
private void fireReceivedPutFetchable(PutFetchable putFetchable) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedPutFetchable(this, putFetchable);
}
}
/**
* Notifies all listeners that a âProtocolErrorâ message was received.
- *
+ *
* @see FcpListener#receivedProtocolError(FcpConnection, ProtocolError)
* @param protocolError
* The âProtocolErrorâ message
*/
private void fireReceivedProtocolError(ProtocolError protocolError) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedProtocolError(this, protocolError);
}
}
/**
* Notifies all registered listeners that a message has been received.
- *
+ *
* @see FcpListener#receivedMessage(FcpConnection, FcpMessage)
* @param fcpMessage
* The message that was received
*/
private void fireMessageReceived(FcpMessage fcpMessage) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.receivedMessage(this, fcpMessage);
}
}
/**
* Notifies all listeners that the connection to the node was closed.
- *
+ *
* @param throwable
* The exception that caused the disconnect, or null
* if there was no exception
* @see FcpListener#connectionClosed(FcpConnection, Throwable)
*/
private void fireConnectionClosed(Throwable throwable) {
- for (FcpListener fcpListener: fcpListeners) {
+ for (FcpListener fcpListener : fcpListeners) {
fcpListener.connectionClosed(this, throwable);
}
}
@@ -666,7 +665,7 @@ public class FcpConnection implements Closeable {
/**
* Connects to the node.
- *
+ *
* @throws IOException
* if an I/O error occurs
* @throws IllegalStateException
@@ -686,7 +685,7 @@ public class FcpConnection implements Closeable {
/**
* Disconnects from the node. If there is no connection to the node, this
* method does nothing.
- *
+ *
* @deprecated Use {@link #close()} instead
*/
@Deprecated
@@ -704,7 +703,7 @@ public class FcpConnection implements Closeable {
/**
* Sends the given FCP message.
- *
+ *
* @param fcpMessage
* The FCP message to send
* @throws IOException
@@ -722,7 +721,7 @@ public class FcpConnection implements Closeable {
/**
* Handles the given message, notifying listeners. This message should only
* be called by {@link FcpConnectionHandler}.
- *
+ *
* @param fcpMessage
* The received message
*/
@@ -819,7 +818,7 @@ public class FcpConnection implements Closeable {
/**
* Handles a disconnect from the node.
- *
+ *
* @param throwable
* The exception that caused the disconnect, or null
* if there was no exception
@@ -831,8 +830,8 @@ public class FcpConnection implements Closeable {
if (connectionHandler != null) {
connectionHandler.stop();
connectionHandler = null;
+ fireConnectionClosed(throwable);
}
- fireConnectionClosed(throwable);
}
//
@@ -842,7 +841,7 @@ public class FcpConnection implements Closeable {
/**
* Incremets the counter in {@link #incomingMessageStatistics} by 1
* for the given message name.
- *
+ *
* @param name
* The name of the message to count
*/
@@ -857,7 +856,7 @@ public class FcpConnection implements Closeable {
/**
* Returns a limited input stream from the nodeâs input stream.
- *
+ *
* @param dataLength
* The length of the stream
* @return The limited input stream
@@ -872,9 +871,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.
- *
- * @author David Roden
- * @version $Id$
+ *
+ * @author David âBombeâ Roden <bombe@freenetproject.org>
*/
private static class LimitedInputStream extends FilterInputStream {
@@ -884,7 +882,7 @@ public class FcpConnection implements Closeable {
/**
* Creates a new LimitedInputStream that supplies at most
* length
bytes from the given input stream.
- *
+ *
* @param inputStream
* The input stream
* @param length
@@ -949,7 +947,7 @@ public class FcpConnection implements Closeable {
/**
* {@inheritDoc} This method does nothing, as {@link #mark(int)} and
* {@link #reset()} are not supported.
- *
+ *
* @see java.io.FilterInputStream#mark(int)
*/
@Override
@@ -959,7 +957,7 @@ public class FcpConnection implements Closeable {
/**
* {@inheritDoc}
- *
+ *
* @see java.io.FilterInputStream#markSupported()
* @return false
*/
@@ -971,7 +969,7 @@ public class FcpConnection implements Closeable {
/**
* {@inheritDoc} This method does nothing, as {@link #mark(int)} and
* {@link #reset()} are not supported.
- *
+ *
* @see java.io.FilterInputStream#reset()
*/
@Override
@@ -982,7 +980,7 @@ public class FcpConnection implements Closeable {
/**
* Consumes the input stream, i.e. read all bytes until the limit is
* reached.
- *
+ *
* @throws IOException
* if an I/O error occurs
*/