c - 如何正确使用 SO_RXQ_OVFL 检测 Linux 套接字上的 UDP 溢出？

Question

我想使用Linux套接字选项SO_RXQ_OVFL来检测UDP溢出。此选项使用辅助消息来报告丢弃的数据包数量。来自男人:

SO_RXQ_OVFL (since Linux 2.6.33)
Indicates that an unsigned 32-bit value ancillary message (cmsg) should be     
attached to received skbs indicating the number of packets dropped by the   
socket between the last received packet and this received packet.

我的代码没有找到辅助消息。这是我所做的:

启动时，我创建套接字并指定 SO_RXQ_OVFL 套接字选项:

int dropmonitor_on = 1;
if ( setsockopt(udpSocket, SOL_SOCKET, SO_RXQ_OVFL, &dropmonitor_on, sizeof(dropmonitor_on) ) != 0 )
{
    perror("setsockopt SO_RXQ_OVFL not supported by your Linux Kernel");
}

然后我有一个接收函数，它调用 recvmsg 并查找辅助消息:

struct sockaddr_in src_addr;  // The source address will be assigned to here

struct iovec iov[1];
iov[0].iov_base=ap_rxBuffer;
iov[0].iov_len=a_maxSizeBytes-1;

int cmsg_len = CMSG_SPACE(sizeof(uint32_t));
char cmsg[CMSG_SPACE(sizeof(uint32_t))];
memset(cmsg,0,cmsg_len);

struct msghdr message;
memset(&message,0,sizeof(struct msghdr));
message.msg_name=&src_addr;
message.msg_namelen=sizeof(struct sockaddr_in);
message.msg_iov=iov;
message.msg_iovlen=1;
message.msg_control=cmsg;
message.msg_controllen=cmsg_len;

int receivedBytes = 0;

if ( (receivedBytes = recvmsg( a_socket, &message, 0 )) == SOCKET_ERROR )
{
    closeSocket(a_socket);
    fatal("recvmsg() failed");
}
else 
{
    // Reception successful so interrogate ancillary message to get number of dropped packets

    int udp_packets_dropped = 0;

    struct cmsghdr* p_cmsg;
    p_cmsg = CMSG_FIRSTHDR(&message);
    for (p_cmsg = CMSG_FIRSTHDR(&message); p_cmsg != NULL; p_cmsg = CMSG_NXTHDR(&message, p_cmsg))
    {
        if ((p_cmsg->cmsg_level == SOL_SOCKET) && (p_cmsg->cmsg_type == SO_RXQ_OVFL))
        {
            int* p_udp_packets_dropped = (int *) CMSG_DATA(p_cmsg);
            udp_packets_dropped = *p_udp_packets_dropped;
            cout << "UDP pkts dropped: " << udp_packets_dropped << endl;
            break;
        }
    }
    if (p_cmsg == NULL)
    {
        fatal("Error: p_cmsg == NULL");
    }
}

当我运行代码时，它会因以下 fatal error 而停止:

Error: p_cmsg == NULL

由上述代码生成，表示未找到辅助消息。奇怪的是，有时我确实收到了一条辅助消息，所以也许我留下了一些未初始化的东西。

我仔细检查了代码，但没有发现任何问题。如果您能提供一些帮助，我将不胜感激。

Answer 1

我也有这个问题

经过一番挖掘，我在内核源代码中发现了一些提示: https://github.com/torvalds/linux/blob/master/net/socket.c

static inline void sock_recv_drops(struct msghdr *msg, struct sock *sk,
                   struct sk_buff *skb)
{
    if (sock_flag(sk, SOCK_RXQ_OVFL) && skb && SOCK_SKB_CB(skb)->dropcount)
        put_cmsg(msg, SOL_SOCKET, SO_RXQ_OVFL,
            sizeof(__u32), &SOCK_SKB_CB(skb)->dropcount);
}

看看“if (... && SOCK_SKB_CB(skb)->dropcount)”，我认为如果dropcount为0，那么cmsg应该为空。您的代码应该是正确的。