Commit graph

1882 commits

Author SHA1 Message Date
Joakim Frostegård
91590858b9 WIP: aquatic_ws; work on simplifying network code 2020-05-13 14:35:05 +02:00
Joakim Frostegård
9c15a97975 Update TODO 2020-05-12 21:11:44 +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
289658815c Update TODO 2020-05-12 16:00:15 +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
Joakim Frostegård
21048727db aquatic_ws: add Config, use in many places; use cli_helpers for cli
Also add mimalloc
2020-05-12 14:58:55 +02:00
Joakim Frostegård
0c8160e3d6 Update TODO: rename aquatic to aquatic_udp; add aquatic_ws TODOs 2020-05-12 12:33:14 +02:00
Joakim Frostegård
2d56ac7c21 aquaticc ws: handle_announce_requests: add #[inline] to helper fn 2020-05-12 12:29:05 +02:00
Joakim Frostegård
499c04d621 aquatic_ws: derive Copy on twenty byte structures, avoid clones 2020-05-12 12:26:49 +02:00
Joakim Frostegård
e76b54e697 aquatic_ws: twenty byte serde: improve comment 2020-05-12 12:24:50 +02:00
Joakim Frostegård
7155f493d9 aquatic_ws: add serialization for 20-byte structures 2020-05-12 00:22:45 +02:00
Joakim Frostegård
9030944c02 aquatic_ws: deserialize 20 byte strings: improve code 2020-05-11 23:35:45 +02:00
Joakim Frostegård
761952513f remove unused dependencies from aquatic_ws; run cargo update 2020-05-11 23:24:50 +02:00
Joakim Frostegård
18c4a51b74 aquatic_ws: use [u8; 20] for info hash etc, fix deserialization 2020-05-11 23:20:58 +02:00
Joakim Frostegård
6b0f2463b6 Update README to reflect reorganisation & aquatic_ws 2020-05-11 17:57:07 +02:00
Joakim Frostegård
5c83af9f88 Move some code from aquatic_udp into aquatic_common 2020-05-11 17:06:37 +02:00
Joakim Frostegård
1b8d74e26d rename aquatic to aquatic_udp, same for bench and load test crates 2020-05-11 16:55:46 +02:00
Joakim Frostegård
f614bab03d update TODO 2020-05-11 16:30:57 +02:00
Joakim Frostegård
f3f2023306 aquatic_ws: update comments 2020-05-11 16:27:42 +02:00
Joakim Frostegård
f1a20b0c8c aquatic_ws: add some fixme comments, update ValidUntil time 2020-05-11 16:22:30 +02:00
Joakim Frostegård
ddef44fb91 Update TODO 2020-05-11 16:20:20 +02:00
Joakim Frostegård
b76f8cdebc aquatic_ws: shorten field names in ConnectionMeta, PeerConnection 2020-05-11 16:19:40 +02:00
Joakim Frostegård
da2d5986b9 aquatic_ws: check for "fake" peer_id's in announce requests 2020-05-11 16:07:51 +02:00
Joakim Frostegård
ab178b3189 add scripts/run-aquatic-ws.sh 2020-05-11 15:41:46 +02:00
Joakim Frostegård
9fc9f2fd9c aquatic_ws: network: remove inactive connections 2020-05-11 15:41:39 +02:00
Joakim Frostegård
87290f4289 aquatic_ws: rename "read_and_forward_in_messages; move around code 2020-05-11 14:42:27 +02:00
Joakim Frostegård
6136184890 aquatic_ws: network: handle network errors better 2020-05-11 14:36:47 +02:00
Joakim Frostegård
656b0da3c6 aquatic_ws: use fn handle_handshake_result in one more location 2020-05-11 14:29:27 +02:00
Joakim Frostegård
583d323c7f aquatic_ws: create fn handle_handshake_result 2020-05-11 14:25:35 +02:00
Joakim Frostegård
274799872f aquatic_ws: clean up; remove connection on IO error; update TODO 2020-05-11 14:13:58 +02:00
Joakim Frostegård
e4bb851c10 aquatic_ws: in listener, remove previous connection if it exists 2020-05-11 14:04:13 +02:00
Joakim Frostegård
0ec73d6cea aquatic_ws: network: ConnectionMap: use Token as key 2020-05-11 13:55:28 +02:00
Joakim Frostegård
a85a72ff66 WIP: aquatic_ws: network: improve connection map & token code 2020-05-11 13:45:17 +02:00
Joakim Frostegård
003e5f2df9 WIP: aquatic_ws: rewrite network code, announce working somewhat 2020-05-10 20:24:04 +02:00
Joakim Frostegård
75c8ccd523 WIP: try to get mio + tungstenite working 2020-05-10 15:25:22 +02:00
Joakim Frostegård
806ac5b184 aquatic_ws protocol: scrape request: add serde rename for info_hashes 2020-05-10 12:10:58 +02:00
Joakim Frostegård
460a778d0d aquatic_ws: protocol: add info hash vector parsing; refactor 2020-05-09 15:31:40 +02:00
Joakim Frostegård
9509c9125f aquatic_ws: add custom deserializer for 20 ascii byte strings 2020-05-09 13:28:01 +02:00
Joakim Frostegård
dcfc1c9854 Update TODO 2020-05-08 21:36:51 +02:00
Joakim Frostegård
e6a4bca04c aquatic ws: split network code into separate functions 2020-05-08 21:26:31 +02:00
Joakim Frostegård
5b58db90e3 aquatic_ws: pass on offers to other peers; minor fixes 2020-05-08 21:05:46 +02:00
Joakim Frostegård
f2ae494902 aquatic: make extract_response_peers generic (for aquatic_ws) 2020-05-08 21:05:17 +02:00
Joakim Frostegård
fa82d93190 aquatic_ws: announce handler: update comments 2020-05-08 02:15:14 +02:00