goldcollection
/
muwire
mirror of https://github.com/zlatinb/muwire
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

set flag before submitting to threadpool

pull/34/head
Zlatin Balevsky 2019-11-15 23:12:17 +00:00
parent 15c59b440f
commit 2e22369ce0
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/main/groovy/com/muwire/core/chat/ChatClient.groovy
View File

@ -1,5 +1,6 @@
package com.muwire.core.chat package com.muwire.core.chat
import java.lang.System.Logger.Level
import java.nio.charset.StandardCharsets import java.nio.charset.StandardCharsets
import java.util.concurrent.Executor import java.util.concurrent.Executor
import java.util.concurrent.Executors import java.util.concurrent.Executors
@ -46,11 +47,11 @@ class ChatClient implements Closeable {
void connectIfNeeded() { void connectIfNeeded() {
if (connection != null || connectInProgress || (System.currentTimeMillis() - lastRejectionTime < REJECTION_BACKOFF)) if (connection != null || connectInProgress || (System.currentTimeMillis() - lastRejectionTime < REJECTION_BACKOFF))
return return
connectInProgress = true
CONNECTOR.execute({connect()}) CONNECTOR.execute({connect()})
} }
private void connect() { private void connect() {
connectInProgress = true
connectThread = Thread.currentThread() connectThread = Thread.currentThread()
Endpoint endpoint = null Endpoint endpoint = null
try { try {
@ -94,6 +95,7 @@ class ChatClient implements Closeable {
eventBus.publish(new ChatConnectionEvent(status : ChatConnectionAttemptStatus.SUCCESSFUL, persona : host, eventBus.publish(new ChatConnectionEvent(status : ChatConnectionAttemptStatus.SUCCESSFUL, persona : host,
connection : connection)) connection : connection))
} catch (Exception e) { } catch (Exception e) {
log.log(java.util.logging.Level.WARNING, "connect failed", e)
eventBus.publish(new ChatConnectionEvent(status : ChatConnectionAttemptStatus.FAILED, persona : host)) eventBus.publish(new ChatConnectionEvent(status : ChatConnectionAttemptStatus.FAILED, persona : host))
if (endpoint != null) { if (endpoint != null) {
try {endpoint.getOutputStream().close() } catch (IOException ignore) {} try {endpoint.getOutputStream().close() } catch (IOException ignore) {}