Commit graph

16 commits

Author SHA1 Message Date
Joakim Frostegård
84f420e2c5 udp bench: use gamma distribution for torrent selection 2022-10-26 20:03:59 +02:00
Joakim Frostegård
91dcd3de4d
Add CanonicalSocketAddr struct (#49)
* Add CanonicalSocketAddr struct to aquatic_common, use in aquatic_udp

* udp_bench: fix build error by using CanonicalSocketAddr
2022-02-02 22:34:54 +01:00
Joakim Frostegård
00c4e74374 udp: use slab for pending scrape responses to fix potential issue
Peers sometimes send multiple scrape requests with the same transaction
id, which would previously cause warnings due to replacing the
PendingScrapeMapEntry and later not finding it.
2022-01-13 18:35:41 +01:00
Joakim Frostegård
e5a1461613
udp: include ConnectionId in PendingScrapeResponseMap key (#42) 2021-12-28 03:16:15 +01:00
Joakim Frostegård
5ef0935c97 udp: remove unused config var max_requests_per_iter 2021-11-18 22:42:36 +01:00
Joakim Frostegård
b617ff9d09 udp: shard request workers by info hash 2021-11-18 22:42:36 +01:00
Joakim Frostegård
4641dd29f2 udp: remove glommio implementation 2021-11-18 22:42:36 +01:00
Joakim Frostegård
821608ab50 aquatic_udp: glommio: return scrape stats in correct order 2021-10-23 16:18:47 +02:00
Joakim Frostegård
1564291471 Run rustfmt 2021-10-23 14:56:00 +02:00
Joakim Frostegård
08920fce5f WIP: aquatic_udp: glommio: work on handling scrape requests 2021-10-23 14:05:54 +02:00
Joakim Frostegård
b10f7b89e7 aquatic_udp: move code only use in mio impl out of crate::common 2021-10-21 15:41:50 +02:00
Joakim Frostegård
de85feec9a aquatic_udp: add and use ConnectedResponse enum 2021-10-18 01:25:25 +02:00
Joakim Frostegård
7616df9686 aquatic_udp: validate requests in socket workers
Also, don't send error responses for unconnected requests
2021-10-18 01:14:32 +02:00
Joakim Frostegård
d0e716f80b Run rustfmt, clean up aquatic_http_protocol/Cargo.toml 2021-08-15 22:26:11 +02:00
Joakim Frostegård
561cc3db55 fix more clippy warnings 2020-08-02 00:36:56 +02:00
Joakim Frostegård
3addab07f0 move plot_pareto from aquatic_udp_bench crate into own crate 2020-05-25 19:38:53 +02:00
Renamed from aquatic_udp_bench/src/bin/aquatic_udp_bench_handlers/scrape.rs (Browse further)