jellyfin-server/MediaBrowser.Api/Playback/StreamState.cs

513 lines
15 KiB
C#
Raw Normal View History

2015-03-28 20:22:27 +00:00
using MediaBrowser.Controller.Library;
2014-04-01 22:23:07 +00:00
using MediaBrowser.Model.Dlna;
using MediaBrowser.Model.Drawing;
2015-03-28 20:22:27 +00:00
using MediaBrowser.Model.Dto;
using MediaBrowser.Model.Entities;
2013-08-10 01:16:31 +00:00
using MediaBrowser.Model.IO;
2014-04-05 15:02:50 +00:00
using MediaBrowser.Model.Logging;
2014-04-25 17:30:41 +00:00
using MediaBrowser.Model.MediaInfo;
2015-02-28 18:47:05 +00:00
using MediaBrowser.Model.Net;
2014-04-05 15:02:50 +00:00
using System;
2013-12-19 21:51:32 +00:00
using System.Collections.Generic;
2014-04-25 17:30:41 +00:00
using System.Globalization;
2013-12-19 21:51:32 +00:00
using System.IO;
2014-01-12 21:32:13 +00:00
using System.Threading;
2013-02-27 04:19:05 +00:00
namespace MediaBrowser.Api.Playback
{
2014-04-05 15:02:50 +00:00
public class StreamState : IDisposable
2013-02-27 04:19:05 +00:00
{
2014-04-05 15:02:50 +00:00
private readonly ILogger _logger;
2015-03-28 20:22:27 +00:00
private readonly IMediaSourceManager _mediaSourceManager;
2014-04-05 15:02:50 +00:00
2013-12-19 21:51:32 +00:00
public string RequestedUrl { get; set; }
2013-02-27 04:19:05 +00:00
public StreamRequest Request { get; set; }
2015-02-28 18:47:05 +00:00
public TranscodingThrottler TranscodingThrottler { get; set; }
2013-02-27 04:19:05 +00:00
2013-03-09 02:34:54 +00:00
public VideoStreamRequest VideoRequest
{
2014-01-22 17:05:32 +00:00
get { return Request as VideoStreamRequest; }
2013-03-09 02:34:54 +00:00
}
2014-06-02 19:32:41 +00:00
public Dictionary<string, string> RemoteHttpHeaders { get; set; }
2013-02-27 04:19:05 +00:00
/// <summary>
/// Gets or sets the log file stream.
/// </summary>
/// <value>The log file stream.</value>
public Stream LogFileStream { get; set; }
public string InputContainer { get; set; }
2014-06-02 19:32:41 +00:00
2015-03-28 20:22:27 +00:00
public MediaSourceInfo MediaSource { get; set; }
2015-05-24 18:33:28 +00:00
2013-02-27 04:19:05 +00:00
public MediaStream AudioStream { get; set; }
public MediaStream VideoStream { get; set; }
public MediaStream SubtitleStream { get; set; }
/// <summary>
/// Gets or sets the iso mount.
/// </summary>
/// <value>The iso mount.</value>
public IIsoMount IsoMount { get; set; }
2013-12-19 21:51:32 +00:00
public string MediaPath { get; set; }
2015-03-18 06:02:22 +00:00
public string WaitForPath { get; set; }
2013-12-19 21:51:32 +00:00
public MediaProtocol InputProtocol { get; set; }
2013-12-19 21:51:32 +00:00
2015-05-24 18:33:28 +00:00
public bool IsOutputVideo
{
get { return Request is VideoStreamRequest; }
}
2013-12-19 21:51:32 +00:00
public bool IsInputVideo { get; set; }
2015-03-17 02:46:21 +00:00
public bool IsInputArchive { get; set; }
2013-12-19 21:51:32 +00:00
public VideoType VideoType { get; set; }
public IsoType? IsoType { get; set; }
public List<string> PlayableStreamFileNames { get; set; }
2013-12-21 18:37:34 +00:00
2016-04-20 18:51:47 +00:00
public int SegmentLength
{
get
{
if (string.Equals(OutputVideoCodec, "copy", StringComparison.OrdinalIgnoreCase))
{
2016-06-30 21:26:43 +00:00
var userAgent = UserAgent ?? string.Empty;
if (userAgent.IndexOf("AppleTV", StringComparison.OrdinalIgnoreCase) != -1)
{
return 10;
}
2016-08-05 05:12:25 +00:00
if (userAgent.IndexOf("cfnetwork", StringComparison.OrdinalIgnoreCase) != -1 ||
userAgent.IndexOf("ipad", StringComparison.OrdinalIgnoreCase) != -1 ||
userAgent.IndexOf("iphone", StringComparison.OrdinalIgnoreCase) != -1 ||
userAgent.IndexOf("ipod", StringComparison.OrdinalIgnoreCase) != -1)
2016-07-23 05:03:16 +00:00
{
return 10;
}
2016-06-30 21:26:43 +00:00
return 6;
2016-04-20 18:51:47 +00:00
}
return 3;
}
}
2014-10-16 03:26:39 +00:00
public int HlsListSize
{
2014-11-11 03:41:55 +00:00
get
{
2015-09-09 17:49:44 +00:00
return 0;
2014-11-11 03:41:55 +00:00
}
2014-10-16 03:26:39 +00:00
}
2014-01-12 21:32:13 +00:00
public long? RunTimeTicks;
2014-01-15 05:05:19 +00:00
2014-08-29 12:14:41 +00:00
public long? InputBitrate { get; set; }
public long? InputFileSize { get; set; }
2014-08-29 12:14:41 +00:00
public string OutputAudioSync = "1";
2016-05-23 03:54:36 +00:00
public string OutputVideoSync = "-1";
2014-01-20 15:04:50 +00:00
2014-04-10 15:06:54 +00:00
public List<string> SupportedAudioCodecs { get; set; }
2016-09-05 05:39:14 +00:00
public List<string> SupportedVideoCodecs { get; set; }
2016-06-30 21:26:43 +00:00
public string UserAgent { get; set; }
2014-04-10 15:06:54 +00:00
2015-03-28 20:22:27 +00:00
public StreamState(IMediaSourceManager mediaSourceManager, ILogger logger)
2014-04-05 15:02:50 +00:00
{
2015-03-28 20:22:27 +00:00
_mediaSourceManager = mediaSourceManager;
2014-04-05 15:02:50 +00:00
_logger = logger;
2014-04-10 15:06:54 +00:00
SupportedAudioCodecs = new List<string>();
2016-09-05 05:39:14 +00:00
SupportedVideoCodecs = new List<string>();
2014-06-04 19:40:05 +00:00
PlayableStreamFileNames = new List<string>();
RemoteHttpHeaders = new Dictionary<string, string>(StringComparer.OrdinalIgnoreCase);
2014-04-05 15:02:50 +00:00
}
2014-03-21 04:52:28 +00:00
public string InputAudioSync { get; set; }
public string InputVideoSync { get; set; }
2014-01-20 15:04:50 +00:00
public bool DeInterlace { get; set; }
2014-10-16 03:26:39 +00:00
2014-10-25 18:32:58 +00:00
public bool ReadInputAtNativeFramerate { get; set; }
public TransportStreamTimestamp InputTimestamp { get; set; }
2014-03-25 05:25:03 +00:00
public string MimeType { get; set; }
public bool EstimateContentLength { get; set; }
public bool EnableMpegtsM2TsMode { get; set; }
public TranscodeSeekInfo TranscodeSeekInfo { get; set; }
2014-06-28 19:35:30 +00:00
public long? EncodingDurationTicks { get; set; }
public string GetMimeType(string outputPath)
{
2014-03-25 05:25:03 +00:00
if (!string.IsNullOrEmpty(MimeType))
{
return MimeType;
}
return MimeTypes.GetMimeType(outputPath);
}
2014-04-05 15:02:50 +00:00
public void Dispose()
{
2015-02-28 18:47:05 +00:00
DisposeTranscodingThrottler();
2014-04-05 15:02:50 +00:00
DisposeLiveStream();
DisposeLogStream();
DisposeIsoMount();
}
private void DisposeLogStream()
{
if (LogFileStream != null)
{
2014-04-06 17:53:23 +00:00
try
{
LogFileStream.Dispose();
}
catch (Exception ex)
{
_logger.ErrorException("Error disposing log stream", ex);
}
2014-04-05 15:02:50 +00:00
LogFileStream = null;
}
}
2015-02-28 18:47:05 +00:00
private void DisposeTranscodingThrottler()
{
if (TranscodingThrottler != null)
{
try
{
TranscodingThrottler.Dispose();
}
catch (Exception ex)
{
_logger.ErrorException("Error disposing TranscodingThrottler", ex);
}
TranscodingThrottler = null;
}
}
2014-04-05 15:02:50 +00:00
private void DisposeIsoMount()
{
if (IsoMount != null)
{
2014-04-06 17:53:23 +00:00
try
{
IsoMount.Dispose();
}
catch (Exception ex)
{
_logger.ErrorException("Error disposing iso mount", ex);
}
2014-04-05 15:02:50 +00:00
IsoMount = null;
}
}
private async void DisposeLiveStream()
{
2016-07-28 06:29:14 +00:00
if (MediaSource.RequiresClosing && string.IsNullOrWhiteSpace(Request.LiveStreamId) && !string.IsNullOrWhiteSpace(MediaSource.LiveStreamId))
2014-04-05 15:02:50 +00:00
{
try
{
2015-03-29 04:56:39 +00:00
await _mediaSourceManager.CloseLiveStream(MediaSource.LiveStreamId, CancellationToken.None).ConfigureAwait(false);
2014-04-05 15:02:50 +00:00
}
catch (Exception ex)
{
2015-03-28 20:22:27 +00:00
_logger.ErrorException("Error closing media source", ex);
2014-04-05 15:02:50 +00:00
}
}
}
2014-06-12 02:38:40 +00:00
public int InternalSubtitleStreamOffset { get; set; }
public string OutputFilePath { get; set; }
public string OutputVideoCodec { get; set; }
public string OutputAudioCodec { get; set; }
public int? OutputAudioChannels;
public int? OutputAudioSampleRate;
public int? OutputAudioBitrate;
public int? OutputVideoBitrate;
2014-10-20 03:04:45 +00:00
public string ActualOutputVideoCodec
{
get
{
var codec = OutputVideoCodec;
if (string.Equals(codec, "copy", StringComparison.OrdinalIgnoreCase))
{
var stream = VideoStream;
if (stream != null)
{
return stream.Codec;
}
return null;
}
return codec;
}
}
public string ActualOutputAudioCodec
{
get
{
var codec = OutputAudioCodec;
if (string.Equals(codec, "copy", StringComparison.OrdinalIgnoreCase))
{
var stream = AudioStream;
if (stream != null)
{
return stream.Codec;
}
return null;
}
return codec;
}
}
public string OutputContainer { get; set; }
2014-04-23 02:47:46 +00:00
public DeviceProfile DeviceProfile { get; set; }
public int? TotalOutputBitrate
{
get
{
return (OutputAudioBitrate ?? 0) + (OutputVideoBitrate ?? 0);
}
}
public int? OutputWidth
{
get
{
if (VideoStream != null && VideoStream.Width.HasValue && VideoStream.Height.HasValue)
{
var size = new ImageSize
{
Width = VideoStream.Width.Value,
Height = VideoStream.Height.Value
};
var newSize = DrawingUtils.Resize(size,
VideoRequest.Width,
VideoRequest.Height,
VideoRequest.MaxWidth,
VideoRequest.MaxHeight);
return Convert.ToInt32(newSize.Width);
}
2014-06-06 17:14:02 +00:00
if (VideoRequest == null)
{
return null;
}
return VideoRequest.MaxWidth ?? VideoRequest.Width;
}
}
public int? OutputHeight
{
get
{
if (VideoStream != null && VideoStream.Width.HasValue && VideoStream.Height.HasValue)
{
var size = new ImageSize
{
Width = VideoStream.Width.Value,
Height = VideoStream.Height.Value
};
var newSize = DrawingUtils.Resize(size,
VideoRequest.Width,
VideoRequest.Height,
VideoRequest.MaxWidth,
VideoRequest.MaxHeight);
return Convert.ToInt32(newSize.Height);
}
2014-06-06 17:14:02 +00:00
if (VideoRequest == null)
{
return null;
}
return VideoRequest.MaxHeight ?? VideoRequest.Height;
}
}
2014-04-24 05:08:10 +00:00
/// <summary>
/// Predicts the audio sample rate that will be in the output stream
/// </summary>
public int? TargetVideoBitDepth
{
get
{
var stream = VideoStream;
return stream == null || !Request.Static ? null : stream.BitDepth;
}
}
2014-09-09 01:15:31 +00:00
/// <summary>
/// Gets the target reference frames.
/// </summary>
/// <value>The target reference frames.</value>
public int? TargetRefFrames
{
get
{
var stream = VideoStream;
return stream == null || !Request.Static ? null : stream.RefFrames;
}
}
public int? TargetVideoStreamCount
{
get
{
if (Request.Static)
{
return GetMediaStreamCount(MediaStreamType.Video, int.MaxValue);
}
return GetMediaStreamCount(MediaStreamType.Video, 1);
}
}
public int? TargetAudioStreamCount
{
get
{
if (Request.Static)
{
return GetMediaStreamCount(MediaStreamType.Audio, int.MaxValue);
}
return GetMediaStreamCount(MediaStreamType.Audio, 1);
}
}
private int? GetMediaStreamCount(MediaStreamType type, int limit)
{
var count = MediaSource.GetStreamCount(type);
if (count.HasValue)
{
count = Math.Min(count.Value, limit);
}
return count;
}
2014-04-24 05:08:10 +00:00
/// <summary>
/// Predicts the audio sample rate that will be in the output stream
/// </summary>
2014-06-23 16:05:19 +00:00
public float? TargetFramerate
2014-04-24 05:08:10 +00:00
{
get
{
var stream = VideoStream;
var requestedFramerate = VideoRequest.MaxFramerate ?? VideoRequest.Framerate;
return requestedFramerate.HasValue && !Request.Static
? requestedFramerate
: stream == null ? null : stream.AverageFrameRate ?? stream.RealFrameRate;
}
}
/// <summary>
/// Predicts the audio sample rate that will be in the output stream
/// </summary>
public double? TargetVideoLevel
{
get
{
var stream = VideoStream;
return !string.IsNullOrEmpty(VideoRequest.Level) && !Request.Static
? double.Parse(VideoRequest.Level, CultureInfo.InvariantCulture)
: stream == null ? null : stream.Level;
}
}
public TransportStreamTimestamp TargetTimestamp
{
get
{
2014-06-02 19:32:41 +00:00
var defaultValue = string.Equals(OutputContainer, "m2ts", StringComparison.OrdinalIgnoreCase) ?
TransportStreamTimestamp.Valid :
2014-04-25 02:45:06 +00:00
TransportStreamTimestamp.None;
2014-04-24 05:08:10 +00:00
return !Request.Static
? defaultValue
: InputTimestamp;
2014-04-24 05:08:10 +00:00
}
}
/// <summary>
/// Predicts the audio sample rate that will be in the output stream
/// </summary>
public int? TargetPacketLength
{
get
{
var stream = VideoStream;
return !Request.Static
? null
: stream == null ? null : stream.PacketLength;
}
}
/// <summary>
/// Predicts the audio sample rate that will be in the output stream
/// </summary>
public string TargetVideoProfile
{
get
{
var stream = VideoStream;
return !string.IsNullOrEmpty(VideoRequest.Profile) && !Request.Static
? VideoRequest.Profile
: stream == null ? null : stream.Profile;
}
}
2015-10-19 16:05:03 +00:00
public string TargetVideoCodecTag
{
get
{
var stream = VideoStream;
return !Request.Static
? null
: stream == null ? null : stream.CodecTag;
}
}
2014-06-22 16:25:47 +00:00
public bool? IsTargetAnamorphic
{
get
{
if (Request.Static)
{
return VideoStream == null ? null : VideoStream.IsAnamorphic;
}
return false;
}
}
2013-02-27 04:19:05 +00:00
}
}