GraffTech/pixel-streaming-session-server
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

sfu support added, IPC cirrus support added, session history added, advanced session info added

Browse Source
This commit is contained in:
PC-ROGE\c
2023-04-19 21:52:30 +03:00
parent b78bdd81fa
commit 9c2c413363
16 changed files with 285 additions and 74 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/modules/session_observer.js
+8 -6
View File
@@ -3,10 +3,10 @@ const database = require('../database/database')
const {is_proc_running, kill_proc} = require('./run_process')
const coordinator = require('./coordinator')
const wait_list = require('./wait_list')
const {free_app_port, free_webrtc_port} = require('./port_alloc')
const {free_app_port, free_webrtc_port, free_sfu_port} = require('./port_alloc')
const observer_timeout = 100
var pending_list = new wait_list([])
let pending_list = new wait_list([])
const start_observer = () => {
check()
@@ -17,8 +17,8 @@ const start_observer = () => {
const check_sessions = async (sessions) => {
await Promise.all(sessions.map(async (session) => {
var webrtc_running = is_proc_running(session.webrtc_pid)
var app_running = is_proc_running(session.app_pid)
let webrtc_running = is_proc_running(session.webrtc_pid)
let app_running = is_proc_running(session.app_pid)
if (webrtc_running && app_running) {
return
@@ -38,9 +38,11 @@ const check_sessions = async (sessions) => {
// free ports allocated for processes
free_webrtc_port(session.webrtc_port)
free_app_port(session.app_port)
free_sfu_port(session.sfu_port)
var close_session_result = await coordinator.close_session(session.session_id)
let close_session_result = await coordinator.close_session(session)
if (close_session_result) {
await database.add_running_session_to_history(session.session_id)
await database.remove_running_session(session.session_id)
} else {
console.error('can not connect to coordinator')
@@ -51,7 +53,7 @@ const check_sessions = async (sessions) => {
}
const check = async () => {
var sessions = await database.get_running_sessions()
let sessions = await database.get_running_sessions()
if (!sessions) {
return