[mirotalksfu] - fix workers WebRrcServer

هذا الالتزام موجود في:
Miroslav Pejic
2024-03-10 09:07:55 +01:00
الأصل 5c449b68d9
التزام 8477707cd1

عرض الملف

@@ -751,29 +751,34 @@ function startServer() {
log.debug('WORKERS:', numWorkers); log.debug('WORKERS:', numWorkers);
for (let i = 0; i < numWorkers; i++) { for (let i = 0; i < numWorkers; i++) {
let worker = await mediasoup.createWorker({ //
const worker = await mediasoup.createWorker({
logLevel: logLevel, logLevel: logLevel,
logTags: logTags, logTags: logTags,
rtcMinPort: rtcMinPort, rtcMinPort: rtcMinPort,
rtcMaxPort: rtcMaxPort, rtcMaxPort: rtcMaxPort,
}); });
worker.on('died', () => {
log.error('Mediasoup worker died, exiting in 2 seconds... [pid:%d]', worker.pid);
setTimeout(() => process.exit(1), 2000);
});
workers.push(worker);
if (config.mediasoup.webRtcServerActive) { if (config.mediasoup.webRtcServerActive) {
// //
log.debug('Create a WebRtcServer', { worker_pid: worker.pid }); log.debug('Create a WebRtcServer', { worker_pid: worker.pid });
const webRtcServerOptions = clone(config.mediasoup.webRtcServerOptions); const webRtcServerOptions = clone(config.mediasoup.webRtcServerOptions);
const portIncrement = numWorkers.length - 1; const portIncrement = i;
for (const listenInfo of webRtcServerOptions.listenInfos) { for (const listenInfo of webRtcServerOptions.listenInfos) {
listenInfo.port += portIncrement; listenInfo.port += portIncrement;
} }
//log.debug('WebRtcServer options', { webRtcServerOptions: webRtcServerOptions });
const webRtcServer = await worker.createWebRtcServer(webRtcServerOptions); const webRtcServer = await worker.createWebRtcServer(webRtcServerOptions);
worker.appData.webRtcServer = webRtcServer; worker.appData.webRtcServer = webRtcServer;
} }
worker.on('died', () => {
log.error('Mediasoup worker died, exiting in 2 seconds... [pid:%d]', worker.pid);
setTimeout(() => process.exit(1), 2000);
});
workers.push(worker);
/* /*
setInterval(async () => { setInterval(async () => {
const usage = await worker.getResourceUsage(); const usage = await worker.getResourceUsage();