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

↓ 28 callersMethodregistration

Returns a reference to the registration.

src/io/poll_evented.rs:98

↓ 23 callersMethodunpack

(&self, src: usize)

src/bits.rs:48

↓ 20 callersMethodclone

(&self)

src/linked_list.rs:64

↓ 8 callersMethodpush

(&self, index: usize)

src/sync_slot_map.rs:22

↓ 8 callersFunctionto_socket_addrs

(arg: T)

src/net/addr.rs:20

↓ 7 callersMethodasync_io

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

src/io/registration.rs:241

↓ 6 callersMethodpack

(&self, value: usize, base: usize)

src/bits.rs:35

↓ 6 callersMethodtry_lock

(&self)

src/sync_slot_map.rs:26

↓ 5 callersMethodis_empty

Returns true if `Ready` is the empty set.

src/io/ready.rs:70

↓ 5 callersFunctionnow

Returns a struct, which when formatted, renders an appropriate `Date` header value.

examples/http-server.rs:240

↓ 4 callersMethodcheck

(self: Arc<Self>, t: T)

src/linked_list.rs:199

↓ 4 callersMethodclear_readiness

(&self, event: ReadyEvent)

src/io/mod.rs:311

↓ 4 callersMethodcontains

Returns true if `self` is a superset of `other`. `other` may represent more than one readiness operations, in which case the function only returns tr

src/io/ready.rs:99

↓ 4 callersMethodis_readable

Returns `true` if the value includes `readable`.

src/io/ready.rs:75

↓ 4 callersMethodis_writable

Returns `true` if the value includes writable `readiness`.

src/io/ready.rs:80

↓ 4 callersFunctionspawn

(f: F)

src/lib.rs:255

↓ 4 callersMethodthen

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

src/bits.rs:18

↓ 4 callersMethodtry_io

Tries to read or write from the socket using a user-provided IO operation. If the socket is ready, the provided closure is called. The closure should

src/net/udp.rs:965

↓ 4 callersMethodtry_io

Tries to read or write from the socket using a user-provided IO operation. If the socket is ready, the provided closure is called. The closure should

src/net/tcp/stream.rs:663

↓ 4 callersMethodwake

(&self)

src/io/mod.rs:163

↓ 3 callersMethodas_usize

Returns a `usize` representation of the `Ready` value. This function is mainly provided to allow the caller to store a readiness value in an `AtomicU

src/io/ready.rs:119

↓ 3 callersMethodclear_readiness

(&self, event: ReadyEvent)

src/io/registration.rs:93

↓ 3 callersMethodintersection

(self, interest: Interest)

src/io/ready.rs:141

↓ 3 callersMethodis_read_closed

Returns `true` if the value includes read-closed `readiness`.

src/io/ready.rs:85

↓ 3 callersMethodis_write_closed

Returns `true` if the value includes write-closed `readiness`.

src/io/ready.rs:90

↓ 3 callersMethodmask

(self)

src/io/mod.rs:550

↓ 3 callersMethodpoll_read_io

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:115

↓ 3 callersMethodpoll_write_io

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:125

↓ 3 callersMethodschedule_local

(&self, task: Arc<dyn DynTask>)

src/lib.rs:193

↓ 3 callersMethodsend

Sends data on the socket to the remote address that the socket is connected to. The [`connect`] method will connect this socket to a remote address.

src/net/udp.rs:425

↓ 3 callersMethodsend_to

Sends data on the socket to the given address. On success, returns the number of bytes written. Address type can be any implementor of [`ToSocketAddr

src/net/udp.rs:713

↓ 3 callersFunctionsleep

(duration: Duration)

src/lib.rs:317

↓ 2 callersMethodblock_on

Block the current thread and wait for the future to complete.

src/lib.rs:106

↓ 2 callersMethodderegister

Deregisters the I/O resource from the reactor it is associated with. This function must be called before the I/O resource associated with the registr

src/io/registration.rs:89

↓ 2 callersFunctiongone

()

src/io/registration.rs:219

↓ 2 callersFunctionmask_for

Returns a `usize` with the right-most `n` bits set.

src/bits.rs:69

↓ 2 callersMethodnext

(&mut self)

src/net/addr.rs:244

↓ 2 callersFunctionpointer_width

Returns the width of a pointer in bits.

src/bits.rs:64

↓ 2 callersMethodpoll

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

src/lib.rs:333

↓ 2 callersMethodpoll_io

( &self, cx: &mut Context<'_>, direction: Direction, mut f: impl FnMut() -> io

src/io/registration.rs:156

↓ 2 callersMethodpoll_ready

Polls for events on the I/O resource's `direction` readiness stream. If called with a task context, notify the task when a new event is received.

src/io/registration.rs:137

↓ 2 callersMethodpoll_write_ready

Polls for write readiness. If the tcp stream is not currently ready for writing, this method will store a clone of the `Waker` from the provided `Con

src/net/tcp/stream.rs:509

↓ 2 callersMethodrecv

Receives a single datagram message on the socket from the remote address to which it is connected. On success, returns the number of bytes read. The

src/net/udp.rs:585

↓ 2 callersMethodrecv_from

Receives a single datagram message on the socket. On success, returns the number of bytes read and the origin. The function must be called with valid

src/net/udp.rs:845

↓ 2 callersMethodregister

(&self, waker: &Waker)

↓ 2 callersMethodschedule_global

(this: &Arc<Self>)

src/task.rs:58

↓ 2 callersMethodset_readiness

Sets the readiness on this `ScheduledIo` by invoking the given closure on the current value, returning the previous readiness value. # Arguments - `t

src/io/mod.rs:335

↓ 2 callersMethodspawn

spawn a task onto this runtime

src/lib.rs:147

↓ 2 callersMethodtake_output

(&self, output: &mut dyn std::any::Any)

src/task.rs:105

↓ 1 callersMethodaccept

(&self)

src/net/tcp/listener.rs:43

↓ 1 callersMethodadd_source

Registers an I/O resource with the reactor for a given `mio::Ready` state. The registration token is returned.

src/io/mod.rs:128

↓ 1 callersMethodbuffer

(&self)

examples/http-server.rs:291

↓ 1 callersMethodcancel

(&self)

src/task.rs:116

↓ 1 callersMethodclear

(&mut self)

src/io/mod.rs:96

↓ 1 callersMethodderegister_source

Deregisters an I/O resource from the reactor.

src/io/mod.rs:154

↓ 1 callersMethodgeneration

(&self)

src/io/mod.rs:307

↓ 1 callersMethodget_local_task

(&self)

src/lib.rs:232

↓ 1 callersMethodget_many_global_tasks

(&self)

src/lib.rs:237

↓ 1 callersMethodinit_workers

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

src/lib.rs:69

↓ 1 callersMethodis_linked

(&self)

src/linked_list.rs:31

↓ 1 callersFunctionmask

(int: mio::Interest)

src/io/mod.rs:434

↓ 1 callersMethodmax_value

Max representable value.

src/bits.rs:31

↓ 1 callersMethodpack_lossy

Packs the value with `base`, losing any bits of `value` that fit. If `value` is larger than the max value that can be represented by the allotted wid

src/bits.rs:44

↓ 1 callersMethodpeek

Receives data on the socket from the remote address to which it is connected, without removing that data from the queue. On success, returns the numbe

src/net/tcp/stream.rs:710

↓ 1 callersMethodpeek_from

Receives data from the socket, without removing it from the input queue. On success, returns the number of bytes read and the address from whence the

src/net/udp.rs:1005

↓ 1 callersMethodpoll

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

src/io/mod.rs:445

↓ 1 callersMethodpoll_read

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

src/net/tcp/stream.rs:773

↓ 1 callersMethodpoll_read_priv

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

src/net/tcp/stream.rs:732

↓ 1 callersMethodpoll_read_ready

Polls for read readiness. If the tcp stream is not currently ready for reading, this method will store a clone of the `Waker` from the provided `Cont

src/net/tcp/stream.rs:327

↓ 1 callersMethodpoll_timeout

(&mut self, handle: &Handle, timeout: Option<Duration>)

src/io/mod.rs:65

↓ 1 callersMethodpoll_write

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

src/net/tcp/stream.rs:783

↓ 1 callersMethodpoll_write_priv

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

src/net/tcp/stream.rs:741

↓ 1 callersMethodpoll_write_vectored

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

src/net/tcp/stream.rs:791

↓ 1 callersMethodpoll_write_vectored_priv

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

src/net/tcp/stream.rs:749

↓ 1 callersMethodpop

The pop function from the 1024cores intrusive MPSC queue algorithm

src/sync_slot_map.rs:65

↓ 1 callersFunctionprocess

(stream: TcpStream)

examples/http-server.rs:51

↓ 1 callersMethodreadiness

(&self, interest: Interest)

src/io/registration.rs:224

↓ 1 callersMethodready_event

(&self, interest: mio::Interest)

src/io/mod.rs:370

↓ 1 callersFunctionrespond

(req: Request<()>)

examples/http-server.rs:67

↓ 1 callersMethodrun_forever

(self: Rc<ExecutorHandle>)

src/lib.rs:202

↓ 1 callersMethodsatisfies

(self, interest: Interest)

src/io/ready.rs:145

↓ 1 callersMethodsend_to_addr

(&self, buf: &[u8], target: SocketAddr)

src/net/udp.rs:806

↓ 1 callersMethodshutdown_std

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 retur

src/net/tcp/stream.rs:722

↓ 1 callersMethodslab_entry

(&self)

src/io/mod.rs:120

↓ 1 callersMethodtake_error

Returns the value of the `SO_ERROR` option.

src/net/tcp/stream.rs:218

↓ 1 callersMethodto_socket_addrs

(&self, _: sealed::Internal)

src/net/addr.rs:37

↓ 1 callersFunctionunpack

Unpacks a value using a mask & shift.

src/bits.rs:75

↓ 1 callersMethodupdate

(&mut self, now: SystemTime, now_unix: u64)

examples/http-server.rs:295

↓ 1 callersMethodwake

(self: Arc<Self>)

src/lib.rs:123

↓ 1 callersMethodwake_by_ref

(self: &Arc<Self>)

src/lib.rs:127

↓ 1 callersMethodwidth

Width, in bits, dedicated to storing the value.

src/bits.rs:26

↓ 1 callersMethodwrite_str

(&mut self, s: &str)

examples/http-server.rs:139

Methodabort

(&self)

src/join_handle.rs:101

Methodacquire_link

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

src/linked_list.rs:79

Methodbind

This function will create a new UDP socket and attempt to bind it to the `addr` provided. Binding with a port number of 0 will request that the OS as

src/net/udp.rs:145

Methodbind

(addr: A)

src/net/tcp/listener.rs:18

src/net/tcp/listener.rs:38

Methodbitand

(self, other: Ready)

src/io/ready.rs:167

next →1–100 of 197, ranked by callers