Method poll_and_route_responses

nodedb/src/control/state/methods.rs:331–346

Poll responses from all Data Plane cores and route them to waiting sessions. Returns the number of responses routed — callers use this for adaptive backoff (zero ⇒ idle, sleep longer; non-zero ⇒ active, stay hot).

(&self)

    /// Returns the number of responses routed — callers use this for adaptive
    /// backoff (zero ⇒ idle, sleep longer; non-zero ⇒ active, stay hot).
    pub fn poll_and_route_responses(&self) -> usize {
        let responses = match self.dispatcher.lock() {
            Ok(mut d) => d.poll_responses(),
            Err(poisoned) => {
                warn!("dispatcher mutex poisoned, recovering");
                poisoned.into_inner().poll_responses()
            }
        };
        let count = responses.len();
        for resp in responses {
            if !self.tracker.complete(resp) {
                warn!("response for unknown or cancelled request");
            }
        }
        count
    }
}