Changes to an unbuffered channel, since we just close it.
This commit is contained in:
parent
1c6414e806
commit
8df55b6964
|
@ -215,7 +215,7 @@ func (p *ConnPool) acquire(dc string, addr net.Addr, version int) (*Conn, error)
|
|||
var wait chan struct{}
|
||||
var ok bool
|
||||
if wait, ok = p.limiter[addr.String()]; !ok {
|
||||
wait = make(chan struct{}, 1)
|
||||
wait = make(chan struct{})
|
||||
p.limiter[addr.String()] = wait
|
||||
}
|
||||
isLeadThread := !ok
|
||||
|
|
Loading…
Reference in New Issue