(addr string)
| 131 | } |
| 132 | |
| 133 | func (p *Pools) remove(addr string) { |
| 134 | p.Lock() |
| 135 | defer p.Unlock() |
| 136 | pool, ok := p.all[addr] |
| 137 | if !ok { |
| 138 | return |
| 139 | } |
| 140 | glog.Warningf("CONN: Disconnecting from %s\n", addr) |
| 141 | delete(p.all, addr) |
| 142 | pool.shutdown() |
| 143 | } |
| 144 | |
| 145 | func (p *Pools) getPool(addr string) (*Pool, bool) { |
| 146 | p.RLock() |