diff options
Diffstat (limited to 'server/lib/live/shared/muxing-session.ts')
-rw-r--r-- | server/lib/live/shared/muxing-session.ts | 20 |
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, |