Functions — github.com/conradludgate/arc-discharge

hub / github.com/conradludgate/arc-discharge / functions

Functions197 in github.com/conradludgate/arc-discharge

⨍ Functions 197◇ Types & classes 45

(&mut self, other: Ready)

src/io/ready.rs:159

Methodconnect

Connects the UDP socket setting the default destination for send() and limiting packets that are read via recv from the address specified in `addr`.

src/net/udp.rs:336

Methodconnect

Opens a TCP connection to a remote host. `addr` is an address of the remote host. Anything which implements the [`ToSocketAddrs`] trait can be suppli

src/net/tcp/stream.rs:106

Methodconnect_addr

Establishes a connection to the specified `addr`.

src/net/tcp/stream.rs:127

Methodconnect_mio

(sys: mio::net::TcpStream)

src/net/tcp/stream.rs:132

Methoddecode

(&mut self, src: &mut BytesMut)

examples/http-server.rs:159

Methoddefault

()

src/linked_list.rs:70

src/io/poll_evented.rs:186

Methoddrop

(&mut self)

src/io/registration.rs:205

Methoddrop

(&mut self)

src/io/poll_evented.rs:198

Methodencode

(&mut self, item: Response<String>, dst: &mut BytesMut)

examples/http-server.rs:104

Methodfmt

(&self, fmt: &mut std::fmt::Formatter<'_>)

src/join_handle.rs:34

Methodfmt

(&self, fmt: &mut fmt::Formatter<'_>)

src/bits.rs:54

Methodfmt

(&self, fmt: &mut fmt::Formatter<'_>)

src/io/ready.rs:181

Methodfmt

(&self, f: &mut fmt::Formatter<'_>)

src/io/poll_evented.rs:192

Methodfmt

(&self, f: &mut fmt::Formatter<'_>)

src/net/udp.rs:1062

Methodfmt

(&self, f: &mut fmt::Formatter<'_>)

src/net/tcp/stream.rs:812

Methodfmt

(&self, f: &mut fmt::Formatter<'_>)

src/net/tcp/listener.rs:73

Methodfmt

(&self, f: &mut fmt::Formatter<'_>)

examples/http-server.rs:274

(link: NonNull<AtomicLink>)

src/linked_list.rs:42

Methodfrom_mio

Must remain crate-private to avoid adding a public dependency on Mio.

src/io/ready.rs:36

Methodfrom_std

(socket: net::UdpSocket)

src/net/udp.rs:218

Methodfrom_std

(stream: std::net::TcpStream)

src/net/tcp/stream.rs:193

Methodfrom_usize

Creates a `Ready` instance using the given `usize` representation. The `usize` representation must have been obtained from a call to `Readiness::as_u

(&self, value: *const dyn DynTask)

src/linked_list.rs:153

Methodget_value

(&self, link: NonNull<FatLink<dyn DynTask>>)

src/linked_list.rs:147

Methodleast_significant

Value is packed in the `width` least-significant bits.

src/bits.rs:11

Methodlink_ops

(&self)

src/linked_list.rs:158

Methodlink_ops_mut

(&mut self)

src/linked_list.rs:162

Functionlist

()

src/linked_list.rs:208

Methodlocal_addr

Returns the local address that this socket is bound to. # Example ```no_run use tokio::net::UdpSocket; # use std::{io, net::SocketAddr}; # #[tokio:

src/net/udp.rs:286

Methodlocal_addr

Returns the local address that this stream is bound to. # Examples ```no_run use tokio::net::TcpStream; # async fn dox() -> Result<(), Box<dyn std:

src/net/tcp/stream.rs:213

Methodlocal_addr

(&self)

src/net/tcp/listener.rs:59

Functionlookup_host

Performs a DNS resolution. The returned iterator may not actually yield any values depending on the outcome of any resolution performed. This API is

src/net/lookup_host.rs:31

Functionmain

()

examples/http-server.rs:28

Methodnew

Make a new multi-threaded runtime with `n` background threads

src/lib.rs:46

Methodnew

(cap: usize)

src/sync_slot_map.rs:12

Methodnew

(fut: F)

src/join_handle.rs:54

Methodnew

(handle: Arc<MTRuntime>, fut: F)

src/task.rs:190

Methodnew

()

src/linked_list.rs:22

src/io/poll_evented.rs:71

Methodnew

(socket: mio::net::UdpSocket)

src/net/udp.rs:170

Methodnew

(connected: mio::net::TcpStream)

src/net/tcp/stream.rs:150

Methodnew

(listener: mio::net::TcpListener)

src/net/tcp/listener.rs:54

Methodnew_with_interest

(io: E, interest: Interest)

src/io/poll_evented.rs:76

Methodnew_with_interest_and_handle

( io: &mut impl Source, interest: Interest, handle: Arc<super::Handle>, )

src/io/registration.rs:63

Methodnew_with_interest_and_handle

( mut io: E, interest: Interest, handle: Arc<Handle>, )

src/io/poll_evented.rs:85

Methodnext

(&self, ptr: Self::LinkPtr)

src/linked_list.rs:91

Methodpeer_addr

Returns the socket address of the remote peer this socket was connected to. # Example ``` use tokio::net::UdpSocket; # use std::{io, net::SocketAdd

src/net/udp.rs:308

Methodpeer_addr

Returns the remote address that this stream is connected to. # Examples ```no_run use tokio::net::TcpStream; # async fn dox() -> Result<(), Box<dyn

src/net/tcp/stream.rs:236

Methodpointer_ops

(&self)

src/linked_list.rs:166

Methodpoll

(mut self: Pin<&mut Self>, cx: &mut Context<'_>)

src/join_handle.rs:62

Methodpoll_close

(self: Pin<&mut Self>, _: &mut Context<'_>)

src/net/tcp/stream.rs:805

Methodpoll_flush

(self: Pin<&mut Self>, _: &mut Context<'_>)

src/net/tcp/stream.rs:800

Methodpoll_peek

Attempts to receive data on the socket, without removing that data from the queue, registering the current task for wakeup if data is not yet availabl

src/net/tcp/stream.rs:282

Methodpoll_peek_from

Receives data from the socket, without removing it from the input queue. On success, returns the number of bytes read. # Notes Note that on multiple

src/net/udp.rs:1038

Methodpoll_read

( &'a self, cx: &mut Context<'_>, buf: &mut [u8], )

src/io/poll_evented.rs:112

Methodpoll_read_ready

Uses the poll path, requiring the caller to ensure mutual exclusion for correctness. Only the last task to call this function is notified.

src/io/registration.rs:103

Methodpoll_readiness

Polls for readiness events in a given direction. These are to support `AsyncRead` and `AsyncWrite` polling methods, which cannot use the `async fn` v

src/io/mod.rs:384

Methodpoll_recv

Attempts to receive a single datagram message on the socket from the remote address to which it is `connect`ed. The [`connect`] method will connect t

src/net/udp.rs:615

Methodpoll_recv_from

Attempts to receive a single datagram on the socket. Note that on multiple calls to a `poll_*` method in the recv direction, only the `Waker` from th

src/net/udp.rs:869

Methodpoll_recv_ready

Polls for read/receive readiness. If the udp stream is not currently ready for receiving, this method will store a clone of the `Waker` from the prov

src/net/udp.rs:544

Methodpoll_send

Attempts to send data on the socket to the remote address to which it was previously `connect`ed. The [`connect`] method will connect this socket to

src/net/udp.rs:455

Methodpoll_send_ready

Polls for write/send readiness. If the udp stream is not currently ready for sending, this method will store a clone of the `Waker` from the provided

src/net/udp.rs:384

Methodpoll_send_to

Attempts to send data on the socket to a given address. Note that on multiple calls to a `poll_*` method in the send direction, only the `Waker` from

src/net/udp.rs:742

Methodpoll_write

( &'a self, cx: &mut Context<'_>, buf: &[u8], )

src/io/poll_evented.rs:134

Methodpoll_write_ready

Uses the poll path, requiring the caller to ensure mutual exclusion for correctness. Only the last task to call this function is notified.

src/io/registration.rs:109

Methodpoll_write_vectored

( &'a self, cx: &mut Context<'_>, bufs: &[io::IoSlice<'_>], )

src/io/poll_evented.rs:165

Methodprev

(&self, ptr: Self::LinkPtr)

src/linked_list.rs:96

Functionpush_pop

()

src/sync_slot_map.rs:109

Methodrelease_link

(&mut self, ptr: Self::LinkPtr)

src/linked_list.rs:84

Methodset_next

(&mut self, ptr: Self::LinkPtr, next: Option<Self::LinkPtr>)

src/linked_list.rs:100

Methodset_prev

(&mut self, ptr: Self::LinkPtr, prev: Option<Self::LinkPtr>)

src/linked_list.rs:105

Methodthread_per_core

Make a new multi-threaded runtime with a thread per logical CPU

src/linked_list.rs:36

Methodtry_from

Consumes stream, returning the tokio I/O object. This is equivalent to [`UdpSocket::from_std(stream)`](UdpSocket::from_std).

src/net/udp.rs:1056

Methodtry_from

Consumes stream, returning the tokio I/O object. This is equivalent to [`TcpStream::from_std(stream)`](TcpStream::from_std).

src/net/tcp/stream.rs:765

Methodtry_from

(stream: net::TcpListener)

src/net/tcp/listener.rs:67

Methodtry_io

( &self, interest: Interest, f: impl FnOnce() -> io::Result<R>, )

src/io/registration.rs:177

Methodtry_read

Tries to read data from the stream into the provided buffer, returning how many bytes were read. Receives any pending data from the socket but does n

src/net/tcp/stream.rs:394

Methodtry_read_vectored

Tries to read data from the stream into the provided buffers, returning how many bytes were read. Data is copied to fill each buffer in order, with t

src/net/tcp/stream.rs:472

Methodtry_recv

Tries to receive a single datagram message on the socket from the remote address to which it is connected. On success, returns the number of bytes rea

src/net/udp.rs:671

Methodtry_recv_from

Tries to receive a single datagram message on the socket. On success, returns the number of bytes read and the origin. The function must be called wi

src/net/udp.rs:927

Methodtry_send

Tries to send data on the socket to the remote address to which it is connected. When the socket buffer is full, `Err(io::ErrorKind::WouldBlock)` is

src/net/udp.rs:509

Methodtry_send_to

Tries to send data on the socket to the given address, but if the send is blocked this will return right away. This function is usually paired with `

src/net/udp.rs:800

Methodtry_write

Try to write a buffer to the stream, returning how many bytes were written. The function will attempt to write the entire contents of `buf`, but only

src/net/tcp/stream.rs:561

Methodtry_write_vectored

Tries to write several buffers to the stream, returning how many bytes were written. Data is written from each buffer in order, with the final buffer

src/net/tcp/stream.rs:623

Methodwake_by_ref

(arc_self: &Arc<Self>)

src/task.rs:206

Methodwrite_fmt

(&mut self, args: fmt::Arguments<'_>)

examples/http-server.rs:144

← previous101–197 of 197, ranked by callers