Method newConnectionProducer

IceFireDB-SQLProxy/pkg/mysql/client/pool.go:229–265

()

}

func (pool *Pool) newConnectionProducer() {
	var connection Connection
	var err error

	for {
		connection.conn = nil

		pool.synchro.Lock()

		connection = pool.getIdleConnectionUnsafe()
		if connection.conn == nil {
			if pool.synchro.stats.TotalCount >= pool.maxAlive {
				// Can't create more connections
				pool.synchro.Unlock()
				time.Sleep(10 * time.Millisecond)
				continue
			}
			pool.synchro.stats.TotalCount++ // "Reserving" new connection
		}

		pool.synchro.Unlock()

		if connection.conn == nil {
			connection, err = pool.createNewConnection()
			if err != nil {
				pool.synchro.Lock()
				pool.synchro.stats.TotalCount-- // Bad luck, should try again
				pool.synchro.Unlock()

				time.Sleep(time.Duration(10+rand.Intn(90)) * time.Millisecond)
				continue
			}
		}

		pool.readyConnection <- connection
	}
}

func (pool *Pool) createNewConnection() (Connection, error) {
	var connection Connection