From fe03ee96ce5bc4184ee60faaab62cea081424eaf Mon Sep 17 00:00:00 2001 From: pabloFuente Date: Fri, 5 Feb 2021 14:07:46 +0100 Subject: [PATCH] openvidu-server: KMS methods to get the number of sessions and webrtc connections --- .../java/io/openvidu/server/kurento/core/KurentoSession.java | 5 +++++ .../src/main/java/io/openvidu/server/kurento/kms/Kms.java | 5 +++++ 2 files changed, 10 insertions(+) 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); + } + }