rte_eth_tx_burst 无法发送数据包

rte_eth_tx_burst can not send packet out

一个dpdk应用生成了几个arp请求包并调用rte_eth_tx_burst发送出去,有些包没有被对端网卡端口接收到(这可以通过wireshark抓包来确认)对等网卡),dpdk-proc-info 显示没有错误计数。 但在调用rte_eth_tx_burst之前让应用休眠10秒,它可以发送所有数据包。

示例代码:

main(){
  port_init();
  sleep(10);
  gen_pkt(mbuf);
  rte_eth_tx_burst(mbuf);
}

系统设置:Ubuntu20.04.2 LTS,dpdk-stable-20.11.3,I350千兆网络连接1521,igb_uio驱动

root@k8s-node:/home/dpdk-stable-20.11.3/build/app# ./dpdk-proc-info -- --xstats
EAL: No legacy callbacks, legacy socket not created
###### NIC extended statistics for port 0  #########
####################################################
rx_good_packets: 10
tx_good_packets: 32
rx_good_bytes: 1203
tx_good_bytes: 1920
rx_missed_errors: 0
rx_errors: 0
tx_errors: 0
rx_mbuf_allocation_errors: 0
rx_q0_packets: 0
rx_q0_bytes: 0
rx_q0_errors: 0
tx_q0_packets: 0
tx_q0_bytes: 0
rx_crc_errors: 0
rx_align_errors: 0
rx_symbol_errors: 0
rx_missed_packets: 0
tx_single_collision_packets: 0
tx_multiple_collision_packets: 0
tx_excessive_collision_packets: 0
tx_late_collisions: 0
tx_total_collisions: 0
tx_deferred_packets: 0
tx_no_carrier_sense_packets: 0
rx_carrier_ext_errors: 0
rx_length_errors: 0
rx_xon_packets: 0
tx_xon_packets: 0
rx_xoff_packets: 0
tx_xoff_packets: 0
rx_flow_control_unsupported_packets: 0
rx_size_64_packets: 4
rx_size_65_to_127_packets: 3
rx_size_128_to_255_packets: 3
rx_size_256_to_511_packets: 0
rx_size_512_to_1023_packets: 0
rx_size_1024_to_max_packets: 0
rx_broadcast_packets: 0
rx_multicast_packets: 10
rx_undersize_errors: 0
rx_fragment_errors: 0
rx_oversize_errors: 0
rx_jabber_errors: 0
rx_management_packets: 0
rx_management_dropped: 0
tx_management_packets: 0
rx_total_packets: 10
tx_total_packets: 32
rx_total_bytes: 1203
tx_total_bytes: 1920
tx_size_64_packets: 32
tx_size_65_to_127_packets: 0
tx_size_128_to_255_packets: 0
tx_size_256_to_511_packets: 0
tx_size_512_to_1023_packets: 0
tx_size_1023_to_max_packets: 0
tx_multicast_packets: 0
tx_broadcast_packets: 32
tx_tso_packets: 0
tx_tso_errors: 0
rx_sent_to_host_packets: 0
tx_sent_by_host_packets: 0
rx_code_violation_packets: 0
interrupt_assert_count: 0
####################################################

root@k8s-node:/home/dpdk-stable-20.11.3/build/app# ./dpdk-proc-info -- --stats
EAL: No legacy callbacks, legacy socket not created

  ######################## NIC statistics for port 0  ########################
  RX-packets: 5           RX-errors:  0           RX-bytes:  785       
  RX-nombuf:  0         
  TX-packets: 32          TX-errors:  0           TX-bytes:  1920      

  Stats reg  0 RX-packets: 0           RX-errors: 0           RX-bytes: 0         
  Stats reg  1 RX-packets: 0           RX-errors: 0           RX-bytes: 0         
  Stats reg  2 RX-packets: 0           RX-errors: 0           RX-bytes: 0         
  Stats reg  3 RX-packets: 0           RX-errors: 0           RX-bytes: 0         
  Stats reg  4 RX-packets: 0           RX-errors: 0           RX-bytes: 0         
  Stats reg  5 RX-packets: 0           RX-errors: 0           RX-bytes: 0         
  Stats reg  6 RX-packets: 0           RX-errors: 0           RX-bytes: 0         
  Stats reg  7 RX-packets: 0           RX-errors: 0           RX-bytes: 0         
  Stats reg  8 RX-packets: 0           RX-errors: 0           RX-bytes: 0         
  Stats reg  9 RX-packets: 0           RX-errors: 0           RX-bytes: 0         
  Stats reg 10 RX-packets: 0           RX-errors: 0           RX-bytes: 0         
  Stats reg 11 RX-packets: 0           RX-errors: 0           RX-bytes: 0         
  Stats reg 12 RX-packets: 0           RX-errors: 0           RX-bytes: 0         
  Stats reg 13 RX-packets: 0           RX-errors: 0           RX-bytes: 0         
  Stats reg 14 RX-packets: 0           RX-errors: 0           RX-bytes: 0         
  Stats reg 15 RX-packets: 0           RX-errors: 0           RX-bytes: 0         

  Stats reg  0 TX-packets: 0           TX-bytes: 0         
  Stats reg  1 TX-packets: 0           TX-bytes: 0         
  Stats reg  2 TX-packets: 0           TX-bytes: 0         
  Stats reg  3 TX-packets: 0           TX-bytes: 0         
  Stats reg  4 TX-packets: 0           TX-bytes: 0         
  Stats reg  5 TX-packets: 0           TX-bytes: 0         
  Stats reg  6 TX-packets: 0           TX-bytes: 0         
  Stats reg  7 TX-packets: 0           TX-bytes: 0         
  Stats reg  8 TX-packets: 0           TX-bytes: 0         
  Stats reg  9 TX-packets: 0           TX-bytes: 0         
  Stats reg 10 TX-packets: 0           TX-bytes: 0         
  Stats reg 11 TX-packets: 0           TX-bytes: 0         
  Stats reg 12 TX-packets: 0           TX-bytes: 0         
  Stats reg 13 TX-packets: 0           TX-bytes: 0         
  Stats reg 14 TX-packets: 0           TX-bytes: 0         
  Stats reg 15 TX-packets: 0           TX-bytes: 0         
  ############################################################################

更新:
感谢您的回复,我修改了代码:

main(){
  uint32_t port_mask = 0x1;
  port_init();
  check_all_ports_link_status(port_mask);
  gen_pkt(mbuf);
  rte_eth_tx_burst(mbuf);
}

得到打印日志:

Checking link status...............................
done
Port0 Link Up. Speed 1000 Mbps - full-duplex

我觉得网卡应该已经完全初始化了,但是对端网卡端口还是漏了很多包

直到物理 link 启动后才能发送数据包也就不足为奇了。这需要一些时间,可以使用 rte_eth_link_get() API 来自动等待。

在大多数工作情况下,为双工 (full/half)、速度 (1、10、25、40、50、100、200) 枚举物理网卡并协商 (auto/disable) 1 秒内。任何超过 2 或 3 秒的时间都表示连接的机器或交换机无法与双工、速度或 auto-negotiation 协商。因此推荐

  1. 如果接口是NIC,请更新驱动程序,两侧的固件
  2. 测试不同的连接电缆,因为 link-sense 可能无法正确连接
  3. 如果是集线器或交换机,请尝试固定速度和 auto-negotiation。
  4. 我不建议从全双工更改为半双工(因为它可能是电缆或 SFI 问题)。

作为暂时的临时解决方法,您可以使用 rte_eth_link_get,这也表明它可能需要 It might need to wait up to 9 seconds

注意:测试是否是电缆问题的简单方法是 运行 两端的 DPDK 以检查 link 启动所需的时间。

修改后的代码片段:

main(){
  port_init();
  
  RTE_ETH_FOREACH_DEV(portid) {
   struct rte_eth_link link;
   memset(&link, 0, sizeof(link));

   do {
        retval = rte_eth_link_get_nowait(port, &link);
        if (retval < 0) {
            printf("Failed link get (port %u): %s\n",
                port, rte_strerror(-retval));
            return retval;
        } else if (link.link_status)
            break;
        printf("Waiting for Link up on port %"PRIu16"\n", port);
        sleep(1);
    } while (!link.link_status);
  }

  gen_pkt(mbuf);
  rte_eth_tx_burst(mbuf);
}

main(){
  port_init();
  
  RTE_ETH_FOREACH_DEV(portid) {
   struct rte_eth_link link;
   memset(&link, 0, sizeof(link));
   ret = rte_eth_link_get(portid, &link);
   if (ret < 0) {
            printf("Port %u link get failed: err=%d\n", portid, ret);
            continue;
    }

  gen_pkt(mbuf);
  rte_eth_tx_burst(mbuf);
}