2

我正在使用 packet_mmap 来读取 UDP 数据包的快速流。当使用以下任一代码段等待传入帧时，它可以正常工作：

// ring[i].iov_base points to the start address of the ith frame
struct tpacket_hdr *header = (struct tpacket_hdr *) ring[i].iov_base;

// Using poll on socket to wait for data
while(!(header -> tp_status & TP_STATUS_USER))
    {
        struct pollfd pfd;
        pfd.fd      = _socket;
        pfd.events  = POLLIN | POLLERR;
        pfd.revents = 0;
        poll(&pfd, 1, -1);
    }

// Using nanosleep to wait for incoming data
while(!(header -> tp_status & TP_STATUS_USER))
    {
        struct timespec t, r;
        t.tv_nsec = 1;
        t.tv_sec = 0; 
        nanosleep(&t, &r)
    }

但是，当我尝试忙等待时（while(!(header -> tp_status & TP_STATUS_USER)) ;在读取了几个数据包后，该语句无限期地保持为真。为什么会这样？内核是否只在发出系统调用时将帧传输到环形缓冲区？输入套接字被初始化为：socket(PF_PACKET, SOCK_DGRAM, htons(ETH_P_IP)).

此外，当使用此代码（使用 poll 或 nanosleep）时，它似乎正在丢弃数据包，而使用 UDP 套接字的简单接收代码则不会，从而使 packet_mmap 实现更慢。有时，套接字会检测到丢弃的数据包，但是当使用以下PACKET_STATISTICS选项时getsockopt：

    if (header -> tp_status & TP_STATUS_LOSING)
    {
        struct tpacket_stats stats;
        socklen_t size_sock = sizeof(tpacket_stats);
        if (getsockopt(_socket, SOL_PACKET, PACKET_STATISTICS, &stats, &size_sock) > -1)
            printf("Dropped packets: [%d, %d]\n", stats.tp_drops, stats.tp_packets);
    }

它声明没有丢弃任何数据包（输出示例：“丢弃的数据包：[0, 5]”）。在套接字上的行为是否PACKET_STATISTICS不同？PACKET_RX_RING

此代码的完整代码列表可在此处获得

4

1 回答 1

3

万一有人遇到这个问题，忙等待是“挂起”，因为tpacket_hdr正在优化并进入寄存器，并且它的值没有在内存中检查。将其标记为volatile可确保内核对此结构所做的任何更改都可以被应用程序看到。

检测到的丢包PACKET_STATISTICS是针对正在接收的前几个数据包，其余是由于系统调用引起的额外开销，应用程序没有跟上传入的数据包。

于 2013-05-07T09:08:56.007 回答