Struct MultiNodeOopController 

pub struct MultiNodeOopController { /* private fields */ }

Out-of-process barrier controller. Bind it on the test driver, then point the children at local_addr() (e.g. via env var).

Implementations

impl MultiNodeOopController

pub async fn start(expected_nodes: usize) -> Result<Self, MultiNodeOopError>

Start the controller with the expected node count. Listens on 127.0.0.1:0 (kernel-assigned port). The accepted address can be read via local_addr().

pub fn local_addr(&self) -> SocketAddr

pub async fn timeout_barrier( &self, label: &str, timeout: Duration, ) -> Result<usize, MultiNodeOopError>

Time-bound a label: if the requested label has not been reached by timeout, every connected child waiter receives TIMEOUT label. Returns the count of arrivals when the timer fired.

pub fn shutdown(self)

Stop accepting new connections and drop the listener task. Pending child connections continue but new BARRIERs against a shut-down controller will fail.