Merge pull request #48 from anyproto/fix-open-requests

Fix openingWaitCount logic
2023-07-14 16:25:31 +02:00 · 2023-07-14 16:19:38 +02:00
1 changed files with 2 additions and 2 deletions
@@ -106,10 +106,10 @@ func (p *peer) AcquireDrpcConn(ctx context.Context) (drpc.Conn, error) {
 	p.mu.Lock()
 	if len(p.inactive) == 0 {
 		wait := p.limiter.wait(len(p.active) + int(p.openingWaitCount.Load()))
+		p.openingWaitCount.Add(1)
+		defer p.openingWaitCount.Add(-1)
 		p.mu.Unlock()
 		if wait != nil {
-			p.openingWaitCount.Add(1)
-			defer p.openingWaitCount.Add(-1)
 			// throttle new connection opening
 			select {
 			case <-ctx.Done():
Author	SHA1	Message	Date
Mikhail Rakhmanov	7049a884a7	Merge pull request #48 from anyproto/fix-open-requests Fix openingWaitCount logic	2023-07-14 16:25:31 +02:00
mcrakhman	21a9ce6035	Fix openingWaitCount logic	2023-07-14 16:19:38 +02:00