summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAlex Clayton <alex.clayton@isode.com>2016-03-15 15:46:56 (GMT)
committerAlex Clayton <alex.clayton@isode.com>2016-03-16 10:04:37 (GMT)
commit1a0b79956729aefe3a10093c58b508ac651e4d0c (patch)
tree89ace2db57d8c6a2b7ef402bff0cd6703987bf6a
parent1eddc7b6041678c47ae3e2e8e632419ae3b5e150 (diff)
downloadstroke-1a0b79956729aefe3a10093c58b508ac651e4d0c.zip
stroke-1a0b79956729aefe3a10093c58b508ac651e4d0c.tar.bz2
Add destroy methods to IncomingJingleFileTransfer and OutgoingJingleFileTransfer.
Add destroy methods to IncomingJingleFileTransfer and OutgoingJingeFlieTranser to match the destructors of the swiften code (as of patch 'Add missing Timer related cleanup code' - 52e685379436794cc0e4c2687c35f5e69a2f09a7). Test-information: Unit tests ran ok. Change-Id: Ie86c5fc74f66d9c62095045475eb6d9447c7699e
-rw-r--r--src/com/isode/stroke/filetransfer/IncomingJingleFileTransfer.java29
-rw-r--r--src/com/isode/stroke/filetransfer/OutgoingJingleFileTransfer.java49
2 files changed, 76 insertions, 2 deletions
diff --git a/src/com/isode/stroke/filetransfer/IncomingJingleFileTransfer.java b/src/com/isode/stroke/filetransfer/IncomingJingleFileTransfer.java
index 60cde19..1c67014 100644
--- a/src/com/isode/stroke/filetransfer/IncomingJingleFileTransfer.java
+++ b/src/com/isode/stroke/filetransfer/IncomingJingleFileTransfer.java
@@ -113,6 +113,32 @@ public class IncomingJingleFileTransfer extends JingleFileTransfer implements In
}
});
}
+
+ @Override
+ protected void finalize() throws Throwable {
+ try {
+ destroy();
+ }
+ finally {
+ super.finalize();
+ }
+ }
+
+ /**
+ * This replaces the C++ destructor. After calling this object should not be used again.
+ * If any methods are called after they behaviour is undefined and they may throw expections.
+ */
+ public void destroy() {
+ if (waitOnHashTimerTickedConnection != null) {
+ waitOnHashTimerTickedConnection.disconnect();
+ waitOnHashTimerTickedConnection = null;
+ }
+ if (waitOnHashTimer != null) {
+ waitOnHashTimer.stop();
+ waitOnHashTimer = null;
+ }
+ hashCalculator = null;
+ }
/**
* IncomingFileTransferMethod.
@@ -494,6 +520,9 @@ public class IncomingJingleFileTransfer extends JingleFileTransfer implements In
}
private void handleWaitOnHashTimerTicked() {
+ if (waitOnHashTimer == null) {
+ return;
+ }
logger_.fine("\n");
waitOnHashTimer.stop();
terminate(JinglePayload.Reason.Type.Success);
diff --git a/src/com/isode/stroke/filetransfer/OutgoingJingleFileTransfer.java b/src/com/isode/stroke/filetransfer/OutgoingJingleFileTransfer.java
index f32821b..aa38022 100644
--- a/src/com/isode/stroke/filetransfer/OutgoingJingleFileTransfer.java
+++ b/src/com/isode/stroke/filetransfer/OutgoingJingleFileTransfer.java
@@ -88,6 +88,16 @@ public class OutgoingJingleFileTransfer extends JingleFileTransfer implements Ou
private SignalConnection processedBytesConnection;
private SignalConnection transferFinishedConnection;
private Logger logger_ = Logger.getLogger(this.getClass().getName());
+
+ /**
+ * Connection to {@link Timer#onTick} of {@link #waitForRemoteTermination}
+ */
+ private final SignalConnection onTickConnection;
+
+ /**
+ * Connection to {@link ReadBytestream#onRead} of {@link #stream}
+ */
+ private SignalConnection streamReadConnection;
public OutgoingJingleFileTransfer(
final JID toJID,
@@ -112,20 +122,52 @@ public class OutgoingJingleFileTransfer extends JingleFileTransfer implements Ou
// calculate both, MD5 and SHA-1 since we don't know which one the other side supports
hashCalculator = new IncrementalBytestreamHashCalculator(true, true, crypto);
- stream.onRead.connect(new Slot1<ByteArray>() {
+ streamReadConnection = stream.onRead.connect(new Slot1<ByteArray>() {
@Override
public void call(ByteArray b) {
+ if (hashCalculator == null) {
+ return;
+ }
hashCalculator.feedData(b);
}
});
waitForRemoteTermination = timerFactory.createTimer(5000);
- waitForRemoteTermination.onTick.connect(new Slot() {
+ onTickConnection = waitForRemoteTermination.onTick.connect(new Slot() {
@Override
public void call() {
handleWaitForRemoteTerminationTimeout();
}
});
}
+
+ @Override
+ protected void finalize() throws Throwable {
+ try {
+ destroy();
+ }
+ finally {
+ super.finalize();
+ }
+ }
+
+ /**
+ * This replaces the C++ destructor. After calling this object should not be used again.
+ * If any methods are called after they behaviour is undefined and they may throw expections.
+ */
+ public void destroy() {
+ if (onTickConnection != null) {
+ onTickConnection.disconnect();
+ }
+ if (waitForRemoteTermination != null) {
+ waitForRemoteTermination.stop();
+ waitForRemoteTermination = null;
+ }
+ if (streamReadConnection != null) {
+ streamReadConnection.disconnect();
+ }
+ hashCalculator = null;
+ removeTransporter();
+ }
/**
* OutgoingFileTransferMethod.
@@ -383,6 +425,9 @@ public class OutgoingJingleFileTransfer extends JingleFileTransfer implements Ou
}
private void handleWaitForRemoteTerminationTimeout() {
+ if (waitForRemoteTermination == null) {
+ return;
+ }
assert(internalState.equals(State.WaitForTermination));
logger_.warning("Other party did not terminate session. Terminate it now.\n");
waitForRemoteTermination.stop();