网络子系统 netpoll_rx处理

tc1989tc

Netpoll_rx的处理：
如果定义了#ifdef CONFIG_NETPOLL 则会在netif_rx中最先调用netpoll_rx处理skb。
在netif_rx中会调用__netpoll_rx(skb)继续处理，在__netpoll_rx(skb)中会给出处理的结果。
int __netpoll_rx(struct sk_buff *skb)
{
        int proto, len, ulen;
        struct iphdr *iph;
        struct udphdr *uh;
        struct netpoll_info *npi = skb->dev->npinfo;
        struct netpoll *np = npi->rx_np;

        if (!np)
                goto out;
        if (skb->dev->type != ARPHRD_ETHER)
                goto out;

        /* check if netpoll clients need ARP */
/*若果是ARP包并且trapped为1，则将skb加入到npi的ARP_tx队列中去，用于快速向对方回复arp rply，但是回复arp报文在哪里开始的暂时还没有找到对应的任务，trapped变量有什么用？*/
if (skb->protocol == htons(ETH_P_ARP) &&
            atomic_read(&trapped)) {
                skb_queue_tail(&npi->arp_tx, skb);
                return 1;
        }

        proto = ntohs(eth_hdr(skb)->h_proto);
        if (proto != ETH_P_IP)
                goto out;
        if (skb->pkt_type == PACKET_OTHERHOST)
                goto out;
        /*为什么多个用户使用该skb也要丢弃数据包*/
        if (skb_shared(skb))
                goto out;

        iph = (struct iphdr *)skb->data;
        if (!pskb_may_pull(skb, sizeof(struct iphdr)))
                goto out;
        if (iph->ihl < 5 || iph->version != 4)
                goto out;
        if (!pskb_may_pull(skb, iph->ihl*4))
                goto out;
        if (ip_fast_csum((u8 *)iph, iph->ihl) != 0)
                goto out;

        len = ntohs(iph->tot_len);
        if (skb->len < len || len < iph->ihl*4)
                goto out;

        /*
         * Our transport medium may have padded the buffer out.
         * Now We trim to the true length of the frame.
         */
        if (pskb_trim_rcsum(skb, len))
                goto out;

        if (iph->protocol != IPPROTO_UDP)
                goto out;

        len -= iph->ihl*4;
        uh = (struct udphdr *)(((char *)iph) + iph->ihl*4);
        ulen = ntohs(uh->len);

        if (ulen != len)
                goto out;
        if (checksum_udp(skb, uh, ulen, iph->saddr, iph->daddr))
                goto out;
        /*local ip 为eth0的ip,local_port 6665 remote_port为6666*/
        if (np->local_ip && np->local_ip != ntohl(iph->daddr))
                goto out;
        if (np->remote_ip && np->remote_ip != ntohl(iph->saddr))
                goto out;
        if (np->local_port && np->local_port != ntohs(uh->dest))
                goto out;
        /*该回调函数初始化是在哪里进行的？*/
        np->rx_hook(np, ntohs(uh->source),
                    (char *)(uh+1),
                    ulen - sizeof(struct udphdr));

        kfree_skb(skb);
        return 1;

out:
        if (atomic_read(&trapped)) {
                kfree_skb(skb);
                return 1;
        }

        return 0;
}
请指导 上文中红色部分标注的问题疑惑？？还有就是对该函数实现的功能不明白，查了哈说是作为网络串口使用

卖萌犯法

回复 1# tc1989tc

没看过这玩意，明天回公司看看代码，你这是2.6 的？

tc1989tc

回复 2# 卖萌犯法


    嗯。。

卖萌犯法

/*若果是ARP包并且trapped为1，则将skb加入到npi的ARP_tx队列中去，用于快速向对方回复arp rply，但是回复arp报文在哪里开始的暂时还没有找到对应的任务，trapped变量有什么用？*/

在netpoll 机制自身调用的 NAPI poll 中捕获ARP。

/*为什么多个用户使用该skb也要丢弃数据包*/

保证这个skb没被别人处理过，以为一会他还要ARP_REPLY呢。

/*该回调函数初始化是在哪里进行的？*/

内核代码中没有这个hook的实现，唯一使用netpoll 机制的netconsole 也只用它作为输出（系统日志的网络输出）。


最后，建议不要使用这个机制，从代码实现上来看，它有些不同寻常（它的优先级实在太高了）。

tc1989tc

回复 4# 卖萌犯法


    跟踪了哈回复arp的代码：
大概是通过调用write_msg-->netpoll_send_udp-->netpoll_send_skb-->netpoll_poll-->service_arp_queue来回复的。但是有点遗憾就是如果网络没有日志发送则不会调用write_msg函数，这样就无法回复arp请求，这样会导致网络不可用吧？

卖萌犯法

回复 5# tc1989tc

这样就无法回复arp请求，这样会导致网络不可用吧

不会，前面已经说了，这里拦截的ARP只是在 netpoll 自身调用的naip->poll 过程中，是个很短暂的过程，而且还退后处理了。

没有使用write_msg的时候，自然也就不会去拦截，而是走正常 netif_recieve_skb 的过程，所以不会有问题。

tc1989tc

回复 6# 卖萌犯法


    你好。我的意思是如果使用的netpoll 来实现网络日志的输出，那么是不是arp的回复只能是在调用write_msg的时候 才会去回复arp呢？？？

卖萌犯法

回复 7# tc1989tc

？？？没有调用write_msg的时候，通过 ARP 协议处理回复啊。

如果你根本不使用 netpoll 呢，系统就不会回复ARP了么？那平常他是怎么进行地址转换的？

tc1989tc

回复 8# 卖萌犯法


    没有用netpoll当然是经过注册的arp_process处理了。。
用了netpoll就是write_msg的时候处理了啊、、

卖萌犯法

回复 9# tc1989tc

我知道你为啥不理解了……
__netpoll_rx 是否被调用，跟 write_msg 是否被调用没有关系，它只取决于是否有人使用 netpoll。使用netpoll 的人， 未必使用 write_msg，这个人可能是只读的。

如果一个人使用了 netpoll 机制，但从不调用 write_msg 会怎样？ —— 答案是：ARP 全部被 arp_process 处理。

所以：

用了netpoll就是write_msg的时候处理了啊

这个理解是不正确的。