如何解决我需要代码片段将带有有效负载的以太网标头从辅助 DPDK 应用程序嵌入到主要
架构如下：
辅助 DPDK 应用程序 ------> 主要 DPDK 应用程序 ----> (EDIT)Interface
在我的 Secondary 中，我有一个 u8 字节向量表示 L2 数据包。 我想将此 L2 数据包发送到主应用程序，以便主应用程序可以将其发送到互联网。 据我了解，L2 数据包必须包裹在 mbuf 中才能放在共享环上。 但我不知道如何进行这种包装。
我不太清楚：我的数据包只是一个字节向量，我如何从中提取有用的信息以填充 mbuf 字段？应该最少填充 mbuf 的哪些字段才能使其正常工作？
为了更好地理解，下面是应该逐步发生的事情：
- 字节向量进入二级（无关紧要）
- Secondary 从共享内存池中获取 mbuf。
- Secondary 将向量放入 mbuf（向量是一个 L2 数据包）
- mbuf 有很多字段代表很多东西，所以我不知道要填充哪个字段以及用什么来填充。
- Secondary 将 mbuf 放在共享环上。
- Primary 从共享环中获取 mbuf。
- 主要将 mbuf 发送到互联网。
这是我目前编写的代码，辅助应用程序使用 Rust，主要应用程序使用 C 语言。
中学在这里 (github)：
记住，L2 Packet 就是 Vec，就像 [1,222,23,34...]，一个简单的数组。
// GETTING THE MBUF FROM SHARED MEMPOOL
let mut my_buffer = self.do_rte_mempool_get();
while let Err(er) = my_buffer {
warn!("rte_mempool_get failed,trying again.");
my_buffer = self.do_rte_mempool_get();
// it may fail if not enough entries are available.
}
warn!("rte_mempool_get success");
// Let's just send an empty packet for starters.
let my_buffer = my_buffer.unwrap();
// HERE I SHOULD PUT THE L2 PACKET INSIDE THE MBUF.
// MY L2 PACKET is a Vec<u8>
// NOW I PUT THE MBUF ON THE SHARED RING,BYE MBUF
let mut res = self.do_rte_ring_enqueue(my_buffer);
// it may fail if not enough room in the ring to enqueue
while let Err(er) = res {
warn!("rte_ring_enqueue failed,trying again.");
res = self.do_rte_ring_enqueue(my_buffer);
}
warn!("rte_ring_enqueue success");
Primary 就在这里（它只是从 ring 中获取 mbuf 并且必须使用 rte_eth_tx_burst() 发送它们）：
/* Run until the application is quit or killed. */
for (;;)
{
// receive packets on rte ring
// then send them to NIC
struct rte_mbuf *bufs[BURST_SIZE];
void *mbuf;
if (rte_ring_dequeue(recv_ring,&mbuf) < 0) {
continue;
}
printf("Received mbuf.\n");
//for now I just want to test it out so I stop here
continue;
//* Send packet to port */
bufs[0] = mbuf;
uint16_t nbPackets = 1;
const uint16_t nb_tx = rte_eth_tx_burst(port,bufs,nbPackets);
// /* Free any unsent packets. */
if (unlikely(nb_tx < nbPackets))
{
rte_pktmbuf_free(bufs[nbPackets]);
}
如果您有任何问题，请告诉我！ 一如既往，感谢阅读！
更新： dpdk 主服务器实际上并未连接到互联网。它只是使用虚拟机的接口。 DPDK 次要和主要都在虚拟机内运行，主要使用的接口通过桥接器连接到主机接口。所以我可以使用 tcpdump 在主机上观看有问题的网桥。
我尝试将 L2 数据包放入二级 mbuf 中，它看起来像这样：
（你也可以勾选github）
// After receiving something on the channel
// I want to send it to the primary DPDK
// And the primary will send it to hardware NIC
let mut my_buffer = self.do_rte_mempool_get();
while let Err(er) = my_buffer {
warn!("rte_mempool_get failed,trying again.");
my_buffer = self.do_rte_mempool_get();
// it may fail if not enough entries are available.
}
warn!("rte_mempool_get success");
// Let's just send an empty packet for starters.
let my_buffer = my_buffer.unwrap();
let my_buffer_struct: *mut rte_mbuf = my_buffer as (*mut rte_mbuf);
unsafe {
// the packet buffer,not the mbuf
let buf_addr: *mut c_void = (*my_buffer_struct).buf_addr;
let mut real_buf_addr = buf_addr.offset((*my_buffer_struct).data_off as isize);
//try to copy the Vec<u8> inside the mbuf
copy(my_data.as_mut_ptr(),real_buf_addr as *mut u8,my_data.len());
(*my_buffer_struct).data_len = my_data.len() as u16;
};
（my_data 是上面代码片段中的 Vec）
现在，在主 DPDK 上，我正在接收那些作为 L2 数据包字节的字节。我打印了它们，它们与中学相同，这很棒。
for (;;)
{
// receive packets on rte ring
// then send them to NIC
struct rte_mbuf *bufs[BURST_SIZE];
void *mbuf;
unsigned char* my_packet;
uint16_t data_len;
uint16_t i = 0;
if (rte_ring_dequeue(recv_ring,&mbuf) < 0) {
continue;
}
printf("Received mbuf.\n");
my_packet = ((unsigned char *)(*(struct rte_mbuf *)mbuf).buf_addr) + ((struct rte_mbuf *)mbuf)->data_off;
data_len = ((struct rte_mbuf *)mbuf)->data_len;
for (i = 0; i < data_len; i++) {
printf("%d ",(uint8_t)my_packet[i]);
}
printf("\n");
//for now I just want to test it out so I stop here
// rte_pktmbuf_free(mbuf);
// continue;
//* Send packet to port */
bufs[0] = (struct rte_mbuf *)mbuf;
uint16_t nbPackets = 1;
const uint16_t nb_tx = rte_eth_tx_burst(port,nbPackets);
// /* Free any unsent packets. */
if (unlikely(nb_tx < nbPackets))
{
rte_pktmbuf_free(bufs[nbPackets]);
}
但问题是，在使用 eth_tx_burst 从主服务器发送 mbuf 后，我在主机上使用 tcpdump 时看不到任何数据包。 所以我猜我没有正确地将数据包包裹在 mbuf 中。 我希望它更有意义。
解决方法
@Mihai，如果需要在二级创建一个 DPDK 缓冲区并通过 RTE_RING 发送，以下是这样做的步骤
- 启动辅助应用程序
- 通过
rte_mempool_lookup获取 Mbuf 池 ptr - 通过
rte_pktmbuf_alloc分配 mbuf 池中的 mbuf - 将 mbuf 中的最小字段（例如
pkt_len,data_len,next and nb_segs）设置为适当的值。 - 使用
rte_pktmbuf_mtod_offset or rte_pktmbuf_mtod获取区域的开始以内存复制您的自定义数据包 - 然后将用户向量中的内容memcopy到DPDK区域
注意：根据checksum offload，实际frame len和chain mbuf mode其他字段需要更新。
代码片段
mbuf_ptr = rte_pktmbuf_alloc(mbuf_pool);
mbuf_ptr->data_len = [size of vector preferably under 1500];
mbuf_ptr->pkt_len = mbuf_ptr->data_len;
struct rte_ether_hdr *eth_hdr = rte_pktmbuf_mtod(created_pkt,struct rte_ether_hdr *);
rte_memcpy(ð_addr,&user_buffer,mbuf_ptr->data_len);
注意：类似于上面的代码已在 Rust + C 线卫中实现以启用 DPDK。
请把上面的代码改写成你的代码
warn!("rte_mempool_get success");
// Let's just send an empty packet for starters.
let my_buffer = my_buffer.unwrap();
let my_buffer_struct: *mut rte_mbuf = my_buffer as (*mut rte_mbuf);
unsafe {
// the packet buffer,not the mbuf
let buf_addr: *mut c_void = (*my_buffer_struct).buf_addr;
let mut real_buf_addr = buf_addr.offset((*my_buffer_struct).data_off as isize);
//try to copy the Vec<u8> inside the mbuf
copy(my_data.as_mut_ptr(),real_buf_addr as *mut u8,my_data.len());
(*my_buffer_struct).data_len = my_data.len() as u16;
};
unsafe {
warn!("Length of segment buffer: {}",(*my_buffer_struct).buf_len);
warn!("Data offset: {}",(*my_buffer_struct).data_off);
let buf_addr: *mut c_void = (*my_buffer_struct).buf_addr;
let real_buf_addr = buf_addr.offset((*my_buffer_struct).data_off as isize);
warn!("Address of buf_addr: {:?}",buf_addr);
warn!("Address of buf_addr + data_off: {:?}",real_buf_addr);
warn!("\n");
};
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。