| 318 | } |
| 319 | |
| 320 | static void |
| 321 | dsw_port_drain_in_ring(uint8_t dev_id, struct dsw_port *port, |
| 322 | eventdev_stop_flush_t flush, void *flush_arg) |
| 323 | { |
| 324 | struct rte_event ev; |
| 325 | |
| 326 | while (rte_event_ring_dequeue_burst(port->in_ring, &ev, 1, NULL)) |
| 327 | flush(dev_id, ev, flush_arg); |
| 328 | } |
| 329 | |
| 330 | static void |
| 331 | dsw_drain(uint8_t dev_id, struct dsw_evdev *dsw, |
no test coverage detected