Struct socks5_server::connection::IncomingConnection

pub struct IncomingConnection<O> { /* private fields */ }

A freshly established TCP connection.

This may not be a valid SOCKS5 connection. You should call authenticate() to perform a SOCKS5 authentication handshake.

It can also be converted back into a raw tokio TcpStream with From trait.

Implementations

impl<O> IncomingConnection<O>

pub async fn authenticate( self ) -> Result<(Authenticated, O), (Error, TcpStream)>

Perform a SOCKS5 authentication handshake using the given Auth adapter.

If the handshake succeeds, an Authenticated alongs with the output of the Auth adapter is returned. Otherwise, the error and the original TcpStream is returned.

Note that this method will not implicitly close the connection even if the handshake failed.

pub async fn shutdown(&mut self) -> Result<(), IoError>

Causes the other peer to receive a read of length 0, indicating that no more data will be sent. This only closes the stream in one direction.

pub fn local_addr(&self) -> Result<SocketAddr, IoError>

Returns the local address that this stream is bound to.

pub fn peer_addr(&self) -> Result<SocketAddr, IoError>

Returns the remote address that this stream is connected to.

pub fn linger(&self) -> Result<Option<Duration>, IoError>

Reads the linger duration for this socket by getting the SO_LINGER option.

For more information about this option, see set_linger.

pub fn set_linger(&self, dur: Option<Duration>) -> Result<(), IoError>

Sets the linger duration of this socket by setting the SO_LINGER option.

This option controls the action taken when a stream has unsent messages and the stream is closed. If SO_LINGER is set, the system shall block the process until it can transmit the data or until the time expires.

If SO_LINGER is not specified, and the stream is closed, the system handles the call in a way that allows the process to continue as quickly as possible.

pub fn nodelay(&self) -> Result<bool, IoError>

Gets the value of the TCP_NODELAY option on this socket.

For more information about this option, see set_nodelay.

pub fn set_nodelay(&self, nodelay: bool) -> Result<(), IoError>

Sets the value of the TCP_NODELAY option on this socket.

If set, this option disables the Nagle algorithm. This means that segments are always sent as soon as possible, even if there is only a small amount of data. When not set, data is buffered until there is a sufficient amount to send out, thereby avoiding the frequent sending of small packets.

pub fn ttl(&self) -> Result<u32, IoError>

Gets the value of the IP_TTL option for this socket.

For more information about this option, see set_ttl.

pub fn set_ttl(&self, ttl: u32) -> Result<(), IoError>

Sets the value for the IP_TTL option on this socket.

This value sets the time-to-live field that is used in every packet sent from this socket.

Trait Implementations

impl<O> From<IncomingConnection<O>> for TcpStream

fn from(conn: IncomingConnection<O>) -> Self

Converts to this type from the input type.