Try to send a response back to the Control Plane.
(&mut self, rsp: Rsp)
| 222 | |
| 223 | /// Try to send a response back to the Control Plane. |
| 224 | pub fn try_send_response(&mut self, rsp: Rsp) -> Result<()> { |
| 225 | let result = self.producer.try_push(rsp); |
| 226 | if result.is_ok() { |
| 227 | let _ = self.rsp_wake.consumer_wake.notify(); |
| 228 | } |
| 229 | result |
| 230 | } |
| 231 | |
| 232 | /// Current backpressure state (read by Data Plane to decide I/O depth). |
| 233 | pub fn pressure(&self) -> PressureState { |