Method CloseIPConns

internal/conns/map.go:75–105

(ip string)

}

func (this *Map) CloseIPConns(ip string) {
	var conns = []net.Conn{}

	this.locker.RLock()
	connMap, ok := this.m[ip]

	// 复制，防止在Close时产生并发冲突
	if ok {
		for _, conn := range connMap {
			conns = append(conns, conn)
		}
	}

	// 需要在Close之前结束，防止死循环
	this.locker.RUnlock()

	if ok {
		for _, conn := range conns {
			// 设置Linger
			lingerConn, isLingerConn := conn.(LingerConn)
			if isLingerConn {
				_ = lingerConn.SetLinger(0)
			}

			// 关闭
			_ = conn.Close()
		}

		// 这里不需要从 m 中删除，因为关闭时会自然触发回调
	}
}

func (this *Map) AllConns() []net.Conn {
	this.locker.RLock()