Fixes Hubs-Foundation#53

klee1611 · Jan 17, 2024 · a3ae813 · a3ae813
1 parent 257315f
commit a3ae813
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/index.js b/index.js
@@ -93,6 +93,7 @@ async function runMediasoupWorkers()
 				rtcMinPort : Number(config.mediasoup.workerSettings.rtcMinPort),
 				rtcMaxPort : Number(config.mediasoup.workerSettings.rtcMaxPort)
 			});
+		worker._pid = i;
 
 		worker.on('died', () =>
 		{

diff --git a/lib/Room.js b/lib/Room.js
@@ -1488,15 +1488,14 @@ class Room extends EventEmitter
 		for (const peer of peersToPipe)
 		{
 			const srcRouter = this._mediasoupRouters.get(peer.data.routerId);
+			if (routerId === peer.data.routerId)
+			{
+				logger.info("~~~skipping~parenting~router~~~")
+				continue;
+			}
 
 			for (const producerId of peer.data.producers.keys())
 			{
-				if (router._producers.has(producerId))
-				{
-					logger.info("~~~skipping~parenting~router~~~")
-					continue;
-				}
-
 				await srcRouter.pipeToRouter({
 					producerId : producerId,
 					router     : router