要求:我想利用DPDK basicfwd,将自定义回复发回传入端口。
解释:
DPDK 端口:端口 0 和端口 1 示例代码:编辑 DPDK 基本代码。 自定义功能:PacketHandler()
要求:有时我需要将自定义数据包(一种 RST 数据包)发送到传入端口。
示例:Port-0 -> RX burst -> PacketHandler() -> normal packets fwd to Port-1, special packets send back to Port-0
代码片段:
while (isRun) {
num_rx = rte_eth_rx_burst(port_id, queue_id, mbufs, BURST_SIZE);
if (num_rx == 0) {
continue;
}
num_tx = 0;
for (int idx = 0; idx < num_rx; idx++) {
struct pcap_pkthdr pktHdr;
gettimeofday(&pktHdr.ts, NULL);
pktHdr.caplen = rte_pktmbuf_pkt_len(mbufs[idx]);
pktHdr.len = rte_pktmbuf_pkt_len(mbufs[idx]);
if (PacketHandler(&pktHdr, rte_pktmbuf_mtod(mbufs[idx], unsigned char *)) > 1) {
printf("Blocked Packets, do not fwd");
//TODO: send custom packet to incoming way
rte_pktmbuf_free(mbufs[idx]);
continue;
}
txbufs[num_tx++] = mbufs[idx];
}
if (num_tx > 0) {
sent = rte_eth_tx_burst(port_id ^ 1, queue_id, txbufs, num_tx);
for (int idx = sent; idx < num_tx; idx++) {
rte_pktmbuf_free(txbufs[idx]);
}
}
}
我的自定义数据包类型是u_char。如何将我的数据包发送到传入方式?
谢谢
选项1
: 简单的方法(但会影响性能)
-
通过
rte_eth_rx_burst
获取数据包
迭代数据包,以更新dest_port = PacketHandler() ? mbufs[idx]->port : (mbufs[idx]->port ^ 1)
使用
dest_port
发送带有rte_eth_tx_burst
的数据包注释掉下面的tx_burst通用调用。
选项2
:
-
创建 2 个 mbof 阵列,即 mbufs_inport 和 mbufs_outport。
-
迭代数据包,以调用 PacketHandler()。匹配的数据包转到
mbufs_inport
,不匹配的数据包转到mbufs_outport
-
为
mbufs_inport
和mbufs_outprt
调用rte_eth_tx_burst
。
选项3
:
-
注册 rx 回调以使用
packethandler
过滤数据包。 -
现在,您可以选择根据
mbuf->portid
直接发回选定的邮件。而不匹配的数据包继续在主环路中。 -
如果担心
packet order
或previous packets needs to be processed
,请使用mbuf-udata64
作为出口端口的占位符。对于不匹配的情况,集合为-1
。然后在主循环中,您有n
数据包的转换tx_burst,以迭代每个数据包,因为您必须检查udata64
值。