From b6fb1f374309ab3d3e58c52915891b1024dee63c Mon Sep 17 00:00:00 2001
From: Florian Schmaus <flo@geekplace.eu>
Date: Mon, 28 Apr 2014 18:18:28 +0200
Subject: [PATCH] Notify PacketReader in case of TLS exceptions

PacketReader will be waiting in startup() as long as either:
- the timeout occurs
- notify is called because the last feature stanza was parser
- notify is called because of an exception while parsing
---
 .../java/org/jivesoftware/smack/PacketReader.java  | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git a/tcp/src/main/java/org/jivesoftware/smack/PacketReader.java b/tcp/src/main/java/org/jivesoftware/smack/PacketReader.java
index a4c270e95..f96ba8dc2 100644
--- a/tcp/src/main/java/org/jivesoftware/smack/PacketReader.java
+++ b/tcp/src/main/java/org/jivesoftware/smack/PacketReader.java
@@ -97,13 +97,12 @@ class PacketReader {
      */
     synchronized public void startup() throws NoResponseException, IOException {
         readerThread.start();
-        // Wait for stream tag before returning. We'll wait a couple of seconds before
-        // giving up and throwing an error.
+
         try {
-            // A waiting thread may be woken up before the wait time or a notify
-            // (although this is a rare thing). Therefore, we continue waiting
-            // until either the server's features have been parsed (and hence a notify was
-            // made) or the total wait time has elapsed.
+            // Wait until either:
+            // - the servers last features stanza has been parsed
+            // - an exception is thrown while parsing
+            // - the timeout occurs
             wait(connection.getPacketReplyTimeout());
         }
         catch (InterruptedException ie) {
@@ -288,6 +287,9 @@ class PacketReader {
             // The exception can be ignored if the the connection is 'done'
             // or if the it was caused because the socket got closed
             if (!(done || connection.isSocketClosed())) {
+                synchronized(this) {
+                    this.notify();
+                }
                 // Close the connection and notify connection listeners of the
                 // error.
                 connection.notifyConnectionError(e);