Commit ac627f9b authored by Vladimir Barsukov's avatar Vladimir Barsukov
Browse files

fix

parent 5cb7114a
...@@ -302,6 +302,7 @@ func (d *Pool) Start() { ...@@ -302,6 +302,7 @@ func (d *Pool) Start() {
return return
} }
rep:
for i, q := range d.notAliveConns { for i, q := range d.notAliveConns {
if err := d.ping(q); err == nil { if err := d.ping(q); err == nil {
d.mu.Lock() d.mu.Lock()
...@@ -313,6 +314,7 @@ func (d *Pool) Start() { ...@@ -313,6 +314,7 @@ func (d *Pool) Start() {
d.SrvAsync = append(d.SrvAsync, q) d.SrvAsync = append(d.SrvAsync, q)
} }
d.mu.Unlock() d.mu.Unlock()
goto rep
} }
} }
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment