loom.rs - source

Files

test_cat

test_mem

test_process_signal

test-process-signal.rs

tests_build

tests_integration

tokio

doc

fs

canonicalize.rs copy.rs create_dir.rs create_dir_all.rs dir_builder.rs file.rs hard_link.rs metadata.rs mod.rs open_options.rs read.rs read_dir.rs read_link.rs read_to_string.rs remove_dir.rs remove_dir_all.rs remove_file.rs rename.rs set_permissions.rs symlink.rs symlink_dir.rs symlink_file.rs symlink_metadata.rs try_exists.rs write.rs

future

block_on.rs maybe_done.rs mod.rs poll_fn.rs trace.rs try_join.rs

io

bsd

util

async_buf_read_ext.rs async_read_ext.rs async_seek_ext.rs async_write_ext.rs buf_reader.rs buf_stream.rs buf_writer.rs chain.rs copy.rs copy_bidirectional.rs copy_buf.rs empty.rs fill_buf.rs flush.rs lines.rs mem.rs mod.rs read.rs read_buf.rs read_exact.rs read_int.rs read_line.rs read_to_end.rs read_to_string.rs read_until.rs repeat.rs shutdown.rs sink.rs split.rs take.rs vec_with_initialized.rs write.rs write_all.rs write_all_buf.rs write_buf.rs write_int.rs write_vectored.rs

async_buf_read.rs async_fd.rs async_read.rs async_seek.rs async_write.rs blocking.rs interest.rs join.rs mod.rs poll_evented.rs read_buf.rs ready.rs seek.rs split.rs stderr.rs stdin.rs stdio_common.rs stdout.rs

loom

std

atomic_u16.rs atomic_u32.rs atomic_u64.rs atomic_u64_native.rs atomic_usize.rs barrier.rs mod.rs mutex.rs parking_lot.rs unsafe_cell.rs

macros

addr_of.rs cfg.rs join.rs loom.rs mod.rs pin.rs ready.rs select.rs support.rs thread_local.rs trace.rs try_join.rs

net

tcp

listener.rs mod.rs socket.rs split.rs split_owned.rs stream.rs

unix

datagram

mod.rs socket.rs

listener.rs mod.rs pipe.rs socket.rs socketaddr.rs split.rs split_owned.rs stream.rs ucred.rs

windows

mod.rs named_pipe.rs

addr.rs lookup_host.rs mod.rs udp.rs

process

unix

mod.rs orphan.rs pidfd_reaper.rs reap.rs

runtime

blocking

mod.rs pool.rs schedule.rs shutdown.rs task.rs

context

blocking.rs current.rs runtime.rs runtime_mt.rs scoped.rs

io

driver

driver.rs metrics.rs mod.rs registration.rs registration_set.rs scheduled_io.rs

metrics

batch.rs histogram.rs io.rs mod.rs runtime.rs scheduler.rs worker.rs

scheduler

current_thread

inject

metrics.rs pop.rs rt_multi_thread.rs shared.rs synced.rs

multi_thread

handle

metrics.rs taskdump.rs

worker

metrics.rs taskdump.rs

counters.rs handle.rs idle.rs mod.rs overflow.rs park.rs queue.rs stats.rs trace.rs worker.rs

multi_thread_alt

handle

worker

metrics.rs taskdump_mock.rs

counters.rs handle.rs idle.rs mod.rs overflow.rs queue.rs stats.rs trace_mock.rs worker.rs

block_in_place.rs defer.rs inject.rs lock.rs mod.rs

signal

task

trace

mod.rs symbol.rs tree.rs

abort.rs core.rs error.rs harness.rs id.rs join.rs list.rs mod.rs raw.rs state.rs waker.rs

time

wheel

level.rs mod.rs

entry.rs handle.rs mod.rs source.rs

builder.rs config.rs context.rs coop.rs driver.rs dump.rs handle.rs id.rs mod.rs park.rs process.rs runtime.rs thread_id.rs

signal

windows

ctrl_c.rs mod.rs registry.rs reusable_box.rs unix.rs windows.rs

sync

mpsc

block.rs bounded.rs chan.rs error.rs list.rs mod.rs unbounded.rs

rwlock

owned_read_guard.rs owned_write_guard.rs owned_write_guard_mapped.rs read_guard.rs write_guard.rs write_guard_mapped.rs

task

atomic_waker.rs mod.rs

barrier.rs batch_semaphore.rs broadcast.rs mod.rs mutex.rs notify.rs once_cell.rs oneshot.rs rwlock.rs semaphore.rs watch.rs

task

blocking.rs builder.rs consume_budget.rs join_set.rs local.rs mod.rs spawn.rs task_local.rs unconstrained.rs yield_now.rs

time

clock.rs error.rs instant.rs interval.rs mod.rs sleep.rs timeout.rs

util

rand

rt.rs rt_unstable.rs

atomic_cell.rs bit.rs cacheline.rs error.rs idle_notified_set.rs linked_list.rs markers.rs memchr.rs mod.rs once_cell.rs rand.rs rc_cell.rs sharded_list.rs sync_wrapper.rs trace.rs try_lock.rs wake.rs wake_list.rs

blocking.rs lib.rs

tokio_macros

entry.rs lib.rs select.rs

tokio_stream

stream_ext

all.rs any.rs chain.rs chunks_timeout.rs collect.rs filter.rs filter_map.rs fold.rs fuse.rs map.rs map_while.rs merge.rs next.rs peekable.rs skip.rs skip_while.rs take.rs take_while.rs then.rs throttle.rs timeout.rs timeout_repeating.rs try_next.rs

wrappers

broadcast.rs interval.rs lines.rs mpsc_bounded.rs mpsc_unbounded.rs read_dir.rs signal_unix.rs signal_windows.rs split.rs tcp_listener.rs unix_listener.rs watch.rs

empty.rs iter.rs lib.rs macros.rs once.rs pending.rs poll_fn.rs stream_close.rs stream_ext.rs stream_map.rs wrappers.rs

tokio_test

io.rs lib.rs macros.rs stream_mock.rs task.rs

tokio_util

codec

any_delimiter_codec.rs bytes_codec.rs decoder.rs encoder.rs framed.rs framed_impl.rs framed_read.rs framed_write.rs length_delimited.rs lines_codec.rs mod.rs

io

copy_to_bytes.rs inspect.rs mod.rs read_buf.rs reader_stream.rs sink_writer.rs stream_reader.rs sync_bridge.rs

net

unix

sync

cancellation_token

guard.rs tree_node.rs

cancellation_token.rs mod.rs mpsc.rs poll_semaphore.rs reusable_box.rs

task

join_map.rs mod.rs spawn_pinned.rs task_tracker.rs

time

wheel

level.rs mod.rs stack.rs

delay_queue.rs mod.rs

udp

frame.rs mod.rs

util

maybe_dangling.rs mod.rs poll_buf.rs

cfg.rs compat.rs context.rs either.rs lib.rs loom.rs tracing.rs

macro_rules! if_loom {
    ($($t:tt)*) => {{
        #[cfg(loom)]
        {
            $($t)*
        }
    }}
}