| 335 | } |
| 336 | |
| 337 | void |
| 338 | add_tx_md_callback(portid_t portid) |
| 339 | { |
| 340 | struct rte_eth_dev_info dev_info; |
| 341 | uint16_t queue; |
| 342 | int ret; |
| 343 | |
| 344 | if (port_id_is_invalid(portid, ENABLED_WARN)) |
| 345 | return; |
| 346 | |
| 347 | ret = eth_dev_info_get_print_err(portid, &dev_info); |
| 348 | if (ret != 0) |
| 349 | return; |
| 350 | |
| 351 | for (queue = 0; queue < dev_info.nb_tx_queues; queue++) |
| 352 | if (!ports[portid].tx_set_md_cb[queue]) |
| 353 | ports[portid].tx_set_md_cb[queue] = |
| 354 | rte_eth_add_tx_callback(portid, queue, |
| 355 | tx_pkt_set_md, NULL); |
| 356 | } |
| 357 | |
| 358 | void |
| 359 | remove_tx_md_callback(portid_t portid) |
no test coverage detected