Method classifyServers

agent/x/agentmcp/manager.go:586–618

classifyServers compares wanted configs against the current server map and returns a diff describing what changed. Acquires and releases m.mu for reading.

(wanted map[string]ServerConfig)

// server map and returns a diff describing what changed.
// Acquires and releases m.mu for reading.
func (m *Manager) classifyServers(wanted map[string]ServerConfig) (*serverDiff, error) {
	m.mu.RLock()
	defer m.mu.RUnlock()

	if m.closed {
		return nil, ErrManagerClosed
	}

	diff := &serverDiff{
		keep: make(map[string]*serverEntry),
	}

	for name, wantCfg := range wanted {
		if existing, ok := m.servers[name]; ok {
			if reflect.DeepEqual(existing.config, wantCfg) {
				diff.keep[name] = existing
			} else {
				diff.toConnect = append(diff.toConnect, wantCfg)
			}
		} else {
			diff.toConnect = append(diff.toConnect, wantCfg)
		}
	}

	for name, entry := range m.servers {
		if _, ok := wanted[name]; !ok {
			diff.toClose = append(diff.toClose, entry)
		}
	}

	diff.prev = maps.Clone(m.servers)
	return diff, nil
}

// connectAll runs connectServer in parallel for the given configs.
// Failed connects are logged and skipped.