Function listToolsWithTimeout

pkg/runtime/runtime.go:1680–1706

listToolsWithTimeout enumerates a toolset's tools under a bounded deadline. The (potentially blocking) Tools call runs in a goroutine and we select on either its completion or the timeout, so a toolset whose Tools() ignores context cancellation — e.g. a wedged MCP stdio subprocess — cannot block sta

(ctx context.Context, toolset tools.ToolSet, timeout time.Duration)

// sends into a buffered channel and exits if the call ever returns, so it does
// not leak past the eventual (or never) return of Tools().
func listToolsWithTimeout(ctx context.Context, toolset tools.ToolSet, timeout time.Duration) ([]tools.Tool, error) {
	// Defend against a zero/negative timeout (e.g. a directly-constructed
	// LocalRuntime that bypassed NewLocalRuntime) so we never collapse to an
	// already-expired context that skips every toolset.
	if timeout <= 0 {
		timeout = defaultToolListTimeout
	}
	toolCtx, cancel := context.WithTimeout(ctx, timeout)
	defer cancel()

	type listResult struct {
		tools []tools.Tool
		err   error
	}
	done := make(chan listResult, 1) // buffered so a late send never blocks
	go func() {
		ts, err := toolset.Tools(toolCtx)
		done <- listResult{tools: ts, err: err}
	}()

	select {
	case <-toolCtx.Done():
		return nil, toolCtx.Err()
	case res := <-done:
		return res.tools, res.err
	}
}

// startToolsetWithTimeout starts a toolset under a bounded deadline, mirroring
// listToolsWithTimeout. The deadline must be enforced by racing the call