mirror of
https://github.com/Caraxi/mare.server.git
synced 2025-12-12 20:17:22 +01:00
expire requests regardless of queue presence of entries
This commit is contained in:
parent
dd74903eff
commit
a3b33c0e6b
1 changed files with 2 additions and 2 deletions
|
|
@ -160,8 +160,6 @@ public class RequestQueueService : IHostedService
|
||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
if (!_queue.Any()) return;
|
|
||||||
|
|
||||||
if (_userQueueRequests[i] != null && ((!_userQueueRequests[i].IsActive && _userQueueRequests[i].ExpirationDate < DateTime.UtcNow)))
|
if (_userQueueRequests[i] != null && ((!_userQueueRequests[i].IsActive && _userQueueRequests[i].ExpirationDate < DateTime.UtcNow)))
|
||||||
{
|
{
|
||||||
_logger.LogDebug("Expiring inactive request {guid} slot {slot}", _userQueueRequests[i].UserRequest.RequestId, i);
|
_logger.LogDebug("Expiring inactive request {guid} slot {slot}", _userQueueRequests[i].UserRequest.RequestId, i);
|
||||||
|
|
@ -174,6 +172,8 @@ public class RequestQueueService : IHostedService
|
||||||
_userQueueRequests[i] = null;
|
_userQueueRequests[i] = null;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (!_queue.Any()) return;
|
||||||
|
|
||||||
if (_userQueueRequests[i] == null)
|
if (_userQueueRequests[i] == null)
|
||||||
{
|
{
|
||||||
bool enqueued = false;
|
bool enqueued = false;
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue