skb中的priority怎么用的？

九陽(yáng)神功愛(ài)喝茶

請(qǐng)教各位前輩，這是我剛才看到的ip包的tos字段與skb的priority之間的關(guān)系，我的問(wèn)題是系統(tǒng)后面是怎么用這個(gè)字段完成什么功能的，具體代碼在哪兒。如蒙回復(fù)不甚感激。

nswcfd

tx路徑上qdisc根據(jù)skb優(yōu)先級(jí)enque/deque的時(shí)候使用。
最簡(jiǎn)單的可以參考net/sched/sch_prio.c的實(shí)現(xiàn)。

九陽(yáng)神功愛(ài)喝茶

非常感謝您的回復(fù)，我這就來(lái)看看，不甚感激啊回復(fù) 2# nswcfd


   

九陽(yáng)神功愛(ài)喝茶

各位兄弟姐妹，經(jīng)過(guò)上面的兄弟的提醒，我找到了PFIFO_FAST流控算法，目前是默認(rèn)的流控算法，用到了skb->priority字段，給大家一個(gè)參考，共同進(jìn)步。感謝Chinaunix

1. 5. 流控算法的具體實(shí)現(xiàn)
   
2. 
   
3. 5.1 PFIFO_FAST
   
4. 
   
5. PFIFO_FAST是缺省的流控算法，網(wǎng)卡初始化時(shí)就是設(shè)置該算法為網(wǎng)卡的流控算法，算法比較簡(jiǎn)單，就
   
6. 在net/sched/sch_generic.c中定義了，沒(méi)在單獨(dú)文件中定義。
   
7. 
   
8. 5.1.1 操作結(jié)構(gòu)定義
   
9. #define PFIFO_FAST_BANDS 3
   
10. static struct Qdisc_ops pfifo_fast_ops = {
    
11. .id  = "pfifo_fast",
    
12. // 私有數(shù)據(jù)是3個(gè)skb數(shù)據(jù)包鏈表頭
    
13. .priv_size = PFIFO_FAST_BANDS * sizeof(struct sk_buff_head),
    
14. .enqueue = pfifo_fast_enqueue,
    
15. .dequeue = pfifo_fast_dequeue,
    
16. .requeue = pfifo_fast_requeue,
    
17. .init  = pfifo_fast_init,
    
18. .reset  = pfifo_fast_reset,
    
19. .dump  = pfifo_fast_dump,
    
20. .owner  = THIS_MODULE,
    
21. };
    
22. 
    
23. 該算法中, 數(shù)據(jù)隊(duì)列是3個(gè), 流控算法就是將數(shù)據(jù)包輸入特定的隊(duì)列, 從特定隊(duì)列中取數(shù)據(jù)包。
    
24. 
    
25. 5.1.2 初始化
    
26. 
    
27. static int pfifo_fast_init(struct Qdisc *qdisc, struct rtattr *opt)
    
28. {
    
29. int prio;
    
30. // qdisc私有數(shù)據(jù)指針, 數(shù)據(jù)包鏈表頭
    
31. struct sk_buff_head *list = qdisc_priv(qdisc);
    
32. // 初始化3個(gè)鏈表頭
    
33. for (prio = 0; prio < PFIFO_FAST_BANDS; prio++)
    
34.   skb_queue_head_init(list + prio);
    
35. return 0;
    
36. }
    
37. 5.1.3 入隊(duì)
    
38. 
    
39. static int pfifo_fast_enqueue(struct sk_buff *skb, struct Qdisc* qdisc)
    
40. {
    
41. // 根據(jù)數(shù)據(jù)包的優(yōu)先級(jí)參數(shù)挑一個(gè)隊(duì)列頭準(zhǔn)備將數(shù)據(jù)包插入該隊(duì)列
    
42. struct sk_buff_head *list = prio2list(skb, qdisc);
    
43. // 如果當(dāng)前隊(duì)列中的數(shù)據(jù)包數(shù)量小于網(wǎng)卡設(shè)備允許的輸出隊(duì)列的數(shù)量
    
44. // 則將該數(shù)據(jù)包插入該隊(duì)列
    
45. if (skb_queue_len(list) < qdisc->dev->tx_queue_len) {
    
46.   qdisc->q.qlen++;
    
47.   return __qdisc_enqueue_tail(skb, qdisc, list);
    
48. }
    
49. // 否則的話(huà)丟棄該數(shù)據(jù)包
    
50. return qdisc_drop(skb, qdisc);
    
51. }
    
52. // 選隊(duì)列處理
    
53. static inline struct sk_buff_head *prio2list(struct sk_buff *skb,
    
54.           struct Qdisc *qdisc)
    
55. {
    
56. // qdisc私有數(shù)據(jù)指針, 數(shù)據(jù)包鏈表頭
    
57. struct sk_buff_head *list = qdisc_priv(qdisc);
    
58. // 根據(jù)數(shù)據(jù)包的優(yōu)先權(quán)值確定隊(duì)列頭偏移值
    
59. // skb->priority是個(gè)32位整數(shù), 只使用最后4位
    
60. return list + prio2band[skb->priority & TC_PRIO_MAX];
    
61. }
    
62. // 優(yōu)先權(quán)值到隊(duì)列號(hào)的變換數(shù)組, 該數(shù)組體現(xiàn)算法內(nèi)容, 通過(guò)修改該數(shù)組可以調(diào)整算法效果
    
63. // 該數(shù)組定義中, 優(yōu)先值(低4位)為1,2,3,5時(shí)使用2號(hào)隊(duì)列, 優(yōu)先值(低4位)為6,7時(shí)使用0號(hào)
    
64. // 隊(duì)列, 其他值為1號(hào)隊(duì)列
    
65. // 在普通情況下skb->priority都是0, 所有應(yīng)該只使用了1號(hào)隊(duì)列
    
66. // 這個(gè)數(shù)組實(shí)際是根據(jù)RFC1349中定義的TOS類(lèi)型值定義的, 在該RFC中TOS就是只有4位有效
    
67. static const u8 prio2band[TC_PRIO_MAX+1] =
    
68. { 1, 2, 2, 2, 1, 2, 0, 0 , 1, 1, 1, 1, 1, 1, 1, 1 };
    
69. 
    
70. 5.1.4 出隊(duì)
    
71. 
    
72. static struct sk_buff *pfifo_fast_dequeue(struct Qdisc* qdisc)
    
73. {
    
74. int prio;
    
75. struct sk_buff_head *list = qdisc_priv(qdisc);
    
76. // 循環(huán)3個(gè)隊(duì)列
    
77. for (prio = 0; prio < PFIFO_FAST_BANDS; prio++) {
    
78. // 如果隊(duì)列非空, 返回隊(duì)列頭的那個(gè)數(shù)據(jù)包
    
79.   if (!skb_queue_empty(list + prio)) {
    
80.    qdisc->q.qlen--;
    
81.    return __qdisc_dequeue_head(qdisc, list + prio);
    
82.   }
    
83. }
    
84. return NULL;
    
85. }
    
86. 
    
87. 由此可見(jiàn), 0號(hào)隊(duì)列有最高優(yōu)先級(jí), 2號(hào)隊(duì)列優(yōu)先級(jí)最低, 只有高優(yōu)先級(jí)隊(duì)列中的數(shù)據(jù)都發(fā)送完后才發(fā)
    
88. 送低優(yōu)先級(jí)隊(duì)列中的數(shù)據(jù)。
    
89. 
    
90. 5.1.5 重入隊(duì)
    
91. 
    
92. static int pfifo_fast_requeue(struct sk_buff *skb, struct Qdisc* qdisc)
    
93. {
    
94. // 隊(duì)列長(zhǎng)度遞增
    
95. qdisc->q.qlen++;
    
96. // 使用標(biāo)準(zhǔn)重入隊(duì)函數(shù)將數(shù)據(jù)插回隊(duì)列鏈表
    
97. return __qdisc_requeue(skb, qdisc, prio2list(skb, qdisc));
    
98. }
    
99. 
    
100. 5.1.6 復(fù)位
     
101. static void pfifo_fast_reset(struct Qdisc* qdisc)
     
102. {
     
103. int prio;
     
104. struct sk_buff_head *list = qdisc_priv(qdisc);
     
105. // 釋放三個(gè)隊(duì)列鏈表中的所有數(shù)據(jù)包
     
106. for (prio = 0; prio < PFIFO_FAST_BANDS; prio++)
     
107.   __qdisc_reset_queue(qdisc, list + prio);
     
108. // 計(jì)數(shù)清零
     
109. qdisc->qstats.backlog = 0;
     
110. qdisc->q.qlen = 0;
     
111. }
     
112. 
     
113. 5.1.7 輸出
     
114. 
     
115. 輸出當(dāng)前算法的內(nèi)容信息, 由于PFIFO_FAST算法核心就是prio2band數(shù)組, 因此就是將該數(shù)組內(nèi)容輸
     
116. 出到數(shù)據(jù)包供用戶(hù)空間獲取。
     
117. static int pfifo_fast_dump(struct Qdisc *qdisc, struct sk_buff *skb)
     
118. {
     
119. // TC優(yōu)先權(quán)數(shù)組結(jié)構(gòu)
     
120. struct tc_prio_qopt opt = { .bands = PFIFO_FAST_BANDS };
     
121. // 將當(dāng)前prio2band數(shù)組內(nèi)容拷貝到選項(xiàng)數(shù)據(jù)中
     
122. memcpy(&opt.priomap, prio2band, TC_PRIO_MAX+1);
     
123. // 將結(jié)構(gòu)作為路由屬性復(fù)制到數(shù)據(jù)包中供返回
     
124. RTA_PUT(skb, TCA_OPTIONS, sizeof(opt), &opt);
     
125. return skb->len;
     
126. rtattr_failure:
     
127. return -1;
     
128. }
     
129. 
     
130. ...... 待續(xù) ......
     
131. 
     
132. 發(fā)表于： 2007-07-28，修改于： 2007-07-29 15:30，已瀏覽3052次，有評(píng)論2條 推薦 投訴
     
133.         網(wǎng)友： burning423         時(shí)間：2007-09-21 08:53:33 IP地址：218.108.51.★
     
134.        
     
135. 
     
136. 5.1.2 初始化
     
137. 
     
138. 
     
139. 
     
140. static int pfifo_fast_init(struct Qdisc *qdisc, struct rtattr *opt)
     
141. 
     
142. {
     
143. 
     
144. int prio;
     
145. 
     
146. // qdisc私有數(shù)據(jù)指針, 數(shù)據(jù)包鏈表頭
     
147. 
     
148. struct sk_buff_head *list = qdisc_priv(qdisc);
     
149. 
     
150. ........................................
     
151. 
     
152. 
     
153. 
     
154. struct sk_buff_head *list = qdisc_priv(qdisc);這語(yǔ)句是怎樣得到qdisc的私有數(shù)據(jù)的?我看了qdisc_priv(qdisc)函數(shù)的定義,可還是不是很明白.你能否給我解釋一下?謝謝了..剛開(kāi)始看內(nèi)核的東西....
     
155. 
     
156. 
     
157.         網(wǎng)友： yfydz         時(shí)間：2007-09-22 21:44:39 IP地址：123.116.100.★
     
158.        
     
159. 
     
160. 每種qdisc定義都包括基本的Qdisc結(jié)構(gòu)和后面一些參數(shù), 大小由prive_size指定, 那些參數(shù)就是該qdisc的私有數(shù)據(jù), 獲取私有數(shù)據(jù)的指針就是從Qdisc起始位置移動(dòng)標(biāo)準(zhǔn)Qdisc大小就是了

復(fù)制代碼