mirror of
https://github.com/Caraxi/mare.server.git
synced 2025-12-12 21:27:22 +01:00
ignore healthchecks in the concurrency filter
This commit is contained in:
parent
1ec60dea05
commit
3dcbeb0c06
1 changed files with 5 additions and 0 deletions
|
|
@ -51,6 +51,11 @@ public sealed class ConcurrencyFilter : IHubFilter, IDisposable
|
||||||
public async ValueTask<object> InvokeMethodAsync(
|
public async ValueTask<object> InvokeMethodAsync(
|
||||||
HubInvocationContext invocationContext, Func<HubInvocationContext, ValueTask<object>> next)
|
HubInvocationContext invocationContext, Func<HubInvocationContext, ValueTask<object>> next)
|
||||||
{
|
{
|
||||||
|
if (string.Equals(invocationContext.HubMethodName, nameof(MareHub.CheckClientHealth), StringComparison.Ordinal))
|
||||||
|
{
|
||||||
|
return await next(invocationContext).ConfigureAwait(false);
|
||||||
|
}
|
||||||
|
|
||||||
await _limiter.WaitAsync(invocationContext.Context.ConnectionAborted).ConfigureAwait(false);
|
await _limiter.WaitAsync(invocationContext.Context.ConnectionAborted).ConfigureAwait(false);
|
||||||
|
|
||||||
try
|
try
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue