Struct SchedulerRelocation 

pub struct SchedulerRelocation<'a, B: SchedulerStreamBackend> { /* private fields */ }

A scheduler’s streams, relocating one stream’s memory: every stream’s queued tasks run and are flushed first, since a queued task holds the addresses its buffers resolved to.

Trait Implementations

impl<B> RelocatingStreams for SchedulerRelocation<'_, B>

where B: SchedulerStreamBackend, B::Stream: RelocatableStream,

fn recording(&mut self) -> bool

Whether any stream is recording a graph.

fn has_outdated(&mut self) -> bool

Whether a growth left pages behind in the relocating stream’s memory: without any, a relocation has nothing to move and waits on nothing.

fn relocation_need(&mut self) -> RelocationNeed

Whether the relocating stream’s memory wants a relocation, before the bytes the device holds are known.

fn bytes_allocated(&mut self) -> u64

The bytes every stream’s memory holds from the device.

fn finish(&mut self)

Get every stream’s queued and submitted work done, or leave it to the CopyQueue to wait for before its first copy.

fn relocate_memory(&mut self, reason: RelocationReason)

Move what the relocating stream’s memory holds on outdated pages.

fn cleanup_memory(&mut self)

Give back every page the relocating stream’s memory holds and nothing needs.

fn device_has_outdated(&mut self) -> bool

Whether a growth left pages behind in any stream’s memory.

fn relocate_device_memory(&mut self, reason: RelocationReason)

Move what every stream’s memory holds on outdated pages.

fn refuse_while_recording(&mut self) -> Result<(), ServerError>

Refuse while any stream records a graph: the pages a recording touches keep their addresses until it seals, and nothing may wait on the device under it.

fn reclaim(&mut self) -> Result<(), ServerError>

Give back everything the relocating stream’s memory holds and nothing needs: what the outdated pages still hold moves first, while the current pages keep the room it moves into, then every page left empty goes back.

fn relocate_when_wanted(&mut self)

Relocate when the memory asks for it: while the device still has a page to spare, or before the pools run out of page sizes.

fn relocate(&mut self, reason: RelocationReason)

Relocate for reason, unless a graph records or nothing is outdated.

fn relocate_device(&mut self, reason: RelocationReason)

Relocate every stream’s memory for reason, unless a graph records or nothing is outdated anywhere.