diff options
author | Chocobozzz <me@florianbigard.com> | 2021-06-17 17:08:47 +0200 |
---|---|---|
committer | Chocobozzz <me@florianbigard.com> | 2021-06-17 17:09:58 +0200 |
commit | e466544fb942992bbf9c455ad2168dc1b9111d97 (patch) | |
tree | b9ec84759846d58fed2af857020558d9bf80a230 /server/lib/live | |
parent | 52fb1d97baa67137e3a9afadb2cc9ec2cfc04952 (diff) | |
download | PeerTube-e466544fb942992bbf9c455ad2168dc1b9111d97.tar.gz PeerTube-e466544fb942992bbf9c455ad2168dc1b9111d97.tar.zst PeerTube-e466544fb942992bbf9c455ad2168dc1b9111d97.zip |
Fix muxing cleanup
Diffstat (limited to 'server/lib/live')
-rw-r--r-- | server/lib/live/live-manager.ts | 2 | ||||
-rw-r--r-- | server/lib/live/shared/muxing-session.ts | 2 |
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[] } = {} |