sfu, observer update

config.js

@@ -28,7 +28,7 @@ module.exports = {
             "-PixelStreamingHideCursor=true",
             "-PixelStreamingKeyFilter=ESC, CTRL",
             "-SimulcastParameters=1.0,5000000,100000000,2.0,1000000,5000000,3.0,500000,2500000",
-            //"-PixelStreamingHudStats=true" // usefull for debug
+            "-PixelStreamingHudStats=true" // usefull for debug
         ]
     }
 }

src/modules/session_observer.js

@@ -8,11 +8,23 @@ const {free_app_port, free_webrtc_port, free_sfu_port} = require('./port_alloc')
 const observer_timeout = 100
 let pending_list = new wait_list([])
 
-const start_observer = () => {
+let can_check = true
+const block_time = 30000
+
+const start_observer = async () => {
+    if (can_check) {
         check()
+    }
     setTimeout(() => start_observer(), observer_timeout)
 }
 
+const block_for = (time) => {
+    can_check = false
+    setTimeout(() => {
+        can_check = true
+    }, time)
+}
+
 // check sessions in parallel
 const check_sessions = async (sessions) => {
 
@@ -47,6 +59,7 @@ const check_sessions = async (sessions) => {
                 await database.remove_running_session(session.session_id)
             } else {
                 console.error('can not connect to coordinator')
+                block_for(block_time)
             }
             pending_list.remove(session.session_id)
         }
@@ -57,10 +70,11 @@ const check = async () => {
     let sessions = await database.get_running_sessions()
 
     if (!sessions) {
+        block_for(block_time)
         return
     }
 
-    check_sessions(sessions)
+    await check_sessions(sessions)
 }
 
 module.exports = {