Struct Worker 

pub struct Worker { /* private fields */ }

Worker context, containing ‘global’ information for the current thread.

Implementations

impl Worker

pub fn new_for_this_thread(worker_id: WorkerThreadID)

pub fn with_active_host<F, R>(f: F) -> Option<R>

where F: FnOnce(&Host) -> R,

Run f with a reference to the current Host, or return None if there is no current Host.

pub fn with_active_process_rc<F, R>(f: F) -> Option<R>

where F: FnOnce(&RootedRc<RootedRefCell<Process>>) -> R,

Run f with a reference to the current RootedRc<RootedRefCell<Process>>, or return None if there isn’t one.

Prefer to pass Process explicitly where feasible. e.g. see ProcessContext.

pub fn with_active_process<F, R>(f: F) -> Option<R>

where F: FnOnce(&Process) -> R,

Run f with a reference to the current Process, or return None if there isn’t one.

Prefer to pass Process explicitly where feasible. e.g. see ProcessContext.

pub fn with_active_thread<F, R>(f: F) -> Option<R>

where F: FnOnce(&Thread) -> R,

Run f with a reference to the current Thread, or return None if there isn’t one.

Prefer to pass Thread explicitly where feasible. e.g. see ThreadContext.

pub fn set_active_host(host: Box<Host>)

Set the currently-active Host.

pub fn take_active_host() -> Box<Host>

Clear the currently-active Host.

pub fn set_active_process(process: &RootedRc<RootedRefCell<Process>>)

Set the currently-active Process.

pub fn clear_active_process()

Clear the currently-active Process.

pub fn set_active_thread(thread: &RootedRc<RootedRefCell<Thread>>)

Set the currently-active Thread.

pub fn clear_active_thread()

Clear the currently-active Thread.

pub fn is_alive() -> bool

Whether currently running on a live Worker.

pub fn worker_id() -> Option<WorkerThreadID>

ID of this thread’s Worker, if any.

pub fn active_process_native_pid() -> Option<Pid>

pub fn active_process_id() -> Option<ProcessId>

pub fn active_thread_id() -> Option<ThreadId>

pub fn active_thread_native_tid() -> Option<Pid>

pub fn set_round_end_time(t: EmulatedTime)

pub fn max_event_runahead_time(host: &Host) -> EmulatedTime

Maximum time that the current event may run ahead to.

pub fn set_current_time(t: EmulatedTime)

pub fn clear_current_time()

pub fn current_time() -> Option<EmulatedTime>

pub fn update_lowest_used_latency(t: SimulationTime)

pub fn reset_next_event_time()

pub fn get_next_event_time() -> Option<EmulatedTime>

pub fn update_next_event_time(t: EmulatedTime)

pub fn send_packet(src_host: &Host, packetrc: PacketRc)

The packet will be dropped if the packet’s destination IP is not part of the simulation (no host has been configured for the IP).

pub fn increment_object_alloc_counter(s: &str)

pub fn increment_object_dealloc_counter(s: &str)

pub fn add_syscall_counts(syscall_counts: &Counter)

pub fn add_to_global_sim_stats()

pub fn is_routable(src: IpAddr, dst: IpAddr) -> bool

pub fn increment_plugin_error_count()

pub fn is_bootstrapping() -> bool

Shadow allows configuration of a “bootstrapping” interval, during which hosts’ network activity does not consume bandwidth. Returns true if we are still within this preliminary interval, or false otherwise.

pub fn resolve_name_to_ip(name: &CStr) -> Option<Ipv4Addr>