Struct Window 

pub struct Window<'c, 'a, D: GraphDriver> { /* private fields */ }

A capture window on one stream: warming up before it opens, opening it, and instantiating what it recorded.

The three steps are ordered and the stream refuses them out of order (see StreamCapture); this type is where each one’s shared half lives.

Implementations

impl<'c, 'a, D: GraphDriver> Window<'c, 'a, D>

pub fn on(command: &'c mut Command<'a, D>) -> Self

The capture window on the stream command is issued on.

pub fn prepare(&mut self, stream_id: StreamId) -> Result<(), ServerError>

Start the warmup run, before the window opens.

The outdated pools of every stream are emptied first: the recording may touch memory any stream owns, every page it touches is guarded for the graph’s life, and a guarded page can no longer be relocated off.

Errors

The stream’s refusal, when it is not in a state a window can open from.

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

Open the window: from here the driver records every launch issued on this stream until the window closes.

Errors

The driver’s refusal to begin recording, with the stream left as it was found — capture state back to none — so the whole prepare-then-open sequence can be retried.

pub fn instantiate( &mut self, stream_id: StreamId, id: GraphId, ) -> Result<Graph<D>, Refused>

Close the window and instantiate what it recorded into a graph registered under id.

The window leaves capture mode first, so none of the paths below can wedge the stream in it — they re-enable the deferred fenced flushes on the way out. A window the caller does not own is closed and torn down all the same, since nobody else is coming back to close it; only its owner gets a graph out of it.

Errors

Refused, which every failure here becomes — the driver’s refusal to close or instantiate, a recording an unreadable input left incomplete, an allocation inside the window, or no window at all. It carries the memory the caller now has to claim, empty when there was nothing to close.