Skip to content

v1.17: Treat super low staked as unstaked in streamer QOS (backport of #701) #732

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

Merged
lijunwangs merged 4 commits into from
Apr 11, 2024
Merged

v1.17: Treat super low staked as unstaked in streamer QOS (backport of #701) #732

Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
cfff9da
Treat super low staked as unstaked in streamer QOS (#701)
lijunwangs Apr 10, 2024
546067e
Fixed merge conflicts
lijunwangs Apr 10, 2024
5920463
remove unsed file
lijunwangs Apr 10, 2024
38e88d7
Addressed Pankaj's comment.
lijunwangs Apr 11, 2024
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
10 changes: 10 additions & 0 deletions streamer/src/nonblocking/quic.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -495,6 +495,16 @@ async fn setup_connection(
stats.clone(),
),
|(pubkey, stake, total_stake, max_stake, min_stake)| {
// The heuristic is that the stake should be large engouh to have 1 stream pass throuh within one throttle
// interval during which we allow max MAX_STREAMS_PER_100MS streams.
let min_stake_ratio = 1_f64 / MAX_STREAMS_PER_100MS as f64;
let stake_ratio = stake as f64 / total_stake as f64;
let stake = if stake_ratio < min_stake_ratio {
// If it is a staked connection with ultra low stake ratio, treat it as unstaked.
0
} else {
stake
};
NewConnectionHandlerParams {
packet_sender,
remote_pubkey: Some(pubkey),
Expand Down