diff --git a/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSession.java b/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSession.java index a4929aab..bcbfa7ce 100644 --- a/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSession.java +++ b/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSession.java @@ -345,4 +345,9 @@ public class KurentoSession extends Session { return json; } + public int getNumberOfWebrtcConnections() { + return this.getActivePublishers() + this.participants.values().stream() + .mapToInt(p -> ((KurentoParticipant) p).getSubscribers().size()).reduce(0, Integer::sum); + } + } diff --git a/openvidu-server/src/main/java/io/openvidu/server/kurento/kms/Kms.java b/openvidu-server/src/main/java/io/openvidu/server/kurento/kms/Kms.java index 65c1bda4..8b09b0f3 100644 --- a/openvidu-server/src/main/java/io/openvidu/server/kurento/kms/Kms.java +++ b/openvidu-server/src/main/java/io/openvidu/server/kurento/kms/Kms.java @@ -250,4 +250,9 @@ public class Kms { return this.uri; } + public int getNumberOfWebrtcConnections() { + return this.kurentoSessions.values().stream().mapToInt(session -> session.getNumberOfWebrtcConnections()) + .reduce(0, Integer::sum); + } + }