()
| 341 | |
| 342 | #[test] |
| 343 | fn eventfd_wake_on_push() { |
| 344 | let bridge: BridgeChannel<u64, u64> = BridgeChannel::new(16, 16).unwrap(); |
| 345 | let mut control = bridge.control; |
| 346 | let data = bridge.data; |
| 347 | |
| 348 | control.try_send_request(1).unwrap(); |
| 349 | |
| 350 | // Consumer wake fd should be signaled. |
| 351 | let count = data.req_wake.consumer_wake.try_read().unwrap(); |
| 352 | assert!(count > 0); |
| 353 | } |
| 354 | |
| 355 | #[test] |
| 356 | fn drain_responses_signals_producer() { |
nothing calls this directly
no test coverage detected