diff options
author | Christian Schneppe <christian@pix-art.de> | 2018-09-11 21:16:09 +0200 |
---|---|---|
committer | Christian Schneppe <christian@pix-art.de> | 2018-09-11 21:16:09 +0200 |
commit | e53542b63abba1d672c7678e8016e0abdce6d171 (patch) | |
tree | 66a65970ce1d5212275fd1712aa2432365a7e38d | |
parent | 5608bbf94d94ca50a0bc2d79e196b1eb09f9b0b4 (diff) |
removed synchronized in favor of another interrupted check in startXmpp()
-rw-r--r-- | src/main/java/de/pixart/messenger/xmpp/XmppConnection.java | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/main/java/de/pixart/messenger/xmpp/XmppConnection.java b/src/main/java/de/pixart/messenger/xmpp/XmppConnection.java index f33817f09..1def41694 100644 --- a/src/main/java/de/pixart/messenger/xmpp/XmppConnection.java +++ b/src/main/java/de/pixart/messenger/xmpp/XmppConnection.java @@ -466,7 +466,7 @@ public class XmppConnection implements Runnable { * * @return true if server returns with valid xmpp, false otherwise */ - private synchronized boolean startXmpp(Socket socket) throws Exception { + private boolean startXmpp(Socket socket) throws Exception { if (Thread.currentThread().isInterrupted()) { throw new InterruptedException(); } @@ -481,6 +481,9 @@ public class XmppConnection implements Runnable { tagWriter.beginDocument(); sendStartStream(); final Tag tag = tagReader.readTag(); + if (Thread.currentThread().isInterrupted()) { + throw new InterruptedException(); + } return tag != null && tag.isStart("stream"); } |