gramps
5066d81aab
Slice 2 of TASK 65. 602 green, 0 warnings. **Clips are still off**: no `ClipBuffer` is passed, so the ffmpeg command line is byte-for-byte what it was before this commit, and a test asserts exactly that (the original args are a strict prefix of the new ones). - `FfmpegArgs` appends a fragmented-MP4 output to `pipe:1` only when `ClipBuffer` is set. One-second fragments (`-frag_duration 1000000`) rather than the 4 s GOP, so a clip can start inside the window instead of at the last keyframe. Stats already own stderr, so stdout was free. - `Fmp4FragmentSplitter` turns that byte stream into whole fragments: `ftyp`+`moov` is the init segment, each `moof`+`mdat` is a fragment. It parses box headers itself, survives a box being cut anywhere across reads, and **resyncs instead of throwing** — a clip fault must never take the stream down. - `FfmpegEncoder` reads it on its own task, never blocking the frame path. Any exception logs and disables clips for the session; the broadcast is untouched. - `IEncoderProcess` gained `StandardOutputBytes` (the seam already had the text reader for probing). Next slices: the replay layer + retention, then the Settings switch with disabled-but-remembered controls.
41 lines
1.3 KiB
C#
41 lines
1.3 KiB
C#
using System.Diagnostics;
|
|
using System.IO;
|
|
|
|
namespace ytLive.Services.Encoder;
|
|
|
|
/// <summary>
|
|
/// The real <see cref="IEncoderProcess"/>: a <see cref="Process"/> with all three
|
|
/// std streams redirected. Constructed by <see cref="FfmpegEncoder"/> for both the
|
|
/// encoder subprocess and the <c>-encoders</c> probe.
|
|
/// </summary>
|
|
public sealed class FfmpegEncoderProcess : IEncoderProcess
|
|
{
|
|
private readonly Process _process;
|
|
|
|
public FfmpegEncoderProcess() => _process = new Process { EnableRaisingEvents = true };
|
|
|
|
public void Start(ProcessStartInfo startInfo)
|
|
{
|
|
_process.StartInfo = startInfo;
|
|
_process.Start();
|
|
}
|
|
|
|
public Stream StandardInput => _process.StandardInput.BaseStream;
|
|
|
|
public Stream StandardOutputBytes => _process.StandardOutput.BaseStream;
|
|
public TextReader StandardOutput => _process.StandardOutput;
|
|
public TextReader StandardError => _process.StandardError;
|
|
|
|
public bool HasExited => _process.HasExited;
|
|
public int ExitCode => _process.ExitCode;
|
|
public void Kill()
|
|
{
|
|
if (!_process.HasExited) _process.Kill();
|
|
}
|
|
|
|
public Task WaitForExitAsync(CancellationToken cancellationToken = default)
|
|
=> _process.WaitForExitAsync(cancellationToken);
|
|
|
|
public void Dispose() => _process.Dispose();
|
|
}
|