Functions — github.com/Fugoes/yaay-rs

hub / github.com/Fugoes/yaay-rs / functions

Functions151 in github.com/Fugoes/yaay-rs

⨍ Functions 151◇ Types & classes 41

↓ 36 callersMethodlock

(&self)

yaay-mt-runtime/src/task_list.rs:128

↓ 7 callersMethodepoch

(&mut self)

yaay-mt-runtime/src/worker.rs:100

↓ 6 callersMethodget_unchecked

()

yaay-mt-runtime/src/task.rs:262

↓ 6 callersMethodnext_epoch

(&self)

yaay-mt-runtime/src/epoch.rs:216

↓ 5 callersMethodpop_front

(&mut self)

yaay-mt-runtime/src/task_list.rs:67

↓ 5 callersMethodpush_back

(&mut self, task: NonNull<Task>)

yaay-mt-runtime/src/task_list.rs:30

↓ 5 callersMethodwait

Wait all builder done built. Return a `WorkerGuard` to handle destruction for workers.

yaay-mt-runtime/src/worker_manager.rs:80

↓ 4 callersFunctiondo_drop

(ptr: NonNull<T>)

yaay-mt-runtime/src/mem.rs:16

↓ 4 callersFunctiondo_new

(data: T)

yaay-mt-runtime/src/mem.rs:7

↓ 4 callersFunctionget_local

()

yaay-mt-runtime/src/shared.rs:20

↓ 4 callersMethodread_exact

(&mut self, buf: &mut [u8])

yaay-mio/src/net/tcp_stream.rs:46

↓ 4 callersMethodwrite_all

(&mut self, buf: &[u8])

yaay-mio/src/net/tcp_stream.rs:56

↓ 3 callersMethodbuild

Build current thread's worker. After return, the `Worker::get()` method would be safe to use.

yaay-mt-runtime/src/worker_manager.rs:98

↓ 3 callersMethodis_empty

(&self)

yaay-mt-runtime/src/task_list.rs:86

↓ 3 callersFunctionnext_seed

(seed: u32)

yaay-mt-runtime/src/rng.rs:8

↓ 3 callersMethodpush_back_batch

(&mut self, tasks: TaskList)

yaay-mt-runtime/src/task_list.rs:36

↓ 3 callersMethodpush_front

(&mut self, task: NonNull<Task>)

yaay-mt-runtime/src/task_list.rs:48

↓ 3 callersFunctionset_local

(ptr: *mut T)

yaay-mt-runtime/src/shared.rs:17

↓ 3 callersMethodwrite

(&mut self, buf: &[u8])

yaay-mio/src/net/tcp_stream.rs:52

↓ 2 callersMethodaccept

(&mut self)

yaay-mio/src/net/tcp_listener.rs:22

↓ 2 callersFunctiondo_dealloc

(ptr: NonNull<T>)

yaay-mt-runtime/src/mem.rs:32

↓ 2 callersFunctiondo_drop_in_place

(ptr: NonNull<T>)

yaay-mt-runtime/src/mem.rs:39

↓ 2 callersFunctiondo_wake_by_ref

(task: NonNull<Task>)

yaay-mt-runtime/src/task_waker.rs:41

↓ 2 callersMethodget

()

yaay-mio/src/shared.rs:39

↓ 2 callersFunctionget_global

()

yaay-mt-runtime/src/shared.rs:14

↓ 2 callersMethodget_instant

(&self)

yaay-mt-runtime/src/epoch.rs:182

↓ 2 callersMethodnotify

(&self)

yaay-mio/src/dispatcher.rs:110

↓ 2 callersMethodpoll_task

(&mut self, task: NonNull<Task>)

yaay-mt-runtime/src/worker.rs:168

↓ 2 callersMethodpop_all

(&mut self)

yaay-mt-runtime/src/task_list.rs:92

↓ 2 callersMethodreader

(&mut self)

yaay-mio/src/net/tcp_stream.rs:29

↓ 2 callersFunctionset_global

(ptr: *mut T)

yaay-mt-runtime/src/shared.rs:11

↓ 2 callersMethodstatus_ref

(&self)

yaay-mio/src/dispatcher.rs:52

↓ 2 callersMethodwake_all_slow

Wake up all worker threads parked in the parking lot by calling `parking_lot::unpark_all()`. Since this is the slow path, no need to inline.

yaay-mt-runtime/src/epoch.rs:257

↓ 2 callersFunctionwork

()

yaay-tests/src/spawn_defer_bench.rs:6

↓ 2 callersMethodwriter

(&mut self)

yaay-mio/src/net/tcp_stream.rs:36

↓ 1 callersMethodacceptor

(&mut self)

yaay-mio/src/net/tcp_listener.rs:16

↓ 1 callersFunctionasync_main

()

yaay-tests/src/mio_empty.rs:18

↓ 1 callersFunctionasync_main

()

yaay-tests/src/tokio_empty.rs:21

↓ 1 callersFunctionasync_main

()

yaay-tests/src/concurrent_wakeup.rs:57

↓ 1 callersFunctionasync_main

(addr: Arc<SocketAddr>)

yaay-tests/src/tokio_ping_pong.rs:29

↓ 1 callersMethodbuilder

Get one builder.

yaay-mt-runtime/src/worker_manager.rs:72

↓ 1 callersFunctiondefer_bench_async_main

(bench: &mut Bencher)

yaay-tests/src/spawn_defer_bench.rs:34

↓ 1 callersMethoddel

(&self, local_i: usize, key: usize)

yaay-mio/src/dispatcher.rs:30

↓ 1 callersFunctiondo_alloc

()

yaay-mt-runtime/src/mem.rs:24

↓ 1 callersFunctiondo_clone

(task: NonNull<Task>)

yaay-mt-runtime/src/task_waker.rs:35

↓ 1 callersFunctiondo_dealloc

(ptr: NonNull<T>)

yaay-mio/src/helper.rs:35

↓ 1 callersFunctiondo_drop

(ptr: NonNull<T>)

yaay-mio/src/helper.rs:19

↓ 1 callersFunctiondo_drop

(task: NonNull<Task>)

yaay-mt-runtime/src/task_waker.rs:46

↓ 1 callersFunctiondo_drop_in_place

(ptr: NonNull<T>)

yaay-mio/src/helper.rs:42

↓ 1 callersFunctiondo_new

(data: T)

yaay-mio/src/helper.rs:10

↓ 1 callersFunctionempty

()

yaay-tests/src/mio_empty.rs:22

↓ 1 callersFunctionempty

()

yaay-tests/src/tokio_empty.rs:27

↓ 1 callersMethodget

()

yaay-mt-runtime/src/worker_manager.rs:51

↓ 1 callersMethodget_status

(&self)

yaay-mt-runtime/src/epoch.rs:188

↓ 1 callersMethodmain_loop

The main loop for the worker thread.

yaay-mt-runtime/src/worker.rs:105

↓ 1 callersFunctionmio_exit

(_: ())

yaay-mio/src/prelude.rs:19

↓ 1 callersFunctionmio_shutdown

(handles: Box<[JoinHandle<()>]>)

yaay-mio/src/prelude.rs:12

↓ 1 callersFunctionping

(mut read_handle: TcpStreamReadHandle, mut write_handle: TcpStreamWriteHandle)

yaay-tests/src/mio_ping_pong.rs:44

↓ 1 callersFunctionping

(mut socket: TcpStream)

yaay-tests/src/tokio_ping_pong.rs:43

↓ 1 callersFunctionping_pong_async_main

(addr: Arc<SocketAddr>)

yaay-tests/src/mio_ping_pong.rs:30

↓ 1 callersMethodpoll

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

yaay-mio/src/helper.rs:53

↓ 1 callersMethodpoll

(task: NonNull<Task>)

yaay-mt-runtime/src/task.rs:140

↓ 1 callersFunctionpong

(addr: Arc<SocketAddr>)

yaay-tests/src/mio_ping_pong.rs:67

↓ 1 callersFunctionpong

(addr: Arc<SocketAddr>)

yaay-tests/src/tokio_ping_pong.rs:53

↓ 1 callersMethodpush_batch

(&self)

yaay-mt-runtime/src/batch.rs:18

↓ 1 callersMethodpush_front_batch

(&mut self, tasks: TaskList)

yaay-mt-runtime/src/task_list.rs:54

↓ 1 callersMethodrun

Push the async main function as a task to local queues. It would return immediately. And the called should wait for all worker threads exit.

yaay-mt-runtime/src/worker_manager.rs:142

↓ 1 callersFunctionseed_from_system_time

()

yaay-mt-runtime/src/rng.rs:3

↓ 1 callersMethodset_active

(&self)

yaay-mt-runtime/src/epoch.rs:193

↓ 1 callersMethodset_inactive

(&self)

yaay-mt-runtime/src/epoch.rs:202

↓ 1 callersFunctionset_shutdown

()

yaay-mio/src/shared.rs:159

↓ 1 callersMethodspawn

(future: T)

yaay-mt-runtime/src/runtime.rs:66

↓ 1 callersMethodspawn

(&mut self, task: NonNull<Task>)

yaay-mt-runtime/src/worker.rs:82

↓ 1 callersFunctionspawn_bench_async_main

(bench: &mut Bencher)

yaay-tests/src/spawn_defer_bench.rs:19

↓ 1 callersFunctiontask_waker_from

(task: NonNull<Task>)

yaay-mt-runtime/src/task_waker.rs:6

↓ 1 callersMethodtry_steal

(&mut self)

yaay-mt-runtime/src/worker.rs:175

↓ 1 callersMethodwait_next_epoch

(&self, old_status: u32, old_instant: Instant)

yaay-mt-runtime/src/epoch.rs:209

↓ 1 callersMethodwait_slow

Using `parking_lot::park()` to park current worker thread. When doing validation inside the parking lot, if both (1) Time elapsed since `old_instant`

yaay-mt-runtime/src/epoch.rs:241

Methodactive_count

(status: u32)

yaay-mt-runtime/src/epoch.rs:224

Methodbatch_guard

()

yaay-mt-runtime/src/runtime.rs:73

Methodbind

(addr: &SocketAddr)

yaay-mio/src/net/tcp_listener.rs:12

Methodbuild

()

yaay-mio/src/shared.rs:48

Methodconnect

(addr: &SocketAddr)

yaay-mio/src/net/tcp_stream.rs:17

Methoddefer

(future: T)

yaay-mt-runtime/src/runtime.rs:59

Methoddefer

(&mut self, task: NonNull<Task>)

yaay-mt-runtime/src/worker.rs:76

Functiondefer_bench

(bench: &mut Bencher)

yaay-tests/src/spawn_defer_bench.rs:26

Methodderef

(&self)

yaay-mt-runtime/src/task_list.rs:149

Methodderef

(&self)

yaay-mt-runtime/src/worker.rs:33

Methodderef_mut

(&mut self)

yaay-mt-runtime/src/task_list.rs:153

Functiondo_alloc

()

yaay-mio/src/helper.rs:27

Methoddrop

(&mut self)

yaay-mio/src/container.rs:40

Methoddrop

(&mut self)

yaay-mt-runtime/src/worker_manager.rs:151

Methoddrop

(&mut self)

yaay-mt-runtime/src/task_list.rs:159

Methoddrop

(&mut self)

yaay-mt-runtime/src/batch.rs:37

Methoddrop_in_place

(task: NonNull<Task>)

yaay-mt-runtime/src/task.rs:187

Methodepoch

(status: u32)

yaay-mt-runtime/src/epoch.rs:231

Functionfn_clone

(data: *const ())

yaay-mt-runtime/src/task_waker.rs:13

Functionfn_dealloc

(task: NonNull<Task>)

yaay-mt-runtime/src/task.rs:232

Functionfn_drop

(data: *const ())

yaay-mt-runtime/src/task_waker.rs:29

Functionfn_drop_in_place

(task: NonNull<Task>)

yaay-mt-runtime/src/task.rs:227

next →1–100 of 151, ranked by callers