aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/lib/live/shared/muxing-session.ts
diff options
context:
space:
mode:
Diffstat (limited to 'server/lib/live/shared/muxing-session.ts')
-rw-r--r--server/lib/live/shared/muxing-session.ts20
1 files changed, 15 insertions, 5 deletions
diff --git a/server/lib/live/shared/muxing-session.ts b/server/lib/live/shared/muxing-session.ts
index 57e28aabf..6632499ff 100644
--- a/server/lib/live/shared/muxing-session.ts
+++ b/server/lib/live/shared/muxing-session.ts
@@ -62,7 +62,10 @@ class MuxingSession extends EventEmitter {
62 private readonly user: MUserId 62 private readonly user: MUserId
63 private readonly sessionId: string 63 private readonly sessionId: string
64 private readonly videoLive: MVideoLiveVideo 64 private readonly videoLive: MVideoLiveVideo
65 private readonly inputUrl: string 65
66 private readonly inputLocalUrl: string
67 private readonly inputPublicUrl: string
68
66 private readonly fps: number 69 private readonly fps: number
67 private readonly allResolutions: number[] 70 private readonly allResolutions: number[]
68 71
@@ -107,7 +110,10 @@ class MuxingSession extends EventEmitter {
107 user: MUserId 110 user: MUserId
108 sessionId: string 111 sessionId: string
109 videoLive: MVideoLiveVideo 112 videoLive: MVideoLiveVideo
110 inputUrl: string 113
114 inputLocalUrl: string
115 inputPublicUrl: string
116
111 fps: number 117 fps: number
112 bitrate: number 118 bitrate: number
113 ratio: number 119 ratio: number
@@ -120,7 +126,10 @@ class MuxingSession extends EventEmitter {
120 this.user = options.user 126 this.user = options.user
121 this.sessionId = options.sessionId 127 this.sessionId = options.sessionId
122 this.videoLive = options.videoLive 128 this.videoLive = options.videoLive
123 this.inputUrl = options.inputUrl 129
130 this.inputLocalUrl = options.inputLocalUrl
131 this.inputPublicUrl = options.inputPublicUrl
132
124 this.fps = options.fps 133 this.fps = options.fps
125 134
126 this.bitrate = options.bitrate 135 this.bitrate = options.bitrate
@@ -375,7 +384,7 @@ class MuxingSession extends EventEmitter {
375 private onTranscodedEnded () { 384 private onTranscodedEnded () {
376 this.emit('transcoding-end', ({ videoUUID: this.videoUUID })) 385 this.emit('transcoding-end', ({ videoUUID: this.videoUUID }))
377 386
378 logger.info('RTMP transmuxing for video %s ended. Scheduling cleanup', this.inputUrl, this.lTags()) 387 logger.info('RTMP transmuxing for video %s ended. Scheduling cleanup', this.inputLocalUrl, this.lTags())
379 388
380 setTimeout(() => { 389 setTimeout(() => {
381 // Wait latest segments generation, and close watchers 390 // Wait latest segments generation, and close watchers
@@ -468,7 +477,8 @@ class MuxingSession extends EventEmitter {
468 477
469 lTags: this.lTags, 478 lTags: this.lTags,
470 479
471 inputUrl: this.inputUrl, 480 inputLocalUrl: this.inputLocalUrl,
481 inputPublicUrl: this.inputPublicUrl,
472 482
473 toTranscode: this.allResolutions.map(resolution => ({ 483 toTranscode: this.allResolutions.map(resolution => ({
474 resolution, 484 resolution,