backport of commit 0395405e2a

pull/4398/head
Elim Tsiagbey 2 years ago
parent 17f39ff357
commit 445fba4653

@ -307,7 +307,7 @@ func (p *ClientProxy) Start() (retErr error) {
if p.callerConnectionsCountCh != nil {
p.callerConnectionsCountCh <- connsCount
}
// If there are no connections and no connections left,
// If there are no connections and no available connections,
// we can exit
if p.ConnectionsLeft() == 0 && connsCount == 0 {
return

@ -457,7 +457,7 @@ func (c *Command) Run(args []string) (retCode int) {
c.updateConnsLeft(connsLeft, clientProxy.ConnectionsCount())
case connsCount := <-connsCountCh:
c.updateConnsLeft(clientProxy.ConnectionsLeft(), connsCount)
// If there are no counts left and there are no connections
// If there are no available connections left and there are no connections
// we can exit
if clientProxy.ConnectionsLeft() == 0 && connsCount == 0 {
return

Loading…
Cancel
Save