ambiser
/
openvidu
mirror of https://github.com/OpenVidu/openvidu.git
8
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix KurentoClient disconnect handler after Netty exception

pull/678/head
pabloFuente 2021-11-30 19:24:30 +01:00
parent 7470261345
commit e73ebfee78
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
openvidu-server/src/main/java/io/openvidu/server/kurento/kms/KmsManager.java
View File

@ -189,9 +189,10 @@ public abstract class KmsManager {
kms.setKurentoClientConnected(false); kms.setKurentoClientConnected(false);
kms.setTimeOfKurentoClientDisconnection(System.currentTimeMillis()); kms.setTimeOfKurentoClientDisconnection(System.currentTimeMillis());
if (kms.getKurentoClient().isClosed()) { if (kms.getKurentoClient().isDestroyed()) {
log.info("Kurento Client \"disconnected\" event for KMS {} [{}]. Closed explicitly", kms.getUri(), log.info(
kms.getKurentoClient().toString()); "Kurento Client \"disconnected\" event for KMS {} [{}]. Closed explicitly by openvidu-server",
kms.getUri(), kms.getKurentoClient().toString());
return; return;
} else { } else {
log.info("Kurento Client \"disconnected\" event for KMS {} [{}]. Waiting reconnection", 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() kms.getUri(), kms.getKurentoSessions().size(), kms.getKurentoSessions().stream()
.map(s -> s.getSessionId()).collect(Collectors.joining(",", "[", "]"))); .map(s -> s.getSessionId()).collect(Collectors.joining(",", "[", "]")));
kms.getKurentoSessions().forEach(kSession -> { kms.getKurentoSessions().forEach(kSession -> {
kSession.restartStatusInKurentoAfterReconnectionToNewKms(timeOfKurentoDisconnection); kSession.restartStatusInKurentoAfterReconnectionToNewKms(
timeOfKurentoDisconnection);
}); });
} else { } else {
log.info("KMS with URI {} is the same process. Nothing must be done", kms.getUri()); log.info("KMS with URI {} is the same process. Nothing must be done", kms.getUri());