Commit graph

164 commits

Author SHA1 Message Date
Joakim Frostegård
1e77745a84 http: move network.rs and handlers.rs to new workers dir, rename 2021-11-27 18:26:57 +01:00
Joakim Frostegård
4071d4d874 http: use idiomatic folder structure 2021-11-27 18:23:29 +01:00
Joakim Frostegård
473276cd46 Switch to rust edition 2021 2021-11-24 18:56:26 +01:00
Joakim Frostegård
028a366ce5 Don't unnecessarily constrain crate versions in Cargo.toml files 2021-11-19 02:45:53 +01:00
Joakim Frostegård
5368dce9f0 http: name worker threads 2021-11-11 17:59:31 +01:00
Joakim Frostegård
40df1b587f run cargo fmt 2021-11-11 17:53:02 +01:00
Joakim Frostegård
4f8328b70a Feature-gate CPU pinning, since it only works on Linux 2021-11-09 11:40:16 +01:00
Joakim Frostegård
e86410291a cpu pinning: set affinity to multiple hyperthreads, fix issues 2021-11-07 13:31:03 +01:00
Joakim Frostegård
57896f4648 http, http load test: improve CPU pinning 2021-11-07 11:25:50 +01:00
Joakim Frostegård
b8073e4bd1 Replace HashMap and IndexMap with indexmap_amortized
This will hopefully get down latency.
2021-11-03 10:35:29 +01:00
Joakim Frostegård
8871d0eec8 http and ws: rename cleaning.interval to torrent_cleaning_interval 2021-11-03 00:11:24 +01:00
Joakim Frostegård
fa3b6bb259 Move fn update_access_list to aquatic_common 2021-11-02 23:33:47 +01:00
Joakim Frostegård
9a1993d72e aquatic_http: use signals for reloading access list 2021-11-02 23:16:18 +01:00
Joakim Frostegård
2be604a2f2 http glommio: do debug-level log on Connection::run failure 2021-11-01 17:18:27 +01:00
Joakim Frostegård
76bd895159 http glommio: wait_for_response: panic if response sender is closed 2021-11-01 17:18:27 +01:00
Joakim Frostegård
90d560c307 http glommio: stop looping if peer closed connection 2021-11-01 17:18:27 +01:00
Joakim Frostegård
6a1c12a38b http glommio: better debug logs for RequestParseError::NeedMoreData 2021-11-01 17:18:27 +01:00
Joakim Frostegård
a9b8b0224d aquatic_http: glommio: remove closed connections in own fn 2021-11-01 17:18:27 +01:00
Joakim Frostegård
f767e8a6fa aquatic_http: glommio: call wait_for_response in handle_request 2021-11-01 17:18:27 +01:00
Joakim Frostegård
edec526d41 aquatic_http: glommio: clean up Connection code, stop storing handle 2021-11-01 17:18:27 +01:00
Joakim Frostegård
afce23e321 aquatic_http: glommio: use futures-rustls 2021-11-01 17:18:27 +01:00
Joakim Frostegård
af0761418e aquatic_http: improve ConnectionMeta field names and types 2021-10-28 19:30:04 +02:00
Joakim Frostegård
cccee914d6 aquatic_http: remove config fields previously used for mio impl 2021-10-28 01:57:16 +02:00
Joakim Frostegård
f60631b29e Run cargo fmt 2021-10-28 01:49:37 +02:00
Joakim Frostegård
130377b8f4 aquatic_http: remove mio implementation 2021-10-28 01:48:32 +02:00
Joakim Frostegård
49ed4371e7 Run cargo fmt, clean up imports 2021-10-28 01:23:43 +02:00
Joakim Frostegård
e6d7f78a7a aquatic_http: don't use bindings_after_at - it causes CI error 2021-10-27 21:11:07 +02:00
Joakim Frostegård
974aaf03b4 aquatic_http: set default impl to glommio for testing 2021-10-27 20:52:01 +02:00
Joakim Frostegård
d6d5cc78b7 udp, http: move privilege drop code into aquatic_common 2021-10-27 20:49:15 +02:00
Joakim Frostegård
af5816e2ab aquatic_http: glommio: periodically update access lists 2021-10-27 20:36:38 +02:00
Joakim Frostegård
35b8a1820d Rename CoreAffinityConfig to CpuPinningConfig, rename fields 2021-10-27 20:21:11 +02:00
Joakim Frostegård
d659117ae5 Move CoreAffinityConfig to aquatic_common, use in glommio http 2021-10-27 20:19:02 +02:00
Joakim Frostegård
8747f8de4e aquatic_udp: glommio: limit request size, use array as buffer 2021-10-27 14:28:15 +02:00
Joakim Frostegård
dd968821e4 aquatic_udp: glommio: refactor networking for less state in Connection 2021-10-27 14:07:49 +02:00
Joakim Frostegård
6404be8ef8 aquatic_http: glommio: add access list, refactor networking slightly 2021-10-27 13:55:17 +02:00
Joakim Frostegård
1a4e5750a3 aquatic_http: glommio: periodically remove closed connections 2021-10-27 13:19:02 +02:00
Joakim Frostegård
9bea7c0898 aquatic_http: glommio: deallocate request buffer after successful parse 2021-10-27 12:30:44 +02:00
Joakim Frostegård
c9233726ab Run cargo fmt 2021-10-27 12:24:27 +02:00
Joakim Frostegård
e7305114ad aquatic_http: glommio: panic if request receiver channel is closed 2021-10-27 12:22:01 +02:00
Joakim Frostegård
b7d61cecd9 aquatic_http: glommio: implement scrape requests 2021-10-27 12:13:54 +02:00
Joakim Frostegård
3e912bb379 aquatic_http: glommio: fix channel join deadlock in network.rs 2021-10-27 01:52:49 +02:00
Joakim Frostegård
d03bf48433 aquatic_http glommio: various fixes to network code 2021-10-27 01:03:31 +02:00
Joakim Frostegård
17412868b9 Run cargo fmt 2021-10-27 00:47:46 +02:00
Joakim Frostegård
8f0dabc706 aquatic_http: work on glommio request handlers 2021-10-27 00:45:30 +02:00
Joakim Frostegård
4fc1509a79 aquatic_http: improve mio and common request handling code 2021-10-26 23:40:11 +02:00
Joakim Frostegård
ea2366c808 aquatic_http: simplify mio request handler 2021-10-26 23:38:15 +02:00
Joakim Frostegård
ce8d1ba0d6 aquatic_http: move much logic formerly in mio module into common mod 2021-10-26 23:33:08 +02:00
Joakim Frostegård
8a66b5ce69 aquatic_udp: glommio: return Request in read_tls to reduce state 2021-10-26 22:21:38 +02:00
Joakim Frostegård
636a434ca6 aquatic_http: glommio: unless keep_alive set, close after send 2021-10-26 21:59:40 +02:00
Joakim Frostegård
eebfa69c70 aquatic_http: work on glommio network implementation 2021-10-26 21:54:41 +02:00