varun-r-mallya/py-libp2p
1
0
Fork 0
mirror of https://github.com/varun-r-mallya/py-libp2p.git synced 2026-02-09 22:50:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

doc: add TODO for limit concurrency

Browse Source
This commit is contained in:
acul71
2025-04-30 09:46:12 +00:00
committed by Paul Robinson
parent 4ad6975ef1
commit 4c02c4ea02
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
libp2p/identity/identify_push/identify_push.py
View File

@ -185,6 +185,10 @@ async def push_identify_to_peers(
peer_ids = set(host.get_peerstore().peer_ids()) peer_ids = set(host.get_peerstore().peer_ids())
# Push to each peer in parallel using a trio.Nursery # Push to each peer in parallel using a trio.Nursery
# TODO: Consider using a bounded nursery to limit concurrency
# and avoid overwhelming the network. This can be done by using
# trio.open_nursery(max_concurrent=10) or similar.
# For now, we will use an unbounded nursery for simplicity.
async with trio.open_nursery() as nursery: async with trio.open_nursery() as nursery:
for peer_id in peer_ids: for peer_id in peer_ids:
nursery.start_soon(push_identify_to_peer, host, peer_id, observed_multiaddr) nursery.start_soon(push_identify_to_peer, host, peer_id, observed_multiaddr)