ToxicMushroom/mare.server
1
0
Fork 0
mirror of https://github.com/Caraxi/mare.server.git synced 2025-12-12 21:07:21 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

requeue requests where files are still downloading

Browse source
This commit is contained in:
Stanley Dimant 2024-05-04 15:21:53 +02:00
parent 761a25c5fc
commit 6ab27d9698
1 changed files with 9 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

18
MareSynchronosServer/MareSynchronosStaticFilesServer/Services/RequestQueueService.cs
View file

@ -169,30 +169,30 @@ public class RequestQueueService : IHostedService
while (true) while (true)
{ {
if (_priorityQueue.TryPeek(out var prioRequest)) if (_priorityQueue.TryDequeue(out var prioRequest))
{ {
if (prioRequest.IsCancelled) if (prioRequest.IsCancelled)
{ {
_priorityQueue.TryDequeue(out var _);
continue; continue;
} }
if (_cachedFileProvider.AnyFilesDownloading(prioRequest.FileIds)) continue;
_priorityQueue.TryDequeue(out var priorityRequest); if (_cachedFileProvider.AnyFilesDownloading(prioRequest.FileIds))
DequeueIntoSlot(priorityRequest, i); _priorityQueue.Enqueue(prioRequest);
DequeueIntoSlot(prioRequest, i);
break; break;
} }
if (_queue.TryPeek(out var request)) if (_queue.TryDequeue(out var request))
{ {
if (request.IsCancelled) if (request.IsCancelled)
{ {
_queue.TryDequeue(out var _);
continue; continue;
} }
if (_cachedFileProvider.AnyFilesDownloading(request.FileIds)) continue;
_queue.TryDequeue(out var priorityRequest); if (_cachedFileProvider.AnyFilesDownloading(request.FileIds))
_queue.Enqueue(request);
DequeueIntoSlot(request, i); DequeueIntoSlot(request, i);
break; break;
} }