| 654 | } |
| 655 | |
| 656 | static void |
| 657 | dsw_port_buffer_parallel(struct dsw_evdev *dsw, struct dsw_port *source_port, |
| 658 | struct rte_event event) |
| 659 | { |
| 660 | uint8_t dest_port_id; |
| 661 | |
| 662 | event.flow_id = dsw_port_get_parallel_flow_id(source_port); |
| 663 | |
| 664 | dest_port_id = dsw_schedule(dsw, event.queue_id, |
| 665 | dsw_flow_id_hash(event.flow_id)); |
| 666 | |
| 667 | dsw_port_buffer_non_paused(dsw, source_port, dest_port_id, &event); |
| 668 | } |
| 669 | |
| 670 | static void |
| 671 | dsw_port_buffer_event(struct dsw_evdev *dsw, struct dsw_port *source_port, |
no test coverage detected