alteropen/jellyfin
1
0
Fork 0
mirror of https://github.com/jellyfin/jellyfin.git synced 2026-06-02 13:58:29 +01:00
Code Issues Actions 8 Packages Projects Releases Wiki Activity

Moved IsFileIdenticalAsync & IsStreamIdenticalAsync to StreamExtensions.

Browse Source
This commit is contained in:
Marc Brooks
2026-05-26 22:37:17 +00:00
parent 961c6d3d54
commit 02ca63cd13
2 changed files with 97 additions and 63 deletions
Download Patch File Download Diff File Expand all files Collapse all files

64
MediaBrowser.XbmcMetadata/Savers/BaseNfoSaver.cs
View File

@@ -208,7 +208,7 @@ namespace MediaBrowser.XbmcMetadata.Savers
Directory.CreateDirectory(directory);
// Compare byte-for-byte before proceeding.
if (File.Exists(path) && await IsFileIdenticalAsync(stream, path, cancellationToken).ConfigureAwait(false))
if (File.Exists(path) && await stream.IsFileIdenticalAsync(path, cancellationToken).ConfigureAwait(false))
{
return; // Don't save since .nfo is unchanged.
}
@@ -239,68 +239,6 @@ namespace MediaBrowser.XbmcMetadata.Savers
}
}
private static async Task<bool> IsFileIdenticalAsync(Stream stream, string path, CancellationToken cancellationToken)
{
ArgumentNullException.ThrowIfNull(stream);
ArgumentException.ThrowIfNullOrEmpty(path);
if (!stream.CanSeek)
{
return false;
}
const int BufferSize = 81920;
var originalPosition = stream.Position;
try
{
stream.Position = 0;
using var existingFileStream = new FileStream(
path,
FileMode.Open,
FileAccess.Read,
FileShare.Read,
bufferSize: BufferSize,
FileOptions.Asynchronous);
if (existingFileStream.Length != stream.Length)
{
return false;
}
var streamBuffer = new byte[BufferSize];
var existingBuffer = new byte[BufferSize];
while (true)
{
cancellationToken.ThrowIfCancellationRequested();
var streamBytesRead = await stream.ReadAsync(streamBuffer.AsMemory(), cancellationToken).ConfigureAwait(false);
var existingBytesRead = await existingFileStream.ReadAsync(existingBuffer.AsMemory(), cancellationToken).ConfigureAwait(false);
if (streamBytesRead != existingBytesRead)
{
return false;
}
if (streamBytesRead == 0)
{
return true;
}
if (!streamBuffer.AsSpan(0, streamBytesRead).SequenceEqual(existingBuffer.AsSpan(0, existingBytesRead)))
{
return false;
}
}
}
finally
{
stream.Position = originalPosition;
}
}
private void SetHidden(string path, bool hidden)
{
try