From 7f16b24192955b3797515a26233e45672123952f 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 f20517c27..d5fbe30b8 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 7eb8c583d..9af5ac128 100644 --- a/server.go +++ b/server.go @@ -1225,6 +1225,7 @@ func newServer(ctx 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{