pub struct Socket { /* private fields */ }
Expand description
Owned wrapper around a system socket.
This type simply wraps an instance of a file descriptor (c_int
) on Unix
and an instance of SOCKET
on Windows. This is the main type exported by
this crate and is intended to mirror the raw semantics of sockets on
platforms as closely as possible. Almost all methods correspond to
precisely one libc or OS API call which is essentially just a “Rustic
translation” of what’s below.
§Converting to and from other types
This type can be freely converted into the network primitives provided by
the standard library, such as TcpStream
or UdpSocket
, using the
From
trait, see the example below.
§Notes
Some methods that set options on Socket
require two system calls to set
their options without overwriting previously set options. We do this by
first getting the current settings, applying the desired changes, and then
updating the settings. This means that the operation is not atomic. This
can lead to a data race when two threads are changing options in parallel.
§Examples
use std::net::{SocketAddr, TcpListener};
use socket2::{Socket, Domain, Type};
// create a TCP listener
let socket = Socket::new(Domain::IPV6, Type::STREAM, None)?;
let address: SocketAddr = "[::1]:12345".parse().unwrap();
let address = address.into();
socket.bind(&address)?;
socket.listen(128)?;
let listener: TcpListener = socket.into();
// ...
Implementations§
source§impl Socket
impl Socket
sourcepub fn new(
domain: Domain,
ty: Type,
protocol: Option<Protocol>
) -> Result<Socket>
pub fn new( domain: Domain, ty: Type, protocol: Option<Protocol> ) -> Result<Socket>
Creates a new socket and sets common flags.
This function corresponds to socket(2)
on Unix and WSASocketW
on
Windows.
On Unix-like systems, the close-on-exec flag is set on the new socket.
Additionally, on Apple platforms SOCK_NOSIGPIPE
is set. On Windows,
the socket is made non-inheritable.
Socket::new_raw
can be used if you don’t want these flags to be set.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=socket§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=socket&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/socket.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/socket.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/socket.2
- OpenBSD: https://man.openbsd.org/socket.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/socket.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/socket
- Windows: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-socket
sourcepub fn new_raw(
domain: Domain,
ty: Type,
protocol: Option<Protocol>
) -> Result<Socket>
pub fn new_raw( domain: Domain, ty: Type, protocol: Option<Protocol> ) -> Result<Socket>
Creates a new socket ready to be configured.
This function corresponds to socket(2)
on Unix and WSASocketW
on
Windows and simply creates a new socket, no other configuration is done.
sourcepub fn pair(
domain: Domain,
ty: Type,
protocol: Option<Protocol>
) -> Result<(Socket, Socket)>
Available on crate feature all
and Unix only.
pub fn pair( domain: Domain, ty: Type, protocol: Option<Protocol> ) -> Result<(Socket, Socket)>
all
and Unix only.Creates a pair of sockets which are connected to each other.
This function corresponds to socketpair(2)
.
This function sets the same flags as in done for Socket::new
,
Socket::pair_raw
can be used if you don’t want to set those flags.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=socketpair§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=socketpair&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/socketpair.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/socketpair.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/socketpair.2
- OpenBSD: https://man.openbsd.org/socketpair.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/socketpair.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/socketpair
sourcepub fn pair_raw(
domain: Domain,
ty: Type,
protocol: Option<Protocol>
) -> Result<(Socket, Socket)>
Available on crate feature all
and Unix only.
pub fn pair_raw( domain: Domain, ty: Type, protocol: Option<Protocol> ) -> Result<(Socket, Socket)>
all
and Unix only.Creates a pair of sockets which are connected to each other.
This function corresponds to socketpair(2)
.
sourcepub fn bind(&self, address: &SockAddr) -> Result<()>
pub fn bind(&self, address: &SockAddr) -> Result<()>
Binds this socket to the specified address.
This function directly corresponds to the bind(2)
function on Windows
and Unix.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=bind§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=bind&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/bind.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/bind.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/bind.2
- OpenBSD: https://man.openbsd.org/bind.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/bind.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/bind
- Windows: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-bind
sourcepub fn connect(&self, address: &SockAddr) -> Result<()>
pub fn connect(&self, address: &SockAddr) -> Result<()>
Initiate a connection on this socket to the specified address.
This function directly corresponds to the connect(2)
function on
Windows and Unix.
An error will be returned if listen
or connect
has already been
called on this builder.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=connect§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=connect&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/connect.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/connect.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/connect.2
- OpenBSD: https://man.openbsd.org/connect.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/connect.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/connect
- Windows: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-connect
§Notes
When using a non-blocking connect (by setting the socket into non-blocking mode before calling this function), socket option can’t be set while connecting. This will cause errors on Windows. Socket options can be safely set before and after connecting the socket.
sourcepub fn connect_timeout(&self, addr: &SockAddr, timeout: Duration) -> Result<()>
pub fn connect_timeout(&self, addr: &SockAddr, timeout: Duration) -> Result<()>
Initiate a connection on this socket to the specified address, only only waiting for a certain period of time for the connection to be established.
Unlike many other methods on Socket
, this does not correspond to a
single C function. It sets the socket to nonblocking mode, connects via
connect(2), and then waits for the connection to complete with poll(2)
on Unix and select on Windows. When the connection is complete, the
socket is set back to blocking mode. On Unix, this will loop over
EINTR
errors.
§Warnings
The non-blocking state of the socket is overridden by this function - it will be returned in blocking mode on success, and in an indeterminate state on failure.
If the connection request times out, it may still be processing in the
background - a second call to connect
or connect_timeout
may fail.
sourcepub fn listen(&self, backlog: c_int) -> Result<()>
pub fn listen(&self, backlog: c_int) -> Result<()>
Mark a socket as ready to accept incoming connection requests using
Socket::accept()
.
This function directly corresponds to the listen(2)
function on
Windows and Unix.
An error will be returned if listen
or connect
has already been
called on this builder.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=listen§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=listen&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/listen.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/listen.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/listen.2
- OpenBSD: https://man.openbsd.org/listen.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/listen.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/listen
- Windows: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-listen
sourcepub fn accept(&self) -> Result<(Socket, SockAddr)>
pub fn accept(&self) -> Result<(Socket, SockAddr)>
Accept a new incoming connection from this listener.
This function uses accept4(2)
on platforms that support it and
accept(2)
platforms that do not.
This function sets the same flags as in done for Socket::new
,
Socket::accept_raw
can be used if you don’t want to set those flags.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=accept§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=accept&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/accept.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/accept.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/accept.2
- OpenBSD: https://man.openbsd.org/accept.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/accept.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/accept
- Windows: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-accept
sourcepub fn accept_raw(&self) -> Result<(Socket, SockAddr)>
pub fn accept_raw(&self) -> Result<(Socket, SockAddr)>
Accept a new incoming connection from this listener.
This function directly corresponds to the accept(2)
function on
Windows and Unix.
sourcepub fn local_addr(&self) -> Result<SockAddr>
pub fn local_addr(&self) -> Result<SockAddr>
Returns the socket address of the local half of this socket.
This function directly corresponds to the getsockname(2)
function on
Windows and Unix.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=getsockname§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=getsockname&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/getsockname.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/getsockname.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/getsockname.2
- OpenBSD: https://man.openbsd.org/getsockname.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/getsockname.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/getsockname
- Windows: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-getsockname
§Notes
Depending on the OS this may return an error if the socket is not bound.
sourcepub fn peer_addr(&self) -> Result<SockAddr>
pub fn peer_addr(&self) -> Result<SockAddr>
Returns the socket address of the remote peer of this socket.
This function directly corresponds to the getpeername(2)
function on
Windows and Unix.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=getpeername§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=getpeername&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/getpeername.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/getpeername.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/getpeername.2
- OpenBSD: https://man.openbsd.org/getpeername.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/getpeername.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/getpeername
- Windows: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-getpeername
§Notes
This returns an error if the socket is not connect
ed.
sourcepub fn type(&self) -> Result<Type>
pub fn type(&self) -> Result<Type>
Returns the Type
of this socket by checking the SO_TYPE
option on
this socket.
sourcepub fn try_clone(&self) -> Result<Socket>
pub fn try_clone(&self) -> Result<Socket>
Creates a new independently owned handle to the underlying socket.
§Notes
On Unix this uses F_DUPFD_CLOEXEC
and thus sets the FD_CLOEXEC
on
the returned socket.
On Windows this uses WSA_FLAG_NO_HANDLE_INHERIT
setting inheriting to
false.
On Windows this can not be used function cannot be used on a QOS-enabled socket, see https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-wsaduplicatesocketw.
sourcepub fn nonblocking(&self) -> Result<bool>
Available on crate feature all
and Unix only.
pub fn nonblocking(&self) -> Result<bool>
all
and Unix only.Returns true if this socket is set to nonblocking mode, false otherwise.
§Notes
On Unix this corresponds to calling fcntl
returning the value of
O_NONBLOCK
.
On Windows it is not possible retrieve the nonblocking mode status.
sourcepub fn set_nonblocking(&self, nonblocking: bool) -> Result<()>
pub fn set_nonblocking(&self, nonblocking: bool) -> Result<()>
Moves this socket into or out of nonblocking mode.
§Notes
On Unix this corresponds to calling fcntl
(un)setting O_NONBLOCK
.
On Windows this corresponds to calling ioctlsocket
(un)setting
FIONBIO
.
sourcepub fn shutdown(&self, how: Shutdown) -> Result<()>
pub fn shutdown(&self, how: Shutdown) -> Result<()>
Shuts down the read, write, or both halves of this connection.
This function will cause all pending and future I/O on the specified portions to return immediately with an appropriate value.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=shutdown§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=shutdown&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/shutdown.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/shutdown.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/shutdown.2
- OpenBSD: https://man.openbsd.org/shutdown.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/shutdown.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/shutdown
- Windows: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-shutdown
sourcepub fn recv(&self, buf: &mut [MaybeUninit<u8>]) -> Result<usize>
pub fn recv(&self, buf: &mut [MaybeUninit<u8>]) -> Result<usize>
Receives data on the socket from the remote address to which it is connected.
The connect
method will connect this socket to a remote address.
This method might fail if the socket is not connected.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=recv§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=recv&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/recv.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/recv.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/recv.2
- OpenBSD: https://man.openbsd.org/recv.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/recv.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/recv
- Windows: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-recv
§Safety
Normally casting a &mut [u8]
to &mut [MaybeUninit<u8>]
would be
unsound, as that allows us to write uninitialised bytes to the buffer.
However this implementation promises to not write uninitialised bytes to
the buf
fer and passes it directly to recv(2)
system call. This
promise ensures that this function can be called using a buf
fer of
type &mut [u8]
.
Note that the io::Read::read
implementation calls this function with
a buf
fer of type &mut [u8]
, allowing initialised buffers to be used
without using unsafe
.
sourcepub fn recv_out_of_band(&self, buf: &mut [MaybeUninit<u8>]) -> Result<usize>
pub fn recv_out_of_band(&self, buf: &mut [MaybeUninit<u8>]) -> Result<usize>
Receives out-of-band (OOB) data on the socket from the remote address to
which it is connected by setting the MSG_OOB
flag for this call.
For more information, see recv
, out_of_band_inline
.
sourcepub fn recv_with_flags(
&self,
buf: &mut [MaybeUninit<u8>],
flags: c_int
) -> Result<usize>
pub fn recv_with_flags( &self, buf: &mut [MaybeUninit<u8>], flags: c_int ) -> Result<usize>
Identical to recv
but allows for specification of arbitrary flags to
the underlying recv
call.
sourcepub fn recv_vectored(
&self,
bufs: &mut [MaybeUninitSlice<'_>]
) -> Result<(usize, RecvFlags)>
Available on non-Redox only.
pub fn recv_vectored( &self, bufs: &mut [MaybeUninitSlice<'_>] ) -> Result<(usize, RecvFlags)>
Receives data on the socket from the remote address to which it is
connected. Unlike recv
this allows passing multiple buffers.
The connect
method will connect this socket to a remote address.
This method might fail if the socket is not connected.
In addition to the number of bytes read, this function returns the flags
for the received message. See RecvFlags
for more information about
the returned flags.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=recvmsg§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=recvmsg&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/recvmsg.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/recvmsg.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/recvmsg.2
- OpenBSD: https://man.openbsd.org/recvmsg.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/recvmsg.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/recvmsg
- Windows: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-recvmsg
§Safety
Normally casting a IoSliceMut
to MaybeUninitSlice
would be unsound,
as that allows us to write uninitialised bytes to the buffer. However
this implementation promises to not write uninitialised bytes to the
bufs
and passes it directly to recvmsg(2)
system call. This promise
ensures that this function can be called using bufs
of type &mut [IoSliceMut]
.
Note that the io::Read::read_vectored
implementation calls this
function with buf
s of type &mut [IoSliceMut]
, allowing initialised
buffers to be used without using unsafe
.
sourcepub fn recv_vectored_with_flags(
&self,
bufs: &mut [MaybeUninitSlice<'_>],
flags: c_int
) -> Result<(usize, RecvFlags)>
Available on non-Redox only.
pub fn recv_vectored_with_flags( &self, bufs: &mut [MaybeUninitSlice<'_>], flags: c_int ) -> Result<(usize, RecvFlags)>
Identical to recv_vectored
but allows for specification of arbitrary
flags to the underlying recvmsg
/WSARecv
call.
§Safety
recv_from_vectored
makes the same safety guarantees regarding bufs
as recv_vectored
.
sourcepub fn peek(&self, buf: &mut [MaybeUninit<u8>]) -> Result<usize>
pub fn peek(&self, buf: &mut [MaybeUninit<u8>]) -> Result<usize>
Receives data on the socket from the remote adress to which it is connected, without removing that data from the queue. On success, returns the number of bytes peeked.
Successive calls return the same data. This is accomplished by passing
MSG_PEEK
as a flag to the underlying recv
system call.
§Safety
peek
makes the same safety guarantees regarding the buf
fer as
recv
.
sourcepub fn recv_from(
&self,
buf: &mut [MaybeUninit<u8>]
) -> Result<(usize, SockAddr)>
pub fn recv_from( &self, buf: &mut [MaybeUninit<u8>] ) -> Result<(usize, SockAddr)>
Receives data from the socket. On success, returns the number of bytes read and the address from whence the data came.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=recvfrom§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=recvfrom&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/recvfrom.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/recvfrom.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/recvfrom.2
- OpenBSD: https://man.openbsd.org/recvfrom.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/recvfrom.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/recvfrom
- Windows: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-recvfrom
§Safety
recv_from
makes the same safety guarantees regarding the buf
fer as
recv
.
sourcepub fn recv_from_with_flags(
&self,
buf: &mut [MaybeUninit<u8>],
flags: c_int
) -> Result<(usize, SockAddr)>
pub fn recv_from_with_flags( &self, buf: &mut [MaybeUninit<u8>], flags: c_int ) -> Result<(usize, SockAddr)>
Identical to recv_from
but allows for specification of arbitrary
flags to the underlying recvfrom
call.
sourcepub fn recv_from_vectored(
&self,
bufs: &mut [MaybeUninitSlice<'_>]
) -> Result<(usize, RecvFlags, SockAddr)>
Available on non-Redox only.
pub fn recv_from_vectored( &self, bufs: &mut [MaybeUninitSlice<'_>] ) -> Result<(usize, RecvFlags, SockAddr)>
Receives data from the socket. Returns the amount of bytes read, the
RecvFlags
and the remote address from the data is coming. Unlike
recv_from
this allows passing multiple buffers.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=recvmsg§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=recvmsg&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/recvmsg.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/recvmsg.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/recvmsg.2
- OpenBSD: https://man.openbsd.org/recvmsg.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/recvmsg.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/recvmsg
- Windows: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-recvmsg
§Safety
recv_from_vectored
makes the same safety guarantees regarding bufs
as recv_vectored
.
sourcepub fn recv_from_vectored_with_flags(
&self,
bufs: &mut [MaybeUninitSlice<'_>],
flags: c_int
) -> Result<(usize, RecvFlags, SockAddr)>
Available on non-Redox only.
pub fn recv_from_vectored_with_flags( &self, bufs: &mut [MaybeUninitSlice<'_>], flags: c_int ) -> Result<(usize, RecvFlags, SockAddr)>
Identical to recv_from_vectored
but allows for specification of
arbitrary flags to the underlying recvmsg
/WSARecvFrom
call.
§Safety
recv_from_vectored
makes the same safety guarantees regarding bufs
as recv_vectored
.
sourcepub fn peek_from(
&self,
buf: &mut [MaybeUninit<u8>]
) -> Result<(usize, SockAddr)>
pub fn peek_from( &self, buf: &mut [MaybeUninit<u8>] ) -> Result<(usize, SockAddr)>
Receives data from the socket, without removing it from the queue.
Successive calls return the same data. This is accomplished by passing
MSG_PEEK
as a flag to the underlying recvfrom
system call.
On success, returns the number of bytes peeked and the address from whence the data came.
§Safety
peek_from
makes the same safety guarantees regarding the buf
fer as
recv
.
§Note: Datagram Sockets
For datagram sockets, the behavior of this method when buf
is smaller than
the datagram at the head of the receive queue differs between Windows and
Unix-like platforms (Linux, macOS, BSDs, etc: colloquially termed “*nix”).
On *nix platforms, the datagram is truncated to the length of buf
.
On Windows, an error corresponding to WSAEMSGSIZE
will be returned.
For consistency between platforms, be sure to provide a sufficiently large buffer to avoid truncation; the exact size required depends on the underlying protocol.
If you just want to know the sender of the data, try peek_sender
.
sourcepub fn peek_sender(&self) -> Result<SockAddr>
pub fn peek_sender(&self) -> Result<SockAddr>
Retrieve the sender for the data at the head of the receive queue.
This is equivalent to calling peek_from
with a zero-sized buffer,
but suppresses the WSAEMSGSIZE
error on Windows.
sourcepub fn recvmsg(
&self,
msg: &mut MsgHdrMut<'_, '_, '_>,
flags: c_int
) -> Result<usize>
Available on Unix and non-Redox only.
pub fn recvmsg( &self, msg: &mut MsgHdrMut<'_, '_, '_>, flags: c_int ) -> Result<usize>
Receive a message from a socket using a message structure.
This is not supported on Windows as calling WSARecvMsg
(the recvmsg
equivalent) is not straight forward on Windows. See
https://github.com/microsoft/Windows-classic-samples/blob/7cbd99ac1d2b4a0beffbaba29ea63d024ceff700/Samples/Win7Samples/netds/winsock/recvmsg/rmmc.cpp
for an example (in C++).
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=recvmsg§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=recvmsg&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/recvmsg.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/recvmsg.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/recvmsg.2
- OpenBSD: https://man.openbsd.org/recvmsg.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/recvmsg.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/recvmsg
- Windows: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-recvmsg
sourcepub fn send(&self, buf: &[u8]) -> Result<usize>
pub fn send(&self, buf: &[u8]) -> Result<usize>
Sends data on the socket to a connected peer.
This is typically used on TCP sockets or datagram sockets which have been connected.
On success returns the number of bytes that were sent.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=send§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=send&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/send.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/send.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/send.2
- OpenBSD: https://man.openbsd.org/send.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/send.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/send
- Windows: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-send
sourcepub fn send_with_flags(&self, buf: &[u8], flags: c_int) -> Result<usize>
pub fn send_with_flags(&self, buf: &[u8], flags: c_int) -> Result<usize>
Identical to send
but allows for specification of arbitrary flags to the underlying
send
call.
sourcepub fn send_vectored(&self, bufs: &[IoSlice<'_>]) -> Result<usize>
Available on non-Redox only.
pub fn send_vectored(&self, bufs: &[IoSlice<'_>]) -> Result<usize>
Send data to the connected peer. Returns the amount of bytes written.
sourcepub fn send_vectored_with_flags(
&self,
bufs: &[IoSlice<'_>],
flags: c_int
) -> Result<usize>
Available on non-Redox only.
pub fn send_vectored_with_flags( &self, bufs: &[IoSlice<'_>], flags: c_int ) -> Result<usize>
Identical to send_vectored
but allows for specification of arbitrary
flags to the underlying sendmsg
/WSASend
call.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=sendmsg§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=sendmsg&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/sendmsg.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/sendmsg.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/sendmsg.2
- OpenBSD: https://man.openbsd.org/sendmsg.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/sendmsg.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/sendmsg
- Windows: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-sendmsg
sourcepub fn send_out_of_band(&self, buf: &[u8]) -> Result<usize>
pub fn send_out_of_band(&self, buf: &[u8]) -> Result<usize>
Sends out-of-band (OOB) data on the socket to connected peer
by setting the MSG_OOB
flag for this call.
For more information, see send
, out_of_band_inline
.
sourcepub fn send_to(&self, buf: &[u8], addr: &SockAddr) -> Result<usize>
pub fn send_to(&self, buf: &[u8], addr: &SockAddr) -> Result<usize>
Sends data on the socket to the given address. On success, returns the number of bytes written.
This is typically used on UDP or datagram-oriented sockets.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=sendto§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=sendto&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/sendto.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/sendto.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/sendto.2
- OpenBSD: https://man.openbsd.org/sendto.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/sendto.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/sendto
- Windows: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-sendto
sourcepub fn send_to_with_flags(
&self,
buf: &[u8],
addr: &SockAddr,
flags: c_int
) -> Result<usize>
pub fn send_to_with_flags( &self, buf: &[u8], addr: &SockAddr, flags: c_int ) -> Result<usize>
Identical to send_to
but allows for specification of arbitrary flags
to the underlying sendto
call.
sourcepub fn send_to_vectored(
&self,
bufs: &[IoSlice<'_>],
addr: &SockAddr
) -> Result<usize>
Available on non-Redox only.
pub fn send_to_vectored( &self, bufs: &[IoSlice<'_>], addr: &SockAddr ) -> Result<usize>
Send data to a peer listening on addr
. Returns the amount of bytes
written.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=sendmsg§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=sendmsg&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/sendmsg.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/sendmsg.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/sendmsg.2
- OpenBSD: https://man.openbsd.org/sendmsg.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/sendmsg.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/sendmsg
- Windows: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-sendmsg
sourcepub fn send_to_vectored_with_flags(
&self,
bufs: &[IoSlice<'_>],
addr: &SockAddr,
flags: c_int
) -> Result<usize>
Available on non-Redox only.
pub fn send_to_vectored_with_flags( &self, bufs: &[IoSlice<'_>], addr: &SockAddr, flags: c_int ) -> Result<usize>
Identical to send_to_vectored
but allows for specification of
arbitrary flags to the underlying sendmsg
/WSASendTo
call.
sourcepub fn sendmsg(&self, msg: &MsgHdr<'_, '_, '_>, flags: c_int) -> Result<usize>
Available on non-Redox only.
pub fn sendmsg(&self, msg: &MsgHdr<'_, '_, '_>, flags: c_int) -> Result<usize>
Send a message on a socket using a message structure.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=sendmsg§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=sendmsg&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/sendmsg.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/sendmsg.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/sendmsg.2
- OpenBSD: https://man.openbsd.org/sendmsg.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/sendmsg.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/sendmsg
- Windows: https://docs.microsoft.com/en-us/windows/win32/api/winsock2/nf-winsock2-sendmsg
source§impl Socket
impl Socket
Socket options get/set using SOL_SOCKET
.
Additional documentation can be found in documentation of the OS.
sourcepub fn broadcast(&self) -> Result<bool>
pub fn broadcast(&self) -> Result<bool>
Get the value of the SO_BROADCAST
option for this socket.
For more information about this option, see set_broadcast
.
sourcepub fn set_broadcast(&self, broadcast: bool) -> Result<()>
pub fn set_broadcast(&self, broadcast: bool) -> Result<()>
Set the value of the SO_BROADCAST
option for this socket.
When enabled, this socket is allowed to send packets to a broadcast address.
sourcepub fn take_error(&self) -> Result<Option<Error>>
pub fn take_error(&self) -> Result<Option<Error>>
Get the value of the SO_ERROR
option on this socket.
This will retrieve the stored error in the underlying socket, clearing the field in the process. This can be useful for checking errors between calls.
sourcepub fn keepalive(&self) -> Result<bool>
pub fn keepalive(&self) -> Result<bool>
Get the value of the SO_KEEPALIVE
option on this socket.
For more information about this option, see set_keepalive
.
sourcepub fn set_keepalive(&self, keepalive: bool) -> Result<()>
pub fn set_keepalive(&self, keepalive: bool) -> Result<()>
Set value for the SO_KEEPALIVE
option on this socket.
Enable sending of keep-alive messages on connection-oriented sockets.
sourcepub fn linger(&self) -> Result<Option<Duration>>
pub fn linger(&self) -> Result<Option<Duration>>
Get the value of the SO_LINGER
option on this socket.
For more information about this option, see set_linger
.
sourcepub fn set_linger(&self, linger: Option<Duration>) -> Result<()>
pub fn set_linger(&self, linger: Option<Duration>) -> Result<()>
Set value for the SO_LINGER
option on this socket.
If linger
is not None
, a close(2) or shutdown(2) will not return
until all queued messages for the socket have been successfully sent or
the linger timeout has been reached. Otherwise, the call returns
immediately and the closing is done in the background. When the socket
is closed as part of exit(2), it always lingers in the background.
§Notes
On most OSs the duration only has a precision of seconds and will be silently truncated.
On Apple platforms (e.g. macOS, iOS, etc) this uses SO_LINGER_SEC
.
sourcepub fn out_of_band_inline(&self) -> Result<bool>
Available on non-Redox only.
pub fn out_of_band_inline(&self) -> Result<bool>
Get value for the SO_OOBINLINE
option on this socket.
For more information about this option, see set_out_of_band_inline
.
sourcepub fn set_out_of_band_inline(&self, oob_inline: bool) -> Result<()>
Available on non-Redox only.
pub fn set_out_of_band_inline(&self, oob_inline: bool) -> Result<()>
Set value for the SO_OOBINLINE
option on this socket.
If this option is enabled, out-of-band data is directly placed into the
receive data stream. Otherwise, out-of-band data is passed only when the
MSG_OOB
flag is set during receiving. As per RFC6093, TCP sockets
using the Urgent mechanism are encouraged to set this flag.
sourcepub fn recv_buffer_size(&self) -> Result<usize>
pub fn recv_buffer_size(&self) -> Result<usize>
Get value for the SO_RCVBUF
option on this socket.
For more information about this option, see set_recv_buffer_size
.
sourcepub fn set_recv_buffer_size(&self, size: usize) -> Result<()>
pub fn set_recv_buffer_size(&self, size: usize) -> Result<()>
Set value for the SO_RCVBUF
option on this socket.
Changes the size of the operating system’s receive buffer associated with the socket.
sourcepub fn read_timeout(&self) -> Result<Option<Duration>>
pub fn read_timeout(&self) -> Result<Option<Duration>>
Get value for the SO_RCVTIMEO
option on this socket.
If the returned timeout is None
, then read
and recv
calls will
block indefinitely.
sourcepub fn set_read_timeout(&self, duration: Option<Duration>) -> Result<()>
pub fn set_read_timeout(&self, duration: Option<Duration>) -> Result<()>
Set value for the SO_RCVTIMEO
option on this socket.
If timeout
is None
, then read
and recv
calls will block
indefinitely.
sourcepub fn reuse_address(&self) -> Result<bool>
pub fn reuse_address(&self) -> Result<bool>
Get the value of the SO_REUSEADDR
option on this socket.
For more information about this option, see set_reuse_address
.
sourcepub fn set_reuse_address(&self, reuse: bool) -> Result<()>
pub fn set_reuse_address(&self, reuse: bool) -> Result<()>
Set value for the SO_REUSEADDR
option on this socket.
This indicates that futher calls to bind
may allow reuse of local
addresses. For IPv4 sockets this means that a socket may bind even when
there’s a socket already listening on this port.
sourcepub fn send_buffer_size(&self) -> Result<usize>
pub fn send_buffer_size(&self) -> Result<usize>
Get the value of the SO_SNDBUF
option on this socket.
For more information about this option, see set_send_buffer_size
.
sourcepub fn set_send_buffer_size(&self, size: usize) -> Result<()>
pub fn set_send_buffer_size(&self, size: usize) -> Result<()>
Set value for the SO_SNDBUF
option on this socket.
Changes the size of the operating system’s send buffer associated with the socket.
sourcepub fn write_timeout(&self) -> Result<Option<Duration>>
pub fn write_timeout(&self) -> Result<Option<Duration>>
Get value for the SO_SNDTIMEO
option on this socket.
If the returned timeout is None
, then write
and send
calls will
block indefinitely.
source§impl Socket
impl Socket
Socket options for IPv4 sockets, get/set using IPPROTO_IP
.
Additional documentation can be found in documentation of the OS.
sourcepub fn header_included(&self) -> Result<bool>
Available on crate feature all
and neither Redox nor target_os="espidf"
only.
pub fn header_included(&self) -> Result<bool>
all
and neither Redox nor target_os="espidf"
only.Get the value of the IP_HDRINCL
option on this socket.
For more information about this option, see set_header_included
.
sourcepub fn set_header_included(&self, included: bool) -> Result<()>
Available on crate feature all
and neither Redox nor target_os="espidf"
only.
pub fn set_header_included(&self, included: bool) -> Result<()>
all
and neither Redox nor target_os="espidf"
only.sourcepub fn join_multicast_v4(
&self,
multiaddr: &Ipv4Addr,
interface: &Ipv4Addr
) -> Result<()>
pub fn join_multicast_v4( &self, multiaddr: &Ipv4Addr, interface: &Ipv4Addr ) -> Result<()>
Join a multicast group using IP_ADD_MEMBERSHIP
option on this socket.
This function specifies a new multicast group for this socket to join.
The address must be a valid multicast address, and interface
is the
address of the local interface with which the system should join the
multicast group. If it’s Ipv4Addr::UNSPECIFIED
(INADDR_ANY
) then
an appropriate interface is chosen by the system.
sourcepub fn leave_multicast_v4(
&self,
multiaddr: &Ipv4Addr,
interface: &Ipv4Addr
) -> Result<()>
pub fn leave_multicast_v4( &self, multiaddr: &Ipv4Addr, interface: &Ipv4Addr ) -> Result<()>
Leave a multicast group using IP_DROP_MEMBERSHIP
option on this socket.
For more information about this option, see join_multicast_v4
.
sourcepub fn join_multicast_v4_n(
&self,
multiaddr: &Ipv4Addr,
interface: &InterfaceIndexOrAddress
) -> Result<()>
pub fn join_multicast_v4_n( &self, multiaddr: &Ipv4Addr, interface: &InterfaceIndexOrAddress ) -> Result<()>
Join a multicast group using IP_ADD_MEMBERSHIP
option on this socket.
This function specifies a new multicast group for this socket to join.
The address must be a valid multicast address, and interface
specifies
the local interface with which the system should join the multicast
group. See InterfaceIndexOrAddress
.
sourcepub fn leave_multicast_v4_n(
&self,
multiaddr: &Ipv4Addr,
interface: &InterfaceIndexOrAddress
) -> Result<()>
pub fn leave_multicast_v4_n( &self, multiaddr: &Ipv4Addr, interface: &InterfaceIndexOrAddress ) -> Result<()>
Leave a multicast group using IP_DROP_MEMBERSHIP
option on this socket.
For more information about this option, see join_multicast_v4_n
.
sourcepub fn join_ssm_v4(
&self,
source: &Ipv4Addr,
group: &Ipv4Addr,
interface: &Ipv4Addr
) -> Result<()>
pub fn join_ssm_v4( &self, source: &Ipv4Addr, group: &Ipv4Addr, interface: &Ipv4Addr ) -> Result<()>
Join a multicast SSM channel using IP_ADD_SOURCE_MEMBERSHIP
option on this socket.
This function specifies a new multicast channel for this socket to join.
The group must be a valid SSM group address, the source must be the address of the sender
and interface
is the address of the local interface with which the system should join the
multicast group. If it’s Ipv4Addr::UNSPECIFIED
(INADDR_ANY
) then
an appropriate interface is chosen by the system.
sourcepub fn leave_ssm_v4(
&self,
source: &Ipv4Addr,
group: &Ipv4Addr,
interface: &Ipv4Addr
) -> Result<()>
pub fn leave_ssm_v4( &self, source: &Ipv4Addr, group: &Ipv4Addr, interface: &Ipv4Addr ) -> Result<()>
Leave a multicast group using IP_DROP_SOURCE_MEMBERSHIP
option on this socket.
For more information about this option, see join_ssm_v4
.
sourcepub fn multicast_if_v4(&self) -> Result<Ipv4Addr>
pub fn multicast_if_v4(&self) -> Result<Ipv4Addr>
Get the value of the IP_MULTICAST_IF
option for this socket.
For more information about this option, see set_multicast_if_v4
.
sourcepub fn set_multicast_if_v4(&self, interface: &Ipv4Addr) -> Result<()>
pub fn set_multicast_if_v4(&self, interface: &Ipv4Addr) -> Result<()>
Set the value of the IP_MULTICAST_IF
option for this socket.
Specifies the interface to use for routing multicast packets.
sourcepub fn multicast_loop_v4(&self) -> Result<bool>
pub fn multicast_loop_v4(&self) -> Result<bool>
Get the value of the IP_MULTICAST_LOOP
option for this socket.
For more information about this option, see set_multicast_loop_v4
.
sourcepub fn set_multicast_loop_v4(&self, loop_v4: bool) -> Result<()>
pub fn set_multicast_loop_v4(&self, loop_v4: bool) -> Result<()>
Set the value of the IP_MULTICAST_LOOP
option for this socket.
If enabled, multicast packets will be looped back to the local socket. Note that this may not have any affect on IPv6 sockets.
sourcepub fn multicast_ttl_v4(&self) -> Result<u32>
pub fn multicast_ttl_v4(&self) -> Result<u32>
Get the value of the IP_MULTICAST_TTL
option for this socket.
For more information about this option, see set_multicast_ttl_v4
.
sourcepub fn set_multicast_ttl_v4(&self, ttl: u32) -> Result<()>
pub fn set_multicast_ttl_v4(&self, ttl: u32) -> Result<()>
Set the value of the IP_MULTICAST_TTL
option for this socket.
Indicates the time-to-live value of outgoing multicast packets for this socket. The default value is 1 which means that multicast packets don’t leave the local network unless explicitly requested.
Note that this may not have any affect on IPv6 sockets.
sourcepub fn ttl(&self) -> Result<u32>
pub fn ttl(&self) -> Result<u32>
Get the value of the IP_TTL
option for this socket.
For more information about this option, see set_ttl
.
sourcepub fn set_ttl(&self, ttl: u32) -> Result<()>
pub fn set_ttl(&self, ttl: u32) -> Result<()>
Set the value of the IP_TTL
option for this socket.
This value sets the time-to-live field that is used in every packet sent from this socket.
sourcepub fn set_tos(&self, tos: u32) -> Result<()>
pub fn set_tos(&self, tos: u32) -> Result<()>
Set the value of the IP_TOS
option for this socket.
This value sets the type-of-service field that is used in every packet sent from this socket.
NOTE: https://docs.microsoft.com/en-us/windows/win32/winsock/ipproto-ip-socket-options
documents that not all versions of windows support IP_TOS
.
sourcepub fn tos(&self) -> Result<u32>
pub fn tos(&self) -> Result<u32>
Get the value of the IP_TOS
option for this socket.
For more information about this option, see set_tos
.
NOTE: https://docs.microsoft.com/en-us/windows/win32/winsock/ipproto-ip-socket-options
documents that not all versions of windows support IP_TOS
.
sourcepub fn set_recv_tos(&self, recv_tos: bool) -> Result<()>
pub fn set_recv_tos(&self, recv_tos: bool) -> Result<()>
Set the value of the IP_RECVTOS
option for this socket.
If enabled, the IP_TOS
ancillary message is passed with
incoming packets. It contains a byte which specifies the
Type of Service/Precedence field of the packet header.
sourcepub fn recv_tos(&self) -> Result<bool>
pub fn recv_tos(&self) -> Result<bool>
Get the value of the IP_RECVTOS
option for this socket.
For more information about this option, see set_recv_tos
.
source§impl Socket
impl Socket
Socket options for IPv6 sockets, get/set using IPPROTO_IPV6
.
Additional documentation can be found in documentation of the OS.
sourcepub fn join_multicast_v6(
&self,
multiaddr: &Ipv6Addr,
interface: u32
) -> Result<()>
pub fn join_multicast_v6( &self, multiaddr: &Ipv6Addr, interface: u32 ) -> Result<()>
Join a multicast group using IPV6_ADD_MEMBERSHIP
option on this socket.
Some OSs use IPV6_JOIN_GROUP
for this option.
This function specifies a new multicast group for this socket to join.
The address must be a valid multicast address, and interface
is the
index of the interface to join/leave (or 0 to indicate any interface).
sourcepub fn leave_multicast_v6(
&self,
multiaddr: &Ipv6Addr,
interface: u32
) -> Result<()>
pub fn leave_multicast_v6( &self, multiaddr: &Ipv6Addr, interface: u32 ) -> Result<()>
Leave a multicast group using IPV6_DROP_MEMBERSHIP
option on this socket.
Some OSs use IPV6_LEAVE_GROUP
for this option.
For more information about this option, see join_multicast_v6
.
sourcepub fn multicast_hops_v6(&self) -> Result<u32>
pub fn multicast_hops_v6(&self) -> Result<u32>
Get the value of the IPV6_MULTICAST_HOPS
option for this socket
For more information about this option, see set_multicast_hops_v6
.
sourcepub fn set_multicast_hops_v6(&self, hops: u32) -> Result<()>
pub fn set_multicast_hops_v6(&self, hops: u32) -> Result<()>
Set the value of the IPV6_MULTICAST_HOPS
option for this socket
Indicates the number of “routers” multicast packets will transit for this socket. The default value is 1 which means that multicast packets don’t leave the local network unless explicitly requested.
sourcepub fn multicast_if_v6(&self) -> Result<u32>
pub fn multicast_if_v6(&self) -> Result<u32>
Get the value of the IPV6_MULTICAST_IF
option for this socket.
For more information about this option, see set_multicast_if_v6
.
sourcepub fn set_multicast_if_v6(&self, interface: u32) -> Result<()>
pub fn set_multicast_if_v6(&self, interface: u32) -> Result<()>
Set the value of the IPV6_MULTICAST_IF
option for this socket.
Specifies the interface to use for routing multicast packets. Unlike ipv4, this is generally required in ipv6 contexts where network routing prefixes may overlap.
sourcepub fn multicast_loop_v6(&self) -> Result<bool>
pub fn multicast_loop_v6(&self) -> Result<bool>
Get the value of the IPV6_MULTICAST_LOOP
option for this socket.
For more information about this option, see set_multicast_loop_v6
.
sourcepub fn set_multicast_loop_v6(&self, loop_v6: bool) -> Result<()>
pub fn set_multicast_loop_v6(&self, loop_v6: bool) -> Result<()>
Set the value of the IPV6_MULTICAST_LOOP
option for this socket.
Controls whether this socket sees the multicast packets it sends itself. Note that this may not have any affect on IPv4 sockets.
sourcepub fn unicast_hops_v6(&self) -> Result<u32>
pub fn unicast_hops_v6(&self) -> Result<u32>
Get the value of the IPV6_UNICAST_HOPS
option for this socket.
Specifies the hop limit for ipv6 unicast packets
sourcepub fn set_unicast_hops_v6(&self, hops: u32) -> Result<()>
pub fn set_unicast_hops_v6(&self, hops: u32) -> Result<()>
Set the value for the IPV6_UNICAST_HOPS
option on this socket.
Specifies the hop limit for ipv6 unicast packets
sourcepub fn only_v6(&self) -> Result<bool>
pub fn only_v6(&self) -> Result<bool>
Get the value of the IPV6_V6ONLY
option for this socket.
For more information about this option, see set_only_v6
.
sourcepub fn set_only_v6(&self, only_v6: bool) -> Result<()>
pub fn set_only_v6(&self, only_v6: bool) -> Result<()>
Set the value for the IPV6_V6ONLY
option on this socket.
If this is set to true
then the socket is restricted to sending and
receiving IPv6 packets only. In this case two IPv4 and IPv6 applications
can bind the same port at the same time.
If this is set to false
then the socket can be used to send and
receive packets from an IPv4-mapped IPv6 address.
sourcepub fn recv_tclass_v6(&self) -> Result<bool>
pub fn recv_tclass_v6(&self) -> Result<bool>
Get the value of the IPV6_RECVTCLASS
option for this socket.
For more information about this option, see set_recv_tclass_v6
.
sourcepub fn set_recv_tclass_v6(&self, recv_tclass: bool) -> Result<()>
pub fn set_recv_tclass_v6(&self, recv_tclass: bool) -> Result<()>
Set the value of the IPV6_RECVTCLASS
option for this socket.
If enabled, the IPV6_TCLASS
ancillary message is passed with incoming
packets. It contains a byte which specifies the traffic class field of
the packet header.
source§impl Socket
impl Socket
Socket options for TCP sockets, get/set using IPPROTO_TCP
.
Additional documentation can be found in documentation of the OS.
sourcepub fn keepalive_time(&self) -> Result<Duration>
Available on crate feature all
and neither Windows nor Haiku nor OpenBSD nor target_os="vita"
only.
pub fn keepalive_time(&self) -> Result<Duration>
all
and neither Windows nor Haiku nor OpenBSD nor target_os="vita"
only.Get the value of the TCP_KEEPIDLE
option on this socket.
This returns the value of TCP_KEEPALIVE
on macOS and iOS and TCP_KEEPIDLE
on all other
supported Unix operating systems.
sourcepub fn keepalive_interval(&self) -> Result<Duration>
Available on crate feature all
and (Android or DragonFly BSD or FreeBSD or Fuchsia or illumos or iOS or Linux or macOS or NetBSD or tvOS or watchOS) only.
pub fn keepalive_interval(&self) -> Result<Duration>
all
and (Android or DragonFly BSD or FreeBSD or Fuchsia or illumos or iOS or Linux or macOS or NetBSD or tvOS or watchOS) only.Get the value of the TCP_KEEPINTVL
option on this socket.
For more information about this option, see set_tcp_keepalive
.
sourcepub fn keepalive_retries(&self) -> Result<u32>
Available on crate feature all
and (Android or DragonFly BSD or FreeBSD or Fuchsia or illumos or iOS or Linux or macOS or NetBSD or tvOS or watchOS) only.
pub fn keepalive_retries(&self) -> Result<u32>
all
and (Android or DragonFly BSD or FreeBSD or Fuchsia or illumos or iOS or Linux or macOS or NetBSD or tvOS or watchOS) only.Get the value of the TCP_KEEPCNT
option on this socket.
For more information about this option, see set_tcp_keepalive
.
sourcepub fn set_tcp_keepalive(&self, params: &TcpKeepalive) -> Result<()>
pub fn set_tcp_keepalive(&self, params: &TcpKeepalive) -> Result<()>
Set parameters configuring TCP keepalive probes for this socket.
The supported parameters depend on the operating system, and are
configured using the TcpKeepalive
struct. At a minimum, all systems
support configuring the keepalive time: the time after which the OS
will start sending keepalive messages on an idle connection.
§Notes
- This will enable
SO_KEEPALIVE
on this socket, if it is not already enabled. - On some platforms, such as Windows, any keepalive parameters not
configured by the
TcpKeepalive
struct passed to this function may be overwritten with their default values. Therefore, this function should either only be called once per socket, or the same parameters should be passed every time it is called.
§Examples
use std::time::Duration;
use socket2::{Socket, TcpKeepalive, Domain, Type};
let socket = Socket::new(Domain::IPV4, Type::STREAM, None)?;
let keepalive = TcpKeepalive::new()
.with_time(Duration::from_secs(4));
// Depending on the target operating system, we may also be able to
// configure the keepalive probe interval and/or the number of
// retries here as well.
socket.set_tcp_keepalive(&keepalive)?;
sourcepub fn nodelay(&self) -> Result<bool>
pub fn nodelay(&self) -> Result<bool>
Get the value of the TCP_NODELAY
option on this socket.
For more information about this option, see set_nodelay
.
sourcepub fn set_nodelay(&self, nodelay: bool) -> Result<()>
pub fn set_nodelay(&self, nodelay: bool) -> Result<()>
Set 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.
source§impl Socket
impl Socket
Unix only API.
sourcepub fn set_cloexec(&self, close_on_exec: bool) -> Result<()>
Available on crate feature all
and Unix only.
pub fn set_cloexec(&self, close_on_exec: bool) -> Result<()>
all
and Unix only.sourcepub fn set_nosigpipe(&self, nosigpipe: bool) -> Result<()>
Available on crate feature all
and (iOS or macOS or tvOS or watchOS) only.
pub fn set_nosigpipe(&self, nosigpipe: bool) -> Result<()>
all
and (iOS or macOS or tvOS or watchOS) only.Sets SO_NOSIGPIPE
on the socket.
sourcepub fn mss(&self) -> Result<u32>
Available on crate feature all
and Unix and non-Redox only.
pub fn mss(&self) -> Result<u32>
all
and Unix and non-Redox only.Gets the value of the TCP_MAXSEG
option on this socket.
For more information about this option, see set_mss
.
sourcepub fn set_mss(&self, mss: u32) -> Result<()>
Available on crate feature all
and Unix and non-Redox only.
pub fn set_mss(&self, mss: u32) -> Result<()>
all
and Unix and non-Redox only.Sets the value of the TCP_MAXSEG
option on this socket.
The TCP_MAXSEG
option denotes the TCP Maximum Segment Size and is only
available on TCP sockets.
sourcepub fn bind_device_by_index(&self, interface: Option<NonZeroU32>) -> Result<()>
👎Deprecated: Use Socket::bind_device_by_index_v4
insteadAvailable on crate feature all
and (iOS or macOS or tvOS or watchOS) only.
pub fn bind_device_by_index(&self, interface: Option<NonZeroU32>) -> Result<()>
Socket::bind_device_by_index_v4
insteadall
and (iOS or macOS or tvOS or watchOS) only.This method is deprecated, use crate::Socket::bind_device_by_index_v4
.
sourcepub fn bind_device_by_index_v4(
&self,
interface: Option<NonZeroU32>
) -> Result<()>
Available on crate feature all
and (iOS or macOS or tvOS or watchOS) only.
pub fn bind_device_by_index_v4( &self, interface: Option<NonZeroU32> ) -> Result<()>
all
and (iOS or macOS or tvOS or watchOS) only.Sets the value for IP_BOUND_IF
option on this socket.
If a socket is bound to an interface, only packets received from that particular interface are processed by the socket.
If interface
is None
, the binding is removed. If the interface
index is not valid, an error is returned.
One can use libc::if_nametoindex
to convert an interface alias to an
index.
sourcepub fn bind_device_by_index_v6(
&self,
interface: Option<NonZeroU32>
) -> Result<()>
Available on crate feature all
and (iOS or macOS or tvOS or watchOS) only.
pub fn bind_device_by_index_v6( &self, interface: Option<NonZeroU32> ) -> Result<()>
all
and (iOS or macOS or tvOS or watchOS) only.Sets the value for IPV6_BOUND_IF
option on this socket.
If a socket is bound to an interface, only packets received from that particular interface are processed by the socket.
If interface
is None
, the binding is removed. If the interface
index is not valid, an error is returned.
One can use libc::if_nametoindex
to convert an interface alias to an
index.
sourcepub fn device_index_v4(&self) -> Result<Option<NonZeroU32>>
Available on crate feature all
and (iOS or macOS or tvOS or watchOS) only.
pub fn device_index_v4(&self) -> Result<Option<NonZeroU32>>
all
and (iOS or macOS or tvOS or watchOS) only.Gets the value for IP_BOUND_IF
option on this socket, i.e. the index
for the interface to which the socket is bound.
Returns None
if the socket is not bound to any interface, otherwise
returns an interface index.
sourcepub fn device_index(&self) -> Result<Option<NonZeroU32>>
👎Deprecated: Use Socket::device_index_v4
insteadAvailable on crate feature all
and (iOS or macOS or tvOS or watchOS) only.
pub fn device_index(&self) -> Result<Option<NonZeroU32>>
Socket::device_index_v4
insteadall
and (iOS or macOS or tvOS or watchOS) only.This method is deprecated, use crate::Socket::device_index_v4
.
sourcepub fn device_index_v6(&self) -> Result<Option<NonZeroU32>>
Available on crate feature all
and (iOS or macOS or tvOS or watchOS) only.
pub fn device_index_v6(&self) -> Result<Option<NonZeroU32>>
all
and (iOS or macOS or tvOS or watchOS) only.Gets the value for IPV6_BOUND_IF
option on this socket, i.e. the index
for the interface to which the socket is bound.
Returns None
if the socket is not bound to any interface, otherwise
returns an interface index.
sourcepub fn reuse_port(&self) -> Result<bool>
Available on crate feature all
and Unix and neither Solaris nor illumos only.
pub fn reuse_port(&self) -> Result<bool>
all
and Unix and neither Solaris nor illumos only.Get the value of the SO_REUSEPORT
option on this socket.
For more information about this option, see set_reuse_port
.
sourcepub fn set_reuse_port(&self, reuse: bool) -> Result<()>
Available on crate feature all
and Unix and neither Solaris nor illumos only.
pub fn set_reuse_port(&self, reuse: bool) -> Result<()>
all
and Unix and neither Solaris nor illumos only.Set value for the SO_REUSEPORT
option on this socket.
This indicates that further calls to bind
may allow reuse of local
addresses. For IPv4 sockets this means that a socket may bind even when
there’s a socket already listening on this port.
sourcepub fn sendfile<F>(
&self,
file: &F,
offset: usize,
length: Option<NonZeroUsize>
) -> Result<usize>where
F: AsRawFd,
Available on crate feature all
and (target_os="aix"
or Android or FreeBSD or iOS or Linux or macOS or tvOS or watchOS) only.
pub fn sendfile<F>(
&self,
file: &F,
offset: usize,
length: Option<NonZeroUsize>
) -> Result<usize>where
F: AsRawFd,
all
and (target_os="aix"
or Android or FreeBSD or iOS or Linux or macOS or tvOS or watchOS) only.Copies data between a file
and this socket using the sendfile(2)
system call. Because this copying is done within the kernel,
sendfile()
is more efficient than the combination of read(2)
and
write(2)
, which would require transferring data to and from user
space.
Different OSs support different kinds of file
s, see the OS
documentation for what kind of files are supported. Generally regular
files are supported by all OSs.
Additional documentation can be found in manual of the OS:
- DragonFly BSD: https://man.dragonflybsd.org/?command=sendfile§ion=2
- FreeBSD: https://www.freebsd.org/cgi/man.cgi?query=sendfile&sektion=2
- Linux: https://man7.org/linux/man-pages/man2/sendfile.2.html
- macOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/sendfile.2.html (archived, actually for iOS)
- NetBSD: https://man.netbsd.org/sendfile.2
- OpenBSD: https://man.openbsd.org/sendfile.2
- iOS: https://developer.apple.com/library/archive/documentation/System/Conceptual/ManPages_iPhoneOS/man2/sendfile.2.html (archived)
- illumos: https://illumos.org/man/3SOCKET/sendfile
The offset
is the absolute offset into the file
to use as starting
point.
Depending on the OS this function may change the offset of file
. For
the best results reset the offset of the file before using it again.
The length
determines how many bytes to send, where a length of None
means it will try to send all bytes.
Trait Implementations§
source§impl AsFd for Socket
Available on Unix only.
impl AsFd for Socket
source§fn as_fd(&self) -> BorrowedFd<'_>
fn as_fd(&self) -> BorrowedFd<'_>
source§impl From<Socket> for TcpListener
impl From<Socket> for TcpListener
source§fn from(socket: Socket) -> TcpListener
fn from(socket: Socket) -> TcpListener
source§impl From<Socket> for UnixDatagram
impl From<Socket> for UnixDatagram
source§fn from(socket: Socket) -> UnixDatagram
fn from(socket: Socket) -> UnixDatagram
source§impl From<Socket> for UnixListener
impl From<Socket> for UnixListener
source§fn from(socket: Socket) -> UnixListener
fn from(socket: Socket) -> UnixListener
source§impl From<Socket> for UnixStream
impl From<Socket> for UnixStream
source§fn from(socket: Socket) -> UnixStream
fn from(socket: Socket) -> UnixStream
source§impl From<TcpListener> for Socket
impl From<TcpListener> for Socket
source§impl From<UnixDatagram> for Socket
impl From<UnixDatagram> for Socket
source§impl From<UnixListener> for Socket
impl From<UnixListener> for Socket
source§impl From<UnixStream> for Socket
impl From<UnixStream> for Socket
source§impl IntoRawFd for Socket
Available on Unix only.
impl IntoRawFd for Socket
source§fn into_raw_fd(self) -> c_int
fn into_raw_fd(self) -> c_int
source§impl<'a> Read for &'a Socket
impl<'a> Read for &'a Socket
source§fn read(&mut self, buf: &mut [u8]) -> Result<usize>
fn read(&mut self, buf: &mut [u8]) -> Result<usize>
source§fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> Result<usize>
fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> Result<usize>
read
, except that it reads into a slice of buffers. Read moresource§fn is_read_vectored(&self) -> bool
fn is_read_vectored(&self) -> bool
can_vector
)1.0.0 · source§fn read_to_end(&mut self, buf: &mut Vec<u8>) -> Result<usize, Error>
fn read_to_end(&mut self, buf: &mut Vec<u8>) -> Result<usize, Error>
buf
. Read more1.0.0 · source§fn read_to_string(&mut self, buf: &mut String) -> Result<usize, Error>
fn read_to_string(&mut self, buf: &mut String) -> Result<usize, Error>
buf
. Read more1.6.0 · source§fn read_exact(&mut self, buf: &mut [u8]) -> Result<(), Error>
fn read_exact(&mut self, buf: &mut [u8]) -> Result<(), Error>
buf
. Read moresource§fn read_buf(&mut self, buf: BorrowedCursor<'_>) -> Result<(), Error>
fn read_buf(&mut self, buf: BorrowedCursor<'_>) -> Result<(), Error>
read_buf
)source§fn read_buf_exact(&mut self, cursor: BorrowedCursor<'_>) -> Result<(), Error>
fn read_buf_exact(&mut self, cursor: BorrowedCursor<'_>) -> Result<(), Error>
read_buf
)cursor
. Read more1.0.0 · source§fn by_ref(&mut self) -> &mut Selfwhere
Self: Sized,
fn by_ref(&mut self) -> &mut Selfwhere
Self: Sized,
Read
. Read moresource§impl Read for Socket
impl Read for Socket
source§fn read(&mut self, buf: &mut [u8]) -> Result<usize>
fn read(&mut self, buf: &mut [u8]) -> Result<usize>
source§fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> Result<usize>
fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> Result<usize>
read
, except that it reads into a slice of buffers. Read moresource§fn is_read_vectored(&self) -> bool
fn is_read_vectored(&self) -> bool
can_vector
)1.0.0 · source§fn read_to_end(&mut self, buf: &mut Vec<u8>) -> Result<usize, Error>
fn read_to_end(&mut self, buf: &mut Vec<u8>) -> Result<usize, Error>
buf
. Read more1.0.0 · source§fn read_to_string(&mut self, buf: &mut String) -> Result<usize, Error>
fn read_to_string(&mut self, buf: &mut String) -> Result<usize, Error>
buf
. Read more1.6.0 · source§fn read_exact(&mut self, buf: &mut [u8]) -> Result<(), Error>
fn read_exact(&mut self, buf: &mut [u8]) -> Result<(), Error>
buf
. Read moresource§fn read_buf(&mut self, buf: BorrowedCursor<'_>) -> Result<(), Error>
fn read_buf(&mut self, buf: BorrowedCursor<'_>) -> Result<(), Error>
read_buf
)source§fn read_buf_exact(&mut self, cursor: BorrowedCursor<'_>) -> Result<(), Error>
fn read_buf_exact(&mut self, cursor: BorrowedCursor<'_>) -> Result<(), Error>
read_buf
)cursor
. Read more1.0.0 · source§fn by_ref(&mut self) -> &mut Selfwhere
Self: Sized,
fn by_ref(&mut self) -> &mut Selfwhere
Self: Sized,
Read
. Read moresource§impl<'a> Write for &'a Socket
impl<'a> Write for &'a Socket
source§fn write(&mut self, buf: &[u8]) -> Result<usize>
fn write(&mut self, buf: &[u8]) -> Result<usize>
source§fn flush(&mut self) -> Result<()>
fn flush(&mut self) -> Result<()>
source§fn is_write_vectored(&self) -> bool
fn is_write_vectored(&self) -> bool
can_vector
)1.0.0 · source§fn write_all(&mut self, buf: &[u8]) -> Result<(), Error>
fn write_all(&mut self, buf: &[u8]) -> Result<(), Error>
source§fn write_all_vectored(&mut self, bufs: &mut [IoSlice<'_>]) -> Result<(), Error>
fn write_all_vectored(&mut self, bufs: &mut [IoSlice<'_>]) -> Result<(), Error>
write_all_vectored
)source§impl Write for Socket
impl Write for Socket
source§fn write(&mut self, buf: &[u8]) -> Result<usize>
fn write(&mut self, buf: &[u8]) -> Result<usize>
source§fn flush(&mut self) -> Result<()>
fn flush(&mut self) -> Result<()>
source§fn is_write_vectored(&self) -> bool
fn is_write_vectored(&self) -> bool
can_vector
)1.0.0 · source§fn write_all(&mut self, buf: &[u8]) -> Result<(), Error>
fn write_all(&mut self, buf: &[u8]) -> Result<(), Error>
source§fn write_all_vectored(&mut self, bufs: &mut [IoSlice<'_>]) -> Result<(), Error>
fn write_all_vectored(&mut self, bufs: &mut [IoSlice<'_>]) -> Result<(), Error>
write_all_vectored
)