diff --git a/app/src/Peer.js b/app/src/Peer.js index 844febbd..532722bb 100644 --- a/app/src/Peer.js +++ b/app/src/Peer.js @@ -114,12 +114,13 @@ module.exports = class Peer { close() { this.transports.forEach((transport, transport_id) => { + transport.close(); + this.delTransport(transport_id); log.debug('Close and delete peer transports', { //transport_id: transport_id, transportInternal: transport.internal, + transport_closed: transport.closed, }); - transport.close(); - this.delTransport(transport_id); }); const peerTransports = this.getTransports(); @@ -208,6 +209,7 @@ module.exports = class Peer { type: type, appData: appData, producer_id: id, + producer_closed: producer.closed, }); } @@ -300,6 +302,7 @@ module.exports = class Peer { kind: kind, type: type, consumer_id: id, + consumer_closed: consumer.closed, }); } }; diff --git a/app/src/Room.js b/app/src/Room.js index b3b5f251..ac1a23a8 100644 --- a/app/src/Room.js +++ b/app/src/Room.js @@ -88,8 +88,11 @@ module.exports = class Room { } closeRouter() { - log.debug('Close Room router id', this.router.id); this.router.close(); + log.debug('Close Room router', { + router_id: this.router.id, + router_closed: this.router.closed, + }); } // #################################################### diff --git a/app/src/Server.js b/app/src/Server.js index 29418f91..48f33603 100644 --- a/app/src/Server.js +++ b/app/src/Server.js @@ -1269,14 +1269,14 @@ function startServer() { return callback({ error: `producer with id "${producer_id}" not found` }); } - log.debug('Producer paused', { peer_name: peer_name, producer_id: producer_id }); - try { await producer.pause(); } catch (error) { return callback({ error: error.message }); } + log.debug('Producer paused', { peer_name: peer_name, producer_id: producer_id }); + callback('successfully'); }); @@ -1301,14 +1301,14 @@ function startServer() { return callback({ error: `producer with id "${producer_id}" not found` }); } - log.debug('Producer resumed', { peer_name: peer_name, producer_id: producer_id }); - try { await producer.resume(); } catch (error) { return callback({ error: error.message }); } + log.debug('Producer resumed', { peer_name: peer_name, producer_id: producer_id }); + callback('successfully'); });