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

some fixes maybe

Browse source
This commit is contained in:
Stanley Dimant 2024-04-28 12:21:24 +02:00
parent ff4ddef18d
commit 33df74b037
1 changed files with 6 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -98,7 +98,7 @@ public class RequestQueueService : IHostedService
public Task StartAsync(CancellationToken cancellationToken)
{
_queueTimer = new System.Timers.Timer(250);
_queueTimer = new System.Timers.Timer(500);
_queueTimer.Elapsed += ProcessQueue;
_queueTimer.AutoReset = true;
_queueTimer.Start();
@ -169,20 +169,22 @@ public class RequestQueueService : IHostedService
while (true)
{
if (_priorityQueue.TryDequeue(out var prioRequest))
if (_priorityQueue.TryPeek(out var prioRequest))
{
if (prioRequest.IsCancelled) continue;
if (_cachedFileProvider.AnyFilesDownloading(prioRequest.FileIds)) continue;
DequeueIntoSlot(prioRequest, i);
_priorityQueue.TryDequeue(out var priorityRequest);
DequeueIntoSlot(priorityRequest, i);
break;
}
if (_queue.TryDequeue(out var request))
if (_queue.TryPeek(out var request))
{
if (request.IsCancelled) continue;
if (_cachedFileProvider.AnyFilesDownloading(request.FileIds)) continue;
_priorityQueue.TryDequeue(out var priorityRequest);
DequeueIntoSlot(request, i);
break;
}