devilreef/denpa-radio
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(streamer): handle stdin EPIPE on ffmpeg exit, raise queue size, color_range tv

Browse source
This commit is contained in:
devilreef 2026-04-30 19:28:10 +06:00
parent a83d063814
commit 2cd7cd3eab
Signed by: devilreef
SSH key fingerprint: SHA256:UZisRr4iuXx+IhkbZnR655L2RWAT6o2rgbGv5F/6m3Y
1 changed files with 12 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

15
streamer/src/ffmpeg.ts
View file

@ -19,14 +19,17 @@ export class Ffmpeg extends EventEmitter {
start(): { videoIn: Writable; audioIn: Writable } { start(): { videoIn: Writable; audioIn: Writable } {
const args = [ const args = [
"-loglevel", "warning", "-loglevel", "warning",
// video in (mjpeg pipe on fd 3) // video in (mjpeg pipe on fd 3) — yuvj420p source, large queue for stable pacing
"-f", "image2pipe", "-c:v", "mjpeg", "-f", "image2pipe", "-c:v", "mjpeg",
"-thread_queue_size", "1024",
"-r", String(this.opts.framerate), "-i", "pipe:3", "-r", String(this.opts.framerate), "-i", "pipe:3",
// audio in (s16le pcm pipe on fd 4) // audio in (s16le pcm pipe on fd 4)
"-f", "s16le", "-ar", "48000", "-ac", "2", "-i", "pipe:4", "-f", "s16le", "-ar", "48000", "-ac", "2",
"-thread_queue_size", "1024",
"-i", "pipe:4",
// video encode // video encode
"-c:v", "libx264", "-preset", "veryfast", "-c:v", "libx264", "-preset", "veryfast",
"-pix_fmt", "yuv420p", "-pix_fmt", "yuv420p", "-color_range", "tv",
"-b:v", this.opts.videoBitrate, "-b:v", this.opts.videoBitrate,
"-maxrate", this.opts.videoBitrate, "-bufsize", "9000k", "-maxrate", this.opts.videoBitrate, "-bufsize", "9000k",
"-g", String(this.opts.framerate * 2), "-keyint_min", String(this.opts.framerate * 2), "-g", String(this.opts.framerate * 2), "-keyint_min", String(this.opts.framerate * 2),
@ -48,6 +51,12 @@ export class Ffmpeg extends EventEmitter {
this.proc.stderr.on("data", (d) => this.emit("log", d.toString())); this.proc.stderr.on("data", (d) => this.emit("log", d.toString()));
this.proc.on("exit", (code) => this.emit("exit", code)); this.proc.on("exit", (code) => this.emit("exit", code));
// ffmpeg exiting (e.g. RTMP drop) closes its stdins — subsequent writes
// emit EPIPE on these sockets, which would crash the supervisor as
// unhandled. Catch them; the proc.on("exit") handler does the actual restart.
videoIn.on("error", (err) => this.emit("log", `videoIn: ${err.message}`));
audioIn.on("error", (err) => this.emit("log", `audioIn: ${err.message}`));
return { videoIn, audioIn }; return { videoIn, audioIn };
} }