Functions — github.com/dicej/ipmpsc

CodeHub MCPcopy Create free account

hub / github.com/dicej/ipmpsc / functions

Functions79 in github.com/dicej/ipmpsc

⨍ Functions 79 ◇ Types & classes 25

↓ 12 callersMethodheader

src/posix.rs:102

↓ 11 callersMethodget

(self, index: u8)

src/bitmask.rs:43

↓ 11 callersMethodmap

src/posix.rs:113

↓ 10 callersMethodsend

Send the specified message, waiting for sufficient contiguous space to become available in the ring buffer if necessary. The serialized size of the m

↓ 7 callersMethodrecv

Attempt to read a message, blocking if necessary until one becomes available.

↓ 6 callersMethodclone

src/windows.rs:155

↓ 6 callersFunctionfork

src/posix.rs:237

↓ 6 callersFunctionuv_stride

ipc-benchmarks/src/lib.rs:55

↓ 6 callersMethodwaiters

src/windows.rs:347

↓ 5 callersMethodlock

src/posix.rs:109

↓ 5 callersMethodthreads

src/windows.rs:351

↓ 4 callersMethodbuffer

src/posix.rs:82

↓ 4 callersMethodlock

src/windows.rs:239

↓ 4 callersMethodnotify_all

src/posix.rs:132

↓ 4 callersMethodrecv_timeout_0

( &'a self, timeout: Option<Duration>, )

↓ 4 callersMethodseek

(&self, position: u32)

↓ 3 callersMethodclear

(&self, index: u8)

src/bitmask.rs:51

↓ 3 callersFunctionflags

↓ 3 callersFunctionpipe

src/posix.rs:228

↓ 3 callersMethodsend_timeout_0

( &self, value: &impl Serialize, wait_until_empty: bool, timeout: Option<Durat

↓ 3 callersMethodtry_recv_0

↓ 3 callersFunctiony_stride

ipc-benchmarks/src/lib.rs:51

↓ 3 callersMethodzero_copy_context

Borrows this receiver for deserializing a message with references that refer directly to this [`Receiver`](struct.Receiver.html)'s ring buffer rather

↓ 2 callersFunctionbench_ipc_channel

(bencher: &mut Bencher, (width, height): (usize, usize))

ipc-benchmarks/src/lib.rs:140

↓ 2 callersFunctionbench_ipc_channel_bytes

( bencher: &mut Bencher, (width, height): (usize, usize), )

ipc-benchmarks/src/lib.rs:209

↓ 2 callersFunctionbench_ipmpsc

(bencher: &mut Bencher, (width, height): (usize, usize))

ipc-benchmarks/src/lib.rs:69

↓ 2 callersMethoddo_wait

(&mut self, view: &View, milliseconds: ULONG)

src/windows.rs:284

↓ 2 callersMethodheader

src/windows.rs:232

↓ 2 callersFunctionmap

↓ 2 callersMethodsend_timeout

Send the specified message, waiting for sufficient contiguous space to become available in the ring buffer if necessary, but only up to the specified

↓ 2 callersMethodset

(self, index: u8)

src/bitmask.rs:47

↓ 2 callersMethodtimed_wait

(&mut self, view: &View, timeout: Option<Duration>)

src/posix.rs:150

↓ 1 callersMethodbuffer

src/windows.rs:144

↓ 1 callersMethodforward

(&self, dst: &mut dyn Write)

src/posix.rs:200

↓ 1 callersMethodinit

src/posix.rs:44

↓ 1 callersMethodmap

src/windows.rs:243

↓ 1 callersMethodmap_mut

src/posix.rs:87

↓ 1 callersMethodnext

src/bitmask.rs:69

↓ 1 callersMethodones

src/bitmask.rs:11

↓ 1 callersMethodopen

Creates a new [`SharedRingBuffer`](struct.SharedRingBuffer.html) backed by a file with the specified name. The file must already exist and have been

↓ 1 callersMethodrecv_timeout

Attempt to read a message, blocking for up to the specified duration if necessary until one becomes available.

↓ 1 callersMethodrun

↓ 1 callersMethodsemaphore

(&self, index: u8)

src/windows.rs:207

↓ 1 callersFunctionsha256

src/windows.rs:41

↓ 1 callersMethodwait

(&mut self, view: &View)

src/windows.rs:310

↓ 1 callersMethodwait

(&mut self, _view: &View)

src/posix.rs:140

↓ 1 callersMethodzeros

src/bitmask.rs:27

src/bitmask.rs:15

Functionarb_case

Functionbench_ipc_channel_bytes_large

(bencher: &mut Bencher)

ipc-benchmarks/src/lib.rs:205

Functionbench_ipc_channel_bytes_small

(bencher: &mut Bencher)

ipc-benchmarks/src/lib.rs:200

Functionbench_ipc_channel_large

(bencher: &mut Bencher)

ipc-benchmarks/src/lib.rs:136

Functionbench_ipc_channel_small

(bencher: &mut Bencher)

ipc-benchmarks/src/lib.rs:131

Functionbench_ipmpsc_large

(bencher: &mut Bencher)

ipc-benchmarks/src/lib.rs:65

Functionbench_ipmpsc_small

(bencher: &mut Bencher)

ipc-benchmarks/src/lib.rs:60

src/bitmask.rs:7

Creates a new [`SharedRingBuffer`](struct.SharedRingBuffer.html) backed by a file with the specified name. The file will be created if it does not al

Methodcreate_temp

Creates a new [`SharedRingBuffer`](struct.SharedRingBuffer.html) backed by a temporary file which will be deleted when the [`SharedRingBuffer`](struct

src/windows.rs:30

src/posix.rs:178

src/windows.rs:369

Functionget_last_error

src/windows.rs:49

src/windows.rs:113

examples/ipmpsc-send.rs:7

examples/ipmpsc-receive.rs:6

src/windows.rs:149

Constructs a [`Receiver`](struct.Receiver.html) from the specified [`SharedRingBuffer`](struct.SharedRingBuffer.html)

Methodnotify_all

src/windows.rs:327

Methodsend_when_empty

Send the specified message, waiting for the ring buffer to become completely empty first. This method is appropriate for sending time-sensitive messa

Functionsimple_case

Functionslow_receiver_with_send_timeout

Functionslow_sender_with_recv_timeout

Methodtimed_wait

(&mut self, view: &View, timeout: Option<Duration>)

src/windows.rs:314

(buffer: Arc<UnsafeCell<Buffer>>)

src/windows.rs:134

(buffer: Arc<UnsafeCell<Buffer>>)

src/posix.rs:78

Attempt to read a message without blocking. This will return `Ok(None)` if there are no messages immediately available.

Functionzero_copy