Method checkForPromotion

internal/manager/manager.go:568–612

checkForPromotion monitors a secondary session and promotes it when ready

(ctx context.Context, secondary *Session)

// checkForPromotion monitors a secondary session and promotes it when ready
func (cm *ConnManager) checkForPromotion(ctx context.Context, secondary *Session) {
	defer func() {
		if r := recover(); r != nil {
			shared.LogErrorf("ConnManager: Panic in checkForPromotion: %v", r)
		}
	}()
	
	// Wait longer for the secondary to establish health and verify multiple health checks
	healthCheckCount := 0
	ticker := time.NewTicker(5 * time.Second)
	defer ticker.Stop()
	
	timeout := time.NewTimer(45 * time.Second) // Increased from 20s
	defer timeout.Stop()
	
	for {
		select {
		case <-timeout.C:
			shared.LogInfof("ConnManager: Secondary session %s promotion timeout reached", secondary.ID)
			return
		case <-ctx.Done():
			return
		case <-secondary.QuicConn.Context().Done():
			shared.LogInfof("ConnManager: Secondary session %s closed before promotion", secondary.ID)
			return
		case <-ticker.C:
			if secondary.IsHealthy() {
				healthCheckCount++
				shared.LogInfof("ConnManager: Secondary session %s health check %d/3 passed", secondary.ID, healthCheckCount)
				
				// Require 3 consecutive successful health checks before promotion
				if healthCheckCount >= 3 {
					shared.LogInfof("ConnManager: Promoting secondary session %s to primary", secondary.ID)
					cm.promoteSecondary(secondary)
					return
				}
			} else {
				// Reset counter if health check fails
				if healthCheckCount > 0 {
					healthCheckCount = 0
				}
			}
		}
	}
}

// promoteSecondary promotes a secondary session to primary
func (cm *ConnManager) promoteSecondary(secondary *Session) {