Method shutdown

internal/manager/manager.go:175–219

shutdown gracefully shuts down the ConnManager

()

// shutdown gracefully shuts down the ConnManager
func (cm *ConnManager) shutdown() error {
	var err error
	
	cm.shutdownOnce.Do(func() {
		shared.LogInfo("ConnManager: Beginning graceful shutdown")
		
		// Signal shutdown to prevent new goroutines
		close(cm.shutdownCh)
		
		// Clean up all sessions
		cm.mu.Lock()
		sessions := make([]*Session, len(cm.sessions))
		copy(sessions, cm.sessions)
		cm.sessions = nil
		cm.mu.Unlock()
		
		// Clean up each session
		for _, session := range sessions {
			if cleanupErr := cm.cleanupSession(session); cleanupErr != nil {
				shared.LogErrorf("Error cleaning up session %s: %v", session.ID, cleanupErr)
				if err == nil {
					err = cleanupErr
				}
			}
		}
		
		// Wait for all goroutines to finish with timeout
		done := make(chan struct{})
		go func() {
			cm.activeGoroutines.Wait()
			close(done)
		}()
		
		select {
		case <-done:
			shared.LogInfo("ConnManager: All goroutines finished cleanly")
		case <-time.After(5 * time.Second):
			shared.LogError("ConnManager: Timeout waiting for goroutines to finish", fmt.Errorf("shutdown timeout"))
		}
		
		shared.LogInfo("ConnManager: Shutdown complete")
	})
	
	return err
}

// monitor watches sessions and handles rotation
func (cm *ConnManager) monitor(ctx context.Context) {