Commit graph

241 commits

Author SHA1 Message Date
Joakim Frostegård
ba060c539b aquatic_ws executable: remove thread log settings, add comment 2020-05-23 20:33:16 +02:00
Joakim Frostegård
66216657ec aquatic_ws: name worker threads
Note: simplelog doesn't seem to pick up thread names, but
this commit is good anyway, since they can be displayed
in e.g. htop on Linux
2020-05-23 20:27:31 +02:00
Joakim Frostegård
bc8916dce4 aquatic_ws: add logging with level configured by config file 2020-05-23 20:16:56 +02:00
Joakim Frostegård
b9ee290ca0 aquatic_ws: add more anyhow error context annotations 2020-05-23 17:15:11 +02:00
Joakim Frostegård
7c33358254 aquatic_ws: polling: don't check if event readable
We only register interest in readable events so this should be OK
2020-05-23 17:06:46 +02:00
Joakim Frostegård
f3bdb6bc2a aquatic_ws: privilege dropping; cli_helpers: show error context 2020-05-23 17:02:52 +02:00
Joakim Frostegård
a596ee155a aquatic_ws: wait for and quit on socket bind errors in workers 2020-05-23 16:38:31 +02:00
Joakim Frostegård
d4bcc14c82 aquatic_ws: add setting Config.ipv6_only 2020-05-23 15:40:56 +02:00
Joakim Frostegård
416d61a2b2 aquatic_ws: split torrent state by ipv4/ipv6 2020-05-23 15:15:01 +02:00
Joakim Frostegård
7430c23ccc aquatic_ws: add simple_logger for debugging, need better solution 2020-05-23 14:53:29 +02:00
Joakim Frostegård
23e0e0bcd0 aquatic_ws: add log::trace statements for message read and write 2020-05-23 14:44:42 +02:00
Joakim Frostegård
a30335730b aquatic_ws: add settings for max ws message sizes, set low defaults 2020-05-23 14:44:03 +02:00
Joakim Frostegård
0f6d6d4b21 aquatic_ws: use log crate for debug error messages 2020-05-23 14:24:26 +02:00
Joakim Frostegård
572aa632b6 aquatic_ws: don't handle connection closed same as other errors 2020-05-23 14:17:03 +02:00
Joakim Frostegård
526faa9aab cli_helpers: use anyhow in app fn; aquatic_ws: reorganize error handling 2020-05-23 14:05:50 +02:00
Joakim Frostegård
b42ff9a23b aquatic_ws: remove DebugCallback and lots of debug output
Some error messages are still printed, though
2020-05-18 13:01:48 +02:00
Joakim Frostegård
1a2432733e aquatic_ws: in scrape handler, limit HashMap preallocation 2020-05-17 21:24:29 +02:00
Joakim Frostegård
4216452fc9 aquatic_udp, aquatic_ws: bind to 0.0.0.0:3000 by default 2020-05-17 11:58:00 +02:00
Joakim Frostegård
7da7d79d90 aquatic_ws: remove no longer valid comment 2020-05-15 17:06:10 +02:00
Joakim Frostegård
ad925c07f1 aquatic_ws: comment out privilege settings since they're not implemented 2020-05-15 17:01:15 +02:00
Joakim Frostegård
0eb4039b5e aquatic_ws: network: use HandshakeMachine::new in Connection 2020-05-15 16:16:03 +02:00
Joakim Frostegård
420dcbc717 aquatic_ws: network: rename common.rs to connection.rs 2020-05-15 16:15:39 +02:00
Joakim Frostegård
73c90622c7 aquatic_ws network: make HandshakeMachine non-public 2020-05-15 16:12:56 +02:00
Joakim Frostegård
cb66364fa5 aquatic_ws: save peer even if AnnounceRequest.bytes_left is None 2020-05-15 16:02:49 +02:00
Joakim Frostegård
138e501599 aquatic_ws: impl read_vectored and write_vectored for Stream 2020-05-14 01:06:18 +02:00
Joakim Frostegård
6c26331ffb aquatic_ws: add inline markers to functions that will probably be hot 2020-05-14 00:25:31 +02:00
Joakim Frostegård
b05db0f699 aquatic_ws: remove unused import 2020-05-13 20:05:39 +02:00
Joakim Frostegård
63b84e7706 aquatic_ws: move more code into Connection impl 2020-05-13 20:02:05 +02:00
Joakim Frostegård
7011a797ee Update TODO; clean up code 2020-05-13 19:40:49 +02:00
Joakim Frostegård
846e076b4b aquatic_ws: move code into Connection impl, so inner can be private 2020-05-13 19:34:46 +02:00
Joakim Frostegård
0bcfffb2bd aquatic_ws: create HandshakeMachine from ConnectionStage 2020-05-13 19:17:33 +02:00
Joakim Frostegård
2967129c1f aquatic_ws: network: streamline handshake handlers 2020-05-13 18:44:10 +02:00
Joakim Frostegård
6d06a43db8 aquatic_ws: add setting for using tls; update TODO 2020-05-13 16:43:23 +02:00
Joakim Frostegård
a6f1d3fa36 aquatic_ws: network: improve comments 2020-05-13 16:02:49 +02:00
Joakim Frostegård
021fd554b0 aquatic_ws: streamline network code 2020-05-13 15:56:45 +02:00
Joakim Frostegård
68abecdaa5 aquatic_ws: run_handshakes_and_read_messages: simplify code 2020-05-13 15:49:07 +02:00
Joakim Frostegård
7e2f371007 aquatic_ws: simplify network code further 2020-05-13 15:14:11 +02:00
Joakim Frostegård
6a8047a5fe aquatic_ws: run_handshakes_and_read_messages: simplify 2020-05-13 15:04:53 +02:00
Joakim Frostegård
012ccd7ec1 aquatic_ws: simplify network code 2020-05-13 15:03:02 +02:00
Joakim Frostegård
05844e9645 WIP: aquatic_ws: continue work on simplifying network code 2020-05-13 14:46:38 +02:00
Joakim Frostegård
91590858b9 WIP: aquatic_ws; work on simplifying network code 2020-05-13 14:35:05 +02:00
Joakim Frostegård
987e1a4a45 aquatic_ws: improve comments in config 2020-05-12 21:08:30 +02:00
Joakim Frostegård
0c93d170de WIP: aquatic_ws network: organize into submodule, other small fixes 2020-05-12 21:04:47 +02:00
Joakim Frostegård
800d3b0efa WIP: aquatic_ws: network: add ConnectionStage::is_established 2020-05-12 20:46:00 +02:00
Joakim Frostegård
6e0b0ccbc2 WIP: aquatic_ws: network: rename PeerConnection to EstablishedWs 2020-05-12 20:31:07 +02:00
Joakim Frostegård
b221f3fc34 WIP: aquatic_ws: support tls and no tls with same functions 2020-05-12 20:20:00 +02:00
Joakim Frostegård
de9a32840f WIP: aquatic_ws: start work on wss (ws with tls) 2020-05-12 18:48:50 +02:00
Joakim Frostegård
7c9ecda53a aquatic_ws: clean torrent state periodically 2020-05-12 15:45:28 +02:00
Joakim Frostegård
de06931242 aquatic_ws: in remove_inactive_connections, run shrink_to_fit on map 2020-05-12 15:24:57 +02:00
Joakim Frostegård
e4bdfd06fb aquatic_ws: set so_reuseport on socket, with new create_listener fn 2020-05-12 15:23:25 +02:00