From 8f0bf47d564380be2ba7c97c7e8ae41dfa837955 Mon Sep 17 00:00:00 2001 From: Roman Shishkin Date: Sat, 21 Mar 2026 21:53:38 +0300 Subject: [PATCH] Add Config.GetConcurrency with default fallback --- internal/cli/run_proxy.go | 1 + internal/config/config.go | 7 +++++++ 2 files changed, 8 insertions(+) diff --git a/internal/cli/run_proxy.go b/internal/cli/run_proxy.go index 9453edaa3..643f6454d 100644 --- a/internal/cli/run_proxy.go +++ b/internal/cli/run_proxy.go @@ -253,6 +253,7 @@ func runProxy(conf *config.Config, version string) error { //nolint: funlen EventStream: eventStream, Secret: conf.Secret, + Concurrency: conf.GetConcurrency(mtglib.DefaultConcurrency), DomainFrontingPort: conf.GetDomainFrontingPort(mtglib.DefaultDomainFrontingPort), DomainFrontingIP: conf.GetDomainFrontingIP(nil), DomainFrontingProxyProtocol: conf.GetDomainFrontingProxyProtocol(false), diff --git a/internal/config/config.go b/internal/config/config.go index 9ced83223..cb51c6365 100644 --- a/internal/config/config.go +++ b/internal/config/config.go @@ -84,6 +84,13 @@ type Config struct { } `json:"stats"` } +func (c *Config) GetConcurrency(defaultValue uint) uint { + if concurrency := c.Concurrency.Get(0); concurrency != 0 { + return concurrency + } + return c.Concurrency.Get(defaultValue) +} + func (c *Config) GetDNS() *url.URL { var dohURL *url.URL