jellyfin/Emby.Server.Implementations/LiveTv/EmbyTV/EncodedRecorder.cs

382 lines
14 KiB
C#
Raw Normal View History

using System;
2016-02-12 07:01:38 +00:00
using System.Collections.Generic;
using System.Globalization;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using MediaBrowser.Common.Configuration;
using MediaBrowser.Controller;
2017-04-21 20:03:07 +00:00
using MediaBrowser.Controller.Configuration;
using MediaBrowser.Controller.Library;
2016-02-12 07:01:38 +00:00
using MediaBrowser.Controller.MediaEncoding;
2017-04-21 20:03:07 +00:00
using MediaBrowser.Model.Configuration;
2016-11-03 23:35:19 +00:00
using MediaBrowser.Model.Diagnostics;
2016-02-12 07:01:38 +00:00
using MediaBrowser.Model.Dto;
using MediaBrowser.Model.Entities;
using MediaBrowser.Model.IO;
using MediaBrowser.Model.Serialization;
using Microsoft.Extensions.Logging;
2016-02-12 07:01:38 +00:00
2016-11-03 23:35:19 +00:00
namespace Emby.Server.Implementations.LiveTv.EmbyTV
2016-02-12 07:01:38 +00:00
{
public class EncodedRecorder : IRecorder
{
private readonly ILogger _logger;
private readonly IFileSystem _fileSystem;
private readonly IMediaEncoder _mediaEncoder;
private readonly IServerApplicationPaths _appPaths;
2016-02-12 07:01:38 +00:00
private bool _hasExited;
2016-11-30 19:50:39 +00:00
private Stream _logFileStream;
2016-02-12 07:01:38 +00:00
private string _targetPath;
2016-11-03 23:35:19 +00:00
private IProcess _process;
private readonly IProcessFactory _processFactory;
2016-02-12 07:01:38 +00:00
private readonly IJsonSerializer _json;
2016-03-07 04:56:45 +00:00
private readonly TaskCompletionSource<bool> _taskCompletionSource = new TaskCompletionSource<bool>();
2017-04-21 20:03:07 +00:00
private readonly IServerConfigurationManager _config;
2016-02-12 07:01:38 +00:00
2019-02-06 19:38:42 +00:00
public EncodedRecorder(
ILogger logger,
IFileSystem fileSystem,
IMediaEncoder mediaEncoder,
IServerApplicationPaths appPaths,
IJsonSerializer json,
IProcessFactory processFactory,
IServerConfigurationManager config)
2016-02-12 07:01:38 +00:00
{
_logger = logger;
_fileSystem = fileSystem;
_mediaEncoder = mediaEncoder;
_appPaths = appPaths;
_json = json;
2016-11-03 23:35:19 +00:00
_processFactory = processFactory;
2017-04-21 20:03:07 +00:00
_config = config;
2016-09-08 06:41:49 +00:00
}
private static bool CopySubtitles => false;
2017-02-21 18:04:35 +00:00
2016-05-10 05:15:06 +00:00
public string GetOutputPath(MediaSourceInfo mediaSource, string targetFile)
{
2018-09-12 17:26:21 +00:00
return Path.ChangeExtension(targetFile, ".ts");
2016-05-10 05:15:06 +00:00
}
2017-05-15 19:45:39 +00:00
public async Task Record(IDirectStreamProvider directStreamProvider, MediaSourceInfo mediaSource, string targetFile, TimeSpan duration, Action onStarted, CancellationToken cancellationToken)
2016-02-12 07:01:38 +00:00
{
2018-09-12 17:26:21 +00:00
// The media source is infinite so we need to handle stopping ourselves
var durationToken = new CancellationTokenSource(duration);
cancellationToken = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken, durationToken.Token).Token;
2016-09-05 20:07:36 +00:00
2016-09-29 12:55:49 +00:00
await RecordFromFile(mediaSource, mediaSource.Path, targetFile, duration, onStarted, cancellationToken).ConfigureAwait(false);
_logger.LogInformation("Recording completed to file {0}", targetFile);
}
2017-04-21 20:03:07 +00:00
private EncodingOptions GetEncodingOptions()
{
return _config.GetConfiguration<EncodingOptions>("encoding");
}
2016-09-29 12:55:49 +00:00
private Task RecordFromFile(MediaSourceInfo mediaSource, string inputFile, string targetFile, TimeSpan duration, Action onStarted, CancellationToken cancellationToken)
{
2016-02-12 07:01:38 +00:00
_targetPath = targetFile;
Directory.CreateDirectory(Path.GetDirectoryName(targetFile));
2016-02-12 07:01:38 +00:00
2016-11-03 23:35:19 +00:00
var process = _processFactory.Create(new ProcessOptions
2016-02-12 07:01:38 +00:00
{
2016-11-03 23:35:19 +00:00
CreateNoWindow = true,
2016-11-30 19:50:39 +00:00
UseShellExecute = false,
2016-02-12 07:01:38 +00:00
2016-11-03 23:35:19 +00:00
// Must consume both stdout and stderr or deadlocks may occur
//RedirectStandardOutput = true,
2016-11-30 19:50:39 +00:00
RedirectStandardError = true,
RedirectStandardInput = true,
2016-02-12 07:01:38 +00:00
2016-11-03 23:35:19 +00:00
FileName = _mediaEncoder.EncoderPath,
Arguments = GetCommandLineArgs(mediaSource, inputFile, targetFile, duration),
2016-02-12 07:01:38 +00:00
2016-11-03 23:35:19 +00:00
IsHidden = true,
ErrorDialog = false,
2016-11-30 19:50:39 +00:00
EnableRaisingEvents = true
2016-11-03 23:35:19 +00:00
});
2016-02-12 07:01:38 +00:00
_process = process;
var commandLineLogMessage = process.StartInfo.FileName + " " + process.StartInfo.Arguments;
_logger.LogInformation(commandLineLogMessage);
2016-02-12 07:01:38 +00:00
2016-11-30 19:50:39 +00:00
var logFilePath = Path.Combine(_appPaths.LogDirectoryPath, "record-transcode-" + Guid.NewGuid() + ".txt");
Directory.CreateDirectory(Path.GetDirectoryName(logFilePath));
2016-02-12 07:01:38 +00:00
2016-11-30 19:50:39 +00:00
// FFMpeg writes debug/error info to stderr. This is useful when debugging so let's put it in the log directory.
_logFileStream = _fileSystem.GetFileStream(logFilePath, FileOpenMode.Create, FileAccessMode.Write, FileShareMode.Read, true);
var commandLineLogMessageBytes = Encoding.UTF8.GetBytes(_json.SerializeToString(mediaSource) + Environment.NewLine + Environment.NewLine + commandLineLogMessage + Environment.NewLine + Environment.NewLine);
_logFileStream.Write(commandLineLogMessageBytes, 0, commandLineLogMessageBytes.Length);
2016-02-12 07:01:38 +00:00
2016-09-29 12:55:49 +00:00
process.Exited += (sender, args) => OnFfMpegProcessExited(process, inputFile);
2016-02-12 07:01:38 +00:00
process.Start();
cancellationToken.Register(Stop);
// MUST read both stdout and stderr asynchronously or a deadlock may occurr
2016-07-02 02:16:05 +00:00
//process.BeginOutputReadLine();
2016-02-12 07:01:38 +00:00
2016-02-29 16:25:21 +00:00
onStarted();
2016-11-30 19:50:39 +00:00
// Important - don't await the log task or we won't be able to kill ffmpeg when the user stops playback
StartStreamingLog(process.StandardError.BaseStream, _logFileStream);
_logger.LogInformation("ffmpeg recording process started for {0}", _targetPath);
2016-09-30 18:43:59 +00:00
2016-06-22 04:40:11 +00:00
return _taskCompletionSource.Task;
2016-02-12 07:01:38 +00:00
}
2016-06-22 04:40:11 +00:00
private string GetCommandLineArgs(MediaSourceInfo mediaSource, string inputTempFile, string targetFile, TimeSpan duration)
2016-02-12 07:01:38 +00:00
{
string videoArgs;
if (EncodeVideo(mediaSource))
{
var maxBitrate = 25000000;
videoArgs = string.Format(
2016-09-30 18:43:59 +00:00
"-codec:v:0 libx264 -force_key_frames \"expr:gte(t,n_forced*5)\" {0} -pix_fmt yuv420p -preset superfast -crf 23 -b:v {1} -maxrate {1} -bufsize ({1}*2) -vsync -1 -profile:v high -level 41",
2016-02-12 07:01:38 +00:00
GetOutputSizeParam(),
maxBitrate.ToString(CultureInfo.InvariantCulture));
}
else
{
videoArgs = "-codec:v:0 copy";
}
2017-05-15 19:45:39 +00:00
videoArgs += " -fflags +genpts";
2016-06-22 04:40:11 +00:00
var durationParam = " -t " + _mediaEncoder.GetTimeParameter(duration.Ticks);
2018-09-12 17:26:21 +00:00
durationParam = string.Empty;
2017-04-21 20:03:07 +00:00
2017-05-02 12:53:21 +00:00
var flags = new List<string>();
if (mediaSource.IgnoreDts)
2017-04-21 20:03:07 +00:00
{
2017-05-02 12:53:21 +00:00
flags.Add("+igndts");
}
if (mediaSource.IgnoreIndex)
{
flags.Add("+ignidx");
2017-04-21 20:03:07 +00:00
}
2017-05-15 19:45:39 +00:00
if (mediaSource.GenPtsInput)
{
flags.Add("+genpts");
}
2017-04-21 20:03:07 +00:00
2017-05-21 07:25:49 +00:00
var inputModifier = "-async 1 -vsync -1";
2016-09-30 06:50:06 +00:00
2017-05-02 12:53:21 +00:00
if (flags.Count > 0)
{
2017-05-21 07:25:49 +00:00
inputModifier += " -fflags " + string.Join("", flags.ToArray());
2017-05-02 12:53:21 +00:00
}
2016-02-12 07:01:38 +00:00
2017-08-11 21:55:48 +00:00
var videoStream = mediaSource.VideoStream;
2016-09-30 06:50:06 +00:00
2017-05-02 12:53:21 +00:00
if (mediaSource.ReadAtNativeFramerate)
2016-09-30 06:50:06 +00:00
{
2017-05-21 07:25:49 +00:00
inputModifier += " -re";
}
if (mediaSource.RequiresLooping)
{
2018-09-12 17:26:21 +00:00
inputModifier += " -stream_loop -1 -reconnect_at_eof 1 -reconnect_streamed 1 -reconnect_delay_max 2";
2016-02-12 07:01:38 +00:00
}
2016-11-09 17:25:33 +00:00
var analyzeDurationSeconds = 5;
var analyzeDuration = " -analyzeduration " +
(analyzeDurationSeconds * 1000000).ToString(CultureInfo.InvariantCulture);
2017-05-21 07:25:49 +00:00
inputModifier += analyzeDuration;
2016-11-09 17:25:33 +00:00
2017-02-21 18:04:35 +00:00
var subtitleArgs = CopySubtitles ? " -codec:s copy" : " -sn";
//var outputParam = string.Equals(Path.GetExtension(targetFile), ".mp4", StringComparison.OrdinalIgnoreCase) ?
// " -f mp4 -movflags frag_keyframe+empty_moov" :
// string.Empty;
var outputParam = string.Empty;
2017-03-26 04:22:30 +00:00
2019-01-07 23:27:46 +00:00
var commandLineArgs = string.Format("-i \"{0}\"{5} {2} -map_metadata -1 -threads 0 {3}{4}{6} -y \"{1}\"",
inputTempFile,
targetFile,
videoArgs,
GetAudioArgs(mediaSource),
subtitleArgs,
durationParam,
2017-05-02 12:53:21 +00:00
outputParam);
2016-02-12 07:01:38 +00:00
2017-05-21 07:25:49 +00:00
return inputModifier + " " + commandLineArgs;
2016-02-12 07:01:38 +00:00
}
private static string GetAudioArgs(MediaSourceInfo mediaSource)
2016-02-12 07:01:38 +00:00
{
var mediaStreams = mediaSource.MediaStreams ?? new List<MediaStream>();
2016-06-15 18:56:37 +00:00
var inputAudioCodec = mediaStreams.Where(i => i.Type == MediaStreamType.Audio).Select(i => i.Codec).FirstOrDefault() ?? string.Empty;
2018-09-12 17:26:21 +00:00
return "-codec:a:0 copy";
2016-02-12 07:01:38 +00:00
2018-09-12 17:26:21 +00:00
//var audioChannels = 2;
//var audioStream = mediaStreams.FirstOrDefault(i => i.Type == MediaStreamType.Audio);
//if (audioStream != null)
//{
// audioChannels = audioStream.Channels ?? audioChannels;
//}
//return "-codec:a:0 aac -strict experimental -ab 320000";
2016-02-12 07:01:38 +00:00
}
private static bool EncodeVideo(MediaSourceInfo mediaSource)
2016-02-12 07:01:38 +00:00
{
2018-09-12 17:26:21 +00:00
return false;
2016-02-12 07:01:38 +00:00
}
protected string GetOutputSizeParam()
{
var filters = new List<string>();
2018-09-12 17:26:21 +00:00
filters.Add("yadif=0:-1:0");
2016-02-12 07:01:38 +00:00
var output = string.Empty;
if (filters.Count > 0)
{
output += string.Format(" -vf \"{0}\"", string.Join(",", filters.ToArray()));
}
return output;
}
private void Stop()
{
if (!_hasExited)
{
try
{
2018-12-20 12:11:26 +00:00
_logger.LogInformation("Stopping ffmpeg recording process for {path}", _targetPath);
2016-02-12 07:01:38 +00:00
2016-11-30 19:50:39 +00:00
//process.Kill();
_process.StandardInput.WriteLine("q");
2016-02-12 07:01:38 +00:00
}
catch (Exception ex)
{
2018-12-20 12:11:26 +00:00
_logger.LogError(ex, "Error stopping recording transcoding job for {path}", _targetPath);
2017-01-20 17:53:48 +00:00
}
if (_hasExited)
{
return;
}
try
{
2018-12-20 12:11:26 +00:00
_logger.LogInformation("Calling recording process.WaitForExit for {path}", _targetPath);
2017-01-20 17:53:48 +00:00
2017-02-17 21:11:13 +00:00
if (_process.WaitForExit(10000))
2017-01-20 17:53:48 +00:00
{
return;
}
}
catch (Exception ex)
{
2018-12-20 12:11:26 +00:00
_logger.LogError(ex, "Error waiting for recording process to exit for {path}", _targetPath);
2017-01-20 17:53:48 +00:00
}
if (_hasExited)
{
return;
}
try
{
2018-12-20 12:11:26 +00:00
_logger.LogInformation("Killing ffmpeg recording process for {path}", _targetPath);
2017-01-20 17:53:48 +00:00
_process.Kill();
}
catch (Exception ex)
{
2018-12-20 12:11:26 +00:00
_logger.LogError(ex, "Error killing recording transcoding job for {path}", _targetPath);
2016-02-12 07:01:38 +00:00
}
}
}
/// <summary>
/// Processes the exited.
/// </summary>
2016-11-03 23:35:19 +00:00
private void OnFfMpegProcessExited(IProcess process, string inputFile)
2016-02-12 07:01:38 +00:00
{
_hasExited = true;
2016-11-30 19:50:39 +00:00
DisposeLogStream();
2016-02-12 07:01:38 +00:00
try
{
2016-11-30 19:50:39 +00:00
var exitCode = process.ExitCode;
2016-03-07 04:56:45 +00:00
2018-12-20 12:11:26 +00:00
_logger.LogInformation("FFMpeg recording exited with code {ExitCode} for {path}", exitCode, _targetPath);
2016-03-07 04:56:45 +00:00
if (exitCode == 0)
{
_taskCompletionSource.TrySetResult(true);
}
else
{
2018-12-20 12:11:26 +00:00
_taskCompletionSource.TrySetException(new Exception(string.Format("Recording for {path} failed. Exit code {ExitCode}", _targetPath, exitCode)));
2016-03-07 04:56:45 +00:00
}
2016-02-12 07:01:38 +00:00
}
catch
{
2018-12-20 12:11:26 +00:00
_logger.LogError("FFMpeg recording exited with an error for {path}.", _targetPath);
_taskCompletionSource.TrySetException(new Exception(string.Format("Recording for {path} failed", _targetPath)));
2016-02-12 07:01:38 +00:00
}
}
2016-11-30 19:50:39 +00:00
private void DisposeLogStream()
{
if (_logFileStream != null)
{
try
{
_logFileStream.Dispose();
}
catch (Exception ex)
{
2018-12-20 12:11:26 +00:00
_logger.LogError(ex, "Error disposing recording log stream");
2016-11-30 19:50:39 +00:00
}
_logFileStream = null;
}
}
private async void StartStreamingLog(Stream source, Stream target)
{
try
{
using (var reader = new StreamReader(source))
{
while (!reader.EndOfStream)
{
var line = await reader.ReadLineAsync().ConfigureAwait(false);
var bytes = Encoding.UTF8.GetBytes(Environment.NewLine + line);
await target.WriteAsync(bytes, 0, bytes.Length).ConfigureAwait(false);
await target.FlushAsync().ConfigureAwait(false);
}
}
}
catch (ObjectDisposedException)
{
// TODO Investigate and properly fix.
2016-11-30 19:50:39 +00:00
// Don't spam the log. This doesn't seem to throw in windows, but sometimes under linux
}
catch (Exception ex)
{
2018-12-20 12:11:26 +00:00
_logger.LogError(ex, "Error reading ffmpeg recording log");
2016-11-30 19:50:39 +00:00
}
}
2016-02-12 07:01:38 +00:00
}
}