Method RemoveAll

conn/pool.go:95–104

RemoveAll removes all pool entries.

()

// RemoveAll removes all pool entries.
func (p *Pools) RemoveAll() {
	p.Lock()
	defer p.Unlock()

	for k, pool := range p.all {
		glog.Warningf("CONN: Disconnecting from %s\n", k)
		delete(p.all, k)
		pool.shutdown()
	}
}

// RemoveInvalid removes invalid nodes from the list of pools.
func (p *Pools) RemoveInvalid(state *pb.MembershipState) {