Method launchPrimarySession

internal/manager/manager.go:453–501

launchPrimarySession launches a new primary session

(ctx context.Context)

// launchPrimarySession launches a new primary session
func (cm *ConnManager) launchPrimarySession(ctx context.Context) {
	defer func() {
		if r := recover(); r != nil {
			shared.LogErrorf("ConnManager: Panic in launchPrimarySession: %v", r)
			cm.clearLaunchState(true, false)
		}
	}()
	defer cm.clearLaunchState(true, false) // Default to failure, update on success
	
	// Check if we already have a primary (race condition guard)
	cm.mu.Lock()
	for _, session := range cm.sessions {
		if session.IsPrimary() {
			cm.mu.Unlock()
			shared.LogInfo("ConnManager: Primary session already exists, skipping launch")
			cm.clearLaunchState(true, true) // Not a failure, just redundant
			return
		}
	}
	cm.mu.Unlock()
	
	session, err := cm.launchSession(ctx)
	if err != nil {
		shared.LogErrorf("ConnManager: Failed to launch primary session: %v", err)
		metrics.RecordSessionFailure()
		return
	}
	
	metrics.RecordSessionLaunch()
	
	session.Role = RolePrimary
	
	cm.mu.Lock()
	// Double-check after acquiring lock (race condition guard)
	for _, existingSession := range cm.sessions {
		if existingSession.IsPrimary() {
			cm.mu.Unlock()
			shared.LogInfof("ConnManager: Primary session already exists, discarding new session %s", session.ID)
			cm.cleanupSession(session) // Use proper cleanup
			cm.clearLaunchState(true, true) // Not a failure, just redundant
			return
		}
	}
	cm.sessions = append(cm.sessions, session)
	cm.mu.Unlock()
	
	cm.clearLaunchState(true, true) // Success
	shared.LogSuccessf("ConnManager: Successfully launched primary session %s", session.ID)
}

// launchSecondarySession launches a new secondary session for rotation
func (cm *ConnManager) launchSecondarySession(ctx context.Context) {