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

openvidu-server: fix possible ghost participant issue after network reconnection

pull/816/head
pabloFuente 2023-06-28 15:43:24 +02:00
parent efcc15a109
commit cc402f34d3
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
openvidu-server/src/main/java/io/openvidu/server/rpc/RpcHandler.java
View File

@ -785,7 +785,9 @@ public class RpcHandler extends DefaultJsonRpcHandler<JsonObject> {
String rpcSessionId = rpcSession.getSessionId(); String rpcSessionId = rpcSession.getSessionId();
String message = ""; String message = "";
if ("Close for not receive ping from client".equals(status)) { if ("Connection closed for reconnection".equals(status)) {
message = "Evicting ghost reconnection participant with private id {}";
} else if ("Close for not receive ping from client".equals(status)) {
message = "Evicting participant with private id {} because of a network disconnection"; message = "Evicting participant with private id {} because of a network disconnection";
} else if (status == null) { // && this.webSocketBrokenPipeTransportError.remove(rpcSessionId) != null)) { } else if (status == null) { // && this.webSocketBrokenPipeTransportError.remove(rpcSessionId) != null)) {
try { try {
@ -810,7 +812,7 @@ public class RpcHandler extends DefaultJsonRpcHandler<JsonObject> {
if (this.webSocketEOFTransportError.remove(rpcSessionId) != null) { if (this.webSocketEOFTransportError.remove(rpcSessionId) != null) {
log.warn( log.warn(
"Evicting participant with private id {} because a transport error took place and its web socket connection is now closed", "Evicting participant with private id {} because a transport error took place and its websocket connection is now closed",
rpcSession.getSessionId()); rpcSession.getSessionId());
this.leaveRoomAfterConnClosed(rpcSessionId, EndReason.networkDisconnect); this.leaveRoomAfterConnClosed(rpcSessionId, EndReason.networkDisconnect);
} }