danvics/rdt-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge pull request #812 from Cucumberrbob/fix/realdebridupdatelock-when-dequeueing

Browse source 
fix: lock RealDebridUpdateLock when dequeuing, not when adding to the queue
This commit is contained in:
Roger Far 2025-05-18 11:05:53 -06:00 committed by GitHub
commit b7efb78814
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 27 additions and 27 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

54
server/RdtClient.Service/Services/Torrents.cs
View file

@ -227,15 +227,24 @@ public class Torrents(
logger.LogDebug("Adding {hash} to debrid provider {torrentInfo}", torrent.Hash, torrent.ToLog()); logger.LogDebug("Adding {hash} to debrid provider {torrentInfo}", torrent.Hash, torrent.ToLog());
var id = torrent.IsFile await RealDebridUpdateLock.WaitAsync();
? await TorrentClient.AddFile(Convert.FromBase64String(torrent.FileOrMagnet))
: await TorrentClient.AddMagnet(torrent.FileOrMagnet);
await torrentData.UpdateRdId(torrent, id); try
{
var id = torrent.IsFile
? await TorrentClient.AddFile(Convert.FromBase64String(torrent.FileOrMagnet))
: await TorrentClient.AddMagnet(torrent.FileOrMagnet);
await UpdateTorrentClientData(torrent); await torrentData.UpdateRdId(torrent, id);
return torrent; await UpdateTorrentClientData(torrent);
return torrent;
}
finally
{
RealDebridUpdateLock.Release();
}
} }
public async Task<IList<TorrentClientAvailableFile>> GetAvailableFiles(String hash) public async Task<IList<TorrentClientAvailableFile>> GetAvailableFiles(String hash)
@ -727,30 +736,21 @@ public class Torrents(
Boolean isFile, Boolean isFile,
Torrent torrent) Torrent torrent)
{ {
await RealDebridUpdateLock.WaitAsync(); var existingTorrent = await torrentData.GetByHash(infoHash);
try if (existingTorrent != null)
{ {
var existingTorrent = await torrentData.GetByHash(infoHash); return existingTorrent;
if (existingTorrent != null)
{
return existingTorrent;
}
var newTorrent = await torrentData.Add(null,
infoHash,
fileOrMagnetContents,
isFile,
torrent.DownloadClient,
torrent);
return newTorrent;
}
finally
{
RealDebridUpdateLock.Release();
} }
var newTorrent = await torrentData.Add(null,
infoHash,
fileOrMagnetContents,
isFile,
torrent.DownloadClient,
torrent);
return newTorrent;
} }
public async Task Update(Torrent torrent) public async Task Update(Torrent torrent)