projects
/
jSite2.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
add PersistentGet
[jSite2.git]
/
src
/
net
/
pterodactylus
/
util
/
fcp
/
FcpConnection.java
diff --git
a/src/net/pterodactylus/util/fcp/FcpConnection.java
b/src/net/pterodactylus/util/fcp/FcpConnection.java
index
d5f05ee
..
fd6add0
100644
(file)
--- a/
src/net/pterodactylus/util/fcp/FcpConnection.java
+++ b/
src/net/pterodactylus/util/fcp/FcpConnection.java
@@
-292,6
+292,18
@@
public class FcpConnection {
}
/**
}
/**
+ * Notifies all listeners that a “PersistentGet” message was received.
+ *
+ * @param persistentGet
+ * The “PersistentGet” message
+ */
+ private void fireReceivedPersistentGet(PersistentGet persistentGet) {
+ for (FcpListener fcpListener: fcpListeners) {
+ fcpListener.receivedPersistentGet(this, persistentGet);
+ }
+ }
+
+ /**
* Notifies all listeners that a “PersistentPut” message was received.
*
* @see FcpListener#receivedPersistentPut(FcpConnection, PersistentPut)
* Notifies all listeners that a “PersistentPut” message was received.
*
* @see FcpListener#receivedPersistentPut(FcpConnection, PersistentPut)
@@
-480,6
+492,8
@@
public class FcpConnection {
fireReceivedSimpleProgress(new SimpleProgress(fcpMessage));
} else if ("ProtocolError".equals(messageName)) {
fireReceivedProtocolError(new ProtocolError(fcpMessage));
fireReceivedSimpleProgress(new SimpleProgress(fcpMessage));
} else if ("ProtocolError".equals(messageName)) {
fireReceivedProtocolError(new ProtocolError(fcpMessage));
+ } else if ("PersistentGet".equals(messageName)) {
+ fireReceivedPersistentGet(new PersistentGet(fcpMessage));
} else if ("PersistentPut".equals(messageName)) {
fireReceivedPersistentPut(new PersistentPut(fcpMessage));
} else if ("URIGenerated".equals(messageName)) {
} else if ("PersistentPut".equals(messageName)) {
fireReceivedPersistentPut(new PersistentPut(fcpMessage));
} else if ("URIGenerated".equals(messageName)) {
@@
-534,6
+548,16
@@
public class FcpConnection {
}
}
}
}
+ /**
+ * Handles a disconnect from the node.
+ */
+ synchronized void handleDisconnect() {
+ Closer.close(remoteInputStream);
+ Closer.close(remoteOutputStream);
+ Closer.close(remoteSocket);
+ connectionHandler = null;
+ }
+
//
// PRIVATE METHODS
//
//
// PRIVATE METHODS
//