From 27778cbe06515f89ce2247d7511a1eca00c54eb7 Mon Sep 17 00:00:00 2001 From: Olaoluwa Osuntokun Date: Mon, 21 Jul 2025 11:52:30 -0500 Subject: [PATCH] multi: wire up gossip filter concurrency config In this commit, we complete the integration of the configurable gossip filter concurrency by wiring the new FilterConcurrency configuration through all layers of the application. The changes connect the gossip.filter-concurrency configuration option from the command-line interface through the server initialization code to the gossiper and sync manager. This ensures that operators can actually use the new configuration option to tune their node's concurrent gossip filter processing capacity based on their specific requirements and available resources. --- config.go | 1 + server.go | 1 + 2 files changed, 2 insertions(+) diff --git a/config.go b/config.go index 53f8f36e5..e7b843f64 100644 --- a/config.go +++ b/config.go @@ -719,6 +719,7 @@ func DefaultConfig() Config { AnnouncementConf: discovery.DefaultProofMatureDelta, MsgRateBytes: discovery.DefaultMsgBytesPerSecond, MsgBurstBytes: discovery.DefaultMsgBytesBurst, + FilterConcurrency: discovery.DefaultFilterConcurrency, }, Invoices: &lncfg.Invoices{ HoldExpiryDelta: lncfg.DefaultHoldInvoiceExpiryDelta, diff --git a/server.go b/server.go index 8730d2710..8b82d4252 100644 --- a/server.go +++ b/server.go @@ -1225,6 +1225,7 @@ func newServer(_ context.Context, cfg *Config, listenAddrs []net.Addr, AssumeChannelValid: cfg.Routing.AssumeChannelValid, MsgRateBytes: cfg.Gossip.MsgRateBytes, MsgBurstBytes: cfg.Gossip.MsgBurstBytes, + FilterConcurrency: cfg.Gossip.FilterConcurrency, }, nodeKeyDesc) accessCfg := &accessManConfig{