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

fixes for activate/finishrequest

Browse source
This commit is contained in:
rootdarkarchon 2023-01-11 17:22:04 +01:00
parent c1f329c233
commit a0cea2432f
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -76,7 +76,7 @@ public class RequestQueueService : IHostedService
public void FinishRequest(Guid request) public void FinishRequest(Guid request)
{ {
var req = _userQueueRequests.First(f => f.UserRequest.RequestId == request); var req = _userQueueRequests.Where(f => f != null).First(f => f.UserRequest.RequestId == request);
var idx = Array.IndexOf(_userQueueRequests, req); var idx = Array.IndexOf(_userQueueRequests, req);
_logger.LogDebug("Finishing Request {guid}, clearing slot {idx}", request, idx); _logger.LogDebug("Finishing Request {guid}, clearing slot {idx}", request, idx);
_userQueueRequests[idx] = null; _userQueueRequests[idx] = null;
@ -85,7 +85,7 @@ public class RequestQueueService : IHostedService
public void ActivateRequest(Guid request) public void ActivateRequest(Guid request)
{ {
_logger.LogDebug("Activating request {guid}", request); _logger.LogDebug("Activating request {guid}", request);
_userQueueRequests.First(f => f.UserRequest.RequestId == request).IsActive = true; _userQueueRequests.Where(f => f != null).First(f => f.UserRequest.RequestId == request).IsActive = true;
} }
private async Task ProcessRequestQueue(CancellationToken ct) private async Task ProcessRequestQueue(CancellationToken ct)