aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/lib/live-manager.ts
diff options
context:
space:
mode:
Diffstat (limited to 'server/lib/live-manager.ts')
-rw-r--r--server/lib/live-manager.ts14
1 files changed, 7 insertions, 7 deletions
diff --git a/server/lib/live-manager.ts b/server/lib/live-manager.ts
index 690e2ce55..4f45ce530 100644
--- a/server/lib/live-manager.ts
+++ b/server/lib/live-manager.ts
@@ -378,13 +378,13 @@ class LiveManager {
378 // Wait latest segments generation, and close watchers 378 // Wait latest segments generation, and close watchers
379 379
380 Promise.all([ tsWatcher.close(), masterWatcher.close() ]) 380 Promise.all([ tsWatcher.close(), masterWatcher.close() ])
381 .then(() => { 381 .then(() => {
382 // Process remaining segments hash 382 // Process remaining segments hash
383 for (const key of Object.keys(segmentsToProcessPerPlaylist)) { 383 for (const key of Object.keys(segmentsToProcessPerPlaylist)) {
384 processSegments(segmentsToProcessPerPlaylist[key]) 384 processSegments(segmentsToProcessPerPlaylist[key])
385 } 385 }
386 }) 386 })
387 .catch(err => logger.error('Cannot close watchers of %s or process remaining hash segments.', outPath, { err })) 387 .catch(err => logger.error('Cannot close watchers of %s or process remaining hash segments.', outPath, { err }))
388 388
389 this.onEndTransmuxing(videoLive.Video.id) 389 this.onEndTransmuxing(videoLive.Video.id)
390 .catch(err => logger.error('Error in closed transmuxing.', { err })) 390 .catch(err => logger.error('Error in closed transmuxing.', { err }))