Try to receive a request from the Control Plane.
(&mut self)
| 204 | |
| 205 | /// Try to receive a request from the Control Plane. |
| 206 | pub fn try_recv_request(&mut self) -> Result<Req> { |
| 207 | let result = self.consumer.try_pop(); |
| 208 | if result.is_ok() { |
| 209 | let _ = self.req_wake.producer_wake.notify(); |
| 210 | } |
| 211 | result |
| 212 | } |
| 213 | |
| 214 | /// Drain up to `max` requests into the buffer. |
| 215 | pub fn drain_requests(&mut self, buf: &mut Vec<Req>, max: usize) -> usize { |