EncodingJobFactory.cs 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793
  1. using MediaBrowser.Controller.Channels;
  2. using MediaBrowser.Controller.Entities;
  3. using MediaBrowser.Controller.Library;
  4. using MediaBrowser.Controller.LiveTv;
  5. using MediaBrowser.Controller.MediaEncoding;
  6. using MediaBrowser.Model.Dlna;
  7. using MediaBrowser.Model.Entities;
  8. using MediaBrowser.Model.Logging;
  9. using MediaBrowser.Model.MediaInfo;
  10. using System;
  11. using System.Collections.Generic;
  12. using System.Globalization;
  13. using System.Linq;
  14. using System.Threading;
  15. using System.Threading.Tasks;
  16. namespace MediaBrowser.MediaEncoding.Encoder
  17. {
  18. public class EncodingJobFactory
  19. {
  20. private readonly ILogger _logger;
  21. private readonly ILiveTvManager _liveTvManager;
  22. private readonly ILibraryManager _libraryManager;
  23. private readonly IChannelManager _channelManager;
  24. private readonly IMediaSourceManager _mediaSourceManager;
  25. protected static readonly CultureInfo UsCulture = new CultureInfo("en-US");
  26. public EncodingJobFactory(ILogger logger, ILiveTvManager liveTvManager, ILibraryManager libraryManager, IChannelManager channelManager, IMediaSourceManager mediaSourceManager)
  27. {
  28. _logger = logger;
  29. _liveTvManager = liveTvManager;
  30. _libraryManager = libraryManager;
  31. _channelManager = channelManager;
  32. _mediaSourceManager = mediaSourceManager;
  33. }
  34. public async Task<EncodingJob> CreateJob(EncodingJobOptions options, bool isVideoRequest, IProgress<double> progress, CancellationToken cancellationToken)
  35. {
  36. var request = options;
  37. if (string.IsNullOrEmpty(request.AudioCodec))
  38. {
  39. request.AudioCodec = InferAudioCodec(request.OutputContainer);
  40. }
  41. var state = new EncodingJob(_logger, _liveTvManager)
  42. {
  43. Options = options,
  44. IsVideoRequest = isVideoRequest,
  45. Progress = progress
  46. };
  47. if (!string.IsNullOrWhiteSpace(request.AudioCodec))
  48. {
  49. state.SupportedAudioCodecs = request.AudioCodec.Split(',').Where(i => !string.IsNullOrWhiteSpace(i)).ToList();
  50. request.AudioCodec = state.SupportedAudioCodecs.FirstOrDefault();
  51. }
  52. var item = _libraryManager.GetItemById(request.ItemId);
  53. List<MediaStream> mediaStreams = null;
  54. state.ItemType = item.GetType().Name;
  55. if (item is ILiveTvRecording)
  56. {
  57. var recording = await _liveTvManager.GetInternalRecording(request.ItemId, cancellationToken).ConfigureAwait(false);
  58. state.VideoType = VideoType.VideoFile;
  59. state.IsInputVideo = string.Equals(recording.MediaType, MediaType.Video, StringComparison.OrdinalIgnoreCase);
  60. var path = recording.RecordingInfo.Path;
  61. var mediaUrl = recording.RecordingInfo.Url;
  62. var source = string.IsNullOrEmpty(request.MediaSourceId)
  63. ? recording.GetMediaSources(false).First()
  64. : _mediaSourceManager.GetStaticMediaSource(recording, request.MediaSourceId, false);
  65. mediaStreams = source.MediaStreams;
  66. // Just to prevent this from being null and causing other methods to fail
  67. state.MediaPath = string.Empty;
  68. if (!string.IsNullOrEmpty(path))
  69. {
  70. state.MediaPath = path;
  71. state.InputProtocol = MediaProtocol.File;
  72. }
  73. else if (!string.IsNullOrEmpty(mediaUrl))
  74. {
  75. state.MediaPath = mediaUrl;
  76. state.InputProtocol = MediaProtocol.Http;
  77. }
  78. state.RunTimeTicks = recording.RunTimeTicks;
  79. state.DeInterlace = true;
  80. state.OutputAudioSync = "1000";
  81. state.InputVideoSync = "-1";
  82. state.InputAudioSync = "1";
  83. state.InputContainer = recording.Container;
  84. state.ReadInputAtNativeFramerate = source.ReadAtNativeFramerate;
  85. }
  86. else if (item is LiveTvChannel)
  87. {
  88. var channel = _liveTvManager.GetInternalChannel(request.ItemId);
  89. state.VideoType = VideoType.VideoFile;
  90. state.IsInputVideo = string.Equals(channel.MediaType, MediaType.Video, StringComparison.OrdinalIgnoreCase);
  91. mediaStreams = new List<MediaStream>();
  92. state.DeInterlace = true;
  93. // Just to prevent this from being null and causing other methods to fail
  94. state.MediaPath = string.Empty;
  95. }
  96. else
  97. {
  98. var mediaSources = await _mediaSourceManager.GetPlayackMediaSources(request.ItemId, false, cancellationToken).ConfigureAwait(false);
  99. var mediaSource = string.IsNullOrEmpty(request.MediaSourceId)
  100. ? mediaSources.First()
  101. : mediaSources.First(i => string.Equals(i.Id, request.MediaSourceId));
  102. mediaStreams = mediaSource.MediaStreams;
  103. state.MediaPath = mediaSource.Path;
  104. state.InputProtocol = mediaSource.Protocol;
  105. state.InputContainer = mediaSource.Container;
  106. state.InputFileSize = mediaSource.Size;
  107. state.InputBitrate = mediaSource.Bitrate;
  108. state.ReadInputAtNativeFramerate = mediaSource.ReadAtNativeFramerate;
  109. state.RunTimeTicks = mediaSource.RunTimeTicks;
  110. state.RemoteHttpHeaders = mediaSource.RequiredHttpHeaders;
  111. var video = item as Video;
  112. if (video != null)
  113. {
  114. state.IsInputVideo = true;
  115. if (mediaSource.VideoType.HasValue)
  116. {
  117. state.VideoType = mediaSource.VideoType.Value;
  118. }
  119. state.IsoType = mediaSource.IsoType;
  120. state.PlayableStreamFileNames = mediaSource.PlayableStreamFileNames.ToList();
  121. if (mediaSource.Timestamp.HasValue)
  122. {
  123. state.InputTimestamp = mediaSource.Timestamp.Value;
  124. }
  125. }
  126. state.RunTimeTicks = mediaSource.RunTimeTicks;
  127. }
  128. AttachMediaStreamInfo(state, mediaStreams, request);
  129. state.OutputAudioBitrate = GetAudioBitrateParam(request, state.AudioStream);
  130. state.OutputAudioSampleRate = request.AudioSampleRate;
  131. state.OutputAudioCodec = GetAudioCodec(request);
  132. state.OutputAudioChannels = GetNumAudioChannelsParam(request, state.AudioStream, state.OutputAudioCodec);
  133. if (isVideoRequest)
  134. {
  135. state.OutputVideoCodec = GetVideoCodec(request);
  136. state.OutputVideoBitrate = GetVideoBitrateParamValue(request, state.VideoStream);
  137. if (state.OutputVideoBitrate.HasValue)
  138. {
  139. var resolution = ResolutionNormalizer.Normalize(state.OutputVideoBitrate.Value,
  140. state.OutputVideoCodec,
  141. request.MaxWidth,
  142. request.MaxHeight);
  143. request.MaxWidth = resolution.MaxWidth;
  144. request.MaxHeight = resolution.MaxHeight;
  145. }
  146. }
  147. ApplyDeviceProfileSettings(state);
  148. if (isVideoRequest)
  149. {
  150. if (state.VideoStream != null && CanStreamCopyVideo(request, state.VideoStream))
  151. {
  152. state.OutputVideoCodec = "copy";
  153. }
  154. if (state.AudioStream != null && CanStreamCopyAudio(request, state.AudioStream, state.SupportedAudioCodecs))
  155. {
  156. state.OutputAudioCodec = "copy";
  157. }
  158. }
  159. return state;
  160. }
  161. internal static void AttachMediaStreamInfo(EncodingJob state,
  162. List<MediaStream> mediaStreams,
  163. EncodingJobOptions videoRequest)
  164. {
  165. if (videoRequest != null)
  166. {
  167. if (string.IsNullOrEmpty(videoRequest.VideoCodec))
  168. {
  169. videoRequest.VideoCodec = InferVideoCodec(videoRequest.OutputContainer);
  170. }
  171. state.VideoStream = GetMediaStream(mediaStreams, videoRequest.VideoStreamIndex, MediaStreamType.Video);
  172. state.SubtitleStream = GetMediaStream(mediaStreams, videoRequest.SubtitleStreamIndex, MediaStreamType.Subtitle, false);
  173. state.AudioStream = GetMediaStream(mediaStreams, videoRequest.AudioStreamIndex, MediaStreamType.Audio);
  174. if (state.SubtitleStream != null && !state.SubtitleStream.IsExternal)
  175. {
  176. state.InternalSubtitleStreamOffset = mediaStreams.Where(i => i.Type == MediaStreamType.Subtitle && !i.IsExternal).ToList().IndexOf(state.SubtitleStream);
  177. }
  178. if (state.VideoStream != null && state.VideoStream.IsInterlaced)
  179. {
  180. state.DeInterlace = true;
  181. }
  182. EnforceResolutionLimit(state, videoRequest);
  183. }
  184. else
  185. {
  186. state.AudioStream = GetMediaStream(mediaStreams, null, MediaStreamType.Audio, true);
  187. }
  188. state.AllMediaStreams = mediaStreams;
  189. }
  190. /// <summary>
  191. /// Infers the video codec.
  192. /// </summary>
  193. /// <param name="container">The container.</param>
  194. /// <returns>System.Nullable{VideoCodecs}.</returns>
  195. private static string InferVideoCodec(string container)
  196. {
  197. if (string.Equals(container, "asf", StringComparison.OrdinalIgnoreCase))
  198. {
  199. return "wmv";
  200. }
  201. if (string.Equals(container, "webm", StringComparison.OrdinalIgnoreCase))
  202. {
  203. return "vpx";
  204. }
  205. if (string.Equals(container, "ogg", StringComparison.OrdinalIgnoreCase) || string.Equals(container, "ogv", StringComparison.OrdinalIgnoreCase))
  206. {
  207. return "theora";
  208. }
  209. if (string.Equals(container, "m3u8", StringComparison.OrdinalIgnoreCase) || string.Equals(container, "ts", StringComparison.OrdinalIgnoreCase))
  210. {
  211. return "h264";
  212. }
  213. return "copy";
  214. }
  215. private string InferAudioCodec(string container)
  216. {
  217. if (string.Equals(container, "mp3", StringComparison.OrdinalIgnoreCase))
  218. {
  219. return "mp3";
  220. }
  221. if (string.Equals(container, "aac", StringComparison.OrdinalIgnoreCase))
  222. {
  223. return "aac";
  224. }
  225. if (string.Equals(container, "wma", StringComparison.OrdinalIgnoreCase))
  226. {
  227. return "wma";
  228. }
  229. if (string.Equals(container, "ogg", StringComparison.OrdinalIgnoreCase))
  230. {
  231. return "vorbis";
  232. }
  233. if (string.Equals(container, "oga", StringComparison.OrdinalIgnoreCase))
  234. {
  235. return "vorbis";
  236. }
  237. if (string.Equals(container, "ogv", StringComparison.OrdinalIgnoreCase))
  238. {
  239. return "vorbis";
  240. }
  241. if (string.Equals(container, "webm", StringComparison.OrdinalIgnoreCase))
  242. {
  243. return "vorbis";
  244. }
  245. if (string.Equals(container, "webma", StringComparison.OrdinalIgnoreCase))
  246. {
  247. return "vorbis";
  248. }
  249. return "copy";
  250. }
  251. /// <summary>
  252. /// Determines which stream will be used for playback
  253. /// </summary>
  254. /// <param name="allStream">All stream.</param>
  255. /// <param name="desiredIndex">Index of the desired.</param>
  256. /// <param name="type">The type.</param>
  257. /// <param name="returnFirstIfNoIndex">if set to <c>true</c> [return first if no index].</param>
  258. /// <returns>MediaStream.</returns>
  259. private static MediaStream GetMediaStream(IEnumerable<MediaStream> allStream, int? desiredIndex, MediaStreamType type, bool returnFirstIfNoIndex = true)
  260. {
  261. var streams = allStream.Where(s => s.Type == type).OrderBy(i => i.Index).ToList();
  262. if (desiredIndex.HasValue)
  263. {
  264. var stream = streams.FirstOrDefault(s => s.Index == desiredIndex.Value);
  265. if (stream != null)
  266. {
  267. return stream;
  268. }
  269. }
  270. if (type == MediaStreamType.Video)
  271. {
  272. streams = streams.Where(i => !string.Equals(i.Codec, "mjpeg", StringComparison.OrdinalIgnoreCase)).ToList();
  273. }
  274. if (returnFirstIfNoIndex && type == MediaStreamType.Audio)
  275. {
  276. return streams.FirstOrDefault(i => i.Channels.HasValue && i.Channels.Value > 0) ??
  277. streams.FirstOrDefault();
  278. }
  279. // Just return the first one
  280. return returnFirstIfNoIndex ? streams.FirstOrDefault() : null;
  281. }
  282. /// <summary>
  283. /// Enforces the resolution limit.
  284. /// </summary>
  285. /// <param name="state">The state.</param>
  286. /// <param name="videoRequest">The video request.</param>
  287. private static void EnforceResolutionLimit(EncodingJob state, EncodingJobOptions videoRequest)
  288. {
  289. // Switch the incoming params to be ceilings rather than fixed values
  290. videoRequest.MaxWidth = videoRequest.MaxWidth ?? videoRequest.Width;
  291. videoRequest.MaxHeight = videoRequest.MaxHeight ?? videoRequest.Height;
  292. videoRequest.Width = null;
  293. videoRequest.Height = null;
  294. }
  295. /// <summary>
  296. /// Gets the number of audio channels to specify on the command line
  297. /// </summary>
  298. /// <param name="request">The request.</param>
  299. /// <param name="audioStream">The audio stream.</param>
  300. /// <param name="outputAudioCodec">The output audio codec.</param>
  301. /// <returns>System.Nullable{System.Int32}.</returns>
  302. private int? GetNumAudioChannelsParam(EncodingJobOptions request, MediaStream audioStream, string outputAudioCodec)
  303. {
  304. if (audioStream != null)
  305. {
  306. var codec = outputAudioCodec ?? string.Empty;
  307. if (audioStream.Channels > 2 && codec.IndexOf("wma", StringComparison.OrdinalIgnoreCase) != -1)
  308. {
  309. // wmav2 currently only supports two channel output
  310. return 2;
  311. }
  312. }
  313. if (request.MaxAudioChannels.HasValue)
  314. {
  315. if (audioStream != null && audioStream.Channels.HasValue)
  316. {
  317. return Math.Min(request.MaxAudioChannels.Value, audioStream.Channels.Value);
  318. }
  319. // If we don't have any media info then limit it to 5 to prevent encoding errors due to asking for too many channels
  320. return Math.Min(request.MaxAudioChannels.Value, 5);
  321. }
  322. return request.AudioChannels;
  323. }
  324. private int? GetVideoBitrateParamValue(EncodingJobOptions request, MediaStream videoStream)
  325. {
  326. var bitrate = request.VideoBitRate;
  327. if (videoStream != null)
  328. {
  329. var isUpscaling = request.Height.HasValue && videoStream.Height.HasValue &&
  330. request.Height.Value > videoStream.Height.Value;
  331. if (request.Width.HasValue && videoStream.Width.HasValue &&
  332. request.Width.Value > videoStream.Width.Value)
  333. {
  334. isUpscaling = true;
  335. }
  336. // Don't allow bitrate increases unless upscaling
  337. if (!isUpscaling)
  338. {
  339. if (bitrate.HasValue && videoStream.BitRate.HasValue)
  340. {
  341. bitrate = Math.Min(bitrate.Value, videoStream.BitRate.Value);
  342. }
  343. }
  344. }
  345. return bitrate;
  346. }
  347. protected string GetVideoBitrateParam(EncodingJob state, string videoCodec, bool isHls)
  348. {
  349. var bitrate = state.OutputVideoBitrate;
  350. if (bitrate.HasValue)
  351. {
  352. var hasFixedResolution = state.Options.HasFixedResolution;
  353. if (string.Equals(videoCodec, "libvpx", StringComparison.OrdinalIgnoreCase))
  354. {
  355. if (hasFixedResolution)
  356. {
  357. return string.Format(" -minrate:v ({0}*.90) -maxrate:v ({0}*1.10) -bufsize:v {0} -b:v {0}", bitrate.Value.ToString(UsCulture));
  358. }
  359. // With vpx when crf is used, b:v becomes a max rate
  360. // https://trac.ffmpeg.org/wiki/vpxEncodingGuide. But higher bitrate source files -b:v causes judder so limite the bitrate but dont allow it to "saturate" the bitrate. So dont contrain it down just up.
  361. return string.Format(" -maxrate:v {0} -bufsize:v ({0}*2) -b:v {0}", bitrate.Value.ToString(UsCulture));
  362. }
  363. if (string.Equals(videoCodec, "msmpeg4", StringComparison.OrdinalIgnoreCase))
  364. {
  365. return string.Format(" -b:v {0}", bitrate.Value.ToString(UsCulture));
  366. }
  367. // H264
  368. if (hasFixedResolution)
  369. {
  370. if (isHls)
  371. {
  372. return string.Format(" -b:v {0} -maxrate ({0}*.80) -bufsize {0}", bitrate.Value.ToString(UsCulture));
  373. }
  374. return string.Format(" -b:v {0}", bitrate.Value.ToString(UsCulture));
  375. }
  376. return string.Format(" -maxrate {0} -bufsize {1}",
  377. bitrate.Value.ToString(UsCulture),
  378. (bitrate.Value * 2).ToString(UsCulture));
  379. }
  380. return string.Empty;
  381. }
  382. private int? GetAudioBitrateParam(EncodingJobOptions request, MediaStream audioStream)
  383. {
  384. if (request.AudioBitRate.HasValue)
  385. {
  386. // Make sure we don't request a bitrate higher than the source
  387. var currentBitrate = audioStream == null ? request.AudioBitRate.Value : audioStream.BitRate ?? request.AudioBitRate.Value;
  388. return request.AudioBitRate.Value;
  389. //return Math.Min(currentBitrate, request.AudioBitRate.Value);
  390. }
  391. return null;
  392. }
  393. /// <summary>
  394. /// Determines whether the specified stream is H264.
  395. /// </summary>
  396. /// <param name="stream">The stream.</param>
  397. /// <returns><c>true</c> if the specified stream is H264; otherwise, <c>false</c>.</returns>
  398. protected bool IsH264(MediaStream stream)
  399. {
  400. var codec = stream.Codec ?? string.Empty;
  401. return codec.IndexOf("264", StringComparison.OrdinalIgnoreCase) != -1 ||
  402. codec.IndexOf("avc", StringComparison.OrdinalIgnoreCase) != -1;
  403. }
  404. /// <summary>
  405. /// Gets the name of the output audio codec
  406. /// </summary>
  407. /// <param name="request">The request.</param>
  408. /// <returns>System.String.</returns>
  409. private string GetAudioCodec(EncodingJobOptions request)
  410. {
  411. var codec = request.AudioCodec;
  412. if (string.Equals(codec, "aac", StringComparison.OrdinalIgnoreCase))
  413. {
  414. return "aac -strict experimental";
  415. }
  416. if (string.Equals(codec, "mp3", StringComparison.OrdinalIgnoreCase))
  417. {
  418. return "libmp3lame";
  419. }
  420. if (string.Equals(codec, "vorbis", StringComparison.OrdinalIgnoreCase))
  421. {
  422. return "libvorbis";
  423. }
  424. if (string.Equals(codec, "wma", StringComparison.OrdinalIgnoreCase))
  425. {
  426. return "wmav2";
  427. }
  428. return (codec ?? string.Empty).ToLower();
  429. }
  430. /// <summary>
  431. /// Gets the name of the output video codec
  432. /// </summary>
  433. /// <param name="request">The request.</param>
  434. /// <returns>System.String.</returns>
  435. private string GetVideoCodec(EncodingJobOptions request)
  436. {
  437. var codec = request.VideoCodec;
  438. if (string.Equals(codec, "h264", StringComparison.OrdinalIgnoreCase))
  439. {
  440. return "libx264";
  441. }
  442. if (string.Equals(codec, "h265", StringComparison.OrdinalIgnoreCase))
  443. {
  444. return "libx265";
  445. }
  446. if (string.Equals(codec, "vpx", StringComparison.OrdinalIgnoreCase))
  447. {
  448. return "libvpx";
  449. }
  450. if (string.Equals(codec, "wmv", StringComparison.OrdinalIgnoreCase))
  451. {
  452. return "wmv2";
  453. }
  454. if (string.Equals(codec, "theora", StringComparison.OrdinalIgnoreCase))
  455. {
  456. return "libtheora";
  457. }
  458. return (codec ?? string.Empty).ToLower();
  459. }
  460. internal static bool CanStreamCopyVideo(EncodingJobOptions request, MediaStream videoStream)
  461. {
  462. if (videoStream.IsInterlaced)
  463. {
  464. return false;
  465. }
  466. // Can't stream copy if we're burning in subtitles
  467. if (request.SubtitleStreamIndex.HasValue)
  468. {
  469. if (request.SubtitleMethod == SubtitleDeliveryMethod.Encode)
  470. {
  471. return false;
  472. }
  473. }
  474. // Source and target codecs must match
  475. if (!string.Equals(request.VideoCodec, videoStream.Codec, StringComparison.OrdinalIgnoreCase))
  476. {
  477. return false;
  478. }
  479. // If client is requesting a specific video profile, it must match the source
  480. if (!string.IsNullOrEmpty(request.Profile))
  481. {
  482. if (string.IsNullOrEmpty(videoStream.Profile))
  483. {
  484. return false;
  485. }
  486. if (!string.Equals(request.Profile, videoStream.Profile, StringComparison.OrdinalIgnoreCase))
  487. {
  488. var currentScore = GetVideoProfileScore(videoStream.Profile);
  489. var requestedScore = GetVideoProfileScore(request.Profile);
  490. if (currentScore == -1 || currentScore > requestedScore)
  491. {
  492. return false;
  493. }
  494. }
  495. }
  496. // Video width must fall within requested value
  497. if (request.MaxWidth.HasValue)
  498. {
  499. if (!videoStream.Width.HasValue || videoStream.Width.Value > request.MaxWidth.Value)
  500. {
  501. return false;
  502. }
  503. }
  504. // Video height must fall within requested value
  505. if (request.MaxHeight.HasValue)
  506. {
  507. if (!videoStream.Height.HasValue || videoStream.Height.Value > request.MaxHeight.Value)
  508. {
  509. return false;
  510. }
  511. }
  512. // Video framerate must fall within requested value
  513. var requestedFramerate = request.MaxFramerate ?? request.Framerate;
  514. if (requestedFramerate.HasValue)
  515. {
  516. var videoFrameRate = videoStream.AverageFrameRate ?? videoStream.RealFrameRate;
  517. if (!videoFrameRate.HasValue || videoFrameRate.Value > requestedFramerate.Value)
  518. {
  519. return false;
  520. }
  521. }
  522. // Video bitrate must fall within requested value
  523. if (request.VideoBitRate.HasValue)
  524. {
  525. if (!videoStream.BitRate.HasValue || videoStream.BitRate.Value > request.VideoBitRate.Value)
  526. {
  527. return false;
  528. }
  529. }
  530. if (request.MaxVideoBitDepth.HasValue)
  531. {
  532. if (videoStream.BitDepth.HasValue && videoStream.BitDepth.Value > request.MaxVideoBitDepth.Value)
  533. {
  534. return false;
  535. }
  536. }
  537. if (request.MaxRefFrames.HasValue)
  538. {
  539. if (videoStream.RefFrames.HasValue && videoStream.RefFrames.Value > request.MaxRefFrames.Value)
  540. {
  541. return false;
  542. }
  543. }
  544. // If a specific level was requested, the source must match or be less than
  545. if (request.Level.HasValue)
  546. {
  547. if (!videoStream.Level.HasValue)
  548. {
  549. return false;
  550. }
  551. if (videoStream.Level.Value > request.Level.Value)
  552. {
  553. return false;
  554. }
  555. }
  556. if (request.Cabac.HasValue && request.Cabac.Value)
  557. {
  558. if (videoStream.IsCabac.HasValue && !videoStream.IsCabac.Value)
  559. {
  560. return false;
  561. }
  562. }
  563. return request.EnableAutoStreamCopy;
  564. }
  565. private static int GetVideoProfileScore(string profile)
  566. {
  567. var list = new List<string>
  568. {
  569. "Constrained Baseline",
  570. "Baseline",
  571. "Extended",
  572. "Main",
  573. "High",
  574. "Progressive High",
  575. "Constrained High"
  576. };
  577. return Array.FindIndex(list.ToArray(), t => string.Equals(t, profile, StringComparison.OrdinalIgnoreCase));
  578. }
  579. internal static bool CanStreamCopyAudio(EncodingJobOptions request, MediaStream audioStream, List<string> supportedAudioCodecs)
  580. {
  581. // Source and target codecs must match
  582. if (string.IsNullOrEmpty(audioStream.Codec) || !supportedAudioCodecs.Contains(audioStream.Codec, StringComparer.OrdinalIgnoreCase))
  583. {
  584. return false;
  585. }
  586. // Video bitrate must fall within requested value
  587. if (request.AudioBitRate.HasValue)
  588. {
  589. if (!audioStream.BitRate.HasValue || audioStream.BitRate.Value <= 0)
  590. {
  591. return false;
  592. }
  593. if (audioStream.BitRate.Value > request.AudioBitRate.Value)
  594. {
  595. return false;
  596. }
  597. }
  598. // Channels must fall within requested value
  599. var channels = request.AudioChannels ?? request.MaxAudioChannels;
  600. if (channels.HasValue)
  601. {
  602. if (!audioStream.Channels.HasValue || audioStream.Channels.Value <= 0)
  603. {
  604. return false;
  605. }
  606. if (audioStream.Channels.Value > channels.Value)
  607. {
  608. return false;
  609. }
  610. }
  611. // Sample rate must fall within requested value
  612. if (request.AudioSampleRate.HasValue)
  613. {
  614. if (!audioStream.SampleRate.HasValue || audioStream.SampleRate.Value <= 0)
  615. {
  616. return false;
  617. }
  618. if (audioStream.SampleRate.Value > request.AudioSampleRate.Value)
  619. {
  620. return false;
  621. }
  622. }
  623. return request.EnableAutoStreamCopy;
  624. }
  625. private void ApplyDeviceProfileSettings(EncodingJob state)
  626. {
  627. var profile = state.Options.DeviceProfile;
  628. if (profile == null)
  629. {
  630. // Don't use settings from the default profile.
  631. // Only use a specific profile if it was requested.
  632. return;
  633. }
  634. var audioCodec = state.ActualOutputAudioCodec;
  635. var videoCodec = state.ActualOutputVideoCodec;
  636. var outputContainer = state.Options.OutputContainer;
  637. var mediaProfile = state.IsVideoRequest ?
  638. profile.GetAudioMediaProfile(outputContainer, audioCodec, state.OutputAudioChannels, state.OutputAudioBitrate) :
  639. profile.GetVideoMediaProfile(outputContainer,
  640. audioCodec,
  641. videoCodec,
  642. state.OutputAudioBitrate,
  643. state.OutputAudioChannels,
  644. state.OutputWidth,
  645. state.OutputHeight,
  646. state.TargetVideoBitDepth,
  647. state.OutputVideoBitrate,
  648. state.TargetVideoProfile,
  649. state.TargetVideoLevel,
  650. state.TargetFramerate,
  651. state.TargetPacketLength,
  652. state.TargetTimestamp,
  653. state.IsTargetAnamorphic,
  654. state.IsTargetCabac,
  655. state.TargetRefFrames);
  656. if (mediaProfile != null)
  657. {
  658. state.MimeType = mediaProfile.MimeType;
  659. }
  660. var transcodingProfile = state.IsVideoRequest ?
  661. profile.GetAudioTranscodingProfile(outputContainer, audioCodec) :
  662. profile.GetVideoTranscodingProfile(outputContainer, audioCodec, videoCodec);
  663. if (transcodingProfile != null)
  664. {
  665. state.EstimateContentLength = transcodingProfile.EstimateContentLength;
  666. state.EnableMpegtsM2TsMode = transcodingProfile.EnableMpegtsM2TsMode;
  667. state.TranscodeSeekInfo = transcodingProfile.TranscodeSeekInfo;
  668. }
  669. }
  670. }
  671. }