jellyfin/MediaBrowser.Api/Playback/Hls/BaseHlsService.cs

322 lines
13 KiB
C#
Raw Normal View History

2015-08-28 04:19:08 +00:00
using MediaBrowser.Common.IO;
using MediaBrowser.Controller.Configuration;
2015-01-20 05:19:13 +00:00
using MediaBrowser.Controller.Devices;
2014-03-25 05:25:03 +00:00
using MediaBrowser.Controller.Dlna;
using MediaBrowser.Controller.Library;
2014-02-20 16:37:41 +00:00
using MediaBrowser.Controller.MediaEncoding;
2015-08-27 15:58:07 +00:00
using MediaBrowser.Model.Entities;
2015-01-20 05:19:13 +00:00
using MediaBrowser.Model.Extensions;
2013-08-28 22:05:00 +00:00
using MediaBrowser.Model.IO;
2015-01-20 05:19:13 +00:00
using MediaBrowser.Model.Net;
2015-05-22 15:59:17 +00:00
using MediaBrowser.Model.Serialization;
2013-02-21 01:33:05 +00:00
using System;
using System.Collections.Generic;
2013-02-21 01:33:05 +00:00
using System.IO;
2013-08-28 22:05:00 +00:00
using System.Text;
2013-12-21 18:37:34 +00:00
using System.Threading;
2013-02-21 01:33:05 +00:00
using System.Threading.Tasks;
2015-10-04 04:23:11 +00:00
using CommonIO;
2013-02-21 01:33:05 +00:00
namespace MediaBrowser.Api.Playback.Hls
2013-02-21 01:33:05 +00:00
{
2013-04-29 16:01:23 +00:00
/// <summary>
/// Class BaseHlsService
/// </summary>
public abstract class BaseHlsService : BaseStreamingService
2013-02-21 01:33:05 +00:00
{
2015-09-20 17:56:26 +00:00
protected BaseHlsService(IServerConfigurationManager serverConfig, IUserManager userManager, ILibraryManager libraryManager, IIsoManager isoManager, IMediaEncoder mediaEncoder, IFileSystem fileSystem, IDlnaManager dlnaManager, ISubtitleEncoder subtitleEncoder, IDeviceManager deviceManager, IMediaSourceManager mediaSourceManager, IZipClient zipClient, IJsonSerializer jsonSerializer)
: base(serverConfig, userManager, libraryManager, isoManager, mediaEncoder, fileSystem, dlnaManager, subtitleEncoder, deviceManager, mediaSourceManager, zipClient, jsonSerializer)
2013-12-06 03:39:44 +00:00
{
}
2013-02-21 01:33:05 +00:00
/// <summary>
/// Gets the audio arguments.
/// </summary>
2013-04-29 16:01:23 +00:00
/// <param name="state">The state.</param>
2013-02-21 01:33:05 +00:00
/// <returns>System.String.</returns>
protected abstract string GetAudioArguments(StreamState state);
2013-02-21 01:33:05 +00:00
/// <summary>
/// Gets the video arguments.
/// </summary>
2013-04-29 16:01:23 +00:00
/// <param name="state">The state.</param>
2013-02-21 01:33:05 +00:00
/// <returns>System.String.</returns>
2014-06-10 17:36:06 +00:00
protected abstract string GetVideoArguments(StreamState state);
2013-02-21 01:33:05 +00:00
/// <summary>
/// Gets the segment file extension.
/// </summary>
/// <param name="state">The state.</param>
/// <returns>System.String.</returns>
protected abstract string GetSegmentFileExtension(StreamState state);
2013-04-29 16:01:23 +00:00
2013-02-21 01:33:05 +00:00
/// <summary>
/// Gets the type of the transcoding job.
/// </summary>
/// <value>The type of the transcoding job.</value>
protected override TranscodingJobType TranscodingJobType
{
get { return TranscodingJobType.Hls; }
}
/// <summary>
/// Processes the request.
2013-02-21 01:33:05 +00:00
/// </summary>
2013-04-29 16:01:23 +00:00
/// <param name="request">The request.</param>
2014-07-01 21:13:32 +00:00
/// <param name="isLive">if set to <c>true</c> [is live].</param>
/// <returns>System.Object.</returns>
2014-07-01 21:13:32 +00:00
protected object ProcessRequest(StreamRequest request, bool isLive)
2013-02-21 01:33:05 +00:00
{
2014-07-01 21:13:32 +00:00
return ProcessRequestAsync(request, isLive).Result;
2013-02-21 01:33:05 +00:00
}
/// <summary>
/// Processes the request async.
2013-02-21 01:33:05 +00:00
/// </summary>
2014-01-12 21:32:13 +00:00
/// <param name="request">The request.</param>
2014-07-01 21:13:32 +00:00
/// <param name="isLive">if set to <c>true</c> [is live].</param>
/// <returns>Task{System.Object}.</returns>
2014-07-01 21:13:32 +00:00
/// <exception cref="ArgumentException">A video bitrate is required
2014-01-12 21:32:13 +00:00
/// or
2014-07-01 21:13:32 +00:00
/// An audio bitrate is required</exception>
private async Task<object> ProcessRequestAsync(StreamRequest request, bool isLive)
2013-02-21 01:33:05 +00:00
{
2014-06-02 19:32:41 +00:00
var cancellationTokenSource = new CancellationTokenSource();
2014-06-20 04:50:30 +00:00
var state = await GetState(request, cancellationTokenSource.Token).ConfigureAwait(false);
2014-01-12 21:32:13 +00:00
2014-07-02 18:34:08 +00:00
if (isLive)
{
state.Request.StartTimeTicks = null;
}
2015-04-13 16:21:10 +00:00
TranscodingJob job = null;
var playlist = state.OutputFilePath;
2013-02-21 01:33:05 +00:00
2015-09-20 17:56:26 +00:00
if (!FileSystem.FileExists(playlist))
2014-04-15 03:54:52 +00:00
{
2014-07-02 18:34:08 +00:00
await ApiEntryPoint.Instance.TranscodingStartLock.WaitAsync(cancellationTokenSource.Token).ConfigureAwait(false);
2014-04-05 15:02:50 +00:00
try
{
2015-09-20 17:56:26 +00:00
if (!FileSystem.FileExists(playlist))
2014-04-15 03:54:52 +00:00
{
// If the playlist doesn't already exist, startup ffmpeg
try
{
2015-04-13 16:21:10 +00:00
job = await StartFfMpeg(state, playlist, cancellationTokenSource).ConfigureAwait(false);
2015-05-22 15:59:17 +00:00
job.IsLiveOutput = isLive;
2014-04-15 03:54:52 +00:00
}
catch
{
state.Dispose();
throw;
}
2015-09-09 17:49:44 +00:00
await WaitForMinimumSegmentCount(playlist, 3, cancellationTokenSource.Token).ConfigureAwait(false);
2014-06-02 19:32:41 +00:00
}
2014-04-05 15:02:50 +00:00
}
2014-04-15 03:54:52 +00:00
finally
2014-04-05 15:02:50 +00:00
{
2014-07-02 18:34:08 +00:00
ApiEntryPoint.Instance.TranscodingStartLock.Release();
2014-04-05 15:02:50 +00:00
}
2013-02-21 01:33:05 +00:00
}
2013-08-28 22:05:00 +00:00
2014-07-01 21:13:32 +00:00
if (isLive)
{
2015-04-13 16:21:10 +00:00
job = job ?? ApiEntryPoint.Instance.OnTranscodeBeginRequest(playlist, TranscodingJobType);
if (job != null)
{
ApiEntryPoint.Instance.OnTranscodeEndRequest(job);
}
2014-12-19 04:20:07 +00:00
return ResultFactory.GetResult(GetLivePlaylistText(playlist, state.SegmentLength), MimeTypes.GetMimeType("playlist.m3u8"), new Dictionary<string, string>());
2014-07-01 21:13:32 +00:00
}
var audioBitrate = state.OutputAudioBitrate ?? 0;
var videoBitrate = state.OutputVideoBitrate ?? 0;
2013-08-30 02:13:58 +00:00
2013-09-06 17:27:06 +00:00
var appendBaselineStream = false;
var baselineStreamBitrate = 64000;
2015-05-24 18:33:28 +00:00
var hlsVideoRequest = state.VideoRequest as GetHlsVideoStreamLegacy;
2013-09-06 17:27:06 +00:00
if (hlsVideoRequest != null)
{
appendBaselineStream = hlsVideoRequest.AppendBaselineStream;
baselineStreamBitrate = hlsVideoRequest.BaselineStreamAudioBitRate ?? baselineStreamBitrate;
}
var playlistText = GetMasterPlaylistFileText(playlist, videoBitrate + audioBitrate, appendBaselineStream, baselineStreamBitrate);
2013-02-21 01:33:05 +00:00
2015-04-13 16:21:10 +00:00
job = job ?? ApiEntryPoint.Instance.OnTranscodeBeginRequest(playlist, TranscodingJobType);
if (job != null)
{
ApiEntryPoint.Instance.OnTranscodeEndRequest(job);
}
2015-09-20 17:56:26 +00:00
2014-09-18 04:50:21 +00:00
return ResultFactory.GetResult(playlistText, MimeTypes.GetMimeType("playlist.m3u8"), new Dictionary<string, string>());
2013-02-21 01:33:05 +00:00
}
2013-10-07 18:22:21 +00:00
2014-12-19 04:20:07 +00:00
private string GetLivePlaylistText(string path, int segmentLength)
{
using (var stream = FileSystem.GetFileStream(path, FileMode.Open, FileAccess.Read, FileShare.ReadWrite))
{
using (var reader = new StreamReader(stream))
{
var text = reader.ReadToEnd();
2015-04-27 17:55:57 +00:00
var newDuration = "#EXT-X-TARGETDURATION:" + segmentLength.ToString(UsCulture);
2014-12-19 04:20:07 +00:00
// ffmpeg pads the reported length by a full second
2015-04-27 17:55:57 +00:00
text = text.Replace("#EXT-X-TARGETDURATION:" + (segmentLength + 1).ToString(UsCulture), newDuration, StringComparison.OrdinalIgnoreCase);
return text;
2014-12-19 04:20:07 +00:00
}
}
}
2013-09-06 17:27:06 +00:00
private string GetMasterPlaylistFileText(string firstPlaylist, int bitrate, bool includeBaselineStream, int baselineStreamBitrate)
2013-02-21 01:33:05 +00:00
{
2013-08-28 22:05:00 +00:00
var builder = new StringBuilder();
builder.AppendLine("#EXTM3U");
2013-09-03 14:37:15 +00:00
// Pad a little to satisfy the apple hls validator
2014-03-27 19:30:21 +00:00
var paddedBitrate = Convert.ToInt32(bitrate * 1.15);
2013-09-03 14:37:15 +00:00
2013-08-28 22:05:00 +00:00
// Main stream
2013-09-03 14:37:15 +00:00
builder.AppendLine("#EXT-X-STREAM-INF:PROGRAM-ID=1,BANDWIDTH=" + paddedBitrate.ToString(UsCulture));
2013-08-28 22:05:00 +00:00
var playlistUrl = "hls/" + Path.GetFileName(firstPlaylist).Replace(".m3u8", "/stream.m3u8");
builder.AppendLine(playlistUrl);
2013-02-21 01:33:05 +00:00
2013-08-28 22:05:00 +00:00
// Low bitrate stream
2013-09-06 17:27:06 +00:00
if (includeBaselineStream)
{
builder.AppendLine("#EXT-X-STREAM-INF:PROGRAM-ID=1,BANDWIDTH=" + baselineStreamBitrate.ToString(UsCulture));
playlistUrl = "hls/" + Path.GetFileName(firstPlaylist).Replace(".m3u8", "-low/stream.m3u8");
builder.AppendLine(playlistUrl);
}
2013-08-28 22:05:00 +00:00
return builder.ToString();
}
2015-03-10 04:33:51 +00:00
protected virtual async Task WaitForMinimumSegmentCount(string playlist, int segmentCount, CancellationToken cancellationToken)
2013-08-28 22:05:00 +00:00
{
2014-07-01 21:13:32 +00:00
Logger.Debug("Waiting for {0} segments in {1}", segmentCount, playlist);
2013-08-28 22:05:00 +00:00
2014-07-01 21:13:32 +00:00
while (true)
2014-06-26 17:04:11 +00:00
{
2014-07-01 21:13:32 +00:00
// Need to use FileShare.ReadWrite because we're reading the file at the same time it's being written
2015-04-02 16:26:42 +00:00
using (var fileStream = GetPlaylistFileStream(playlist))
2013-02-21 01:33:05 +00:00
{
2014-07-01 21:13:32 +00:00
using (var reader = new StreamReader(fileStream))
2013-02-21 01:33:05 +00:00
{
2014-07-01 21:13:32 +00:00
var count = 0;
while (!reader.EndOfStream)
2014-06-26 17:04:11 +00:00
{
var line = await reader.ReadLineAsync().ConfigureAwait(false);
if (line.IndexOf("#EXTINF:", StringComparison.OrdinalIgnoreCase) != -1)
{
count++;
if (count >= segmentCount)
{
2014-07-01 21:13:32 +00:00
Logger.Debug("Finished waiting for {0} segments in {1}", segmentCount, playlist);
2014-06-26 17:04:11 +00:00
return;
}
}
}
2014-07-01 21:13:32 +00:00
await Task.Delay(100, cancellationToken).ConfigureAwait(false);
2013-02-21 01:33:05 +00:00
}
}
}
}
2013-04-29 16:01:23 +00:00
2015-04-02 16:26:42 +00:00
protected Stream GetPlaylistFileStream(string path)
{
var tmpPath = path + ".tmp";
try
{
return FileSystem.GetFileStream(tmpPath, FileMode.Open, FileAccess.Read, FileShare.ReadWrite, true);
}
catch (IOException)
{
return FileSystem.GetFileStream(path, FileMode.Open, FileAccess.Read, FileShare.ReadWrite, true);
}
}
2015-03-28 20:22:27 +00:00
protected override string GetCommandLineArguments(string outputPath, StreamState state, bool isEncoding)
2013-02-21 01:33:05 +00:00
{
2015-05-24 18:33:28 +00:00
var hlsVideoRequest = state.VideoRequest as GetHlsVideoStreamLegacy;
2014-07-08 01:41:03 +00:00
var itsOffsetMs = hlsVideoRequest == null
? 0
2014-07-01 21:13:32 +00:00
: hlsVideoRequest.TimeStampOffsetMs;
2014-03-31 01:00:47 +00:00
var itsOffset = itsOffsetMs == 0 ? string.Empty : string.Format("-itsoffset {0} ", TimeSpan.FromMilliseconds(itsOffsetMs).TotalSeconds.ToString(UsCulture));
var threads = GetNumberOfThreads(state, false);
2014-01-22 01:37:01 +00:00
var inputModifier = GetInputModifier(state);
2014-01-23 18:05:41 +00:00
2014-06-19 15:41:58 +00:00
// If isEncoding is true we're actually starting ffmpeg
2014-06-10 17:36:06 +00:00
var startNumberParam = isEncoding ? GetStartNumber(state).ToString(UsCulture) : "0";
2014-04-15 03:54:52 +00:00
2014-07-01 21:13:32 +00:00
var baseUrlParam = string.Empty;
if (state.Request is GetLiveHlsStream)
{
baseUrlParam = string.Format(" -hls_base_url \"{0}/\"",
"hls/" + Path.GetFileNameWithoutExtension(outputPath));
}
2014-12-20 06:06:27 +00:00
var args = string.Format("{0} {1} {2} -map_metadata -1 -threads {3} {4} {5} -sc_threshold 0 {6} -hls_time {7} -start_number {8} -hls_list_size {9}{10} -y \"{11}\"",
itsOffset,
2014-01-22 01:37:01 +00:00
inputModifier,
2015-03-28 20:22:27 +00:00
GetInputArgument(state),
threads,
GetMapArgs(state),
2014-06-10 17:36:06 +00:00
GetVideoArguments(state),
GetAudioArguments(state),
2014-01-12 21:32:13 +00:00
state.SegmentLength.ToString(UsCulture),
2014-01-23 18:05:41 +00:00
startNumberParam,
2014-03-04 04:58:19 +00:00
state.HlsListSize.ToString(UsCulture),
2014-07-01 21:13:32 +00:00
baseUrlParam,
2013-08-28 22:05:00 +00:00
outputPath
2013-02-21 01:33:05 +00:00
).Trim();
2013-08-28 22:05:00 +00:00
2013-09-06 17:27:06 +00:00
if (hlsVideoRequest != null)
2013-08-28 22:05:00 +00:00
{
if (hlsVideoRequest.AppendBaselineStream)
2013-09-06 17:27:06 +00:00
{
var lowBitratePath = Path.Combine(Path.GetDirectoryName(outputPath), Path.GetFileNameWithoutExtension(outputPath) + "-low.m3u8");
2013-08-28 22:05:00 +00:00
2013-09-06 17:27:06 +00:00
var bitrate = hlsVideoRequest.BaselineStreamAudioBitRate ?? 64000;
2013-08-28 22:05:00 +00:00
2014-06-02 19:32:41 +00:00
var lowBitrateParams = string.Format(" -threads {0} -vn -codec:a:0 libmp3lame -ac 2 -ab {1} -hls_time {2} -start_number {3} -hls_list_size {4} -y \"{5}\"",
threads,
2014-01-12 21:32:13 +00:00
bitrate / 2,
state.SegmentLength.ToString(UsCulture),
2014-01-23 18:05:41 +00:00
startNumberParam,
2014-03-04 04:58:19 +00:00
state.HlsListSize.ToString(UsCulture),
2014-01-12 21:32:13 +00:00
lowBitratePath);
2013-09-06 17:27:06 +00:00
args += " " + lowBitrateParams;
}
2013-08-28 22:05:00 +00:00
}
return args;
2013-02-21 01:33:05 +00:00
}
2014-01-23 18:05:41 +00:00
protected virtual int GetStartNumber(StreamState state)
{
return 0;
}
2015-08-27 15:58:07 +00:00
protected override bool CanStreamCopyAudio(VideoStreamRequest request, MediaStream audioStream, List<string> supportedAudioCodecs)
{
return false;
}
2013-02-21 01:33:05 +00:00
}
2015-09-20 17:56:26 +00:00
}