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

more queue fixes

Browse source
This commit is contained in:
Stanley Dimant 2024-05-04 15:31:59 +02:00
parent 6ab27d9698
commit 69b5dba901
1 changed files with 11 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -2,6 +2,7 @@
using MareSynchronosShared.Services;
using MareSynchronosStaticFilesServer.Utils;
using System.Collections.Concurrent;
using System.Linq;
using System.Timers;
namespace MareSynchronosStaticFilesServer.Services;
@ -169,7 +170,8 @@ public class RequestQueueService : IHostedService
while (true)
{
if (_priorityQueue.TryDequeue(out var prioRequest))
if (!_priorityQueue.All(u => _cachedFileProvider.AnyFilesDownloading(u.FileIds))
&& _priorityQueue.TryDequeue(out var prioRequest))
{
if (prioRequest.IsCancelled)
{
@ -177,13 +179,17 @@ public class RequestQueueService : IHostedService
}
if (_cachedFileProvider.AnyFilesDownloading(prioRequest.FileIds))
{
_priorityQueue.Enqueue(prioRequest);
continue;
}
DequeueIntoSlot(prioRequest, i);
break;
}
if (_queue.TryDequeue(out var request))
if (!_queue.All(u => _cachedFileProvider.AnyFilesDownloading(u.FileIds))
&& _queue.TryDequeue(out var request))
{
if (request.IsCancelled)
{
@ -191,7 +197,10 @@ public class RequestQueueService : IHostedService
}
if (_cachedFileProvider.AnyFilesDownloading(request.FileIds))
{
_queue.Enqueue(request);
continue;
}
DequeueIntoSlot(request, i);
break;