Commit graph

1016 commits

Author SHA1 Message Date
Joakim Frostegård
0d7119d121
Merge pull request #18 from greatest-ape/ws-glommio
Rewrite aquatic_ws with glommio
2021-11-02 17:03:37 +01:00
Joakim Frostegård
814cd0e6d0 aquatic_ws_load_test: remove unused config fields 2021-11-02 16:34:22 +01:00
Joakim Frostegård
b62639f0d2 Update TODO 2021-11-02 16:19:38 +01:00
Joakim Frostegård
eb304059cc README: mention enabling CPU extensions 2021-11-02 16:13:50 +01:00
Joakim Frostegård
34ba70aee8 Update TODO 2021-11-02 12:19:11 +01:00
Joakim Frostegård
98237c928f aquatic_ws: improve channel sending error handling 2021-11-02 12:06:53 +01:00
Joakim Frostegård
6140596d7e aquatic_ws: in request workers, await out message channel space 2021-11-02 11:58:10 +01:00
Joakim Frostegård
2f5e023fd7 aquatic_ws: use unbounded local out message channel 2021-11-02 11:57:43 +01:00
Joakim Frostegård
3e3acd5adf Update TODO 2021-11-02 11:57:12 +01:00
Joakim Frostegård
6d4e090061 ws load test: send offer answers 2021-11-02 11:51:51 +01:00
Joakim Frostegård
839f516dcb ws load test: rewrite with glommio and futures-rustls 2021-11-02 11:38:11 +01:00
Joakim Frostegård
eb2c294300 Improve README 2021-11-02 00:47:34 +01:00
Joakim Frostegård
93d4e43cfa README: mention need to raise memlock limits 2021-11-02 00:05:59 +01:00
Joakim Frostegård
dcf86d2df2 aquatic_ws: remove unused statistics code and histogram dependency 2021-11-01 23:57:44 +01:00
Joakim Frostegård
65851fa544 aquatic_ws: remove unused config keys 2021-11-01 23:47:30 +01:00
Joakim Frostegård
e00dcaa5c3 aquatic_ws: log ConnectionWriter::send_error_response errors 2021-11-01 22:19:00 +01:00
Joakim Frostegård
724932a498 aquatic_ws: pending scrape responses: avoid cloning stats 2021-11-01 22:17:31 +01:00
Joakim Frostegård
07e1b8230f aquatic_ws: reclaim pending_scrape_slab memory after entry removal 2021-11-01 21:41:05 +01:00
Joakim Frostegård
7ae7442284 aquatic_ws_protocol: clean up, run rustfmt 2021-11-01 21:36:07 +01:00
Joakim Frostegård
d2595e9746 aquatic_ws: split networking into reader and writer tasks 2021-11-01 21:34:34 +01:00
Joakim Frostegård
77c9ca03e8 aquatic_ws_protocol: attempt to parse ws message from binary as well 2021-11-01 19:42:52 +01:00
Joakim Frostegård
ca415af2b9 README: update aquatic_ws info to reflect new glommio implementation 2021-11-01 19:33:45 +01:00
Joakim Frostegård
2ea88c465c File transfer CI: use rustls-style tls config for aquatic_ws 2021-11-01 19:26:49 +01:00
Joakim Frostegård
23c2eff6f3 aquatic_ws: move comment on empty info hashes to network.rs 2021-11-01 19:25:14 +01:00
Joakim Frostegård
786642f486 aquatic_ws: in handlers, collect out messages in Vec for sending 2021-11-01 19:20:49 +01:00
Joakim Frostegård
24bfaf67c0 aquatic_ws: rewrite to use glommio 2021-11-01 19:08:00 +01:00
Joakim Frostegård
02c4111f4a
Merge pull request #17 from greatest-ape/http-futures-rustls
aquatic_http: use futures-rustls, improve networking code
2021-11-01 17:24:58 +01:00
Joakim Frostegård
83a4e318a4 aquatic_http_protocol: cargo fmt 2021-11-01 17:18:27 +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
5a1bedfe85
Merge pull request #15 from greatest-ape/udp-fixes
aquatic_udp mio implementation: clean connections according to interval, print more statistics
2021-10-31 21:35:30 +01:00
Joakim Frostegård
1949ed2e9c aquatic_udp: mio: rewrite connection cleaning interval logic 2021-10-31 21:12:52 +01:00
Joakim Frostegård
03a344eb8e aquatic_udp: mio: print num torrents and peers in statistics 2021-10-31 19:57:30 +01:00
Joakim Frostegård
143585792c aquatic_udp: mio: actually clean connections according to config 2021-10-31 19:43:38 +01:00
Joakim Frostegård
b2347ef3b0 Update TODO 2021-10-30 17:40:59 +02:00
Joakim Frostegård
3a598956a1
Merge pull request #14 from greatest-ape/bug-fixes
Bug fixes
2021-10-30 17:38:58 +02:00
Joakim Frostegård
df9aaccb46 aquatic_http_protocol: fix serde_quickcheck_identity_test
Since empty info hash Vec is no longer allowed, don't allow
it in test data and expect parsing to succeed.
2021-10-30 17:06:28 +02:00
Joakim Frostegård
bb75907c07 aquatic_udp: double MAX_PACKAGE_SIZE to allow for large responses 2021-10-30 17:03:07 +02:00
Joakim Frostegård
0107b3a77e aquatic_udp: add (failing) test for writing ipv6 announce responses 2021-10-30 16:51:59 +02:00
Joakim Frostegård
819821edf0 Update TODO 2021-10-29 15:11:01 +02:00
Joakim Frostegård
ca644ba2df
Merge pull request #13 from greatest-ape/http-glommio
aquatic_http: replace mio implementation with new glommio implementation
2021-10-29 08:20:42 +02:00
Joakim Frostegård
64051b15a8
Merge branch 'master' into http-glommio 2021-10-28 21:22:41 +02:00
Joakim Frostegård
4f055c7c6f Update TODO 2021-10-28 20:23:56 +02:00
Joakim Frostegård
af0761418e aquatic_http: improve ConnectionMeta field names and types 2021-10-28 19:30:04 +02:00