aboutsummaryrefslogtreecommitdiffhomepage
diff options
context:
space:
mode:
authorChocobozzz <me@florianbigard.com>2021-06-17 17:08:47 +0200
committerChocobozzz <me@florianbigard.com>2021-06-17 17:09:58 +0200
commite466544fb942992bbf9c455ad2168dc1b9111d97 (patch)
treeb9ec84759846d58fed2af857020558d9bf80a230
parent52fb1d97baa67137e3a9afadb2cc9ec2cfc04952 (diff)
downloadPeerTube-e466544fb942992bbf9c455ad2168dc1b9111d97.tar.gz
PeerTube-e466544fb942992bbf9c455ad2168dc1b9111d97.tar.zst
PeerTube-e466544fb942992bbf9c455ad2168dc1b9111d97.zip
Fix muxing cleanup
-rw-r--r--server/lib/live/live-manager.ts2
-rw-r--r--server/lib/live/shared/muxing-session.ts2
2 files changed, 1 insertions, 3 deletions
diff --git a/server/lib/live/live-manager.ts b/server/lib/live/live-manager.ts
index 1863c0b0c..014cd3fcf 100644
--- a/server/lib/live/live-manager.ts
+++ b/server/lib/live/live-manager.ts
@@ -160,8 +160,8 @@ class LiveManager {
160 160
161 const muxingSession = this.muxingSessions.get(sessionId) 161 const muxingSession = this.muxingSessions.get(sessionId)
162 if (muxingSession) { 162 if (muxingSession) {
163 // Muxing session will fire and event so we correctly cleanup the session
163 muxingSession.abort() 164 muxingSession.abort()
164 muxingSession.destroy()
165 165
166 this.muxingSessions.delete(sessionId) 166 this.muxingSessions.delete(sessionId)
167 } 167 }
diff --git a/server/lib/live/shared/muxing-session.ts b/server/lib/live/shared/muxing-session.ts
index 7788eea2d..eb2007b29 100644
--- a/server/lib/live/shared/muxing-session.ts
+++ b/server/lib/live/shared/muxing-session.ts
@@ -60,8 +60,6 @@ class MuxingSession extends EventEmitter {
60 private readonly videoUUID: string 60 private readonly videoUUID: string
61 private readonly saveReplay: boolean 61 private readonly saveReplay: boolean
62 62
63 private toto: Buffer
64
65 private readonly lTags: LoggerTagsFn 63 private readonly lTags: LoggerTagsFn
66 64
67 private segmentsToProcessPerPlaylist: { [playlistId: string]: string[] } = {} 65 private segmentsToProcessPerPlaylist: { [playlistId: string]: string[] } = {}