networkException/netapp
1
0
Fork 0
forked from lx/netapp
Code Pull requests Activity
181 commits 6 branches 17 tags 408 KiB
Commit graph

181 commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
networkException 47a470b281
everywhere: support unix sockets 
This patch adds support for listening on and connecting to unix sockets.

This requires having wrapper types for various tokio specific network
abstractions while also supporting things like serialization and
deserialization.

Unfortionately i was unable to find a published crate fulfilling these
requirements.

For this reason I've published a crate myself. Called `tokio-unix-tcp`,
it serves as a drop in replacement for Tokio's TCP and Unix network
types.

I plan to maintain this library outside the scope of this project as
well, in general the code should be simple and stable enough however
to not require maintainance going forward.

As i said this crate aims to support the requirement mentioned above.
In addition to this it also strives to be more correct about handling
the different types of unix sockets, which the libraries i reviewed
were weak at. A list of these crates can be found in the crate README
under "Related work".

---

The changes to netapp can be summarized as the following:

- `std::net::SocketAddr` has been replaced by
  `tokio_unix_tcp::NamedSocketAddr` in most places. This enum encapsulates
  a IP address and port as well as a path in its variants and describes
  a concrete socket address netapp can bind or connect to.

- In some places `tokio_unix_tcp::SocketAddr` is used instead of
  `tokio_unix_tcp::NamedSocketAddr` as mentioned above. This is due to
  the way unix sockets work:

  The remote peer of a client from the perspective of a server is not
  a concrete path but `unnamed`. They just share a file descriptor
  for the actual communication channel. The local address of the server
  is the actual file system path the server is listening on.

  In some cases netapp might be configured to connect to another peer
  using a unix socket and to not send a reachable IP address and port
  or unix socket path using the `HelloMessage`.

  As per the above (the client's remote address will be `unnamed`),
  we have no way of connecting back to that peer. This will currently
  cause the connection to be aborted by the server.

- Listening on Unix sockets requires some additional handling like
  removing a previous file at the bind path and setting a correct
  mode (defaulting to `0o222` currently). This is handled by
  `tokio_unix_tcp`.

---

I've tested these changes by including them in garage and running basic
administration commands against a node and by running the unit tests here.

Basalt peering is currently lacking a proper cost calculation for unix
sockets - I'm sadly not familiar with this code.
 2023-11-05 22:29:12 +01:00
networkException e6976dea5a
cargo: add tokio-unix-tcp as a dependency 2023-11-05 22:29:11 +01:00
Alex 170ddbfac4 Merge pull request 'netapp 0.10' (#12) from next-0.10 into main 
Reviewed-on: lx/netapp#12
 2023-10-23 09:24:40 +00:00
Alex 2484d7654a update rmp-serde to v1.1, bump to 0.10.0 2023-09-27 12:32:54 +02:00
Alex b7beb15492 bump to v0.5.4 2023-09-21 15:54:35 +02:00
Alex 34aade6ce9 update .drone.yml 2023-02-01 00:09:13 +01:00
Alex 6df6411b72 fix clippy 2023-01-31 23:57:33 +01:00
Alex e4c0be848d
Ability to configure ping timeout interval 2022-09-19 19:46:41 +02:00
Alex 1a413eef97
Add async version of parse_and_resolve_peer_addr 2022-09-14 15:45:05 +02:00
Alex 8ac109e3a8 Merge pull request 'add streaming body to requests and responses' (#3) from stream-body into main 
Reviewed-on: lx/netapp#3
 2022-09-13 12:56:53 +02:00
Alex 298e956a19
undo needless change 2022-09-13 12:48:54 +02:00
Alex 395f942fc7
Fix potential memory leak 2022-09-13 12:37:55 +02:00
Alex b509e6057f
Missing cleanup 2022-09-13 12:28:01 +02:00
Alex c00676feba
Uniformize flag naming 2022-09-13 12:25:37 +02:00
Alex 18d5abc981
add precision to protocol description 2022-09-13 12:20:49 +02:00
Alex 8ab6256c3b
No longer need to derive Clone on message types 2022-09-13 12:12:55 +02:00
Alex 9362d26890
fill_buffer do something only if buf is empty 2022-09-13 12:08:33 +02:00
Alex db96af2609
Add comment on cancellation 2022-09-13 12:05:42 +02:00
Alex add2b54743
fix comment 2022-09-13 11:52:35 +02:00
Alex bf0e82047f
try make more like before 2022-09-13 11:51:03 +02:00
Alex 2305c2cf03
Use BytesMut instead of Vec<u8> in bytes_buf (extend is probably faster) 2022-09-13 11:31:19 +02:00
Alex f022a77f97
Add documentation 2022-09-12 17:43:10 +02:00
Alex 8a7aca9837
reword doc comment 2022-09-12 17:20:45 +02:00
Alex f0326607ee
slightly change example 2022-09-12 17:19:26 +02:00
Alex 0f799a7768
Implement Least Attained First scheduling of streams 2022-09-06 19:42:49 +02:00
Alex 5af23955af
Merge branch 'main' into stream-body 2022-09-02 14:24:45 +02:00
Alex a82700c5a2 Merge pull request 'Fix ping timeout and interval' (#4) from fix-ping into main 
Reviewed-on: lx/netapp#4
 2022-09-02 14:22:57 +02:00
Alex ca25331d73
Bump to v0.4.5 2022-09-02 14:21:42 +02:00
Alex 9bf29a7a18
Merge branch 'fix-ping' into stream-body 2022-09-02 14:15:02 +02:00
Alex c865cc9f9c
Merge branch 'main' into fix-ping 2022-09-02 14:02:08 +02:00
Alex 8c73b27655
Update dependencies 2022-09-02 14:00:52 +02:00
Alex f6ad1d0fab
less verbosity 2022-09-01 16:13:43 +02:00
Alex b82ad70dd5
Correctly defuse cancellation on simple requests 2022-09-01 16:11:42 +02:00
Alex b931d0d1cf
try debug 2022-09-01 16:01:56 +02:00
Alex 522f420e2b
Implement request cancellation 2022-09-01 15:54:11 +02:00
Alex 3292566738
fix trace message 2022-09-01 14:43:27 +02:00
Alex 22d96929d5
Merge branch 'fix-ping' into stream-body 2022-09-01 14:23:10 +02:00
Alex 4a59b73d7b
Add actual support for order tag 2022-09-01 12:46:33 +02:00
Alex cd203f5708
Add OrderTag to Req and Resp, refactor errors 2022-09-01 12:15:50 +02:00
Alex 745c786184
Also encode errorkind in stream 2022-09-01 11:34:53 +02:00
Alex 7909a95d3c
Stream errors are now std::io::Error 2022-09-01 11:21:24 +02:00
Alex 263db66fce
Refactor: create a BytesBuf utility crate (will also be usefull in Garage) 2022-09-01 10:29:26 +02:00
Alex 3fd30c6e28
recv side: use unbounded channel to remove deadlock 2022-09-01 09:45:24 +02:00
Alex 2c9d595da0
Remove useless phantom and pub(crate) 2022-08-31 22:19:40 +02:00
Alex d75146fb81
SVR -> SRV 2022-08-31 17:04:45 +02:00
Alex 7703659742
Be more lenient on pings 2022-08-31 16:25:36 +02:00
Alex 984ba65e65
Better messages in proto.rs 2022-08-31 16:10:14 +02:00
Alex 01db3c4319
add debug_name in proto to differenciate messages 2022-08-31 15:58:05 +02:00
Alex 700f783956
Add dump of sending queue 2022-08-31 15:08:51 +02:00
Alex 81b2ff3a4e
Ping less frequently 2022-08-31 15:06:21 +02:00