jellyfin/MediaBrowser.Api/LiveTv/ProgressiveFileCopier.cs

165 lines
5.9 KiB
C#
Raw Normal View History

using System;
using System.Collections.Generic;
2013-02-27 04:19:05 +00:00
using System.IO;
2016-07-24 16:46:17 +00:00
using System.Threading;
2013-02-27 04:19:05 +00:00
using System.Threading.Tasks;
2016-10-05 07:15:29 +00:00
using MediaBrowser.Controller.Library;
using MediaBrowser.Model.IO;
using MediaBrowser.Model.Logging;
2016-10-25 19:02:04 +00:00
using MediaBrowser.Model.Services;
2017-05-22 04:54:02 +00:00
using MediaBrowser.Model.System;
2013-02-27 04:19:05 +00:00
namespace MediaBrowser.Api.LiveTv
2013-02-27 04:19:05 +00:00
{
2016-10-25 19:02:04 +00:00
public class ProgressiveFileCopier : IAsyncStreamWriter, IHasHeaders
2014-06-26 17:04:11 +00:00
{
private readonly IFileSystem _fileSystem;
2016-03-22 03:27:46 +00:00
private readonly ILogger _logger;
private readonly string _path;
private readonly CancellationToken _cancellationToken;
private readonly Dictionary<string, string> _outputHeaders;
2014-06-26 17:04:11 +00:00
2017-05-22 04:54:02 +00:00
const int StreamCopyToBufferSize = 81920;
2016-03-22 03:27:46 +00:00
2014-09-03 02:30:24 +00:00
private long _bytesWritten = 0;
2016-09-30 02:21:24 +00:00
public long StartPosition { get; set; }
2016-09-25 18:39:13 +00:00
public bool AllowEndOfFile = true;
2016-10-25 19:02:04 +00:00
private readonly IDirectStreamProvider _directStreamProvider;
2017-05-22 04:54:02 +00:00
private readonly IEnvironmentInfo _environment;
2016-10-05 07:15:29 +00:00
public ProgressiveFileCopier(IFileSystem fileSystem, string path, Dictionary<string, string> outputHeaders, ILogger logger, IEnvironmentInfo environment, CancellationToken cancellationToken)
2014-06-26 17:04:11 +00:00
{
_fileSystem = fileSystem;
_path = path;
_outputHeaders = outputHeaders;
2016-03-22 03:27:46 +00:00
_logger = logger;
_cancellationToken = cancellationToken;
2017-05-22 04:54:02 +00:00
_environment = environment;
2014-06-26 17:04:11 +00:00
}
public ProgressiveFileCopier(IDirectStreamProvider directStreamProvider, Dictionary<string, string> outputHeaders, ILogger logger, IEnvironmentInfo environment, CancellationToken cancellationToken)
2016-10-05 07:15:29 +00:00
{
_directStreamProvider = directStreamProvider;
_outputHeaders = outputHeaders;
_logger = logger;
_cancellationToken = cancellationToken;
2017-05-22 04:54:02 +00:00
_environment = environment;
2016-10-05 07:15:29 +00:00
}
2016-10-25 19:02:04 +00:00
public IDictionary<string, string> Headers
{
get
{
return _outputHeaders;
}
}
2017-05-22 04:54:02 +00:00
private Stream GetInputStream(bool allowAsyncFileRead)
2016-10-05 07:15:29 +00:00
{
2017-06-01 04:27:17 +00:00
var fileOpenOptions = FileOpenOptions.SequentialScan;
2017-05-22 04:54:02 +00:00
if (allowAsyncFileRead)
{
fileOpenOptions |= FileOpenOptions.Asynchronous;
}
return _fileSystem.GetFileStream(_path, FileOpenMode.Open, FileAccessMode.Read, FileShareMode.ReadWrite, fileOpenOptions);
2016-10-05 07:15:29 +00:00
}
2016-10-25 19:02:04 +00:00
public async Task WriteToAsync(Stream outputStream, CancellationToken cancellationToken)
2013-02-27 04:19:05 +00:00
{
2017-05-22 04:54:02 +00:00
cancellationToken = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken, _cancellationToken).Token;
if (_directStreamProvider != null)
2013-02-27 04:19:05 +00:00
{
await _directStreamProvider.CopyToAsync(outputStream, cancellationToken).ConfigureAwait(false);
return;
}
2016-10-05 07:15:29 +00:00
var eofCount = 0;
// use non-async filestream along with read due to https://github.com/dotnet/corefx/issues/6039
var allowAsyncFileRead = _environment.OperatingSystem != OperatingSystem.Windows;
2017-05-22 04:54:02 +00:00
using (var inputStream = GetInputStream(allowAsyncFileRead))
{
if (StartPosition > 0)
2013-02-27 04:19:05 +00:00
{
inputStream.Position = StartPosition;
}
while (eofCount < 20 || !AllowEndOfFile)
{
int bytesRead;
if (allowAsyncFileRead)
{
bytesRead = await CopyToInternalAsync(inputStream, outputStream, cancellationToken).ConfigureAwait(false);
}
else
2016-09-30 02:21:24 +00:00
{
bytesRead = await CopyToInternalAsyncWithSyncRead(inputStream, outputStream, cancellationToken).ConfigureAwait(false);
2016-09-30 02:21:24 +00:00
}
//var position = fs.Position;
//_logger.Debug("Streamed {0} bytes to position {1} from file {2}", bytesRead, position, path);
if (bytesRead == 0)
{
eofCount++;
await Task.Delay(100, cancellationToken).ConfigureAwait(false);
}
else
{
eofCount = 0;
2013-02-27 04:19:05 +00:00
}
}
}
2013-02-27 04:19:05 +00:00
}
2014-09-03 02:30:24 +00:00
2017-05-22 04:54:02 +00:00
private async Task<int> CopyToInternalAsyncWithSyncRead(Stream source, Stream destination, CancellationToken cancellationToken)
2014-09-03 02:30:24 +00:00
{
2017-05-22 04:54:02 +00:00
var array = new byte[StreamCopyToBufferSize];
2016-07-24 16:46:17 +00:00
int bytesRead;
int totalBytesRead = 0;
2016-03-22 03:27:46 +00:00
2017-05-22 04:54:02 +00:00
while ((bytesRead = source.Read(array, 0, array.Length)) != 0)
2016-07-24 16:46:17 +00:00
{
2017-05-22 04:54:02 +00:00
var bytesToWrite = bytesRead;
if (bytesToWrite > 0)
{
await destination.WriteAsync(array, 0, Convert.ToInt32(bytesToWrite), cancellationToken).ConfigureAwait(false);
2014-09-03 02:30:24 +00:00
2017-05-22 04:54:02 +00:00
_bytesWritten += bytesRead;
totalBytesRead += bytesRead;
}
}
return totalBytesRead;
}
private async Task<int> CopyToInternalAsync(Stream source, Stream destination, CancellationToken cancellationToken)
{
var array = new byte[StreamCopyToBufferSize];
int bytesRead;
int totalBytesRead = 0;
while ((bytesRead = await source.ReadAsync(array, 0, array.Length, cancellationToken).ConfigureAwait(false)) != 0)
{
var bytesToWrite = bytesRead;
if (bytesToWrite > 0)
2014-09-03 02:30:24 +00:00
{
2017-05-22 04:54:02 +00:00
await destination.WriteAsync(array, 0, Convert.ToInt32(bytesToWrite), cancellationToken).ConfigureAwait(false);
_bytesWritten += bytesRead;
totalBytesRead += bytesRead;
2014-09-03 02:30:24 +00:00
}
}
2016-07-24 16:46:17 +00:00
return totalBytesRead;
2014-09-03 02:30:24 +00:00
}
2013-02-27 04:19:05 +00:00
}
}