网络子系统 netpoll_rx处理

tc1989tc 发表于 2013-07-11 21:20

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的时候处理了啊
这个理解是不正确的。

页: [1] 2

Chinaunix's Archiver

网络子系统 netpoll_rx处理