From 2ca48444e26e7a0b6c8d934401d682b3cbe9c16f Mon Sep 17 00:00:00 2001 From: Aliaksandr Valialkin Date: Fri, 6 Jan 2023 22:13:32 -0800 Subject: [PATCH] lib/vmselectapi: typo fix after 20e9598254078124b230fcb00e35d404e0f6fe8d --- lib/vmselectapi/server.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/vmselectapi/server.go b/lib/vmselectapi/server.go index 94aacef1ae..6d391371bc 100644 --- a/lib/vmselectapi/server.go +++ b/lib/vmselectapi/server.go @@ -512,7 +512,7 @@ func (s *Server) processRPCWithConcurrencyLimit(ctx *vmselectRequestCtx, rpcName t := timerpool.Get(d) s.concurrencyLimitReached.Inc() select { - case <-s.concurrencyLimitCh: + case s.concurrencyLimitCh <- struct{}{}: timerpool.Put(t) ctx.qt.Printf("wait in queue because -%s=%d concurrent requests are executed", s.limits.MaxConcurrentRequestsFlagName, s.limits.MaxConcurrentRequests) case <-t.C: