Skip to content
This repository has been archived by the owner on Nov 15, 2023. It is now read-only.

Limit number of incoming connections #391

Merged
merged 9 commits into from
Jul 27, 2018
Merged

Limit number of incoming connections #391

Changes from 1 commit
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
6a8dae0
Limit number of incoming connections
sorpaas Jul 20, 2018
02532cd
Check Endpoint::Listener before checking num_open_connections.incoming
sorpaas Jul 20, 2018
374e367
Maintain at least 1-1/n portion of outgoing connections
sorpaas Jul 20, 2018
f7edca6
Remove use
sorpaas Jul 20, 2018
ba11932
Default incoming_peers_factor to 2
sorpaas Jul 20, 2018
fcbb654
Merge branch 'master' of https://github.com/paritytech/polkadot into …
sorpaas Jul 25, 2018
25f33a7
Use max_incoming_peers and max_outgoing peers to check whether connec…
sorpaas Jul 25, 2018
ef765f7
Fix expected_max_peers: reserved peers are not counted in config.max_…
sorpaas Jul 25, 2018
15654bf
typo: fix test
sorpaas Jul 25, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Check Endpoint::Listener before checking num_open_connections.incoming
  • Loading branch information
@sorpaas
sorpaas committed Jul 20, 2018
commit 02532cd3d23be2fe5d0ec865aca1447cfa2a4fd0
3 changes: 2 additions & 1 deletion substrate/network-libp2p/src/network_state.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -552,7 +552,8 @@ impl NetworkState {
if !node_is_reserved {
if self.reserved_only.load(atomic::Ordering::Relaxed) ||
num_open_connections.total >= self.max_peers ||
num_open_connections.incoming >= self.max_incoming_peers
(endpoint == Endpoint::Listener &&
num_open_connections.incoming >= self.max_incoming_peers)
{
debug!(target: "sub-libp2p", "Refusing node {:?} because we \
reached the max number of peers", node_id);
Expand Down