Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Make a server ping next servers #356

Merged
merged 8 commits into from
Jul 15, 2023
Merged

Make a server ping next servers #356

Changes from 1 commit
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
9316c55
Add ping coroutines
borzunov Jul 15, 2023
4b5ca4a
Ping next servers
borzunov Jul 15, 2023
c0da388
Add PingAggregator, refactor
borzunov Jul 15, 2023
66aa061
Don't ping if we're disconnecting
borzunov Jul 15, 2023
3e23a2e
Report only 10 fastest servers to save DHT
borzunov Jul 15, 2023
aab1dad
Fix Python 3.7
borzunov Jul 15, 2023
35b96ef
Fix issues
borzunov Jul 15, 2023
218b37a
Set ema_alpha = 0.2
borzunov Jul 15, 2023
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
Set ema_alpha = 0.2
  • Loading branch information
@borzunov
borzunov committed Jul 15, 2023
commit 218b37a05e9a130faa59aa8341b5023fc2f09bb3
2 changes: 1 addition & 1 deletion src/petals/utils/ping.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ async def ping_parallel(peer_ids: Sequence[hivemind.PeerID], *args, **kwargs) ->


class PingAggregator:
def __init__(self, dht: hivemind.DHT, *, ema_alpha: float = 0.1, expiration: float = 3600):
def __init__(self, dht: hivemind.DHT, *, ema_alpha: float = 0.2, expiration: float = 3600):
self.dht = dht
self.ema_alpha = ema_alpha
self.expiration = expiration
Expand Down
Loading