t0w0bi/ClubPenguinServer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

requeue requests where files are still downloading

Browse Source
This commit is contained in:
Stanley Dimant
2024-05-04 15:21:53 +02:00
committed by Loporrit
parent 9269a403b5
commit a116545c9e
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

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