关于调用__qdisc_run的疑问

chishanmingshen

from 3.6.10

1. 
   
2. static inline int __dev_xmit_skb(struct sk_buff *skb, struct Qdisc *q,
   
3.                                  struct net_device *dev,
   
4.                                  struct netdev_queue *txq)
   
5. {
   
6.         spinlock_t *root_lock = qdisc_lock(q);
   
7.         bool contended;
   
8.         int rc;
   
9. 
   
10.         qdisc_skb_cb(skb)->pkt_len = skb->len;
    
11.         qdisc_calculate_pkt_len(skb, q);
    
12.         /*
    
13.          * Heuristic to force contended enqueues to serialize on a
    
14.          * separate lock before trying to get qdisc main lock.
    
15.          * This permits __QDISC_STATE_RUNNING owner to get the lock more often
    
16.          * and dequeue packets faster.
    
17.          */
    
18.         contended = qdisc_is_running(q);
    
19.         if (unlikely(contended))
    
20.                 spin_lock(&q->busylock);
    
21. 
    
22.         spin_lock(root_lock);
    
23.         if (unlikely(test_bit(__QDISC_STATE_DEACTIVATED, &q->state))) {
    
24.                 kfree_skb(skb);
    
25.                 rc = NET_XMIT_DROP;
    
26.         } else if ((q->flags & TCQ_F_CAN_BYPASS) && !qdisc_qlen(q) &&
    
27.                    qdisc_run_begin(q)) {
    
28.                 /*
    
29.                  * This is a work-conserving queue; there are no old skbs
    
30.                  * waiting to be sent out; and the qdisc is not running -
    
31.                  * xmit the skb directly.
    
32.                  */
    
33.                 if (!(dev->priv_flags & IFF_XMIT_DST_RELEASE))
    
34.                         skb_dst_force(skb);
    
35. 
    
36.                 qdisc_bstats_update(q, skb);
    
37. 
    
38.                 if (sch_direct_xmit(skb, q, dev, txq, root_lock)) {
    
39.                         if (unlikely(contended)) {
    
40.                                 spin_unlock(&q->busylock);
    
41.                                 contended = false;
    
42.                         }
    
43.                         __qdisc_run(q);<-----------------------------------------第1处
    
44.                 } else
    
45.                         qdisc_run_end(q);
    
46. 
    
47.                 rc = NET_XMIT_SUCCESS;
    
48.         } else {
    
49.                 skb_dst_force(skb);
    
50.                 rc = q->enqueue(skb, q) & NET_XMIT_MASK;
    
51.                 if (qdisc_run_begin(q)) {
    
52.                         if (unlikely(contended)) {
    
53.                                 spin_unlock(&q->busylock);
    
54.                                 contended = false;
    
55.                         }
    
56.                         __qdisc_run(q);<----------------------------------------第2处
    
57.                 }
    
58.         }
    
59.         spin_unlock(root_lock);
    
60.         if (unlikely(contended))
    
61.                 spin_unlock(&q->busylock);
    
62.         return rc;
    
63. }
    

复制代码

对于__dev_xmit_skb()中调用__qdisc_run()的2种case不理解...
应该全都留在softirq中做__qdisc_run()啊, 怎么要在此处也做__qdisc_run()?

我的理解是__qdisc_run()是个qos的独立处理, 可能比较耗时.

请指点, 谢谢!

瀚海书香

qdisc_run里面进行了检查啊。如果其他的任务需要调度，会释放cpu并激活软中断进行处理，不会影响的。

chishanmingshen

你说的我明白.

其实我不明白发包是如何能实现控制速率的.

如果说发包时和软中断这2个地方都可以控制性地发包, 那么为何不仅仅在软中断发呢? 这样不是更不影响其它进程么?

回复 2# 瀚海书香


   

chishanmingshen

好吧, 好像也不是一个值得纠结的问题... 呵呵...

瀚海书香

回复 3# chishanmingshen

其实我不明白发包是如何能实现控制速率的.

速率的控制是在不同qdisc的dequeue函数中实现的。
   

chishanmingshen

对于qos的内部算法, 暂时我不关注.

对于为何两处有调用__qdisc_run(), 看来不是个值得深究的问题, 呵呵.
这个貌似仅仅是在不影响发包进程的前提下, 早于软中断地处理qos而已, 暂时我就这么理解了.

如果理解不对, 还请指点...
谢谢!

chishanmingshen

还有不同见解的么。。。

没有就要结贴了。。。

瀚海书香

回复 7# chishanmingshen
可以结贴了

   

polejo

回复 2# 瀚海书香

    我也有些疑惑啊。
你说的检查应该是 qdisc_run 中的 need_resched()   break

这样__dev_xmit_skb 在没有被软中断打断时，就会直接调用__qdisc_run()到tc队列中了。
也就是说发包可以由软中断做，也可以不通过软中断做。

是否意味着在发包速率较小的情况下，都是这样直接发送出去的，TX软中断都没有用武之地。

polejo

回复 9# polejo


    确实是这样啊！
发200k包出去时，观察 /proc/softirqs 的NET_TX 基本没有增长。
配了个tc规则，把速率限制到100k，模拟发包压力大的情况，这时候看到 softirq 才会猛增