Skip to content

Commit ba381d7

Browse files
committed
First attepmts at fixing network related issues
1 parent e654a19 commit ba381d7

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

src/main/kotlin/dev/arbjerg/lavalink/internal/LavalinkSocket.kt

+5-2
Original file line numberDiff line numberDiff line change
@@ -137,9 +137,10 @@ class LavalinkSocket(private val node: LavalinkNode) : WebSocketListener(), Clos
137137
override fun onClosed(webSocket: WebSocket, code: Int, reason: String) {
138138
if (mayReconnect) {
139139
logger.info("${node.name} disconnected, reconnecting in ${reconnectInterval / 1000} seconds")
140-
node.available = false
141-
open = false
142140
}
141+
142+
node.available = false
143+
open = false
143144
}
144145

145146
override fun onFailure(webSocket: WebSocket, t: Throwable, response: Response?) {
@@ -229,12 +230,14 @@ class LavalinkSocket(private val node: LavalinkNode) : WebSocketListener(), Clos
229230
}
230231
.build()
231232

233+
mayReconnect = true
232234
socket = node.httpClient.newWebSocket(request, this)
233235
}
234236

235237
override fun close() {
236238
mayReconnect = false
237239
open = false
240+
node.available = false
238241
socket?.close(1000, "Client shutdown")
239242
socket?.cancel()
240243
}

0 commit comments

Comments
 (0)