BaseStreamingService.cs 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787
  1. using MediaBrowser.Common.Extensions;
  2. using MediaBrowser.Common.IO;
  3. using MediaBrowser.Common.MediaInfo;
  4. using MediaBrowser.Controller;
  5. using MediaBrowser.Controller.Dto;
  6. using MediaBrowser.Controller.Entities;
  7. using MediaBrowser.Controller.Library;
  8. using MediaBrowser.Controller.Providers.MediaInfo;
  9. using MediaBrowser.Model.Drawing;
  10. using MediaBrowser.Model.Dto;
  11. using MediaBrowser.Model.Entities;
  12. using System;
  13. using System.Collections.Generic;
  14. using System.ComponentModel;
  15. using System.Diagnostics;
  16. using System.IO;
  17. using System.Linq;
  18. using System.Threading;
  19. using System.Threading.Tasks;
  20. namespace MediaBrowser.Api.Playback
  21. {
  22. /// <summary>
  23. /// Class BaseStreamingService
  24. /// </summary>
  25. public abstract class BaseStreamingService : BaseApiService
  26. {
  27. /// <summary>
  28. /// Gets or sets the application paths.
  29. /// </summary>
  30. /// <value>The application paths.</value>
  31. protected IServerApplicationPaths ApplicationPaths { get; set; }
  32. /// <summary>
  33. /// Gets or sets the user manager.
  34. /// </summary>
  35. /// <value>The user manager.</value>
  36. protected IUserManager UserManager { get; set; }
  37. /// <summary>
  38. /// Gets or sets the library manager.
  39. /// </summary>
  40. /// <value>The library manager.</value>
  41. protected ILibraryManager LibraryManager { get; set; }
  42. /// <summary>
  43. /// Gets or sets the iso manager.
  44. /// </summary>
  45. /// <value>The iso manager.</value>
  46. protected IIsoManager IsoManager { get; set; }
  47. /// <summary>
  48. /// Gets or sets the media encoder.
  49. /// </summary>
  50. /// <value>The media encoder.</value>
  51. protected IMediaEncoder MediaEncoder { get; set; }
  52. /// <summary>
  53. /// Initializes a new instance of the <see cref="BaseStreamingService" /> class.
  54. /// </summary>
  55. /// <param name="appPaths">The app paths.</param>
  56. /// <param name="userManager">The user manager.</param>
  57. /// <param name="libraryManager">The library manager.</param>
  58. /// <param name="isoManager">The iso manager.</param>
  59. /// <param name="mediaEncoder">The media encoder.</param>
  60. protected BaseStreamingService(IServerApplicationPaths appPaths, IUserManager userManager, ILibraryManager libraryManager, IIsoManager isoManager, IMediaEncoder mediaEncoder)
  61. {
  62. ApplicationPaths = appPaths;
  63. UserManager = userManager;
  64. LibraryManager = libraryManager;
  65. IsoManager = isoManager;
  66. MediaEncoder = mediaEncoder;
  67. }
  68. /// <summary>
  69. /// Gets the command line arguments.
  70. /// </summary>
  71. /// <param name="outputPath">The output path.</param>
  72. /// <param name="state">The state.</param>
  73. /// <param name="performSubtitleConversions">if set to <c>true</c> [perform subtitle conversions].</param>
  74. /// <returns>System.String.</returns>
  75. protected abstract string GetCommandLineArguments(string outputPath, StreamState state, bool performSubtitleConversions);
  76. /// <summary>
  77. /// Gets the type of the transcoding job.
  78. /// </summary>
  79. /// <value>The type of the transcoding job.</value>
  80. protected abstract TranscodingJobType TranscodingJobType { get; }
  81. /// <summary>
  82. /// Gets the output file extension.
  83. /// </summary>
  84. /// <param name="state">The state.</param>
  85. /// <returns>System.String.</returns>
  86. protected virtual string GetOutputFileExtension(StreamState state)
  87. {
  88. return Path.GetExtension(state.Url);
  89. }
  90. /// <summary>
  91. /// Gets the output file path.
  92. /// </summary>
  93. /// <param name="state">The state.</param>
  94. /// <returns>System.String.</returns>
  95. protected string GetOutputFilePath(StreamState state)
  96. {
  97. var folder = ApplicationPaths.EncodedMediaCachePath;
  98. return Path.Combine(folder, GetCommandLineArguments("dummy\\dummy", state, false).GetMD5() + GetOutputFileExtension(state).ToLower());
  99. }
  100. /// <summary>
  101. /// The fast seek offset seconds
  102. /// </summary>
  103. private const int FastSeekOffsetSeconds = 1;
  104. /// <summary>
  105. /// Gets the fast seek command line parameter.
  106. /// </summary>
  107. /// <param name="request">The request.</param>
  108. /// <returns>System.String.</returns>
  109. /// <value>The fast seek command line parameter.</value>
  110. protected string GetFastSeekCommandLineParameter(StreamRequest request)
  111. {
  112. var time = request.StartTimeTicks;
  113. if (time.HasValue)
  114. {
  115. var seconds = TimeSpan.FromTicks(time.Value).TotalSeconds - FastSeekOffsetSeconds;
  116. if (seconds > 0)
  117. {
  118. return string.Format("-ss {0}", seconds);
  119. }
  120. }
  121. return string.Empty;
  122. }
  123. /// <summary>
  124. /// Gets the slow seek command line parameter.
  125. /// </summary>
  126. /// <param name="request">The request.</param>
  127. /// <returns>System.String.</returns>
  128. /// <value>The slow seek command line parameter.</value>
  129. protected string GetSlowSeekCommandLineParameter(StreamRequest request)
  130. {
  131. var time = request.StartTimeTicks;
  132. if (time.HasValue)
  133. {
  134. if (TimeSpan.FromTicks(time.Value).TotalSeconds - FastSeekOffsetSeconds > 0)
  135. {
  136. return string.Format(" -ss {0}", FastSeekOffsetSeconds);
  137. }
  138. }
  139. return string.Empty;
  140. }
  141. /// <summary>
  142. /// Gets the map args.
  143. /// </summary>
  144. /// <param name="state">The state.</param>
  145. /// <returns>System.String.</returns>
  146. protected virtual string GetMapArgs(StreamState state)
  147. {
  148. var args = string.Empty;
  149. if (state.VideoStream != null)
  150. {
  151. args += string.Format("-map 0:{0}", state.VideoStream.Index);
  152. }
  153. else
  154. {
  155. args += "-map -0:v";
  156. }
  157. if (state.AudioStream != null)
  158. {
  159. args += string.Format(" -map 0:{0}", state.AudioStream.Index);
  160. }
  161. else
  162. {
  163. args += " -map -0:a";
  164. }
  165. if (state.SubtitleStream == null)
  166. {
  167. args += " -map -0:s";
  168. }
  169. return args;
  170. }
  171. /// <summary>
  172. /// Determines which stream will be used for playback
  173. /// </summary>
  174. /// <param name="allStream">All stream.</param>
  175. /// <param name="desiredIndex">Index of the desired.</param>
  176. /// <param name="type">The type.</param>
  177. /// <param name="returnFirstIfNoIndex">if set to <c>true</c> [return first if no index].</param>
  178. /// <returns>MediaStream.</returns>
  179. private MediaStream GetMediaStream(IEnumerable<MediaStream> allStream, int? desiredIndex, MediaStreamType type, bool returnFirstIfNoIndex = true)
  180. {
  181. var streams = allStream.Where(s => s.Type == type).ToList();
  182. if (desiredIndex.HasValue)
  183. {
  184. var stream = streams.FirstOrDefault(s => s.Index == desiredIndex.Value);
  185. if (stream != null)
  186. {
  187. return stream;
  188. }
  189. }
  190. // Just return the first one
  191. return returnFirstIfNoIndex ? streams.FirstOrDefault() : null;
  192. }
  193. /// <summary>
  194. /// If we're going to put a fixed size on the command line, this will calculate it
  195. /// </summary>
  196. /// <param name="state">The state.</param>
  197. /// <param name="outputVideoCodec">The output video codec.</param>
  198. /// <param name="performTextSubtitleConversion">if set to <c>true</c> [perform text subtitle conversion].</param>
  199. /// <returns>System.String.</returns>
  200. protected string GetOutputSizeParam(StreamState state, string outputVideoCodec, bool performTextSubtitleConversion)
  201. {
  202. // http://sonnati.wordpress.com/2012/10/19/ffmpeg-the-swiss-army-knife-of-internet-streaming-part-vi/
  203. var assSubtitleParam = string.Empty;
  204. var request = state.VideoRequest;
  205. if (state.SubtitleStream != null)
  206. {
  207. if (state.SubtitleStream.Codec.IndexOf("srt", StringComparison.OrdinalIgnoreCase) != -1 || state.SubtitleStream.Codec.IndexOf("subrip", StringComparison.OrdinalIgnoreCase) != -1)
  208. {
  209. assSubtitleParam = GetTextSubtitleParam((Video)state.Item, state.SubtitleStream, request.StartTimeTicks, performTextSubtitleConversion);
  210. }
  211. }
  212. // If fixed dimensions were supplied
  213. if (request.Width.HasValue && request.Height.HasValue)
  214. {
  215. return string.Format(" -vf \"scale={0}:{1}{2}\"", request.Width.Value, request.Height.Value, assSubtitleParam);
  216. }
  217. var isH264Output = outputVideoCodec.Equals("libx264", StringComparison.OrdinalIgnoreCase);
  218. // If a fixed width was requested
  219. if (request.Width.HasValue)
  220. {
  221. return isH264Output ?
  222. string.Format(" -vf \"scale={0}:trunc(ow/a/2)*2{1}\"", request.Width.Value, assSubtitleParam) :
  223. string.Format(" -vf \"scale={0}:-1{1}\"", request.Width.Value, assSubtitleParam);
  224. }
  225. // If a max width was requested
  226. if (request.MaxWidth.HasValue && !request.MaxHeight.HasValue)
  227. {
  228. return isH264Output ?
  229. string.Format(" -vf \"scale=min(iw\\,{0}):trunc(ow/a/2)*2{1}\"", request.MaxWidth.Value, assSubtitleParam) :
  230. string.Format(" -vf \"scale=min(iw\\,{0}):-1{1}\"", request.MaxWidth.Value, assSubtitleParam);
  231. }
  232. // Need to perform calculations manually
  233. // Try to account for bad media info
  234. var currentHeight = state.VideoStream.Height ?? request.MaxHeight ?? request.Height ?? 0;
  235. var currentWidth = state.VideoStream.Width ?? request.MaxWidth ?? request.Width ?? 0;
  236. var outputSize = DrawingUtils.Resize(currentWidth, currentHeight, request.Width, request.Height, request.MaxWidth, request.MaxHeight);
  237. // If we're encoding with libx264, it can't handle odd numbered widths or heights, so we'll have to fix that
  238. if (isH264Output)
  239. {
  240. return string.Format(" -vf \"scale=trunc({0}/2)*2:trunc({1}/2)*2{2}\"", outputSize.Width, outputSize.Height, assSubtitleParam);
  241. }
  242. // Otherwise use -vf scale since ffmpeg will ensure internally that the aspect ratio is preserved
  243. return string.Format(" -vf \"scale={0}:-1{1}\"", Convert.ToInt32(outputSize.Width), assSubtitleParam);
  244. }
  245. /// <summary>
  246. /// Gets the text subtitle param.
  247. /// </summary>
  248. /// <param name="video">The video.</param>
  249. /// <param name="subtitleStream">The subtitle stream.</param>
  250. /// <param name="startTimeTicks">The start time ticks.</param>
  251. /// <param name="performConversion">if set to <c>true</c> [perform conversion].</param>
  252. /// <returns>System.String.</returns>
  253. protected string GetTextSubtitleParam(Video video, MediaStream subtitleStream, long? startTimeTicks, bool performConversion)
  254. {
  255. var path = subtitleStream.IsExternal ? GetConvertedAssPath(video, subtitleStream, startTimeTicks, performConversion) : GetExtractedAssPath(video, subtitleStream, startTimeTicks, performConversion);
  256. if (string.IsNullOrEmpty(path))
  257. {
  258. return string.Empty;
  259. }
  260. return string.Format(",ass='{0}'", path.Replace('\\', '/').Replace(":/", "\\:/"));
  261. }
  262. /// <summary>
  263. /// Gets the extracted ass path.
  264. /// </summary>
  265. /// <param name="video">The video.</param>
  266. /// <param name="subtitleStream">The subtitle stream.</param>
  267. /// <param name="startTimeTicks">The start time ticks.</param>
  268. /// <param name="performConversion">if set to <c>true</c> [perform conversion].</param>
  269. /// <returns>System.String.</returns>
  270. private string GetExtractedAssPath(Video video, MediaStream subtitleStream, long? startTimeTicks, bool performConversion)
  271. {
  272. var offset = TimeSpan.FromTicks(startTimeTicks ?? 0);
  273. var path = Kernel.Instance.FFMpegManager.GetSubtitleCachePath(video, subtitleStream.Index, offset, ".ass");
  274. if (performConversion && !File.Exists(path))
  275. {
  276. InputType type;
  277. var inputPath = MediaEncoderHelpers.GetInputArgument(video, null, out type);
  278. try
  279. {
  280. var task = MediaEncoder.ExtractTextSubtitle(inputPath, type, subtitleStream.Index, offset, path, CancellationToken.None);
  281. Task.WaitAll(task);
  282. }
  283. catch
  284. {
  285. return null;
  286. }
  287. }
  288. return path;
  289. }
  290. /// <summary>
  291. /// Gets the converted ass path.
  292. /// </summary>
  293. /// <param name="video">The video.</param>
  294. /// <param name="subtitleStream">The subtitle stream.</param>
  295. /// <param name="startTimeTicks">The start time ticks.</param>
  296. /// <param name="performConversion">if set to <c>true</c> [perform conversion].</param>
  297. /// <returns>System.String.</returns>
  298. private string GetConvertedAssPath(Video video, MediaStream subtitleStream, long? startTimeTicks, bool performConversion)
  299. {
  300. var offset = startTimeTicks.HasValue
  301. ? TimeSpan.FromTicks(startTimeTicks.Value)
  302. : TimeSpan.FromTicks(0);
  303. var path = Kernel.Instance.FFMpegManager.GetSubtitleCachePath(video, subtitleStream.Index, offset, ".ass");
  304. if (performConversion && !File.Exists(path))
  305. {
  306. try
  307. {
  308. var task = MediaEncoder.ConvertTextSubtitleToAss(subtitleStream.Path, path, offset, CancellationToken.None);
  309. Task.WaitAll(task);
  310. }
  311. catch
  312. {
  313. return null;
  314. }
  315. }
  316. return path;
  317. }
  318. /// <summary>
  319. /// Gets the internal graphical subtitle param.
  320. /// </summary>
  321. /// <param name="state">The state.</param>
  322. /// <param name="outputVideoCodec">The output video codec.</param>
  323. /// <returns>System.String.</returns>
  324. protected string GetInternalGraphicalSubtitleParam(StreamState state, string outputVideoCodec)
  325. {
  326. var outputSizeParam = string.Empty;
  327. var request = state.VideoRequest;
  328. // Add resolution params, if specified
  329. if (request.Width.HasValue || request.Height.HasValue || request.MaxHeight.HasValue || request.MaxWidth.HasValue)
  330. {
  331. outputSizeParam = GetOutputSizeParam(state, outputVideoCodec, false).TrimEnd('"');
  332. outputSizeParam = "," + outputSizeParam.Substring(outputSizeParam.IndexOf("scale", StringComparison.OrdinalIgnoreCase));
  333. }
  334. return string.Format(" -filter_complex \"[0:{0}]format=yuva444p,lut=u=128:v=128:y=gammaval(.3)[sub] ; [0:{1}] [sub] overlay{2}\"", state.SubtitleStream.Index, state.VideoStream.Index, outputSizeParam);
  335. }
  336. /// <summary>
  337. /// Gets the probe size argument.
  338. /// </summary>
  339. /// <param name="item">The item.</param>
  340. /// <returns>System.String.</returns>
  341. protected string GetProbeSizeArgument(BaseItem item)
  342. {
  343. return MediaEncoder.GetProbeSizeArgument(MediaEncoderHelpers.GetInputType(item));
  344. }
  345. /// <summary>
  346. /// Gets the number of audio channels to specify on the command line
  347. /// </summary>
  348. /// <param name="request">The request.</param>
  349. /// <param name="audioStream">The audio stream.</param>
  350. /// <returns>System.Nullable{System.Int32}.</returns>
  351. protected int? GetNumAudioChannelsParam(StreamRequest request, MediaStream audioStream)
  352. {
  353. if (audioStream.Channels > 2 && request.AudioCodec.HasValue)
  354. {
  355. if (request.AudioCodec.Value == AudioCodecs.Aac)
  356. {
  357. // libvo_aacenc currently only supports two channel output
  358. return 2;
  359. }
  360. if (request.AudioCodec.Value == AudioCodecs.Wma)
  361. {
  362. // wmav2 currently only supports two channel output
  363. return 2;
  364. }
  365. }
  366. return request.AudioChannels;
  367. }
  368. /// <summary>
  369. /// Determines whether the specified stream is H264.
  370. /// </summary>
  371. /// <param name="stream">The stream.</param>
  372. /// <returns><c>true</c> if the specified stream is H264; otherwise, <c>false</c>.</returns>
  373. protected bool IsH264(MediaStream stream)
  374. {
  375. return stream.Codec.IndexOf("264", StringComparison.OrdinalIgnoreCase) != -1 ||
  376. stream.Codec.IndexOf("avc", StringComparison.OrdinalIgnoreCase) != -1;
  377. }
  378. /// <summary>
  379. /// Gets the name of the output audio codec
  380. /// </summary>
  381. /// <param name="request">The request.</param>
  382. /// <returns>System.String.</returns>
  383. protected string GetAudioCodec(StreamRequest request)
  384. {
  385. var codec = request.AudioCodec;
  386. if (codec.HasValue)
  387. {
  388. if (codec == AudioCodecs.Aac)
  389. {
  390. return "libvo_aacenc";
  391. }
  392. if (codec == AudioCodecs.Mp3)
  393. {
  394. return "libmp3lame";
  395. }
  396. if (codec == AudioCodecs.Vorbis)
  397. {
  398. return "libvorbis";
  399. }
  400. if (codec == AudioCodecs.Wma)
  401. {
  402. return "wmav2";
  403. }
  404. return codec.ToString().ToLower();
  405. }
  406. return "copy";
  407. }
  408. /// <summary>
  409. /// Gets the name of the output video codec
  410. /// </summary>
  411. /// <param name="request">The request.</param>
  412. /// <returns>System.String.</returns>
  413. protected string GetVideoCodec(VideoStreamRequest request)
  414. {
  415. var codec = request.VideoCodec;
  416. if (codec.HasValue)
  417. {
  418. if (codec == VideoCodecs.H264)
  419. {
  420. return "libx264";
  421. }
  422. if (codec == VideoCodecs.Vpx)
  423. {
  424. return "libvpx";
  425. }
  426. if (codec == VideoCodecs.Wmv)
  427. {
  428. return "wmv2";
  429. }
  430. if (codec == VideoCodecs.Theora)
  431. {
  432. return "libtheora";
  433. }
  434. return codec.ToString().ToLower();
  435. }
  436. return "copy";
  437. }
  438. /// <summary>
  439. /// Gets the input argument.
  440. /// </summary>
  441. /// <param name="item">The item.</param>
  442. /// <param name="isoMount">The iso mount.</param>
  443. /// <returns>System.String.</returns>
  444. protected string GetInputArgument(BaseItem item, IIsoMount isoMount)
  445. {
  446. var type = InputType.AudioFile;
  447. var inputPath = new[] { item.Path };
  448. var video = item as Video;
  449. if (video != null)
  450. {
  451. inputPath = MediaEncoderHelpers.GetInputArgument(video, isoMount, out type);
  452. }
  453. return MediaEncoder.GetInputArgument(inputPath, type);
  454. }
  455. /// <summary>
  456. /// Starts the FFMPEG.
  457. /// </summary>
  458. /// <param name="state">The state.</param>
  459. /// <param name="outputPath">The output path.</param>
  460. /// <returns>Task.</returns>
  461. protected async Task StartFfMpeg(StreamState state, string outputPath)
  462. {
  463. var video = state.Item as Video;
  464. if (video != null && video.VideoType == VideoType.Iso && video.IsoType.HasValue && IsoManager.CanMount(video.Path))
  465. {
  466. state.IsoMount = await IsoManager.Mount(video.Path, CancellationToken.None).ConfigureAwait(false);
  467. }
  468. var process = new Process
  469. {
  470. StartInfo = new ProcessStartInfo
  471. {
  472. CreateNoWindow = true,
  473. UseShellExecute = false,
  474. // Must consume both stdout and stderr or deadlocks may occur
  475. RedirectStandardOutput = true,
  476. RedirectStandardError = true,
  477. FileName = MediaEncoder.EncoderPath,
  478. WorkingDirectory = Path.GetDirectoryName(MediaEncoder.EncoderPath),
  479. Arguments = GetCommandLineArguments(outputPath, state, true),
  480. WindowStyle = ProcessWindowStyle.Hidden,
  481. ErrorDialog = false
  482. },
  483. EnableRaisingEvents = true
  484. };
  485. ApiEntryPoint.Instance.OnTranscodeBeginning(outputPath, TranscodingJobType, process);
  486. Logger.Info(process.StartInfo.FileName + " " + process.StartInfo.Arguments);
  487. var logFilePath = Path.Combine(ApplicationPaths.LogDirectoryPath, "ffmpeg-" + Guid.NewGuid() + ".txt");
  488. // FFMpeg writes debug/error info to stderr. This is useful when debugging so let's put it in the log directory.
  489. state.LogFileStream = new FileStream(logFilePath, FileMode.Create, FileAccess.Write, FileShare.Read, StreamDefaults.DefaultFileStreamBufferSize, FileOptions.Asynchronous);
  490. process.Exited += (sender, args) => OnFfMpegProcessExited(process, state);
  491. try
  492. {
  493. process.Start();
  494. }
  495. catch (Win32Exception ex)
  496. {
  497. Logger.ErrorException("Error starting ffmpeg", ex);
  498. ApiEntryPoint.Instance.OnTranscodeFailedToStart(outputPath, TranscodingJobType);
  499. state.LogFileStream.Dispose();
  500. throw;
  501. }
  502. // MUST read both stdout and stderr asynchronously or a deadlock may occurr
  503. process.BeginOutputReadLine();
  504. // Important - don't await the log task or we won't be able to kill ffmpeg when the user stops playback
  505. process.StandardError.BaseStream.CopyToAsync(state.LogFileStream);
  506. // Wait for the file to exist before proceeeding
  507. while (!File.Exists(outputPath))
  508. {
  509. await Task.Delay(100).ConfigureAwait(false);
  510. }
  511. }
  512. /// <summary>
  513. /// Processes the exited.
  514. /// </summary>
  515. /// <param name="process">The process.</param>
  516. /// <param name="state">The state.</param>
  517. protected void OnFfMpegProcessExited(Process process, StreamState state)
  518. {
  519. if (state.IsoMount != null)
  520. {
  521. state.IsoMount.Dispose();
  522. state.IsoMount = null;
  523. }
  524. var outputFilePath = GetOutputFilePath(state);
  525. state.LogFileStream.Dispose();
  526. int? exitCode = null;
  527. try
  528. {
  529. exitCode = process.ExitCode;
  530. Logger.Info("FFMpeg exited with code {0} for {1}", exitCode.Value, outputFilePath);
  531. }
  532. catch
  533. {
  534. Logger.Info("FFMpeg exited with an error for {0}", outputFilePath);
  535. }
  536. process.Dispose();
  537. ApiEntryPoint.Instance.OnTranscodingFinished(outputFilePath, TranscodingJobType);
  538. if (!exitCode.HasValue || exitCode.Value != 0 || state.Item is Video)
  539. {
  540. Logger.Info("Deleting partial stream file(s) {0}", outputFilePath);
  541. try
  542. {
  543. DeletePartialStreamFiles(outputFilePath);
  544. }
  545. catch (IOException ex)
  546. {
  547. Logger.ErrorException("Error deleting partial stream file(s) {0}", ex, outputFilePath);
  548. }
  549. }
  550. else
  551. {
  552. Logger.Info("FFMpeg completed and exited normally for {0}", outputFilePath);
  553. }
  554. }
  555. /// <summary>
  556. /// Deletes the partial stream files.
  557. /// </summary>
  558. /// <param name="outputFilePath">The output file path.</param>
  559. protected abstract void DeletePartialStreamFiles(string outputFilePath);
  560. /// <summary>
  561. /// Gets the state.
  562. /// </summary>
  563. /// <param name="request">The request.</param>
  564. /// <returns>StreamState.</returns>
  565. protected StreamState GetState(StreamRequest request)
  566. {
  567. var item = DtoBuilder.GetItemByClientId(request.Id, UserManager, LibraryManager);
  568. var media = (IHasMediaStreams)item;
  569. var url = RequestContext.PathInfo;
  570. if (!request.AudioCodec.HasValue)
  571. {
  572. request.AudioCodec = InferAudioCodec(url);
  573. }
  574. var state = new StreamState
  575. {
  576. Item = item,
  577. Request = request,
  578. Url = url
  579. };
  580. var videoRequest = request as VideoStreamRequest;
  581. if (videoRequest != null)
  582. {
  583. if (!videoRequest.VideoCodec.HasValue)
  584. {
  585. videoRequest.VideoCodec = InferVideoCodec(url);
  586. }
  587. state.VideoStream = GetMediaStream(media.MediaStreams, videoRequest.VideoStreamIndex, MediaStreamType.Video);
  588. state.SubtitleStream = GetMediaStream(media.MediaStreams, videoRequest.SubtitleStreamIndex, MediaStreamType.Subtitle, false);
  589. state.AudioStream = GetMediaStream(media.MediaStreams, videoRequest.AudioStreamIndex, MediaStreamType.Audio);
  590. }
  591. else
  592. {
  593. state.AudioStream = GetMediaStream(media.MediaStreams, null, MediaStreamType.Audio, true);
  594. }
  595. return state;
  596. }
  597. /// <summary>
  598. /// Infers the audio codec based on the url
  599. /// </summary>
  600. /// <param name="url">The URL.</param>
  601. /// <returns>System.Nullable{AudioCodecs}.</returns>
  602. private AudioCodecs? InferAudioCodec(string url)
  603. {
  604. var ext = Path.GetExtension(url);
  605. if (string.Equals(ext, ".mp3", StringComparison.OrdinalIgnoreCase))
  606. {
  607. return AudioCodecs.Mp3;
  608. }
  609. if (string.Equals(ext, ".aac", StringComparison.OrdinalIgnoreCase))
  610. {
  611. return AudioCodecs.Aac;
  612. }
  613. if (string.Equals(ext, ".wma", StringComparison.OrdinalIgnoreCase))
  614. {
  615. return AudioCodecs.Wma;
  616. }
  617. if (string.Equals(ext, ".ogg", StringComparison.OrdinalIgnoreCase))
  618. {
  619. return AudioCodecs.Vorbis;
  620. }
  621. if (string.Equals(ext, ".oga", StringComparison.OrdinalIgnoreCase))
  622. {
  623. return AudioCodecs.Vorbis;
  624. }
  625. if (string.Equals(ext, ".ogv", StringComparison.OrdinalIgnoreCase))
  626. {
  627. return AudioCodecs.Vorbis;
  628. }
  629. if (string.Equals(ext, ".webm", StringComparison.OrdinalIgnoreCase))
  630. {
  631. return AudioCodecs.Vorbis;
  632. }
  633. if (string.Equals(ext, ".webma", StringComparison.OrdinalIgnoreCase))
  634. {
  635. return AudioCodecs.Vorbis;
  636. }
  637. return null;
  638. }
  639. /// <summary>
  640. /// Infers the video codec.
  641. /// </summary>
  642. /// <param name="url">The URL.</param>
  643. /// <returns>System.Nullable{VideoCodecs}.</returns>
  644. private VideoCodecs? InferVideoCodec(string url)
  645. {
  646. var ext = Path.GetExtension(url);
  647. if (string.Equals(ext, ".asf", StringComparison.OrdinalIgnoreCase))
  648. {
  649. return VideoCodecs.Wmv;
  650. }
  651. if (string.Equals(ext, ".webm", StringComparison.OrdinalIgnoreCase))
  652. {
  653. return VideoCodecs.Vpx;
  654. }
  655. if (string.Equals(ext, ".ogg", StringComparison.OrdinalIgnoreCase) || string.Equals(ext, ".ogv", StringComparison.OrdinalIgnoreCase))
  656. {
  657. return VideoCodecs.Theora;
  658. }
  659. if (string.Equals(ext, ".m3u8", StringComparison.OrdinalIgnoreCase) || string.Equals(ext, ".ts", StringComparison.OrdinalIgnoreCase))
  660. {
  661. return VideoCodecs.H264;
  662. }
  663. return null;
  664. }
  665. }
  666. }