Method Close

rpc/pool.go:195–207

Close closes all FreeLists in the pool.

()

// Close closes all FreeLists in the pool.
func (p *ClientPool) Close() error {
	var errmsgs []string
	p.nodeFreeLists.Range(func(k, v interface{}) bool {
		if err := v.(*freelist).close(); err != nil {
			errmsgs = append(errmsgs, err.Error())
		}
		return true
	})
	if len(errmsgs) > 0 {
		return errors.Wrap(errors.New(strings.Join(errmsgs, ", ")), "close connection pool")
	}
	return nil
}

// Len returns the connection count in the pool.
func (p *ClientPool) Len() (total int) {