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