|
@@ -1,27 +1,15 @@
|
|
|
-using MediaBrowser.Api.Playback;
|
|
|
-using MediaBrowser.Common.Configuration;
|
|
|
+using System;
|
|
|
using MediaBrowser.Controller.Configuration;
|
|
|
using MediaBrowser.Controller.Library;
|
|
|
+using MediaBrowser.Controller.Net;
|
|
|
using MediaBrowser.Controller.Plugins;
|
|
|
using MediaBrowser.Controller.Session;
|
|
|
-using MediaBrowser.Model.Configuration;
|
|
|
-using MediaBrowser.Model.Logging;
|
|
|
-using MediaBrowser.Model.Session;
|
|
|
-using System;
|
|
|
-using System.Collections.Concurrent;
|
|
|
-using System.Collections.Generic;
|
|
|
-using System.Diagnostics;
|
|
|
-using System.IO;
|
|
|
-using System.Linq;
|
|
|
-using System.Threading;
|
|
|
-using System.Threading.Tasks;
|
|
|
-
|
|
|
-using MediaBrowser.Controller.MediaEncoding;
|
|
|
-using MediaBrowser.Controller.Net;
|
|
|
using MediaBrowser.Model.Diagnostics;
|
|
|
using MediaBrowser.Model.IO;
|
|
|
-using MediaBrowser.Model.Dto;
|
|
|
+using MediaBrowser.Model.Logging;
|
|
|
using MediaBrowser.Model.Threading;
|
|
|
+using System.Collections.Generic;
|
|
|
+using System.Threading;
|
|
|
|
|
|
namespace MediaBrowser.Api
|
|
|
{
|
|
@@ -53,11 +41,6 @@ namespace MediaBrowser.Api
|
|
|
public readonly ITimerFactory TimerFactory;
|
|
|
public readonly IProcessFactory ProcessFactory;
|
|
|
|
|
|
- /// <summary>
|
|
|
- /// The active transcoding jobs
|
|
|
- /// </summary>
|
|
|
- private readonly List<TranscodingJob> _activeTranscodingJobs = new List<TranscodingJob>();
|
|
|
-
|
|
|
private readonly Dictionary<string, SemaphoreSlim> _transcodingLocks =
|
|
|
new Dictionary<string, SemaphoreSlim>();
|
|
|
|
|
@@ -81,39 +64,21 @@ namespace MediaBrowser.Api
|
|
|
ResultFactory = resultFactory;
|
|
|
|
|
|
Instance = this;
|
|
|
- _sessionManager.PlaybackProgress += _sessionManager_PlaybackProgress;
|
|
|
- _sessionManager.PlaybackStart += _sessionManager_PlaybackStart;
|
|
|
}
|
|
|
|
|
|
- public SemaphoreSlim GetTranscodingLock(string outputPath)
|
|
|
+ public static string[] Split(string value, char separator, bool removeEmpty)
|
|
|
{
|
|
|
- lock (_transcodingLocks)
|
|
|
+ if (string.IsNullOrWhiteSpace(value))
|
|
|
{
|
|
|
- SemaphoreSlim result;
|
|
|
- if (!_transcodingLocks.TryGetValue(outputPath, out result))
|
|
|
- {
|
|
|
- result = new SemaphoreSlim(1, 1);
|
|
|
- _transcodingLocks[outputPath] = result;
|
|
|
- }
|
|
|
-
|
|
|
- return result;
|
|
|
+ return new string[] { };
|
|
|
}
|
|
|
- }
|
|
|
|
|
|
- private void _sessionManager_PlaybackStart(object sender, PlaybackProgressEventArgs e)
|
|
|
- {
|
|
|
- if (!string.IsNullOrWhiteSpace(e.PlaySessionId))
|
|
|
+ if (removeEmpty)
|
|
|
{
|
|
|
- PingTranscodingJob(e.PlaySessionId, e.IsPaused);
|
|
|
+ return value.Split(new[] { separator }, StringSplitOptions.RemoveEmptyEntries);
|
|
|
}
|
|
|
- }
|
|
|
|
|
|
- void _sessionManager_PlaybackProgress(object sender, PlaybackProgressEventArgs e)
|
|
|
- {
|
|
|
- if (!string.IsNullOrWhiteSpace(e.PlaySessionId))
|
|
|
- {
|
|
|
- PingTranscodingJob(e.PlaySessionId, e.IsPaused);
|
|
|
- }
|
|
|
+ return value.Split(separator);
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
@@ -121,41 +86,6 @@ namespace MediaBrowser.Api
|
|
|
/// </summary>
|
|
|
public void Run()
|
|
|
{
|
|
|
- try
|
|
|
- {
|
|
|
- DeleteEncodedMediaCache();
|
|
|
- }
|
|
|
- catch (FileNotFoundException)
|
|
|
- {
|
|
|
- // Don't clutter the log
|
|
|
- }
|
|
|
- catch (IOException)
|
|
|
- {
|
|
|
- // Don't clutter the log
|
|
|
- }
|
|
|
- catch (Exception ex)
|
|
|
- {
|
|
|
- Logger.ErrorException("Error deleting encoded media cache", ex);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- public EncodingOptions GetEncodingOptions()
|
|
|
- {
|
|
|
- return _config.GetConfiguration<EncodingOptions>("encoding");
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// Deletes the encoded media cache.
|
|
|
- /// </summary>
|
|
|
- private void DeleteEncodedMediaCache()
|
|
|
- {
|
|
|
- var path = _config.ApplicationPaths.TranscodingTempPath;
|
|
|
-
|
|
|
- foreach (var file in _fileSystem.GetFilePaths(path, true)
|
|
|
- .ToList())
|
|
|
- {
|
|
|
- _fileSystem.DeleteFile(file);
|
|
|
- }
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
@@ -163,660 +93,6 @@ namespace MediaBrowser.Api
|
|
|
/// </summary>
|
|
|
public void Dispose()
|
|
|
{
|
|
|
- Dispose(true);
|
|
|
- GC.SuppressFinalize(this);
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// Releases unmanaged and - optionally - managed resources.
|
|
|
- /// </summary>
|
|
|
- /// <param name="dispose"><c>true</c> to release both managed and unmanaged resources; <c>false</c> to release only unmanaged resources.</param>
|
|
|
- protected virtual void Dispose(bool dispose)
|
|
|
- {
|
|
|
- var list = _activeTranscodingJobs.ToList();
|
|
|
- var jobCount = list.Count;
|
|
|
-
|
|
|
- Parallel.ForEach(list, j => KillTranscodingJob(j, false, path => true));
|
|
|
-
|
|
|
- // Try to allow for some time to kill the ffmpeg processes and delete the partial stream files
|
|
|
- if (jobCount > 0)
|
|
|
- {
|
|
|
- var task = Task.Delay(1000);
|
|
|
- Task.WaitAll(task);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// Called when [transcode beginning].
|
|
|
- /// </summary>
|
|
|
- /// <param name="path">The path.</param>
|
|
|
- /// <param name="playSessionId">The play session identifier.</param>
|
|
|
- /// <param name="liveStreamId">The live stream identifier.</param>
|
|
|
- /// <param name="transcodingJobId">The transcoding job identifier.</param>
|
|
|
- /// <param name="type">The type.</param>
|
|
|
- /// <param name="process">The process.</param>
|
|
|
- /// <param name="deviceId">The device id.</param>
|
|
|
- /// <param name="state">The state.</param>
|
|
|
- /// <param name="cancellationTokenSource">The cancellation token source.</param>
|
|
|
- /// <returns>TranscodingJob.</returns>
|
|
|
- public TranscodingJob OnTranscodeBeginning(string path,
|
|
|
- string playSessionId,
|
|
|
- string liveStreamId,
|
|
|
- string transcodingJobId,
|
|
|
- TranscodingJobType type,
|
|
|
- IProcess process,
|
|
|
- string deviceId,
|
|
|
- StreamState state,
|
|
|
- CancellationTokenSource cancellationTokenSource)
|
|
|
- {
|
|
|
- lock (_activeTranscodingJobs)
|
|
|
- {
|
|
|
- var job = new TranscodingJob(Logger, TimerFactory)
|
|
|
- {
|
|
|
- Type = type,
|
|
|
- Path = path,
|
|
|
- Process = process,
|
|
|
- ActiveRequestCount = 1,
|
|
|
- DeviceId = deviceId,
|
|
|
- CancellationTokenSource = cancellationTokenSource,
|
|
|
- Id = transcodingJobId,
|
|
|
- PlaySessionId = playSessionId,
|
|
|
- LiveStreamId = liveStreamId,
|
|
|
- MediaSource = state.MediaSource
|
|
|
- };
|
|
|
-
|
|
|
- _activeTranscodingJobs.Add(job);
|
|
|
-
|
|
|
- ReportTranscodingProgress(job, state, null, null, null, null, null);
|
|
|
-
|
|
|
- return job;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- public void ReportTranscodingProgress(TranscodingJob job, StreamState state, TimeSpan? transcodingPosition, float? framerate, double? percentComplete, long? bytesTranscoded, int? bitRate)
|
|
|
- {
|
|
|
- var ticks = transcodingPosition.HasValue ? transcodingPosition.Value.Ticks : (long?)null;
|
|
|
-
|
|
|
- if (job != null)
|
|
|
- {
|
|
|
- job.Framerate = framerate;
|
|
|
- job.CompletionPercentage = percentComplete;
|
|
|
- job.TranscodingPositionTicks = ticks;
|
|
|
- job.BytesTranscoded = bytesTranscoded;
|
|
|
- job.BitRate = bitRate;
|
|
|
- }
|
|
|
-
|
|
|
- var deviceId = state.Request.DeviceId;
|
|
|
-
|
|
|
- if (!string.IsNullOrWhiteSpace(deviceId))
|
|
|
- {
|
|
|
- var audioCodec = state.ActualOutputAudioCodec;
|
|
|
- var videoCodec = state.ActualOutputVideoCodec;
|
|
|
-
|
|
|
- _sessionManager.ReportTranscodingInfo(deviceId, new TranscodingInfo
|
|
|
- {
|
|
|
- Bitrate = bitRate ?? state.TotalOutputBitrate,
|
|
|
- AudioCodec = audioCodec,
|
|
|
- VideoCodec = videoCodec,
|
|
|
- Container = state.OutputContainer,
|
|
|
- Framerate = framerate,
|
|
|
- CompletionPercentage = percentComplete,
|
|
|
- Width = state.OutputWidth,
|
|
|
- Height = state.OutputHeight,
|
|
|
- AudioChannels = state.OutputAudioChannels,
|
|
|
- IsAudioDirect = string.Equals(state.OutputAudioCodec, "copy", StringComparison.OrdinalIgnoreCase),
|
|
|
- IsVideoDirect = string.Equals(state.OutputVideoCodec, "copy", StringComparison.OrdinalIgnoreCase),
|
|
|
- TranscodeReasons = state.TranscodeReasons
|
|
|
- });
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// <summary>
|
|
|
- /// The progressive
|
|
|
- /// </summary>
|
|
|
- /// Called when [transcode failed to start].
|
|
|
- /// </summary>
|
|
|
- /// <param name="path">The path.</param>
|
|
|
- /// <param name="type">The type.</param>
|
|
|
- /// <param name="state">The state.</param>
|
|
|
- public void OnTranscodeFailedToStart(string path, TranscodingJobType type, StreamState state)
|
|
|
- {
|
|
|
- lock (_activeTranscodingJobs)
|
|
|
- {
|
|
|
- var job = _activeTranscodingJobs.FirstOrDefault(j => j.Type == type && string.Equals(j.Path, path, StringComparison.OrdinalIgnoreCase));
|
|
|
-
|
|
|
- if (job != null)
|
|
|
- {
|
|
|
- _activeTranscodingJobs.Remove(job);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- lock (_transcodingLocks)
|
|
|
- {
|
|
|
- _transcodingLocks.Remove(path);
|
|
|
- }
|
|
|
-
|
|
|
- if (!string.IsNullOrWhiteSpace(state.Request.DeviceId))
|
|
|
- {
|
|
|
- _sessionManager.ClearTranscodingInfo(state.Request.DeviceId);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// Determines whether [has active transcoding job] [the specified path].
|
|
|
- /// </summary>
|
|
|
- /// <param name="path">The path.</param>
|
|
|
- /// <param name="type">The type.</param>
|
|
|
- /// <returns><c>true</c> if [has active transcoding job] [the specified path]; otherwise, <c>false</c>.</returns>
|
|
|
- public bool HasActiveTranscodingJob(string path, TranscodingJobType type)
|
|
|
- {
|
|
|
- return GetTranscodingJob(path, type) != null;
|
|
|
- }
|
|
|
-
|
|
|
- public TranscodingJob GetTranscodingJob(string path, TranscodingJobType type)
|
|
|
- {
|
|
|
- lock (_activeTranscodingJobs)
|
|
|
- {
|
|
|
- return _activeTranscodingJobs.FirstOrDefault(j => j.Type == type && string.Equals(j.Path, path, StringComparison.OrdinalIgnoreCase));
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- public TranscodingJob GetTranscodingJob(string playSessionId)
|
|
|
- {
|
|
|
- lock (_activeTranscodingJobs)
|
|
|
- {
|
|
|
- return _activeTranscodingJobs.FirstOrDefault(j => string.Equals(j.PlaySessionId, playSessionId, StringComparison.OrdinalIgnoreCase));
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// Called when [transcode begin request].
|
|
|
- /// </summary>
|
|
|
- /// <param name="path">The path.</param>
|
|
|
- /// <param name="type">The type.</param>
|
|
|
- public TranscodingJob OnTranscodeBeginRequest(string path, TranscodingJobType type)
|
|
|
- {
|
|
|
- lock (_activeTranscodingJobs)
|
|
|
- {
|
|
|
- var job = _activeTranscodingJobs.FirstOrDefault(j => j.Type == type && string.Equals(j.Path, path, StringComparison.OrdinalIgnoreCase));
|
|
|
-
|
|
|
- if (job == null)
|
|
|
- {
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- OnTranscodeBeginRequest(job);
|
|
|
-
|
|
|
- return job;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- public void OnTranscodeBeginRequest(TranscodingJob job)
|
|
|
- {
|
|
|
- job.ActiveRequestCount++;
|
|
|
-
|
|
|
- if (string.IsNullOrWhiteSpace(job.PlaySessionId) || job.Type == TranscodingJobType.Progressive)
|
|
|
- {
|
|
|
- job.StopKillTimer();
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- public void OnTranscodeEndRequest(TranscodingJob job)
|
|
|
- {
|
|
|
- job.ActiveRequestCount--;
|
|
|
- //Logger.Debug("OnTranscodeEndRequest job.ActiveRequestCount={0}", job.ActiveRequestCount);
|
|
|
- if (job.ActiveRequestCount <= 0)
|
|
|
- {
|
|
|
- PingTimer(job, false);
|
|
|
- }
|
|
|
- }
|
|
|
- internal void PingTranscodingJob(string playSessionId, bool? isUserPaused)
|
|
|
- {
|
|
|
- if (string.IsNullOrEmpty(playSessionId))
|
|
|
- {
|
|
|
- throw new ArgumentNullException("playSessionId");
|
|
|
- }
|
|
|
-
|
|
|
- //Logger.Debug("PingTranscodingJob PlaySessionId={0} isUsedPaused: {1}", playSessionId, isUserPaused);
|
|
|
-
|
|
|
- List<TranscodingJob> jobs;
|
|
|
-
|
|
|
- lock (_activeTranscodingJobs)
|
|
|
- {
|
|
|
- // This is really only needed for HLS.
|
|
|
- // Progressive streams can stop on their own reliably
|
|
|
- jobs = _activeTranscodingJobs.Where(j => string.Equals(playSessionId, j.PlaySessionId, StringComparison.OrdinalIgnoreCase)).ToList();
|
|
|
- }
|
|
|
-
|
|
|
- foreach (var job in jobs)
|
|
|
- {
|
|
|
- if (isUserPaused.HasValue)
|
|
|
- {
|
|
|
- //Logger.Debug("Setting job.IsUserPaused to {0}. jobId: {1}", isUserPaused, job.Id);
|
|
|
- job.IsUserPaused = isUserPaused.Value;
|
|
|
- }
|
|
|
- PingTimer(job, true);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- private void PingTimer(TranscodingJob job, bool isProgressCheckIn)
|
|
|
- {
|
|
|
- if (job.HasExited)
|
|
|
- {
|
|
|
- job.StopKillTimer();
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- var timerDuration = 10000;
|
|
|
-
|
|
|
- if (job.Type != TranscodingJobType.Progressive)
|
|
|
- {
|
|
|
- timerDuration = 60000;
|
|
|
- }
|
|
|
-
|
|
|
- job.PingTimeout = timerDuration;
|
|
|
- job.LastPingDate = DateTime.UtcNow;
|
|
|
-
|
|
|
- // Don't start the timer for playback checkins with progressive streaming
|
|
|
- if (job.Type != TranscodingJobType.Progressive || !isProgressCheckIn)
|
|
|
- {
|
|
|
- job.StartKillTimer(OnTranscodeKillTimerStopped);
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- job.ChangeKillTimerIfStarted();
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// Called when [transcode kill timer stopped].
|
|
|
- /// </summary>
|
|
|
- /// <param name="state">The state.</param>
|
|
|
- private void OnTranscodeKillTimerStopped(object state)
|
|
|
- {
|
|
|
- var job = (TranscodingJob)state;
|
|
|
-
|
|
|
- if (!job.HasExited && job.Type != TranscodingJobType.Progressive)
|
|
|
- {
|
|
|
- var timeSinceLastPing = (DateTime.UtcNow - job.LastPingDate).TotalMilliseconds;
|
|
|
-
|
|
|
- if (timeSinceLastPing < job.PingTimeout)
|
|
|
- {
|
|
|
- job.StartKillTimer(OnTranscodeKillTimerStopped, job.PingTimeout);
|
|
|
- return;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- Logger.Info("Transcoding kill timer stopped for JobId {0} PlaySessionId {1}. Killing transcoding", job.Id, job.PlaySessionId);
|
|
|
-
|
|
|
- KillTranscodingJob(job, true, path => true);
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// Kills the single transcoding job.
|
|
|
- /// </summary>
|
|
|
- /// <param name="deviceId">The device id.</param>
|
|
|
- /// <param name="playSessionId">The play session identifier.</param>
|
|
|
- /// <param name="deleteFiles">The delete files.</param>
|
|
|
- /// <returns>Task.</returns>
|
|
|
- internal void KillTranscodingJobs(string deviceId, string playSessionId, Func<string, bool> deleteFiles)
|
|
|
- {
|
|
|
- KillTranscodingJobs(j =>
|
|
|
- {
|
|
|
- if (!string.IsNullOrWhiteSpace(playSessionId))
|
|
|
- {
|
|
|
- return string.Equals(playSessionId, j.PlaySessionId, StringComparison.OrdinalIgnoreCase);
|
|
|
- }
|
|
|
-
|
|
|
- return string.Equals(deviceId, j.DeviceId, StringComparison.OrdinalIgnoreCase);
|
|
|
-
|
|
|
- }, deleteFiles);
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// Kills the transcoding jobs.
|
|
|
- /// </summary>
|
|
|
- /// <param name="killJob">The kill job.</param>
|
|
|
- /// <param name="deleteFiles">The delete files.</param>
|
|
|
- /// <returns>Task.</returns>
|
|
|
- private void KillTranscodingJobs(Func<TranscodingJob, bool> killJob, Func<string, bool> deleteFiles)
|
|
|
- {
|
|
|
- var jobs = new List<TranscodingJob>();
|
|
|
-
|
|
|
- lock (_activeTranscodingJobs)
|
|
|
- {
|
|
|
- // This is really only needed for HLS.
|
|
|
- // Progressive streams can stop on their own reliably
|
|
|
- jobs.AddRange(_activeTranscodingJobs.Where(killJob));
|
|
|
- }
|
|
|
-
|
|
|
- if (jobs.Count == 0)
|
|
|
- {
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- foreach (var job in jobs)
|
|
|
- {
|
|
|
- KillTranscodingJob(job, false, deleteFiles);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// Kills the transcoding job.
|
|
|
- /// </summary>
|
|
|
- /// <param name="job">The job.</param>
|
|
|
- /// <param name="closeLiveStream">if set to <c>true</c> [close live stream].</param>
|
|
|
- /// <param name="delete">The delete.</param>
|
|
|
- private async void KillTranscodingJob(TranscodingJob job, bool closeLiveStream, Func<string, bool> delete)
|
|
|
- {
|
|
|
- job.DisposeKillTimer();
|
|
|
-
|
|
|
- Logger.Debug("KillTranscodingJob - JobId {0} PlaySessionId {1}. Killing transcoding", job.Id, job.PlaySessionId);
|
|
|
-
|
|
|
- lock (_activeTranscodingJobs)
|
|
|
- {
|
|
|
- _activeTranscodingJobs.Remove(job);
|
|
|
-
|
|
|
- if (!job.CancellationTokenSource.IsCancellationRequested)
|
|
|
- {
|
|
|
- job.CancellationTokenSource.Cancel();
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- lock (_transcodingLocks)
|
|
|
- {
|
|
|
- _transcodingLocks.Remove(job.Path);
|
|
|
- }
|
|
|
-
|
|
|
- lock (job.ProcessLock)
|
|
|
- {
|
|
|
- if (job.TranscodingThrottler != null)
|
|
|
- {
|
|
|
- job.TranscodingThrottler.Stop();
|
|
|
- }
|
|
|
-
|
|
|
- var process = job.Process;
|
|
|
-
|
|
|
- var hasExited = job.HasExited;
|
|
|
-
|
|
|
- if (!hasExited)
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- Logger.Info("Stopping ffmpeg process with q command for {0}", job.Path);
|
|
|
-
|
|
|
- //process.Kill();
|
|
|
- process.StandardInput.WriteLine("q");
|
|
|
-
|
|
|
- // Need to wait because killing is asynchronous
|
|
|
- if (!process.WaitForExit(5000))
|
|
|
- {
|
|
|
- Logger.Info("Killing ffmpeg process for {0}", job.Path);
|
|
|
- process.Kill();
|
|
|
- }
|
|
|
- }
|
|
|
- catch (Exception ex)
|
|
|
- {
|
|
|
- Logger.ErrorException("Error killing transcoding job for {0}", ex, job.Path);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- if (delete(job.Path))
|
|
|
- {
|
|
|
- DeletePartialStreamFiles(job.Path, job.Type, 0, 1500);
|
|
|
- }
|
|
|
-
|
|
|
- if (closeLiveStream && !string.IsNullOrWhiteSpace(job.LiveStreamId))
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- await _mediaSourceManager.CloseLiveStream(job.LiveStreamId).ConfigureAwait(false);
|
|
|
- }
|
|
|
- catch (Exception ex)
|
|
|
- {
|
|
|
- Logger.ErrorException("Error closing live stream for {0}", ex, job.Path);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- private async void DeletePartialStreamFiles(string path, TranscodingJobType jobType, int retryCount, int delayMs)
|
|
|
- {
|
|
|
- if (retryCount >= 10)
|
|
|
- {
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- Logger.Info("Deleting partial stream file(s) {0}", path);
|
|
|
-
|
|
|
- await Task.Delay(delayMs).ConfigureAwait(false);
|
|
|
-
|
|
|
- try
|
|
|
- {
|
|
|
- if (jobType == TranscodingJobType.Progressive)
|
|
|
- {
|
|
|
- DeleteProgressivePartialStreamFiles(path);
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- DeleteHlsPartialStreamFiles(path);
|
|
|
- }
|
|
|
- }
|
|
|
- catch (FileNotFoundException)
|
|
|
- {
|
|
|
-
|
|
|
- }
|
|
|
- catch (IOException)
|
|
|
- {
|
|
|
- //Logger.ErrorException("Error deleting partial stream file(s) {0}", ex, path);
|
|
|
-
|
|
|
- DeletePartialStreamFiles(path, jobType, retryCount + 1, 500);
|
|
|
- }
|
|
|
- catch
|
|
|
- {
|
|
|
- //Logger.ErrorException("Error deleting partial stream file(s) {0}", ex, path);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// Deletes the progressive partial stream files.
|
|
|
- /// </summary>
|
|
|
- /// <param name="outputFilePath">The output file path.</param>
|
|
|
- private void DeleteProgressivePartialStreamFiles(string outputFilePath)
|
|
|
- {
|
|
|
- _fileSystem.DeleteFile(outputFilePath);
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// Deletes the HLS partial stream files.
|
|
|
- /// </summary>
|
|
|
- /// <param name="outputFilePath">The output file path.</param>
|
|
|
- private void DeleteHlsPartialStreamFiles(string outputFilePath)
|
|
|
- {
|
|
|
- var directory = _fileSystem.GetDirectoryName(outputFilePath);
|
|
|
- var name = Path.GetFileNameWithoutExtension(outputFilePath);
|
|
|
-
|
|
|
- var filesToDelete = _fileSystem.GetFilePaths(directory)
|
|
|
- .Where(f => f.IndexOf(name, StringComparison.OrdinalIgnoreCase) != -1)
|
|
|
- .ToList();
|
|
|
-
|
|
|
- Exception e = null;
|
|
|
-
|
|
|
- foreach (var file in filesToDelete)
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- //Logger.Debug("Deleting HLS file {0}", file);
|
|
|
- _fileSystem.DeleteFile(file);
|
|
|
- }
|
|
|
- catch (FileNotFoundException)
|
|
|
- {
|
|
|
-
|
|
|
- }
|
|
|
- catch (IOException ex)
|
|
|
- {
|
|
|
- e = ex;
|
|
|
- //Logger.ErrorException("Error deleting HLS file {0}", ex, file);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- if (e != null)
|
|
|
- {
|
|
|
- throw e;
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// Class TranscodingJob
|
|
|
- /// </summary>
|
|
|
- public class TranscodingJob
|
|
|
- {
|
|
|
- /// <summary>
|
|
|
- /// Gets or sets the play session identifier.
|
|
|
- /// </summary>
|
|
|
- /// <value>The play session identifier.</value>
|
|
|
- public string PlaySessionId { get; set; }
|
|
|
- /// <summary>
|
|
|
- /// Gets or sets the live stream identifier.
|
|
|
- /// </summary>
|
|
|
- /// <value>The live stream identifier.</value>
|
|
|
- public string LiveStreamId { get; set; }
|
|
|
-
|
|
|
- public bool IsLiveOutput { get; set; }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// Gets or sets the path.
|
|
|
- /// </summary>
|
|
|
- /// <value>The path.</value>
|
|
|
- public MediaSourceInfo MediaSource { get; set; }
|
|
|
- public string Path { get; set; }
|
|
|
- /// <summary>
|
|
|
- /// Gets or sets the type.
|
|
|
- /// </summary>
|
|
|
- /// <value>The type.</value>
|
|
|
- public TranscodingJobType Type { get; set; }
|
|
|
- /// <summary>
|
|
|
- /// Gets or sets the process.
|
|
|
- /// </summary>
|
|
|
- /// <value>The process.</value>
|
|
|
- public IProcess Process { get; set; }
|
|
|
- public ILogger Logger { get; private set; }
|
|
|
- /// <summary>
|
|
|
- /// Gets or sets the active request count.
|
|
|
- /// </summary>
|
|
|
- /// <value>The active request count.</value>
|
|
|
- public int ActiveRequestCount { get; set; }
|
|
|
- /// <summary>
|
|
|
- /// Gets or sets the kill timer.
|
|
|
- /// </summary>
|
|
|
- /// <value>The kill timer.</value>
|
|
|
- private ITimer KillTimer { get; set; }
|
|
|
-
|
|
|
- private readonly ITimerFactory _timerFactory;
|
|
|
-
|
|
|
- public string DeviceId { get; set; }
|
|
|
-
|
|
|
- public CancellationTokenSource CancellationTokenSource { get; set; }
|
|
|
-
|
|
|
- public object ProcessLock = new object();
|
|
|
-
|
|
|
- public bool HasExited { get; set; }
|
|
|
- public bool IsUserPaused { get; set; }
|
|
|
-
|
|
|
- public string Id { get; set; }
|
|
|
-
|
|
|
- public float? Framerate { get; set; }
|
|
|
- public double? CompletionPercentage { get; set; }
|
|
|
-
|
|
|
- public long? BytesDownloaded { get; set; }
|
|
|
- public long? BytesTranscoded { get; set; }
|
|
|
- public int? BitRate { get; set; }
|
|
|
-
|
|
|
- public long? TranscodingPositionTicks { get; set; }
|
|
|
- public long? DownloadPositionTicks { get; set; }
|
|
|
-
|
|
|
- public TranscodingThrottler TranscodingThrottler { get; set; }
|
|
|
-
|
|
|
- private readonly object _timerLock = new object();
|
|
|
-
|
|
|
- public DateTime LastPingDate { get; set; }
|
|
|
- public int PingTimeout { get; set; }
|
|
|
-
|
|
|
- public TranscodingJob(ILogger logger, ITimerFactory timerFactory)
|
|
|
- {
|
|
|
- Logger = logger;
|
|
|
- _timerFactory = timerFactory;
|
|
|
- }
|
|
|
-
|
|
|
- public void StopKillTimer()
|
|
|
- {
|
|
|
- lock (_timerLock)
|
|
|
- {
|
|
|
- if (KillTimer != null)
|
|
|
- {
|
|
|
- KillTimer.Change(Timeout.Infinite, Timeout.Infinite);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- public void DisposeKillTimer()
|
|
|
- {
|
|
|
- lock (_timerLock)
|
|
|
- {
|
|
|
- if (KillTimer != null)
|
|
|
- {
|
|
|
- KillTimer.Dispose();
|
|
|
- KillTimer = null;
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- public void StartKillTimer(Action<object> callback)
|
|
|
- {
|
|
|
- StartKillTimer(callback, PingTimeout);
|
|
|
- }
|
|
|
-
|
|
|
- public void StartKillTimer(Action<object> callback, int intervalMs)
|
|
|
- {
|
|
|
- if (HasExited)
|
|
|
- {
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- lock (_timerLock)
|
|
|
- {
|
|
|
- if (KillTimer == null)
|
|
|
- {
|
|
|
- //Logger.Debug("Starting kill timer at {0}ms. JobId {1} PlaySessionId {2}", intervalMs, Id, PlaySessionId);
|
|
|
- KillTimer = _timerFactory.Create(callback, this, intervalMs, Timeout.Infinite);
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- //Logger.Debug("Changing kill timer to {0}ms. JobId {1} PlaySessionId {2}", intervalMs, Id, PlaySessionId);
|
|
|
- KillTimer.Change(intervalMs, Timeout.Infinite);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- public void ChangeKillTimerIfStarted()
|
|
|
- {
|
|
|
- if (HasExited)
|
|
|
- {
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- lock (_timerLock)
|
|
|
- {
|
|
|
- if (KillTimer != null)
|
|
|
- {
|
|
|
- var intervalMs = PingTimeout;
|
|
|
-
|
|
|
- //Logger.Debug("Changing kill timer to {0}ms. JobId {1} PlaySessionId {2}", intervalMs, Id, PlaySessionId);
|
|
|
- KillTimer.Change(intervalMs, Timeout.Infinite);
|
|
|
- }
|
|
|
- }
|
|
|
}
|
|
|
}
|
|
|
}
|