Try #4707:

p2p/host.go

@@ -109,7 +109,7 @@ func New(_ context.Context, logger log.Log, cfg Config, prologue []byte, opts ..
 		libp2p.BandwidthReporter(p2pmetrics.NewBandwidthCollector()),
 	}
 	if cfg.Metrics {
-		lopts = append(lopts, setupResourcesManager)
+		lopts = append(lopts, setupResourcesManager(cfg.HighPeers))
 	}
 	if !cfg.DisableNatPort {
 		lopts = append(lopts, libp2p.NATPortMap())
@@ -130,22 +130,27 @@ func New(_ context.Context, logger log.Log, cfg Config, prologue []byte, opts ..
 	return Upgrade(h, opts...)
 }
 
-func setupResourcesManager(cfg *libp2p.Config) error {
-	rcmgrObs.MustRegisterWith(prometheus.DefaultRegisterer)
-	str, err := rcmgrObs.NewStatsTraceReporter()
-	if err != nil {
-		return err
-	}
-	limits := rcmgr.DefaultLimits
-	libp2p.SetDefaultServiceLimits(&limits)
+func setupResourcesManager(highPeers int) func(cfg *libp2p.Config) error {
+	return func(cfg *libp2p.Config) error {
+		rcmgrObs.MustRegisterWith(prometheus.DefaultRegisterer)
+		str, err := rcmgrObs.NewStatsTraceReporter()
+		if err != nil {
+			return err
+		}
+		limits := rcmgr.DefaultLimits
+		limits.SystemBaseLimit.ConnsInbound = highPeers
+		limits.SystemBaseLimit.ConnsOutbound = highPeers
+		limits.SystemBaseLimit.Conns = 2 * highPeers
+		libp2p.SetDefaultServiceLimits(&limits)
 
-	mgr, err := rcmgr.NewResourceManager(
-		rcmgr.NewFixedLimiter(limits.AutoScale()),
-		rcmgr.WithTraceReporter(str),
-	)
-	if err != nil {
-		return err
+		mgr, err := rcmgr.NewResourceManager(
+			rcmgr.NewFixedLimiter(limits.AutoScale()),
+			rcmgr.WithTraceReporter(str),
+		)
+		if err != nil {
+			return err
+		}
+		cfg.Apply(libp2p.ResourceManager(mgr))
+		return nil
 	}
-	cfg.Apply(libp2p.ResourceManager(mgr))
-	return nil
 }