NamespaceManager.PrepareReloadNamespace之后原有连接池未销毁，连接泄露

[joeytang]

NamespaceManager.PrepareReloadNamespace可以销毁原有连接吗

当我们变更一个namespace的对应的数据库实例列表时，通过管控接口，/reload/prepare/{namespace} 进行重新装载配置信息。通过数据库实例上tcp连接信息，能看到从weir还是会有连接与下掉的实例保持。代码跟踪发现在执行这个prepare管控接口的时候，会去重建连接池。重建之后，直接将原有连接池替换掉。原来的连接池没有销毁。

func (b *BackendImpl) initConnPools() error {
	connPools := make(map[string]*ConnPool)
	for addr := range b.cfg.Addrs {
		poolCfg := &ConnPoolConfig{
			Config:      Config{Addr: addr, UserName: b.cfg.UserName, Password: b.cfg.Password},
			Capacity:    b.cfg.Capacity,
			IdleTimeout: b.cfg.IdleTimeout,
		}
		connPool := NewConnPool(b.ns, poolCfg)
		connPools[addr] = connPool
	}
	successfulInitConnPoolAddrs := make(map[string]struct{})
	var initConnPoolErr error
	for addr, connPool := range connPools {
		if err := connPool.Init(); err != nil {
			initConnPoolErr = err
			break
		}
		successfulInitConnPoolAddrs[addr] = struct{}{}
	}
	if initConnPoolErr != nil {
		for addr := range successfulInitConnPoolAddrs {
			if err := connPools[addr].Close(); err != nil {
				logutil.BgLogger().Sugar().Error("close inited conn pool error, addr: %s, err: %v", addr, err)
			}
		}
		return initConnPoolErr
	}
	**b.connPools = connPools**
	return nil
}

[joeytang]

连接池自己会根据idletimeout时间自动关闭连接。因此理论上不会存在泄漏问题。但是现象看我们设置了idle为120秒，目前实例已经下线十几个小时了，连接依然在

[joeytang]

// closeIdleResources scans the pool for idle resources
func (rp *ResourcePool) closeIdleResources() {
	available := int(rp.Available())
	idleTimeout := rp.IdleTimeout()

	for i := 0; i < available; i++ {
		var wrapper resourceWrapper
		select {
		case wrapper = <-rp.resources:
		default:
			// stop early if we don't get anything new from the pool
			return
		}

		func() {
			defer func() { rp.resources <- wrapper }()

			if wrapper.resource != nil && idleTimeout > 0 && time.Until(wrapper.timeUsed.Add(idleTimeout)) < 0 {
				wrapper.resource.Close()
				rp.idleClosed.Add(1)
//此处能看到过期后会重新打开连接资源
				rp.reopenResource(&wrapper)
			}
		}()

	}
}
//连接资源重新打开的时候，会直接建立与数据库实例的tcp连接。这样这个连接会一直在。
//除非这个数据库实例网络不可用了
func (rp *ResourcePool) reopenResource(wrapper *resourceWrapper) {
	if r, err := rp.factory(context.TODO()); err == nil {
		wrapper.resource = r
		wrapper.timeUsed = time.Now()
	} else {
		wrapper.resource = nil
		rp.active.Add(-1)
	}
}

问题可能在这里