Chinaunix

标题: 网络子系统 netpoll_rx处理 [打印本页]

作者: tc1989tc    时间: 2013-07-11 21:20
标题: 网络子系统 netpoll_rx处理
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;
}
请指导 上文中红色部分标注的问题疑惑??还有就是对该函数实现的功能不明白,查了哈说是作为网络串口使用
作者: 卖萌犯法    时间: 2013-07-17 20:24
回复 1# tc1989tc

没看过这玩意,明天回公司看看代码,你这是2.6 的?
作者: tc1989tc    时间: 2013-07-17 21:14
回复 2# 卖萌犯法


    嗯。。
作者: 卖萌犯法    时间: 2013-07-20 19:33
/*若果是ARP包并且trapped为1,则将skb加入到npi的ARP_tx队列中去,用于快速向对方回复arp rply,但是回复arp报文在哪里开始的暂时还没有找到对应的任务,trapped变量有什么用?*/


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

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


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

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


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


最后,建议不要使用这个机制,从代码实现上来看,它有些不同寻常(它的优先级实在太高了)。
作者: tc1989tc    时间: 2013-07-20 20:37
回复 4# 卖萌犯法


    跟踪了哈回复arp的代码:
大概是通过调用write_msg-->netpoll_send_udp-->netpoll_send_skb-->netpoll_poll-->service_arp_queue来回复的。但是有点遗憾就是如果网络没有日志发送则不会调用write_msg函数,这样就无法回复arp请求,这样会导致网络不可用吧?
作者: 卖萌犯法    时间: 2013-07-20 23:43
回复 5# tc1989tc

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

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

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

作者: tc1989tc    时间: 2013-07-21 21:08
回复 6# 卖萌犯法


    你好。我的意思是如果使用的netpoll 来实现网络日志的输出,那么是不是arp的回复只能是在调用write_msg的时候 才会去回复arp呢???
作者: 卖萌犯法    时间: 2013-07-22 02:18
回复 7# tc1989tc

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

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

作者: tc1989tc    时间: 2013-07-22 18:02
回复 8# 卖萌犯法


    没有用netpoll当然是经过注册的arp_process处理了。。
用了netpoll就是write_msg的时候处理了啊、、
作者: 卖萌犯法    时间: 2013-07-23 08:48
本帖最后由 卖萌犯法 于 2013-07-23 08:49 编辑

回复 9# tc1989tc

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

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

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

这个理解是不正确的。


作者: tc1989tc    时间: 2013-07-23 13:10
回复 10# 卖萌犯法


    那段代码确实没有跟踪到。。。按照它的处理流程如果是arp就添加到struct netpoll_info 的arp_tx队列后,就返回1,导致netpoll_receive_skb函数调用也返回值1.还好使netif_receive_skb函数返回NET_RX_DROP;这样就会回到process_backlog函数循环处理其他的skb了。。。。就是没有跟踪到调用struct netpoll_info 的arp_tx队列的skb。。??
作者: 卖萌犯法    时间: 2013-07-26 19:40
回复 11# tc1989tc

这样就会回到process_backlog函数循环处理其他的skb了。。。。


NAPI机制下不会返回process_backlog,那是旧机制。

就是没有跟踪到调用struct netpoll_info 的arp_tx队列的skb。。??


这句话没看懂。你是说没跟踪到谁发送了他么? 在 netpoll_send_msg (大概意思,忘记具体名字了)的最后,有个 service_arp_xxx 什么的,记不住了,手头没代码。


作者: tc1989tc    时间: 2013-07-26 22:37
回复 12# 卖萌犯法


    哎  被你说晕了  我怎么的代码是如果arp被net_poll处理了 会返回到process_backlog函数呢
还有就是我前面不是说了吗 如果arp被net_poll处理是在这里被处理回复的
write_msg-->netpoll_send_udp-->netpoll_send_skb-->netpoll_poll-->service_arp_queue。你怎么说都是在arp_process处理的啊???
版主来解决哈这个疑问撒
作者: super皮波    时间: 2015-03-04 19:55
楼主能不能说说这里,我也看蒙了
作者: super皮波    时间: 2015-03-04 19:56
本帖最后由 super皮波 于 2015-03-04 19:56 编辑

回复 13# tc1989tc

我也没看懂,如果netpoll不发送udp的包的话,是否arp永远都不应答了?
   
作者: tc1989tc    时间: 2015-03-04 20:55
回复 15# super皮波


    我也不知道啊 当时没有跟踪了。。
很久没碰内核代码了




欢迎光临 Chinaunix (http://bbs.chinaunix.net/) Powered by Discuz! X3.2