From e73ebfee78eb93f92801a4940ef1be8c1afed40b Mon Sep 17 00:00:00 2001 From: pabloFuente Date: Tue, 30 Nov 2021 19:24:30 +0100 Subject: [PATCH] Fix KurentoClient disconnect handler after Netty exception --- .../io/openvidu/server/kurento/kms/KmsManager.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/openvidu-server/src/main/java/io/openvidu/server/kurento/kms/KmsManager.java b/openvidu-server/src/main/java/io/openvidu/server/kurento/kms/KmsManager.java index 55376403..7c594f7c 100644 --- a/openvidu-server/src/main/java/io/openvidu/server/kurento/kms/KmsManager.java +++ b/openvidu-server/src/main/java/io/openvidu/server/kurento/kms/KmsManager.java @@ -189,9 +189,10 @@ public abstract class KmsManager { kms.setKurentoClientConnected(false); kms.setTimeOfKurentoClientDisconnection(System.currentTimeMillis()); - if (kms.getKurentoClient().isClosed()) { - log.info("Kurento Client \"disconnected\" event for KMS {} [{}]. Closed explicitly", kms.getUri(), - kms.getKurentoClient().toString()); + if (kms.getKurentoClient().isDestroyed()) { + log.info( + "Kurento Client \"disconnected\" event for KMS {} [{}]. Closed explicitly by openvidu-server", + kms.getUri(), kms.getKurentoClient().toString()); return; } else { log.info("Kurento Client \"disconnected\" event for KMS {} [{}]. Waiting reconnection", @@ -279,7 +280,8 @@ public abstract class KmsManager { kms.getUri(), kms.getKurentoSessions().size(), kms.getKurentoSessions().stream() .map(s -> s.getSessionId()).collect(Collectors.joining(",", "[", "]"))); kms.getKurentoSessions().forEach(kSession -> { - kSession.restartStatusInKurentoAfterReconnectionToNewKms(timeOfKurentoDisconnection); + kSession.restartStatusInKurentoAfterReconnectionToNewKms( + timeOfKurentoDisconnection); }); } else { log.info("KMS with URI {} is the same process. Nothing must be done", kms.getUri());