Method startNewConnections

IceFireDB-SQLProxy/pkg/mysql/client/pool.go:449–469

(count int)

}

func (pool *Pool) startNewConnections(count int) error {
	connections := make([]Connection, 0, count)
	for i := 0; i < count; i++ {
		conn, err := pool.createNewConnection()
		if err != nil {
			return err
		} else {
			pool.synchro.Lock()
			pool.synchro.stats.TotalCount++
			pool.synchro.Unlock()
			connections = append(connections, conn)
		}
	}

	pool.synchro.Lock()
	for _, connection := range connections {
		pool.putConnectionUnsafe(connection)
	}
	pool.synchro.Unlock()
	return nil
}

func (pool *Pool) ping(conn *Conn) error {
	deadline := time.Now().Add(100 * time.Millisecond)