Functions — github.com/Diggsey/lockless

CodeHub MCPcopy Create free account

hub / github.com/Diggsey/lockless / functions

Functions216 in github.com/Diggsey/lockless

⨍ Functions 216◇ Types & classes 44

↓ 1 callersMethodtry_allocate

src/primitives/index_allocator.rs:31

↓ 1 callersMethodtry_allocate_id

src/handle/ids.rs:46

↓ 1 callersFunctionvalidate_value

src/containers/mpsc_queue.rs:91

↓ 1 callersFunctionwraps_around

(start: usize, end: usize, size: usize)

src/containers/mpmc_queue.rs:57

↓ 1 callersFunctionwraps_around

Determine if we can just add empty elements to the end of the ring-buffer. If the "live section" wraps around, then we can't.

src/containers/mpsc_queue.rs:72

(&self, value: T)

src/primitives/append_list.rs:42

Functionatomic_cell_bench

(b: &mut Bencher)

Functionbounded_atomic_cell_bench

(b: &mut Bencher)

Functionbounded_mpmc_queue_bench

(b: &mut Bencher)

Functionbounded_mpsc_queue_bench

(b: &mut Bencher)

tests/mpmc.rs:23

tests/mpsc.rs:25

Functionchannel

tests/mpmc.rs:18

Functionchannel

tests/mpsc.rs:18

src/handle/bounded.rs:38

src/handle/resizing.rs:67

src/containers/atomic_cell_array.rs:130

src/containers/mpmc_queue.rs:260

src/containers/atomic_cell.rs:84

src/containers/mpsc_queue.rs:310

src/sync/mpmc_queue.rs:349

src/sync/mpsc_queue.rs:341

src/primitives/atomic_cell.rs:130

src/handle/core.rs:61

src/sync/mpmc_queue.rs:355

src/sync/mpsc_queue.rs:309

src/primitives/prepend_list.rs:61

src/primitives/atomic_cell.rs:51

src/primitives/append_list.rs:81

(&self, id: IdType)

src/handle/bounded.rs:18

(&self, id: IdType)

src/handle/resizing.rs:47

src/containers/storage.rs:10

(ptr: *mut Node<T>)

src/primitives/prepend_list.rs:29

(ptr: *mut Node<T>)

src/primitives/append_list.rs:26

src/handle/core.rs:42

Methodid_allocator

src/containers/atomic_cell_array.rs:99

Methodid_allocator

src/containers/mpmc_queue.rs:233

Methodid_allocator

src/containers/atomic_cell.rs:57

Methodid_allocator

src/containers/mpsc_queue.rs:260

Methodid_allocator

src/sync/mpsc_queue.rs:66

src/handle/bounded.rs:32

src/handle/inner.rs:8

(&mut self, index: usize, value: T)

src/containers/atomic_cell_array.rs:21

(ptr: NodePtr<T>)

src/primitives/prepend_list.rs:23

(ptr: NodePtr<T>)

src/primitives/append_list.rs:20

Functionis_ready

(res: &AsyncSink<T>)

tests/mpmc.rs:275

Functionis_ready

(res: &AsyncSink<T>)

tests/mpsc.rs:257

Functionis_send

tests/mpmc.rs:16

Functionis_send

tests/mpsc.rs:16

src/containers/atomic_cell_array.rs:44

(inner: Self::HandleInner)

src/handle/bounded.rs:26

(inner: Self::HandleInner)

src/handle/resizing.rs:55

src/handle/ids.rs:43

src/handle/core.rs:29

src/containers/atomic_cell_array.rs:25

src/containers/mpmc_queue.rs:70

src/containers/scratch.rs:18

src/containers/atomic_cell.rs:13

Constructor takes an iterator to "fill" the buffer with an initial set of values (even empty cells have a value index...)

src/containers/mpsc_queue.rs:99

src/containers/storage.rs:49

(max_accessors: usize, size: usize)

src/sync/mpmc_queue.rs:87

(max_senders: usize, size: usize)

src/sync/mpsc_queue.rs:94

(ptr: NodePtr<T>)

src/primitives/prepend_list.rs:37

src/primitives/index_allocator.rs:22

src/primitives/atomic_cell.rs:27

src/primitives/append_list.rs:38

Methodnew_internal

(ptr: NodePtr<T>)

src/primitives/append_list.rs:34

src/primitives/append_list.rs:92

src/sync/mpsc_queue.rs:302

Methodpoll_complete

src/sync/mpmc_queue.rs:390

Methodpoll_complete

src/sync/mpsc_queue.rs:354

Methodraise_id_limit

(&mut self, new_limit: usize)

src/containers/atomic_cell_array.rs:102

Methodraise_id_limit

(&mut self, new_limit: usize)

src/containers/mpmc_queue.rs:236

Methodraise_id_limit

(&mut self, new_limit: usize)

src/containers/atomic_cell.rs:60

Methodraise_id_limit

(&mut self, new_limit: usize)

src/containers/mpsc_queue.rs:263

Methodraise_id_limit

(&mut self, new_limit: usize)

src/sync/mpsc_queue.rs:70

src/containers/mpsc_queue.rs:281

Functionrecv_close_gets_none

tests/mpmc.rs:127

Functionrecv_close_gets_none

tests/mpsc.rs:115

Functionresizing_atomic_cell_bench

(b: &mut Bencher)

(&mut self, value: T)

src/containers/mpsc_queue.rs:301

Functionsend_recv

tests/mpmc.rs:29

Functionsend_recv

tests/mpsc.rs:31

Functionsend_recv_no_buffer

tests/mpmc.rs:39

Functionsend_recv_no_buffer

tests/mpsc.rs:41

Functionsend_recv_threads

tests/mpmc.rs:96

Functionsend_recv_threads

tests/mpsc.rs:84

Functionsend_recv_threads_no_capacity

tests/mpmc.rs:108

Functionsend_recv_threads_no_capacity

tests/mpsc.rs:96

Functionsend_shared_recv

tests/mpmc.rs:69

Functionsend_shared_recv

tests/mpsc.rs:71

Functionsend_shared_send

tests/mpmc.rs:82

Methodstart_send

(&mut self, msg: T)

src/sync/mpsc_queue.rs:350

Functionstress_receiver_multi_task_bounded_hard

tests/mpmc.rs:195

Functionstress_receiver_multi_task_bounded_hard

tests/mpsc.rs:177

Functionstress_shared_bounded_hard

tests/mpmc.rs:157

Functionstress_shared_bounded_hard

tests/mpsc.rs:145

(&self, index: usize, value: &mut T)

src/containers/atomic_cell_array.rs:39

(&self, value: T)

src/primitives/atomic_cell.rs:108

Methodtry_allocate_id

src/handle/bounded.rs:14

← previous next →101–200 of 216, ranked by callers