From ad798e1d1b89e1e094e663c38bae9158c0a3bbdf Mon Sep 17 00:00:00 2001 From: vyzo Date: Tue, 18 Jan 2022 10:57:07 +0200 Subject: [PATCH] default connection manager --- defaults.go | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) diff --git a/defaults.go b/defaults.go index 21b7f0b000..eabbc128c5 100644 --- a/defaults.go +++ b/defaults.go @@ -13,6 +13,7 @@ import ( rcmgr "github.com/libp2p/go-libp2p-resource-manager" tls "github.com/libp2p/go-libp2p-tls" yamux "github.com/libp2p/go-libp2p-yamux" + "github.com/libp2p/go-libp2p/p2p/net/connmgr" "github.com/libp2p/go-tcp-transport" ws "github.com/libp2p/go-ws-transport" "github.com/multiformats/go-multiaddr" @@ -92,11 +93,17 @@ var DefaultResourceManager = func(cfg *Config) error { SetDefaultServiceLimits(limiter) mgr, err := rcmgr.NewResourceManager(limiter) + return cfg.Apply(ResourceManager(mgr)) +} + +// DefaultConnManager creates a default connection manager +var DefaultConnectionManager = func(cfg *Config) error { + mgr, err := connmgr.NewConnManager(192, 256) if err != nil { return err } - return cfg.Apply(ResourceManager(mgr)) + return cfg.Apply(ConnectionManager(mgr)) } // Complete list of default options and when to fallback on them. @@ -139,6 +146,10 @@ var defaults = []struct { fallback: func(cfg *Config) bool { return cfg.ResourceManager == nil }, opt: DefaultResourceManager, }, + { + fallback: func(cfg *Config) bool { return cfg.ConnManager == nil }, + opt: DefaultConnectionManager, + }, } // Defaults configures libp2p to use the default options. Can be combined with