20 commits

Author	SHA1	Message	Date
Joakim Frostegård	14c973f72f	udp: Config.socket_workers: make value 0 auto-use available vCPUs	2024-02-10 23:07:59 +01:00
Joakim Frostegård	2c7bcf71ad	bencher: change to account for new aquatic_udp implementation	2024-02-10 18:51:13 +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	2da966098f	WIP: use shared swarm state in mio worker	2024-02-10 11:21:48 +01:00
Joakim Frostegård	53497308f1	udp: create file with thread-shared torrent map implementation	2024-02-10 10:01:45 +01:00
Joakim Frostegård	40e33d8af1	fix prometheus timeout mask metrics	2024-02-04 00:03:01 +01:00
Joakim Frostegård	d7e06468c3	http: quit if any worker thread quits	2024-02-03 22:38:05 +01:00
Joakim Frostegård	4ca73630c4	Move prometheus endpoint spawner from udp to common crate	2024-02-03 22:07:56 +01:00
Joakim Frostegård	b4e27903dc	udp: actually register global metrics handler	2024-02-02 14:46:42 +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	216bb93088	udp: improve WorkerType Display implementation	2024-01-29 22:27:03 +01:00
Joakim Frostegård	6dec985d45	udp: store prometheus exporter thread handle, periodically render	2024-01-29 22:09:20 +01:00
Joakim Frostegård	8f838098aa	udp: replace PanicSentinel with loop over JoinHandles	2024-01-29 21:45:50 +01:00
Joakim Frostegård	9d1bba5e92	udp: fix/silence clippy warnings	2024-01-20 10:08:53 +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	c4e644cb23	udp: log (info-level) estimated channel memory use	2024-01-02 16:57:46 +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	9b032f7e24	Move all crates to new crates dir	2023-10-18 23:53:41 +02:00

Renamed from aquatic_udp/src/lib.rs (Browse further)