Functions — github.com/Diggsey/lockless

hub / github.com/Diggsey/lockless / functions

Functions216 in github.com/Diggsey/lockless

⨍ Functions 216◇ Types & classes 44

↓ 77 callersFunctionnew

(max_accessors: usize, size: usize)

src/sync/mpmc_queue.rs:405

↓ 62 callersMethodunwrap

(mut self)

src/primitives/atomic_cell.rs:36

↓ 33 callersFunctionnew

(max_accessors: usize, size: usize)

src/containers/mpmc_queue.rs:289

↓ 28 callersMethodclone

(&self)

src/handle/core.rs:55

↓ 26 callersMethodnone_storing_iter

(&mut self, n: usize)

src/containers/storage.rs:55

↓ 22 callersMethodreplace

(&self, place: &mut Place<T>, value: Option<T>)

src/containers/storage.rs:43

↓ 21 callersMethodget_mut

(&self, id: &mut T)

src/containers/scratch.rs:15

↓ 20 callersMethodextend

(&mut self, iter: I)

src/containers/scratch.rs:23

↓ 20 callersMethodsend

(&mut self, value: T)

src/containers/mpmc_queue.rs:272

↓ 18 callersMethodpush

(&self, id: &mut MpmcQueueAccessorId, value: T)

src/sync/mpmc_queue.rs:214

↓ 15 callersMethodswap

(&self, value: &mut T)

src/containers/atomic_cell.rs:16

↓ 13 callersMethodinto_iter

(self)

src/primitives/append_list.rs:75

↓ 12 callersMethodwith_mut

(&mut self, f: F)

src/handle/core.rs:48

↓ 10 callersMethoditer

(&self)

src/primitives/append_list.rs:66

↓ 9 callersMethodborrow

(&self)

src/containers/storage.rs:22

↓ 9 callersMethodid_allocator

(&self)

src/sync/mpmc_queue.rs:57

↓ 9 callersMethodwith

(&self, f: F)

src/handle/core.rs:45

↓ 7 callersMethodid_limit

(&self)

src/handle/ids.rs:52

↓ 7 callersMethodreserve

(&mut self, extra: usize)

src/containers/storage.rs:52

↓ 7 callersMethodresize

(&mut self, new_len: usize)

src/primitives/index_allocator.rs:65

↓ 6 callersMethodget

(&self)

src/primitives/atomic_cell.rs:76

↓ 6 callersMethodlen

(&self)

src/containers/mpmc_queue.rs:97

↓ 6 callersMethodpop

(&self, id: &mut MpmcQueueAccessorId)

src/sync/mpmc_queue.rs:259

↓ 6 callersMethodstart_send

(&mut self, msg: T)

src/sync/mpmc_queue.rs:386

↓ 5 callersMethodborrow_mut

(&mut self)

src/containers/storage.rs:28

↓ 5 callersMethodget_mut

(&mut self)

src/primitives/atomic_cell.rs:45

↓ 5 callersMethodread

(&self)

src/primitives/atomic_cell.rs:73

↓ 5 callersMethodstore

(&mut self, value: U)

src/containers/scratch.rs:12

↓ 5 callersFunctionwith_receiver_id

(f: F)

src/sync/mpsc_queue.rs:25

↓ 5 callersFunctionwith_sender_id

(sender_id: &mut MpscQueueSenderId, f: F)

src/sync/mpsc_queue.rs:22

↓ 4 callersMethodclose

(&self, id: &mut MpmcQueueAccessorId)

src/sync/mpmc_queue.rs:281

↓ 4 callersMethodinc_sender_count

(&self)

src/sync/mpsc_queue.rs:273

↓ 4 callersMethodlen

This is the length of the buffer, not the number of "live" elements

src/containers/mpsc_queue.rs:132

↓ 4 callersFunctionnext_cell

(mut index: usize, size2: usize)

src/containers/mpmc_queue.rs:49

↓ 4 callersMethodpop

(&self)

src/sync/mpsc_queue.rs:230

↓ 4 callersMethodwake_task

Wake another parked task

src/sync/mpmc_queue.rs:189

↓ 4 callersMethodwake_task

Wake another parked task

src/sync/mpsc_queue.rs:166

↓ 3 callersMethoddec_msg_count

(&self)

src/sync/mpsc_queue.rs:155

↓ 3 callersFunctionfree

(ptr: *mut T)

src/primitives/atomic_cell.rs:16

↓ 3 callersMethodinc_receiver_count

(&self)

src/sync/mpmc_queue.rs:306

↓ 3 callersMethodinc_sender_count

(&self)

src/sync/mpmc_queue.rs:296

↓ 3 callersMethodpop_inner

(&self)

src/sync/mpsc_queue.rs:218

↓ 3 callersMethodpush

(&self, value: &mut T)

src/containers/mpmc_queue.rs:101

↓ 3 callersMethodtry_update

(&self, mut f: F)

src/primitives/atomic_ext.rs:11

↓ 3 callersMethodtry_update_indirect

Updates a second atomic referred to by this one. Calling code must be careful to tag pointers to avoid the ABA problem.

src/primitives/atomic_ext.rs:26

↓ 3 callersFunctionword_bits

()

src/primitives/index_allocator.rs:17

↓ 2 callersFunctionallocate

Helper functions for allocation in stable rust

src/primitives/atomic_cell.rs:9

↓ 2 callersMethodextend

(&mut self, iter: I)

src/containers/atomic_cell_array.rs:31

↓ 2 callersMethodid_limit

(&self)

src/handle/resizing.rs:61

↓ 2 callersMethodinc_msg_count_lower

(&self, id: &mut MpmcQueueAccessorId)

src/sync/mpmc_queue.rs:146

↓ 2 callersMethodnext

(&mut self)

src/containers/storage.rs:71

↓ 2 callersFunctionnext_cell

Advance a pointer by one cell, wrapping if necessary

src/containers/mpsc_queue.rs:62

↓ 2 callersMethodpark_self

Returns true if was already parked

src/sync/mpmc_queue.rs:198

↓ 2 callersMethodpark_self

Returns true if was already parked

src/sync/mpsc_queue.rs:175

↓ 2 callersMethodpoll

(&mut self)

src/sync/mpmc_queue.rs:342

↓ 2 callersMethodpop_inner

(&self, id: &mut MpmcQueueAccessorId)

src/sync/mpmc_queue.rs:246

↓ 2 callersMethodpush

(&self, id: &mut MpscQueueSenderId, value: T)

src/sync/mpsc_queue.rs:191

↓ 2 callersMethodreceive

(&mut self)

src/containers/mpmc_queue.rs:250

↓ 2 callersFunctionreceiver_index

()

src/sync/mpsc_queue.rs:31

↓ 2 callersMethodreserve

(&mut self, extra: usize)

src/containers/atomic_cell_array.rs:17

↓ 2 callersMethodunpark_self

Undo a previous `park_self` operation

src/sync/mpmc_queue.rs:207

↓ 2 callersMethodunpark_self

Undo a previous `park_self` operation

src/sync/mpsc_queue.rs:184

↓ 2 callersMethodwrite

(&self, value: T)

src/primitives/atomic_cell.rs:68

↓ 1 callersMethodappend_list

(&self, other: AppendList<T>)

src/primitives/append_list.rs:60

↓ 1 callersMethodappend_ptr

(&self, p: *mut Node<T>)

src/primitives/append_list.rs:49

↓ 1 callersFunctionatomic_cell_smoke

()

src/lib.rs:25

↓ 1 callersFunctionbounded_atomic_cell_smoke

()

src/lib.rs:60

↓ 1 callersFunctionbounded_mpmc_queue_smoke

()

src/lib.rs:173

↓ 1 callersFunctionbounded_mpsc_queue_smoke

()

src/lib.rs:130

↓ 1 callersMethodclose

(&self)

src/sync/mpsc_queue.rs:263

↓ 1 callersMethoddec_msg_count_lower

(&self, id: &mut MpmcQueueAccessorId)

src/sync/mpmc_queue.rs:157

↓ 1 callersMethoddec_msg_count_upper

(&self, id: &mut MpmcQueueAccessorId)

src/sync/mpmc_queue.rs:177

↓ 1 callersMethoddec_receiver_count

(&self, id: &mut MpmcQueueAccessorId)

src/sync/mpmc_queue.rs:310

↓ 1 callersMethoddec_sender_count

(&self, id: &mut MpmcQueueAccessorId)

src/sync/mpmc_queue.rs:300

↓ 1 callersMethoddec_sender_count

(&self, id: &mut MpscQueueSenderId)

src/sync/mpsc_queue.rs:277

↓ 1 callersFunctiondiv_up

(a: usize, b: usize)

src/primitives/index_allocator.rs:13

↓ 1 callersMethoddrain

Must not be called while there are any remaining receivers

src/sync/mpmc_queue.rs:242

↓ 1 callersMethoddrain

(&self)

src/sync/mpsc_queue.rs:224

↓ 1 callersMethodextend

(&mut self, iter: I)

src/containers/mpmc_queue.rs:79

↓ 1 callersMethodextend

(&mut self, iter: I)

src/containers/mpsc_queue.rs:112

↓ 1 callersMethodfree

(&self, id: usize)

src/primitives/index_allocator.rs:57

↓ 1 callersMethodfree_id

(&self, id: IdType)

src/handle/ids.rs:49

↓ 1 callersMethodinc_msg_count

(&self, id: &mut MpscQueueSenderId)

src/sync/mpsc_queue.rs:126

↓ 1 callersMethodinc_msg_count_upper

(&self, id: &mut MpmcQueueAccessorId)

src/sync/mpmc_queue.rs:125

↓ 1 callersMethodlen

(&self)

src/primitives/index_allocator.rs:90

↓ 1 callersMethodpop

(&self, value: &mut T)

src/containers/mpmc_queue.rs:143

↓ 1 callersMethodpop

(&self, receiver: F)

src/containers/mpsc_queue.rs:199

↓ 1 callersMethodpush

(&mut self, value: T)

src/containers/atomic_cell_array.rs:13

↓ 1 callersMethodpush

Swap a value onto the tail of the queue. If the queue is observed to be full, there are no side effects and `false` is returned.

src/containers/mpsc_queue.rs:138

↓ 1 callersMethodpush

(&self, mut node: Box<Node<T>>)

src/primitives/prepend_list.rs:45

↓ 1 callersMethodraise_id_limit

(&mut self, new_limit: usize)

src/sync/mpmc_queue.rs:61

↓ 1 callersFunctionreplace_forget

(dest: &mut T, value: T)

src/primitives/prepend_list.rs:18

↓ 1 callersFunctionresizing_atomic_cell_smoke

()

src/lib.rs:95

↓ 1 callersFunctionrotate_slice

(slice: &mut [T], places: usize)

src/containers/mpmc_queue.rs:62

↓ 1 callersFunctionrotate_slice

In-place rotation algorithm (shifts to the right)

src/containers/mpsc_queue.rs:81

↓ 1 callersFunctionsender_index

(sender_id: &mut MpscQueueSenderId)

src/sync/mpsc_queue.rs:28

↓ 1 callersMethodset

(&self, p: *mut T)

src/primitives/atomic_cell.rs:79

↓ 1 callersMethodsize_hint

(&self)

src/containers/storage.rs:80

↓ 1 callersMethodstore

(&mut self, value: Option<T>)

src/containers/storage.rs:38

↓ 1 callersMethodswap

(&self, ptr: NodePtr<T>)

src/primitives/prepend_list.rs:40

next →1–100 of 216, ranked by callers