forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-04-23 18:12:24 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

p2p/server: expose MaxInboundConns and MaxDialedConns

Browse source 
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
This commit is contained in:
Csaba Kiraly 2025-03-25 18:19:25 +01:00
parent 23cda63d5a
commit ea8d05a1c9
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
p2p/server.go
View file

@ -511,7 +511,7 @@ func (srv *Server) setupDiscovery() error {
func (srv *Server) setupDialScheduler() { func (srv *Server) setupDialScheduler() {
config := dialConfig{ config := dialConfig{
self: srv.localnode.ID(), self: srv.localnode.ID(),
maxDialPeers: srv.maxDialedConns(), maxDialPeers: srv.MaxDialedConns(),
maxActiveDials: srv.MaxPendingPeers, maxActiveDials: srv.MaxPendingPeers,
log: srv.Logger, log: srv.Logger,
netRestrict: srv.NetRestrict, netRestrict: srv.NetRestrict,
@ -535,11 +535,11 @@ func (srv *Server) setupConnManager() {
srv.connman = newConnManager(config, srv.Peers) srv.connman = newConnManager(config, srv.Peers)
} }
func (srv *Server) maxInboundConns() int { func (srv *Server) MaxInboundConns() int {
return srv.MaxPeers - srv.maxDialedConns() return srv.MaxPeers - srv.MaxDialedConns()
} }
func (srv *Server) maxDialedConns() (limit int) { func (srv *Server) MaxDialedConns() (limit int) {
if srv.NoDial || srv.MaxPeers == 0 { if srv.NoDial || srv.MaxPeers == 0 {
return 0 return 0
} }
@ -746,7 +746,7 @@ func (srv *Server) postHandshakeChecks(peers map[enode.ID]*Peer, inboundCount in
switch { switch {
case !c.is(trustedConn) && len(peers) >= srv.MaxPeers: case !c.is(trustedConn) && len(peers) >= srv.MaxPeers:
return DiscTooManyPeers return DiscTooManyPeers
case !c.is(trustedConn) && c.is(inboundConn) && inboundCount >= srv.maxInboundConns(): case !c.is(trustedConn) && c.is(inboundConn) && inboundCount >= srv.MaxInboundConns():
return DiscTooManyPeers return DiscTooManyPeers
case peers[c.node.ID()] != nil: case peers[c.node.ID()] != nil:
return DiscAlreadyConnected return DiscAlreadyConnected