zishuo/Archive
1
0
Fork 0
mirror of https://github.com/bolucat/Archive.git synced 2025-10-07 17:12:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update On Sat Aug 3 20:32:16 CEST 2024

Browse Source
This commit is contained in:
github-action[bot]
2024-08-03 20:32:16 +02:00
parent c804dc06ba
commit 8a31e512a8
122 changed files with 2408 additions and 5505 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
shadowsocks-rust/crates/shadowsocks/src/net/udp.rs
View File

@@ -53,8 +53,11 @@ use super::{
target_os = "freebsd"
))]
pub struct BatchSendMessage<'a> {
/// Optional target address
pub addr: Option<SocketAddr>,
/// Data to be transmitted
pub data: &'a [IoSlice<'a>],
/// Output result. The number of bytes sent by `batch_send`
pub data_len: usize,
}
@@ -67,8 +70,11 @@ pub struct BatchSendMessage<'a> {
target_os = "freebsd"
))]
pub struct BatchRecvMessage<'a> {
/// Peer address
pub addr: SocketAddr,
/// Data buffer for receiving
pub data: &'a mut [IoSliceMut<'a>],
/// Output result. The number of bytes received by `batch_recv`
pub data_len: usize,
}

29
shadowsocks-rust/crates/shadowsocks/src/relay/udprelay/proxy_socket.rs
View File

@@ -222,7 +222,7 @@ impl ProxySocket {
.map_err(Into::into)
}
/// Send a UDP packet to addr through proxy
/// Send a UDP packet to addr through proxy with `ControlData`
pub async fn send_with_ctrl(
&self,
addr: &Address,
@@ -261,11 +261,19 @@ impl ProxySocket {
}
/// poll family functions
/// the send_timeout is ignored.
///
/// Send a UDP packet to addr through proxy
///
/// NOTE: the `send_timeout` is ignored.
pub fn poll_send(&self, addr: &Address, payload: &[u8], cx: &mut Context<'_>) -> Poll<ProxySocketResult<usize>> {
self.poll_send_with_ctrl(addr, &DEFAULT_SOCKET_CONTROL, payload, cx)
}
/// poll family functions
///
/// Send a UDP packet to addr through proxy with `ControlData`
///
/// NOTE: the `send_timeout` is ignored.
pub fn poll_send_with_ctrl(
&self,
addr: &Address,
@@ -299,6 +307,11 @@ impl ProxySocket {
}
}
/// poll family functions
///
/// Send a UDP packet to addr through proxy `target`
///
/// NOTE: the `send_timeout` is ignored.
pub fn poll_send_to(
&self,
target: SocketAddr,
@@ -309,6 +322,11 @@ impl ProxySocket {
self.poll_send_to_with_ctrl(target, addr, &DEFAULT_SOCKET_CONTROL, payload, cx)
}
/// poll family functions
///
/// Send a UDP packet to addr through proxy `target` with `ControlData`
///
/// NOTE: the `send_timeout` is ignored.
pub fn poll_send_to_with_ctrl(
&self,
target: SocketAddr,
@@ -341,11 +359,14 @@ impl ProxySocket {
}
}
/// poll family functions
///
/// Check if socket is ready to `send`, or writable.
pub fn poll_send_ready(&self, cx: &mut Context<'_>) -> Poll<ProxySocketResult<()>> {
self.socket.poll_send_ready(cx).map_err(|x| x.into())
}
/// Send a UDP packet to target from proxy
/// Send a UDP packet to target through proxy `target`
pub async fn send_to<A: ToSocketAddrs>(
&self,
target: A,
@@ -357,7 +378,7 @@ impl ProxySocket {
.map_err(Into::into)
}
/// Send a UDP packet to target from proxy
/// Send a UDP packet to target through proxy `target`
pub async fn send_to_with_ctrl<A: ToSocketAddrs>(
&self,
target: A,