Val Packett
2d18eb6686
udp: fix msghdr creation on musl libc
...
Right now building for musl also requires updating glommio to a git
version.
2024-03-30 10:31:16 +01:00
Joakim Frostegård
f4ef9fcfc9
udp: fix test_connection_validator
2024-02-10 22:56:37 +01:00
Joakim Frostegård
680da048b8
udp: add ConnectionValidator.update_elapsed, call regularly
...
This is faster than doing it for each request
2024-02-10 22:47:36 +01:00
Joakim Frostegård
94247b8e35
udp: mio: don't recalculate PeerUntil every announce request
2024-02-10 22:22:19 +01:00
Joakim Frostegård
19533b3f8e
udp: mio: make send_response a method
2024-02-10 22:13:01 +01:00
Joakim Frostegård
7116fdd862
udp: io_uring: improve docs
2024-02-10 21:55:39 +01:00
Joakim Frostegård
ebf4ecbf6a
udp: fix torrent count statistics
2024-02-10 21:45:34 +01:00
Joakim Frostegård
358c8951c0
udp: improve udp uring code
2024-02-10 18:06:42 +01:00
Joakim Frostegård
6d784c25e9
udp: remove pending scrape config stuff, adjust io uring code
2024-02-10 15:56:34 +01:00
Joakim Frostegård
71a3cb9a5a
udp: remove socket_worker config, adjust other code, fix statistics
2024-02-10 15:54:26 +01:00
Joakim Frostegård
c4fd3c9e83
udp: add cleaning worker
2024-02-10 15:48:09 +01:00
Joakim Frostegård
7fa143964e
udp: remove swarm worker and related logic
2024-02-10 11:40:11 +01:00
Joakim Frostegård
a2e1dd4eef
udp: use shared swarm state in io uring implementation
2024-02-10 11:35:52 +01:00
Joakim Frostegård
2da966098f
WIP: use shared swarm state in mio worker
2024-02-10 11:21:48 +01:00
Joakim Frostegård
c980c23ffc
bencher: also bench aquatic_udp with io_uring
2024-02-09 01:21:24 +01:00
Joakim Frostegård
e705c03981
Explicity use IndexMap::swap_remove to silence warnings
2024-02-06 18:34:17 +01:00
Joakim Frostegård
be5165bcf2
udp: mio socket worker: make send_response plain fn
2024-02-02 13:48:06 +01:00
Joakim Frostegård
405bbaca93
udp: improve statistics structs
...
- Now, workers don't need to keep track of which atomic usize
to update
- Additionally, prometheus now gets separate information per
socket worker
2024-02-02 13:39:46 +01:00
Joakim Frostegård
e2e525b560
udp: move PeerStatus from common.rs to swarm worker
2024-02-01 23:25:43 +01:00
Joakim Frostegård
1967d8aa3e
udp: return errors from threads instead of panicking in some cases
2024-01-29 22:17:30 +01:00
Joakim Frostegård
ae75d0cbe4
udp socket worker: fix warning
2024-01-29 22:12:08 +01:00
Joakim Frostegård
8f838098aa
udp: replace PanicSentinel with loop over JoinHandles
2024-01-29 21:45:50 +01:00
Joakim Frostegård
1c59972834
udp protocol: rename "write" and "from_bytes" methods
2024-01-29 19:38:12 +01:00
Joakim Frostegård
9d1bba5e92
udp: fix/silence clippy warnings
2024-01-20 10:08:53 +01:00
Joakim Frostegård
5401eaf85f
Run cargo clippy --fix and cargo fmt
2024-01-20 09:56:14 +01:00
Joakim Frostegård
0c03048ce8
udp: update metrics crate
2024-01-20 09:42:17 +01:00
Joakim Frostegård
1a6b4345d4
udp: remove thingbuf in favor of crossbeam channel
...
thingbuf didn't have obvious performance advantages and is a lot less
mature. Furthermore, it doesn't support anything like crossbeam
Receiver::try_iter, which is prefereable now that announce responses
can be sent to any socket worker.
2024-01-20 09:41:07 +01:00
Joakim Frostegård
e77c9f46e7
udp: store torrents with few peers without an extra heap alloc
2024-01-20 09:40:09 +01:00
Joakim Frostegård
0eaa4475e2
udp: index peers by packet src ip and provided port instead of peer_id
2024-01-04 17:04:17 +01:00
Joakim Frostegård
6870a9e9c4
udp: lower log level from info to debug for several mio statements
2024-01-02 17:00:22 +01:00
Joakim Frostegård
b527af7195
udp: distribute announce swarm responses among socket workers
...
They don't have to be sent from the same worker that received the
request, so we can decrease performance loss from underutilized
threads this way.
2024-01-01 14:13:30 +01:00
Joakim Frostegård
ba8bdd6ae6
udp: harden ConnectionValidator
2023-12-26 00:19:47 +01:00
Joakim Frostegård
cb39eb69c8
udp: reorder code in swarm storage
2023-12-10 12:13:56 +01:00
Joakim Frostegård
0c4140165b
udp: reuse response channel mem, add backpressure, faster peer extract
2023-12-10 12:07:38 +01:00
Joakim Frostegård
0e12dd1b13
use zerocopy in udp protocol, easy running transfer CI locally
2023-12-02 12:24:41 +01:00
Joakim Frostegård
af16a9e682
udp: fix io_uring soundness issues
2023-11-23 18:52:13 +01:00
Joakim Frostegård
fe5ccf6646
ws: refactor, bug fixes, improvements ( #155 )
...
- split swarm worker into two modules
- split socket worker into two modules
- keep track of which offers peers have sent and only allow matching
answers
- always clean up after closing connection
- use channel for telling connections to close
- move some logic into new ConnectionRunner struct
- use slotmap for connection reference storage
- fix double counting of error responses
- actually close connections that take too long to send responses to
- remove announced_info_hashes entry on AnnounceEvent::Stopped
2023-11-09 18:06:21 +01:00
Joakim Frostegård
9b032f7e24
Move all crates to new crates dir
2023-10-18 23:53:41 +02:00
