Fix log to use the new variable and fix stats (#1467)

lynckia · Oct 2, 2019 · 2edef3b · 2edef3b
1 parent 1a4e0a4
commit 2edef3b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/erizo_controller/ROV/rovMetricsGatherer.js b/erizo_controller/ROV/rovMetricsGatherer.js
@@ -59,9 +59,9 @@ class RovMetricsGatherer {
   getTotalPublishersAndSubscribers() {
     this.log.debug('Getting total publishers and subscribers');
     const requestPromises = [];
-    const command = 'var totalValues = {publishers: 0, subscribers: 0}; context.rooms.forEach((room)' +
-      '=> {const pubsubList = room.controller.getSubscribers(); const publishersInList = Object.keys(pubsubList); totalValues.publishers += publishersInList.length;' +
-      'publishersInList.forEach((pubId) => {totalValues.subscribers += pubsubList[pubId].length; });}); console.log(JSON.stringify(totalValues));';
+    const command = 'var totalValues = {publishers: 0, subscribers: 0};' +
+      'context.rooms.forEach((room) => {room.streamManager.forEachPublishedStream((pub) => {totalValues.publishers += 1;' +
+      'totalValues.subscribers += pub.avSubscribers.size; });}); console.log(JSON.stringify(totalValues));';
     this.rovClient.components.erizoControllers.forEach((controller) => {
       requestPromises.push(controller.runAndGetPromise(command));
     });

diff --git a/erizo_controller/erizoController/roomController.js b/erizo_controller/erizoController/roomController.js
@@ -47,7 +47,7 @@ exports.RoomController = (spec) => {
           if (streamsInErizo.length > 0) {
             log.error('message: ErizoJS timed out will be removed, ' +
               `erizoId: ${erizoId}, ` +
-              `publishersAffected: ${erizo.publishers.length}`);
+              `publishersAffected: ${streamsInErizo.length}`);
             streamsInErizo.forEach((publisher) => {
               dispatchEvent('unpublish', publisher.id);
             });