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

kms

Browse source
This commit is contained in:
Stanley Dimant 2024-04-28 12:27:28 +02:00
parent 33df74b037
commit ff81b269b8
1 changed files with 11 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -171,7 +171,11 @@ public class RequestQueueService : IHostedService
{ {
if (_priorityQueue.TryPeek(out var prioRequest)) if (_priorityQueue.TryPeek(out var prioRequest))
{ {
if (prioRequest.IsCancelled) continue; if (prioRequest.IsCancelled)
{
_priorityQueue.TryDequeue(out var _);
continue;
}
if (_cachedFileProvider.AnyFilesDownloading(prioRequest.FileIds)) continue; if (_cachedFileProvider.AnyFilesDownloading(prioRequest.FileIds)) continue;
_priorityQueue.TryDequeue(out var priorityRequest); _priorityQueue.TryDequeue(out var priorityRequest);
@ -181,10 +185,14 @@ public class RequestQueueService : IHostedService
if (_queue.TryPeek(out var request)) if (_queue.TryPeek(out var request))
{ {
if (request.IsCancelled) continue; if (request.IsCancelled)
{
_queue.TryDequeue(out var _);
continue;
}
if (_cachedFileProvider.AnyFilesDownloading(request.FileIds)) continue; if (_cachedFileProvider.AnyFilesDownloading(request.FileIds)) continue;
_priorityQueue.TryDequeue(out var priorityRequest); _queue.TryDequeue(out var priorityRequest);
DequeueIntoSlot(request, i); DequeueIntoSlot(request, i);
break; break;
} }