Method installServers

agent/x/agentmcp/manager.go:661–710

installServers builds the new server map from diff.keep and the connected list, falling back to diff.prev when a connect failed. Returns old entries replaced by successful connects (caller closes them). Acquires and releases m.mu.

(
	wanted map[string]ServerConfig,
	diff *serverDiff,
	connected []connectedServer,
	snap map[string]fileSnapshot,
)

// Returns old entries replaced by successful connects (caller
// closes them). Acquires and releases m.mu.
func (m *Manager) installServers(
	wanted map[string]ServerConfig,
	diff *serverDiff,
	connected []connectedServer,
	snap map[string]fileSnapshot,
) ([]*serverEntry, error) {
	m.mu.Lock()
	defer m.mu.Unlock()

	if m.closed {
		for _, cs := range connected {
			_ = cs.client.Close()
		}
		return nil, ErrManagerClosed
	}

	newConnected := make(map[string]connectedServer, len(connected))
	for _, cs := range connected {
		newConnected[cs.name] = cs
	}

	newServers := make(map[string]*serverEntry, len(wanted))
	for name, entry := range diff.keep {
		newServers[name] = entry
	}

	var replaced []*serverEntry
	for name, wantCfg := range wanted {
		if _, kept := diff.keep[name]; kept {
			continue
		}
		if cs, ok := newConnected[wantCfg.Name]; ok {
			newServers[wantCfg.Name] = &serverEntry{
				config: cs.config,
				client: cs.client,
			}
			if prev, existed := diff.prev[wantCfg.Name]; existed {
				replaced = append(replaced, prev)
			}
		} else if prev, existed := diff.prev[wantCfg.Name]; existed {
			// Connect failed; retain the old client.
			newServers[wantCfg.Name] = prev
		}
	}

	m.servers = newServers
	m.serverGen++
	m.snapshot = snap
	return replaced, nil
}

// captureSnapshot stats each path and returns the current
// snapshot map.