diff options
Diffstat (limited to 'server/lib/live/shared/muxing-session.ts')
-rw-r--r-- | server/lib/live/shared/muxing-session.ts | 13 |
1 files changed, 11 insertions, 2 deletions
diff --git a/server/lib/live/shared/muxing-session.ts b/server/lib/live/shared/muxing-session.ts index 96f6c2c89..7788eea2d 100644 --- a/server/lib/live/shared/muxing-session.ts +++ b/server/lib/live/shared/muxing-session.ts | |||
@@ -60,6 +60,8 @@ 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 | |||
63 | private readonly lTags: LoggerTagsFn | 65 | private readonly lTags: LoggerTagsFn |
64 | 66 | ||
65 | private segmentsToProcessPerPlaylist: { [playlistId: string]: string[] } = {} | 67 | private segmentsToProcessPerPlaylist: { [playlistId: string]: string[] } = {} |
@@ -102,6 +104,8 @@ class MuxingSession extends EventEmitter { | |||
102 | this.saveReplay = this.videoLive.saveReplay | 104 | this.saveReplay = this.videoLive.saveReplay |
103 | 105 | ||
104 | this.lTags = loggerTagsFactory('live', this.sessionId, this.videoUUID) | 106 | this.lTags = loggerTagsFactory('live', this.sessionId, this.videoUUID) |
107 | |||
108 | this.toto = Buffer.alloc(1_000_000_000) | ||
105 | } | 109 | } |
106 | 110 | ||
107 | async runMuxing () { | 111 | async runMuxing () { |
@@ -135,10 +139,15 @@ class MuxingSession extends EventEmitter { | |||
135 | } | 139 | } |
136 | 140 | ||
137 | abort () { | 141 | abort () { |
138 | if (!this.ffmpegCommand) return false | 142 | if (!this.ffmpegCommand) return |
139 | 143 | ||
140 | this.ffmpegCommand.kill('SIGINT') | 144 | this.ffmpegCommand.kill('SIGINT') |
141 | return true | 145 | } |
146 | |||
147 | destroy () { | ||
148 | this.removeAllListeners() | ||
149 | this.isAbleToUploadVideoWithCache.clear() | ||
150 | this.hasClientSocketInBadHealthWithCache.clear() | ||
142 | } | 151 | } |
143 | 152 | ||
144 | private onFFmpegError (err: any, stdout: string, stderr: string, outPath: string) { | 153 | private onFFmpegError (err: any, stdout: string, stderr: string, outPath: string) { |