Method try_recv_response

nodedb-bridge/src/async_bridge.rs:155–164

Try to receive a response from the Data Plane. On success, signals the producer wake eventfd so the TPC core knows there's space for more responses.

(&mut self)

    /// On success, signals the producer wake eventfd so the TPC core knows
    /// there's space for more responses.
    pub fn try_recv_response(&mut self) -> Result<Rsp> {
        let result = self.consumer.try_pop();

        if result.is_ok() {
            // Signal the Data Plane that response queue has space.
            let _ = self.rsp_wake.producer_wake.notify();
        }

        result
    }

    /// Drain up to `max` responses into the buffer.
    pub fn drain_responses(&mut self, buf: &mut Vec<Rsp>, max: usize) -> usize {