使用 DPDK-basicfwd 示例如何将自定义数据包发送到所需端口
using DPDK-basicfwd example how to send custom packet to desired port
要求:我想使用 DPDK basicfwd,将自定义回复发送回传入端口。
解释:
DPDK 端口:Port-0 和 Port-1
示例代码:编辑 DPDK basicfwd。
自定义函数: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]->端口 : (mbufs[idx]->端口 ^ 1)
用rte_eth_tx_burst
和dest_port
发送数据包
注释掉下面的 tx_burst 通用调用。
选项2
:
创建2个mbuf数组即mbufs_inport和mbufs_outport.
迭代数据包,以调用 PacketHandler()。匹配的数据包转到 mbufs_inport
,不匹配的数据包转到 mbufs_outport
为 mbufs_inport
和 mbufs_outprt
调用 rte_eth_tx_burst
。
选项3
:
注册 rx-callback 以使用 packethandler
.
过滤数据包
现在您可以选择根据mbuf->portid
直接发回所选内容。而不匹配的数据包在主循环中继续。
如果担心 packet order
或 previous packets needs to be processed
,请使用 mbuf-udata64
作为退出端口的占位符。对于不匹配的情况,设置为 -1
。然后在主循环中,您已将 tx_burst 转换为 n
数据包以针对每个数据包进行迭代,因为您必须检查 udata64
值。
要求:我想使用 DPDK basicfwd,将自定义回复发送回传入端口。
解释:
DPDK 端口:Port-0 和 Port-1
示例代码:编辑 DPDK basicfwd。
自定义函数: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]->端口 : (mbufs[idx]->端口 ^ 1)
用
rte_eth_tx_burst
和dest_port
发送数据包
注释掉下面的 tx_burst 通用调用。
选项2
:
创建2个mbuf数组即mbufs_inport和mbufs_outport.
迭代数据包,以调用 PacketHandler()。匹配的数据包转到
mbufs_inport
,不匹配的数据包转到mbufs_outport
为
mbufs_inport
和mbufs_outprt
调用rte_eth_tx_burst
。
选项3
:
注册 rx-callback 以使用
packethandler
. 过滤数据包
现在您可以选择根据
mbuf->portid
直接发回所选内容。而不匹配的数据包在主循环中继续。如果担心
packet order
或previous packets needs to be processed
,请使用mbuf-udata64
作为退出端口的占位符。对于不匹配的情况,设置为-1
。然后在主循环中,您已将 tx_burst 转换为n
数据包以针对每个数据包进行迭代,因为您必须检查udata64
值。