From 1a0b79956729aefe3a10093c58b508ac651e4d0c Mon Sep 17 00:00:00 2001
From: Alex Clayton <alex.clayton@isode.com>
Date: Tue, 15 Mar 2016 15:46:56 +0000
Subject: 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

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();
-- 
cgit v0.10.2-6-g49f6