dpdk代码，利用rte相关函数和结构，将接收到的数据发送到另外一个线程去处理数据，用c实现 -DPDK中文网

定义全局变量和结构体：

#define MAX_PACKET_LEN 1500

typedef struct {
    uint8_t *data;      // 接收到的数据
    uint32_t len;       // 数据长度
} Packet;

static rte_ring *packet_queue;   // 存储Packet结构体的队列
static pthread_t thread_id;      // 处理数据的线程ID

初始化队列和启动处理数据的线程：

void init_packet_queue() {
    packet_queue = rte_ring_create("packet_queue", 1024, SOCKET_ID_ANY, RING_F_SP_ENQ | RING_F_SC_DEQ);
}

int start_process_thread() {
    int ret = pthread_create(&thread_id, NULL, process_thread_func, NULL);
    if (ret != 0) {
        printf("Failed to create process thread: %s\n", strerror(ret));
        return -1;
    }

    return 0;
}

在接收数据的回调函数中，将接收到的数据存储到Packet结构体中，并将Packet结构体发送到队列中：

static int packet_receive_callback(uint16_t portid, uint16_t queueid,
                                    struct rte_mbuf *pkt_buf,
                                    __attribute__((unused)) struct rte_eth_rxmode *mode,
                                    __attribute__((unused)) void *param) {

    Packet packet;

    packet.data = rte_pktmbuf_mtod(pkt_buf, uint8_t *);
    packet.len = pkt_buf->pkt_len;

    // 发送Packet结构体到队列中
    if (rte_ring_enqueue(packet_queue, &packet) < 0) {
        printf("Failed to enqueue packet\n");
        rte_pktmbuf_free(pkt_buf);
        return -1;
    }

    rte_pktmbuf_free(pkt_buf);

    return 0;
}

在处理数据的线程中，从队列中获取Packet结构体，并调用处理数据的函数：

void *process_thread_func(void *arg) {
    while (1) {
        Packet packet;

        // 从队列中获取Packet结构体
        if (rte_ring_dequeue(packet_queue, &packet) < 0) {
            continue;
        }

        process_packet(packet);     // 处理Packet结构体中的数据

        free(packet.data);          // 释放内存
    }

    return NULL;
}

void process_packet(Packet packet) {
    // 处理接收到的数据
}