]>
Commit | Line | Data |
---|---|---|
2865d42c LF |
1 | /****************************************************************************** |
2 | * rtl8712_recv.c | |
3 | * | |
4 | * Copyright(c) 2007 - 2010 Realtek Corporation. All rights reserved. | |
5 | * Linux device driver for RTL8192SU | |
6 | * | |
7 | * This program is free software; you can redistribute it and/or modify it | |
8 | * under the terms of version 2 of the GNU General Public License as | |
9 | * published by the Free Software Foundation. | |
10 | * | |
11 | * This program is distributed in the hope that it will be useful, but WITHOUT | |
12 | * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or | |
13 | * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for | |
14 | * more details. | |
15 | * | |
16 | * You should have received a copy of the GNU General Public License along with | |
17 | * this program; if not, write to the Free Software Foundation, Inc., | |
18 | * 51 Franklin Street, Fifth Floor, Boston, MA 02110, USA | |
19 | * | |
20 | * Modifications for inclusion into the Linux staging tree are | |
21 | * Copyright(c) 2010 Larry Finger. All rights reserved. | |
22 | * | |
23 | * Contact information: | |
24 | * WLAN FAE <wlanfae@realtek.com> | |
25 | * Larry Finger <Larry.Finger@lwfinger.net> | |
26 | * | |
27 | ******************************************************************************/ | |
28 | ||
29 | #define _RTL8712_RECV_C_ | |
30 | ||
be9a1204 | 31 | #include <linux/if_ether.h> |
20467825 | 32 | #include <linux/ip.h> |
be9a1204 | 33 | |
2865d42c LF |
34 | #include "osdep_service.h" |
35 | #include "drv_types.h" | |
36 | #include "recv_osdep.h" | |
37 | #include "mlme_osdep.h" | |
2865d42c LF |
38 | #include "ethernet.h" |
39 | #include "usb_ops.h" | |
40 | #include "wifi.h" | |
41 | ||
42 | /* Bridge-Tunnel header (for EtherTypes ETH_P_AARP and ETH_P_IPX) */ | |
43 | static u8 bridge_tunnel_header[] = {0xaa, 0xaa, 0x03, 0x00, 0x00, 0xf8}; | |
44 | ||
45 | /* Ethernet-II snap header (RFC1042 for most EtherTypes) */ | |
46 | static u8 rfc1042_header[] = {0xaa, 0xaa, 0x03, 0x00, 0x00, 0x00}; | |
47 | ||
48 | static void recv_tasklet(void *priv); | |
49 | ||
50 | int r8712_init_recv_priv(struct recv_priv *precvpriv, struct _adapter *padapter) | |
51 | { | |
52 | int i; | |
53 | struct recv_buf *precvbuf; | |
54 | int res = _SUCCESS; | |
55 | addr_t tmpaddr = 0; | |
56 | int alignment = 0; | |
57 | struct sk_buff *pskb = NULL; | |
58 | ||
2865d42c LF |
59 | /*init recv_buf*/ |
60 | _init_queue(&precvpriv->free_recv_buf_queue); | |
5eafbb0c RTD |
61 | precvpriv->pallocated_recv_buf = |
62 | kzalloc(NR_RECVBUFF * sizeof(struct recv_buf) + 4, GFP_ATOMIC); | |
a667dbce | 63 | if (!precvpriv->pallocated_recv_buf) |
2865d42c | 64 | return _FAIL; |
2865d42c LF |
65 | precvpriv->precv_buf = precvpriv->pallocated_recv_buf + 4 - |
66 | ((addr_t) (precvpriv->pallocated_recv_buf) & 3); | |
67 | precvbuf = (struct recv_buf *)precvpriv->precv_buf; | |
68 | for (i = 0; i < NR_RECVBUFF; i++) { | |
534c4acd | 69 | INIT_LIST_HEAD(&precvbuf->list); |
2865d42c LF |
70 | spin_lock_init(&precvbuf->recvbuf_lock); |
71 | res = r8712_os_recvbuf_resource_alloc(padapter, precvbuf); | |
72 | if (res == _FAIL) | |
73 | break; | |
74 | precvbuf->ref_cnt = 0; | |
75 | precvbuf->adapter = padapter; | |
fdfbf789 | 76 | list_add_tail(&precvbuf->list, |
2865d42c LF |
77 | &(precvpriv->free_recv_buf_queue.queue)); |
78 | precvbuf++; | |
79 | } | |
80 | precvpriv->free_recv_buf_queue_cnt = NR_RECVBUFF; | |
81 | tasklet_init(&precvpriv->recv_tasklet, | |
82 | (void(*)(unsigned long))recv_tasklet, | |
83 | (unsigned long)padapter); | |
84 | skb_queue_head_init(&precvpriv->rx_skb_queue); | |
85 | ||
86 | skb_queue_head_init(&precvpriv->free_recv_skb_queue); | |
87 | for (i = 0; i < NR_PREALLOC_RECV_SKB; i++) { | |
88 | pskb = netdev_alloc_skb(padapter->pnetdev, MAX_RECVBUF_SZ + | |
89 | RECVBUFF_ALIGN_SZ); | |
90 | if (pskb) { | |
2865d42c | 91 | tmpaddr = (addr_t)pskb->data; |
4ef2de5a | 92 | alignment = tmpaddr & (RECVBUFF_ALIGN_SZ - 1); |
2865d42c LF |
93 | skb_reserve(pskb, (RECVBUFF_ALIGN_SZ - alignment)); |
94 | skb_queue_tail(&precvpriv->free_recv_skb_queue, pskb); | |
95 | } | |
96 | pskb = NULL; | |
97 | } | |
98 | return res; | |
99 | } | |
100 | ||
101 | void r8712_free_recv_priv(struct recv_priv *precvpriv) | |
102 | { | |
103 | int i; | |
104 | struct recv_buf *precvbuf; | |
105 | struct _adapter *padapter = precvpriv->adapter; | |
106 | ||
107 | precvbuf = (struct recv_buf *)precvpriv->precv_buf; | |
77e73e8c | 108 | for (i = 0; i < NR_RECVBUFF; i++) { |
2865d42c LF |
109 | r8712_os_recvbuf_resource_free(padapter, precvbuf); |
110 | precvbuf++; | |
111 | } | |
112 | kfree(precvpriv->pallocated_recv_buf); | |
113 | skb_queue_purge(&precvpriv->rx_skb_queue); | |
114 | if (skb_queue_len(&precvpriv->rx_skb_queue)) | |
87a573ad | 115 | netdev_warn(padapter->pnetdev, "r8712u: rx_skb_queue not empty\n"); |
2865d42c LF |
116 | skb_queue_purge(&precvpriv->free_recv_skb_queue); |
117 | if (skb_queue_len(&precvpriv->free_recv_skb_queue)) | |
87a573ad PF |
118 | netdev_warn(padapter->pnetdev, "r8712u: free_recv_skb_queue not empty %d\n", |
119 | skb_queue_len(&precvpriv->free_recv_skb_queue)); | |
2865d42c LF |
120 | } |
121 | ||
122 | int r8712_init_recvbuf(struct _adapter *padapter, struct recv_buf *precvbuf) | |
123 | { | |
2865d42c LF |
124 | precvbuf->transfer_len = 0; |
125 | precvbuf->len = 0; | |
126 | precvbuf->ref_cnt = 0; | |
127 | if (precvbuf->pbuf) { | |
128 | precvbuf->pdata = precvbuf->pbuf; | |
129 | precvbuf->phead = precvbuf->pbuf; | |
130 | precvbuf->ptail = precvbuf->pbuf; | |
131 | precvbuf->pend = precvbuf->pdata + MAX_RECVBUF_SZ; | |
132 | } | |
8ffca9ea | 133 | return _SUCCESS; |
2865d42c LF |
134 | } |
135 | ||
2865d42c LF |
136 | int r8712_free_recvframe(union recv_frame *precvframe, |
137 | struct __queue *pfree_recv_queue) | |
138 | { | |
139 | unsigned long irqL; | |
140 | struct _adapter *padapter = precvframe->u.hdr.adapter; | |
141 | struct recv_priv *precvpriv = &padapter->recvpriv; | |
142 | ||
143 | if (precvframe->u.hdr.pkt) { | |
144 | dev_kfree_skb_any(precvframe->u.hdr.pkt);/*free skb by driver*/ | |
145 | precvframe->u.hdr.pkt = NULL; | |
146 | } | |
147 | spin_lock_irqsave(&pfree_recv_queue->lock, irqL); | |
29197b7c | 148 | list_del_init(&(precvframe->u.hdr.list)); |
e99a428a | 149 | list_add_tail(&(precvframe->u.hdr.list), &pfree_recv_queue->queue); |
2865d42c LF |
150 | if (padapter != NULL) { |
151 | if (pfree_recv_queue == &precvpriv->free_recv_queue) | |
152 | precvpriv->free_recvframe_cnt++; | |
153 | } | |
154 | spin_unlock_irqrestore(&pfree_recv_queue->lock, irqL); | |
155 | return _SUCCESS; | |
156 | } | |
157 | ||
158 | static void update_recvframe_attrib_from_recvstat(struct rx_pkt_attrib *pattrib, | |
159 | struct recv_stat *prxstat) | |
160 | { | |
a90391e4 | 161 | u16 drvinfo_sz; |
2865d42c | 162 | |
4ef2de5a | 163 | drvinfo_sz = (le32_to_cpu(prxstat->rxdw0) & 0x000f0000) >> 16; |
5c7c5d80 | 164 | drvinfo_sz <<= 3; |
2865d42c | 165 | /*TODO: |
bef611a9 RB |
166 | * Offset 0 |
167 | */ | |
2865d42c LF |
168 | pattrib->bdecrypted = ((le32_to_cpu(prxstat->rxdw0) & BIT(27)) >> 27) |
169 | ? 0 : 1; | |
25978642 | 170 | pattrib->crc_err = (le32_to_cpu(prxstat->rxdw0) & BIT(14)) >> 14; |
2865d42c LF |
171 | /*Offset 4*/ |
172 | /*Offset 8*/ | |
173 | /*Offset 12*/ | |
174 | if (le32_to_cpu(prxstat->rxdw3) & BIT(13)) { | |
175 | pattrib->tcpchk_valid = 1; /* valid */ | |
176 | if (le32_to_cpu(prxstat->rxdw3) & BIT(11)) | |
177 | pattrib->tcp_chkrpt = 1; /* correct */ | |
178 | else | |
179 | pattrib->tcp_chkrpt = 0; /* incorrect */ | |
180 | if (le32_to_cpu(prxstat->rxdw3) & BIT(12)) | |
181 | pattrib->ip_chkrpt = 1; /* correct */ | |
182 | else | |
183 | pattrib->ip_chkrpt = 0; /* incorrect */ | |
168a2c10 | 184 | } else { |
2865d42c | 185 | pattrib->tcpchk_valid = 0; /* invalid */ |
168a2c10 | 186 | } |
2865d42c | 187 | pattrib->mcs_rate = (u8)((le32_to_cpu(prxstat->rxdw3)) & 0x3f); |
ee5b1aad | 188 | pattrib->htc = (u8)((le32_to_cpu(prxstat->rxdw3) >> 14) & 0x1); |
2865d42c LF |
189 | /*Offset 16*/ |
190 | /*Offset 20*/ | |
191 | /*phy_info*/ | |
2865d42c LF |
192 | } |
193 | ||
194 | /*perform defrag*/ | |
16e53729 | 195 | static union recv_frame *recvframe_defrag(struct _adapter *adapter, |
2865d42c LF |
196 | struct __queue *defrag_q) |
197 | { | |
198 | struct list_head *plist, *phead; | |
e29d3ebc | 199 | u8 wlanhdr_offset; |
2865d42c LF |
200 | u8 curfragnum; |
201 | struct recv_frame_hdr *pfhdr, *pnfhdr; | |
202 | union recv_frame *prframe, *pnextrframe; | |
203 | struct __queue *pfree_recv_queue; | |
204 | ||
205 | pfree_recv_queue = &adapter->recvpriv.free_recv_queue; | |
e99a428a | 206 | phead = &defrag_q->queue; |
849fb0a8 | 207 | plist = phead->next; |
fcc2cf12 | 208 | prframe = container_of(plist, union recv_frame, u.list); |
29197b7c | 209 | list_del_init(&prframe->u.list); |
2865d42c LF |
210 | pfhdr = &prframe->u.hdr; |
211 | curfragnum = 0; | |
212 | if (curfragnum != pfhdr->attrib.frag_num) { | |
213 | /*the first fragment number must be 0 | |
bef611a9 RB |
214 | *free the whole queue |
215 | */ | |
2865d42c | 216 | r8712_free_recvframe(prframe, pfree_recv_queue); |
ee5b1aad AB |
217 | r8712_free_recvframe_queue(defrag_q, pfree_recv_queue); |
218 | return NULL; | |
2865d42c | 219 | } |
ee5b1aad | 220 | curfragnum++; |
e99a428a | 221 | plist = &defrag_q->queue; |
849fb0a8 | 222 | plist = plist->next; |
1ca96884 | 223 | while (!end_of_queue_search(phead, plist)) { |
fcc2cf12 | 224 | pnextrframe = container_of(plist, union recv_frame, u.list); |
2865d42c | 225 | pnfhdr = &pnextrframe->u.hdr; |
ee5b1aad | 226 | /*check the fragment sequence (2nd ~n fragment frame) */ |
2865d42c LF |
227 | if (curfragnum != pnfhdr->attrib.frag_num) { |
228 | /* the fragment number must increase (after decache) | |
bef611a9 RB |
229 | * release the defrag_q & prframe |
230 | */ | |
2865d42c | 231 | r8712_free_recvframe(prframe, pfree_recv_queue); |
ee5b1aad AB |
232 | r8712_free_recvframe_queue(defrag_q, pfree_recv_queue); |
233 | return NULL; | |
2865d42c | 234 | } |
ee5b1aad | 235 | curfragnum++; |
2865d42c | 236 | /* copy the 2nd~n fragment frame's payload to the first fragment |
bef611a9 RB |
237 | * get the 2nd~last fragment frame's payload |
238 | */ | |
2865d42c LF |
239 | wlanhdr_offset = pnfhdr->attrib.hdrlen + pnfhdr->attrib.iv_len; |
240 | recvframe_pull(pnextrframe, wlanhdr_offset); | |
241 | /* append to first fragment frame's tail (if privacy frame, | |
bef611a9 RB |
242 | * pull the ICV) |
243 | */ | |
2865d42c LF |
244 | recvframe_pull_tail(prframe, pfhdr->attrib.icv_len); |
245 | memcpy(pfhdr->rx_tail, pnfhdr->rx_data, pnfhdr->len); | |
246 | recvframe_put(prframe, pnfhdr->len); | |
247 | pfhdr->attrib.icv_len = pnfhdr->attrib.icv_len; | |
849fb0a8 | 248 | plist = plist->next; |
b0b0fb0f | 249 | } |
2865d42c LF |
250 | /* free the defrag_q queue and return the prframe */ |
251 | r8712_free_recvframe_queue(defrag_q, pfree_recv_queue); | |
252 | return prframe; | |
253 | } | |
254 | ||
255 | /* check if need to defrag, if needed queue the frame to defrag_q */ | |
256 | union recv_frame *r8712_recvframe_chk_defrag(struct _adapter *padapter, | |
257 | union recv_frame *precv_frame) | |
258 | { | |
259 | u8 ismfrag; | |
260 | u8 fragnum; | |
261 | u8 *psta_addr; | |
262 | struct recv_frame_hdr *pfhdr; | |
263 | struct sta_info *psta; | |
77e73e8c | 264 | struct sta_priv *pstapriv; |
2865d42c LF |
265 | struct list_head *phead; |
266 | union recv_frame *prtnframe = NULL; | |
267 | struct __queue *pfree_recv_queue, *pdefrag_q; | |
268 | ||
269 | pstapriv = &padapter->stapriv; | |
270 | pfhdr = &precv_frame->u.hdr; | |
271 | pfree_recv_queue = &padapter->recvpriv.free_recv_queue; | |
272 | /* need to define struct of wlan header frame ctrl */ | |
273 | ismfrag = pfhdr->attrib.mfrag; | |
274 | fragnum = pfhdr->attrib.frag_num; | |
275 | psta_addr = pfhdr->attrib.ta; | |
276 | psta = r8712_get_stainfo(pstapriv, psta_addr); | |
a667dbce | 277 | if (!psta) |
2865d42c LF |
278 | pdefrag_q = NULL; |
279 | else | |
280 | pdefrag_q = &psta->sta_recvpriv.defrag_q; | |
281 | ||
282 | if ((ismfrag == 0) && (fragnum == 0)) | |
283 | prtnframe = precv_frame;/*isn't a fragment frame*/ | |
284 | if (ismfrag == 1) { | |
285 | /* 0~(n-1) fragment frame | |
bef611a9 RB |
286 | * enqueue to defraf_g |
287 | */ | |
2865d42c LF |
288 | if (pdefrag_q != NULL) { |
289 | if (fragnum == 0) { | |
290 | /*the first fragment*/ | |
df353f61 | 291 | if (!list_empty(&pdefrag_q->queue)) { |
2865d42c LF |
292 | /*free current defrag_q */ |
293 | r8712_free_recvframe_queue(pdefrag_q, | |
294 | pfree_recv_queue); | |
295 | } | |
296 | } | |
297 | /* Then enqueue the 0~(n-1) fragment to the defrag_q */ | |
e99a428a | 298 | phead = &pdefrag_q->queue; |
fdfbf789 | 299 | list_add_tail(&pfhdr->list, phead); |
2865d42c LF |
300 | prtnframe = NULL; |
301 | } else { | |
302 | /* can't find this ta's defrag_queue, so free this | |
bef611a9 RB |
303 | * recv_frame |
304 | */ | |
2865d42c LF |
305 | r8712_free_recvframe(precv_frame, pfree_recv_queue); |
306 | prtnframe = NULL; | |
307 | } | |
308 | ||
309 | } | |
310 | if ((ismfrag == 0) && (fragnum != 0)) { | |
311 | /* the last fragment frame | |
bef611a9 RB |
312 | * enqueue the last fragment |
313 | */ | |
2865d42c | 314 | if (pdefrag_q != NULL) { |
e99a428a | 315 | phead = &pdefrag_q->queue; |
fdfbf789 | 316 | list_add_tail(&pfhdr->list, phead); |
2865d42c LF |
317 | /*call recvframe_defrag to defrag*/ |
318 | precv_frame = recvframe_defrag(padapter, pdefrag_q); | |
319 | prtnframe = precv_frame; | |
320 | } else { | |
321 | /* can't find this ta's defrag_queue, so free this | |
bef611a9 RB |
322 | * recv_frame |
323 | */ | |
2865d42c LF |
324 | r8712_free_recvframe(precv_frame, pfree_recv_queue); |
325 | prtnframe = NULL; | |
326 | } | |
327 | } | |
328 | if ((prtnframe != NULL) && (prtnframe->u.hdr.attrib.privacy)) { | |
329 | /* after defrag we must check tkip mic code */ | |
330 | if (r8712_recvframe_chkmic(padapter, prtnframe) == _FAIL) { | |
331 | r8712_free_recvframe(prtnframe, pfree_recv_queue); | |
332 | prtnframe = NULL; | |
333 | } | |
334 | } | |
335 | return prtnframe; | |
336 | } | |
337 | ||
16e53729 | 338 | static int amsdu_to_msdu(struct _adapter *padapter, union recv_frame *prframe) |
2865d42c LF |
339 | { |
340 | int a_len, padding_len; | |
341 | u16 eth_type, nSubframe_Length; | |
342 | u8 nr_subframes, i; | |
b952f4df | 343 | unsigned char *pdata; |
2865d42c LF |
344 | struct rx_pkt_attrib *pattrib; |
345 | _pkt *sub_skb, *subframes[MAX_SUBFRAME_COUNT]; | |
346 | struct recv_priv *precvpriv = &padapter->recvpriv; | |
347 | struct __queue *pfree_recv_queue = &(precvpriv->free_recv_queue); | |
2865d42c LF |
348 | |
349 | nr_subframes = 0; | |
350 | pattrib = &prframe->u.hdr.attrib; | |
351 | recvframe_pull(prframe, prframe->u.hdr.attrib.hdrlen); | |
352 | if (prframe->u.hdr.attrib.iv_len > 0) | |
353 | recvframe_pull(prframe, prframe->u.hdr.attrib.iv_len); | |
354 | a_len = prframe->u.hdr.len; | |
355 | pdata = prframe->u.hdr.rx_data; | |
356 | while (a_len > ETH_HLEN) { | |
357 | /* Offset 12 denote 2 mac address */ | |
358 | nSubframe_Length = *((u16 *)(pdata + 12)); | |
359 | /*==m==>change the length order*/ | |
360 | nSubframe_Length = (nSubframe_Length >> 8) + | |
361 | (nSubframe_Length << 8); | |
362 | if (a_len < (ETHERNET_HEADER_SIZE + nSubframe_Length)) { | |
87a573ad PF |
363 | netdev_warn(padapter->pnetdev, "r8712u: nRemain_Length is %d and nSubframe_Length is: %d\n", |
364 | a_len, nSubframe_Length); | |
2865d42c LF |
365 | goto exit; |
366 | } | |
367 | /* move the data point to data content */ | |
368 | pdata += ETH_HLEN; | |
369 | a_len -= ETH_HLEN; | |
370 | /* Allocate new skb for releasing to upper layer */ | |
371 | sub_skb = dev_alloc_skb(nSubframe_Length + 12); | |
5ca136a0 LF |
372 | if (!sub_skb) |
373 | break; | |
2865d42c | 374 | skb_reserve(sub_skb, 12); |
b952f4df | 375 | skb_put_data(sub_skb, pdata, nSubframe_Length); |
2865d42c LF |
376 | subframes[nr_subframes++] = sub_skb; |
377 | if (nr_subframes >= MAX_SUBFRAME_COUNT) { | |
87a573ad | 378 | netdev_warn(padapter->pnetdev, "r8712u: ParseSubframe(): Too many Subframes! Packets dropped!\n"); |
2865d42c LF |
379 | break; |
380 | } | |
381 | pdata += nSubframe_Length; | |
382 | a_len -= nSubframe_Length; | |
383 | if (a_len != 0) { | |
384 | padding_len = 4 - ((nSubframe_Length + ETH_HLEN) & 3); | |
385 | if (padding_len == 4) | |
386 | padding_len = 0; | |
387 | if (a_len < padding_len) | |
388 | goto exit; | |
389 | pdata += padding_len; | |
390 | a_len -= padding_len; | |
391 | } | |
392 | } | |
393 | for (i = 0; i < nr_subframes; i++) { | |
394 | sub_skb = subframes[i]; | |
395 | /* convert hdr + possible LLC headers into Ethernet header */ | |
396 | eth_type = (sub_skb->data[6] << 8) | sub_skb->data[7]; | |
397 | if (sub_skb->len >= 8 && | |
398 | ((!memcmp(sub_skb->data, rfc1042_header, SNAP_SIZE) && | |
399 | eth_type != ETH_P_AARP && eth_type != ETH_P_IPX) || | |
400 | !memcmp(sub_skb->data, bridge_tunnel_header, SNAP_SIZE))) { | |
401 | /* remove RFC1042 or Bridge-Tunnel encapsulation and | |
bef611a9 RB |
402 | * replace EtherType |
403 | */ | |
2865d42c LF |
404 | skb_pull(sub_skb, SNAP_SIZE); |
405 | memcpy(skb_push(sub_skb, ETH_ALEN), pattrib->src, | |
406 | ETH_ALEN); | |
407 | memcpy(skb_push(sub_skb, ETH_ALEN), pattrib->dst, | |
408 | ETH_ALEN); | |
409 | } else { | |
16b8852f | 410 | __be16 len; |
2865d42c LF |
411 | /* Leave Ethernet header part of hdr and full payload */ |
412 | len = htons(sub_skb->len); | |
413 | memcpy(skb_push(sub_skb, 2), &len, 2); | |
414 | memcpy(skb_push(sub_skb, ETH_ALEN), pattrib->src, | |
415 | ETH_ALEN); | |
416 | memcpy(skb_push(sub_skb, ETH_ALEN), pattrib->dst, | |
417 | ETH_ALEN); | |
418 | } | |
419 | /* Indicate the packets to upper layer */ | |
420 | if (sub_skb) { | |
421 | sub_skb->protocol = | |
422 | eth_type_trans(sub_skb, padapter->pnetdev); | |
423 | sub_skb->dev = padapter->pnetdev; | |
424 | if ((pattrib->tcpchk_valid == 1) && | |
425 | (pattrib->tcp_chkrpt == 1)) { | |
426 | sub_skb->ip_summed = CHECKSUM_UNNECESSARY; | |
168a2c10 | 427 | } else { |
2865d42c | 428 | sub_skb->ip_summed = CHECKSUM_NONE; |
168a2c10 | 429 | } |
2865d42c LF |
430 | netif_rx(sub_skb); |
431 | } | |
432 | } | |
433 | exit: | |
434 | prframe->u.hdr.len = 0; | |
435 | r8712_free_recvframe(prframe, pfree_recv_queue); | |
8ffca9ea | 436 | return _SUCCESS; |
2865d42c LF |
437 | } |
438 | ||
439 | void r8712_rxcmd_event_hdl(struct _adapter *padapter, void *prxcmdbuf) | |
440 | { | |
16b8852f | 441 | __le32 voffset; |
2865d42c | 442 | u8 *poffset; |
e29d3ebc | 443 | u16 cmd_len, drvinfo_sz; |
2865d42c LF |
444 | struct recv_stat *prxstat; |
445 | ||
c66de311 | 446 | poffset = prxcmdbuf; |
16b8852f | 447 | voffset = *(__le32 *)poffset; |
c66de311 | 448 | prxstat = prxcmdbuf; |
25978642 | 449 | drvinfo_sz = (le32_to_cpu(prxstat->rxdw0) & 0x000f0000) >> 16; |
5c7c5d80 | 450 | drvinfo_sz <<= 3; |
2865d42c LF |
451 | poffset += RXDESC_SIZE + drvinfo_sz; |
452 | do { | |
16b8852f | 453 | voffset = *(__le32 *)poffset; |
2865d42c | 454 | cmd_len = (u16)(le32_to_cpu(voffset) & 0xffff); |
16b8852f | 455 | r8712_event_handle(padapter, (__le32 *)poffset); |
be10ac2b | 456 | poffset += (cmd_len + 8);/*8 bytes alignment*/ |
2865d42c LF |
457 | } while (le32_to_cpu(voffset) & BIT(31)); |
458 | ||
459 | } | |
460 | ||
461 | static int check_indicate_seq(struct recv_reorder_ctrl *preorder_ctrl, | |
462 | u16 seq_num) | |
463 | { | |
464 | u8 wsize = preorder_ctrl->wsize_b; | |
465 | u16 wend = (preorder_ctrl->indicate_seq + wsize - 1) % 4096; | |
466 | ||
467 | /* Rx Reorder initialize condition.*/ | |
468 | if (preorder_ctrl->indicate_seq == 0xffff) | |
469 | preorder_ctrl->indicate_seq = seq_num; | |
470 | /* Drop out the packet which SeqNum is smaller than WinStart */ | |
471 | if (SN_LESS(seq_num, preorder_ctrl->indicate_seq)) | |
472 | return false; | |
473 | /* | |
474 | * Sliding window manipulation. Conditions includes: | |
475 | * 1. Incoming SeqNum is equal to WinStart =>Window shift 1 | |
476 | * 2. Incoming SeqNum is larger than the WinEnd => Window shift N | |
477 | */ | |
478 | if (SN_EQUAL(seq_num, preorder_ctrl->indicate_seq)) | |
479 | preorder_ctrl->indicate_seq = (preorder_ctrl->indicate_seq + | |
480 | 1) % 4096; | |
481 | else if (SN_LESS(wend, seq_num)) { | |
482 | if (seq_num >= (wsize - 1)) | |
483 | preorder_ctrl->indicate_seq = seq_num + 1 - wsize; | |
484 | else | |
485 | preorder_ctrl->indicate_seq = 4095 - (wsize - | |
486 | (seq_num + 1)) + 1; | |
487 | } | |
488 | return true; | |
489 | } | |
490 | ||
491 | static int enqueue_reorder_recvframe(struct recv_reorder_ctrl *preorder_ctrl, | |
492 | union recv_frame *prframe) | |
493 | { | |
494 | struct list_head *phead, *plist; | |
495 | union recv_frame *pnextrframe; | |
496 | struct rx_pkt_attrib *pnextattrib; | |
497 | struct __queue *ppending_recvframe_queue = | |
498 | &preorder_ctrl->pending_recvframe_queue; | |
499 | struct rx_pkt_attrib *pattrib = &prframe->u.hdr.attrib; | |
500 | ||
e99a428a | 501 | phead = &ppending_recvframe_queue->queue; |
849fb0a8 | 502 | plist = phead->next; |
1ca96884 | 503 | while (!end_of_queue_search(phead, plist)) { |
fcc2cf12 | 504 | pnextrframe = container_of(plist, union recv_frame, u.list); |
2865d42c LF |
505 | pnextattrib = &pnextrframe->u.hdr.attrib; |
506 | if (SN_LESS(pnextattrib->seq_num, pattrib->seq_num)) | |
849fb0a8 | 507 | plist = plist->next; |
2865d42c LF |
508 | else if (SN_EQUAL(pnextattrib->seq_num, pattrib->seq_num)) |
509 | return false; | |
8681a1d4 MK |
510 | else |
511 | break; | |
2865d42c | 512 | } |
29197b7c | 513 | list_del_init(&(prframe->u.hdr.list)); |
fdfbf789 | 514 | list_add_tail(&(prframe->u.hdr.list), plist); |
2865d42c LF |
515 | return true; |
516 | } | |
517 | ||
518 | int r8712_recv_indicatepkts_in_order(struct _adapter *padapter, | |
519 | struct recv_reorder_ctrl *preorder_ctrl, | |
520 | int bforced) | |
521 | { | |
522 | struct list_head *phead, *plist; | |
523 | union recv_frame *prframe; | |
524 | struct rx_pkt_attrib *pattrib; | |
525 | int bPktInBuf = false; | |
526 | struct recv_priv *precvpriv = &padapter->recvpriv; | |
527 | struct __queue *ppending_recvframe_queue = | |
528 | &preorder_ctrl->pending_recvframe_queue; | |
529 | ||
e99a428a | 530 | phead = &ppending_recvframe_queue->queue; |
849fb0a8 | 531 | plist = phead->next; |
2865d42c | 532 | /* Handling some condition for forced indicate case.*/ |
1ca96884 | 533 | if (bforced) { |
9672b1bd | 534 | if (list_empty(phead)) |
2865d42c | 535 | return true; |
68de8d67 | 536 | |
fcc2cf12 | 537 | prframe = container_of(plist, union recv_frame, u.list); |
68de8d67 MK |
538 | pattrib = &prframe->u.hdr.attrib; |
539 | preorder_ctrl->indicate_seq = pattrib->seq_num; | |
2865d42c LF |
540 | } |
541 | /* Prepare indication list and indication. | |
bef611a9 RB |
542 | * Check if there is any packet need indicate. |
543 | */ | |
9672b1bd | 544 | while (!list_empty(phead)) { |
fcc2cf12 | 545 | prframe = container_of(plist, union recv_frame, u.list); |
2865d42c LF |
546 | pattrib = &prframe->u.hdr.attrib; |
547 | if (!SN_LESS(preorder_ctrl->indicate_seq, pattrib->seq_num)) { | |
849fb0a8 | 548 | plist = plist->next; |
29197b7c | 549 | list_del_init(&(prframe->u.hdr.list)); |
2865d42c LF |
550 | if (SN_EQUAL(preorder_ctrl->indicate_seq, |
551 | pattrib->seq_num)) | |
552 | preorder_ctrl->indicate_seq = | |
553 | (preorder_ctrl->indicate_seq + 1) % 4096; | |
554 | /*indicate this recv_frame*/ | |
555 | if (!pattrib->amsdu) { | |
1ca96884 LB |
556 | if (!padapter->bDriverStopped && |
557 | !padapter->bSurpriseRemoved) { | |
2865d42c LF |
558 | /* indicate this recv_frame */ |
559 | r8712_recv_indicatepkt(padapter, | |
560 | prframe); | |
561 | } | |
562 | } else if (pattrib->amsdu == 1) { | |
563 | if (amsdu_to_msdu(padapter, prframe) != | |
564 | _SUCCESS) | |
565 | r8712_free_recvframe(prframe, | |
566 | &precvpriv->free_recv_queue); | |
567 | } | |
568 | /* Update local variables. */ | |
569 | bPktInBuf = false; | |
570 | } else { | |
571 | bPktInBuf = true; | |
572 | break; | |
573 | } | |
574 | } | |
575 | return bPktInBuf; | |
576 | } | |
577 | ||
578 | static int recv_indicatepkt_reorder(struct _adapter *padapter, | |
579 | union recv_frame *prframe) | |
580 | { | |
581 | unsigned long irql; | |
582 | struct rx_pkt_attrib *pattrib = &prframe->u.hdr.attrib; | |
583 | struct recv_reorder_ctrl *preorder_ctrl = prframe->u.hdr.preorder_ctrl; | |
584 | struct __queue *ppending_recvframe_queue = | |
585 | &preorder_ctrl->pending_recvframe_queue; | |
586 | ||
587 | if (!pattrib->amsdu) { | |
588 | /* s1. */ | |
589 | r8712_wlanhdr_to_ethhdr(prframe); | |
590 | if (pattrib->qos != 1) { | |
1ca96884 LB |
591 | if (!padapter->bDriverStopped && |
592 | !padapter->bSurpriseRemoved) { | |
2865d42c LF |
593 | r8712_recv_indicatepkt(padapter, prframe); |
594 | return _SUCCESS; | |
168a2c10 | 595 | } else { |
2865d42c | 596 | return _FAIL; |
168a2c10 | 597 | } |
2865d42c LF |
598 | } |
599 | } | |
600 | spin_lock_irqsave(&ppending_recvframe_queue->lock, irql); | |
be10ac2b | 601 | /*s2. check if winstart_b(indicate_seq) needs to be updated*/ |
2865d42c LF |
602 | if (!check_indicate_seq(preorder_ctrl, pattrib->seq_num)) |
603 | goto _err_exit; | |
604 | /*s3. Insert all packet into Reorder Queue to maintain its ordering.*/ | |
605 | if (!enqueue_reorder_recvframe(preorder_ctrl, prframe)) | |
606 | goto _err_exit; | |
607 | /*s4. | |
608 | * Indication process. | |
609 | * After Packet dropping and Sliding Window shifting as above, we can | |
610 | * now just indicate the packets with the SeqNum smaller than latest | |
611 | * WinStart and buffer other packets. | |
612 | * | |
613 | * For Rx Reorder condition: | |
614 | * 1. All packets with SeqNum smaller than WinStart => Indicate | |
615 | * 2. All packets with SeqNum larger than or equal to | |
616 | * WinStart => Buffer it. | |
617 | */ | |
618 | if (r8712_recv_indicatepkts_in_order(padapter, preorder_ctrl, false) == | |
619 | true) { | |
c703c750 VT |
620 | mod_timer(&preorder_ctrl->reordering_ctrl_timer, |
621 | jiffies + msecs_to_jiffies(REORDER_WAIT_TIME)); | |
2865d42c LF |
622 | spin_unlock_irqrestore(&ppending_recvframe_queue->lock, irql); |
623 | } else { | |
624 | spin_unlock_irqrestore(&ppending_recvframe_queue->lock, irql); | |
4eef520d | 625 | del_timer(&preorder_ctrl->reordering_ctrl_timer); |
2865d42c LF |
626 | } |
627 | return _SUCCESS; | |
628 | _err_exit: | |
629 | spin_unlock_irqrestore(&ppending_recvframe_queue->lock, irql); | |
630 | return _FAIL; | |
631 | } | |
632 | ||
633 | void r8712_reordering_ctrl_timeout_handler(void *pcontext) | |
634 | { | |
635 | unsigned long irql; | |
c66de311 | 636 | struct recv_reorder_ctrl *preorder_ctrl = pcontext; |
2865d42c LF |
637 | struct _adapter *padapter = preorder_ctrl->padapter; |
638 | struct __queue *ppending_recvframe_queue = | |
639 | &preorder_ctrl->pending_recvframe_queue; | |
640 | ||
641 | if (padapter->bDriverStopped || padapter->bSurpriseRemoved) | |
642 | return; | |
643 | spin_lock_irqsave(&ppending_recvframe_queue->lock, irql); | |
644 | r8712_recv_indicatepkts_in_order(padapter, preorder_ctrl, true); | |
645 | spin_unlock_irqrestore(&ppending_recvframe_queue->lock, irql); | |
646 | } | |
647 | ||
648 | static int r8712_process_recv_indicatepkts(struct _adapter *padapter, | |
649 | union recv_frame *prframe) | |
650 | { | |
651 | int retval = _SUCCESS; | |
652 | struct mlme_priv *pmlmepriv = &padapter->mlmepriv; | |
653 | struct ht_priv *phtpriv = &pmlmepriv->htpriv; | |
654 | ||
655 | if (phtpriv->ht_option == 1) { /*B/G/N Mode*/ | |
656 | if (recv_indicatepkt_reorder(padapter, prframe) != _SUCCESS) { | |
657 | /* including perform A-MPDU Rx Ordering Buffer Control*/ | |
1ca96884 LB |
658 | if (!padapter->bDriverStopped && |
659 | !padapter->bSurpriseRemoved) | |
2865d42c LF |
660 | return _FAIL; |
661 | } | |
662 | } else { /*B/G mode*/ | |
663 | retval = r8712_wlanhdr_to_ethhdr(prframe); | |
664 | if (retval != _SUCCESS) | |
665 | return retval; | |
1ca96884 | 666 | if (!padapter->bDriverStopped && !padapter->bSurpriseRemoved) { |
2865d42c LF |
667 | /* indicate this recv_frame */ |
668 | r8712_recv_indicatepkt(padapter, prframe); | |
168a2c10 | 669 | } else { |
2865d42c | 670 | return _FAIL; |
168a2c10 | 671 | } |
2865d42c LF |
672 | } |
673 | return retval; | |
674 | } | |
675 | ||
676 | static u8 query_rx_pwr_percentage(s8 antpower) | |
677 | { | |
678 | if ((antpower <= -100) || (antpower >= 20)) | |
679 | return 0; | |
680 | else if (antpower >= 0) | |
681 | return 100; | |
682 | else | |
683 | return 100 + antpower; | |
684 | } | |
685 | ||
686 | static u8 evm_db2percentage(s8 value) | |
687 | { | |
688 | /* | |
689 | * -33dB~0dB to 0%~99% | |
690 | */ | |
691 | s8 ret_val; | |
692 | ||
693 | ret_val = value; | |
694 | if (ret_val >= 0) | |
695 | ret_val = 0; | |
696 | if (ret_val <= -33) | |
697 | ret_val = -33; | |
698 | ret_val = -ret_val; | |
699 | ret_val *= 3; | |
700 | if (ret_val == 99) | |
701 | ret_val = 100; | |
702 | return ret_val; | |
703 | } | |
704 | ||
705 | s32 r8712_signal_scale_mapping(s32 cur_sig) | |
706 | { | |
707 | s32 ret_sig; | |
708 | ||
709 | if (cur_sig >= 51 && cur_sig <= 100) | |
710 | ret_sig = 100; | |
711 | else if (cur_sig >= 41 && cur_sig <= 50) | |
712 | ret_sig = 80 + ((cur_sig - 40) * 2); | |
713 | else if (cur_sig >= 31 && cur_sig <= 40) | |
714 | ret_sig = 66 + (cur_sig - 30); | |
715 | else if (cur_sig >= 21 && cur_sig <= 30) | |
716 | ret_sig = 54 + (cur_sig - 20); | |
717 | else if (cur_sig >= 10 && cur_sig <= 20) | |
718 | ret_sig = 42 + (((cur_sig - 10) * 2) / 3); | |
719 | else if (cur_sig >= 5 && cur_sig <= 9) | |
720 | ret_sig = 22 + (((cur_sig - 5) * 3) / 2); | |
721 | else if (cur_sig >= 1 && cur_sig <= 4) | |
722 | ret_sig = 6 + (((cur_sig - 1) * 3) / 2); | |
723 | else | |
724 | ret_sig = cur_sig; | |
725 | return ret_sig; | |
726 | } | |
727 | ||
728 | static s32 translate2dbm(struct _adapter *padapter, u8 signal_strength_idx) | |
729 | { | |
730 | s32 signal_power; /* in dBm.*/ | |
731 | /* Translate to dBm (x=0.5y-95).*/ | |
732 | signal_power = (s32)((signal_strength_idx + 1) >> 1); | |
733 | signal_power -= 95; | |
734 | return signal_power; | |
735 | } | |
736 | ||
737 | static void query_rx_phy_status(struct _adapter *padapter, | |
738 | union recv_frame *prframe) | |
739 | { | |
740 | u8 i, max_spatial_stream, evm; | |
741 | struct recv_stat *prxstat = (struct recv_stat *)prframe->u.hdr.rx_head; | |
742 | struct phy_stat *pphy_stat = (struct phy_stat *)(prxstat + 1); | |
743 | u8 *pphy_head = (u8 *)(prxstat + 1); | |
744 | s8 rx_pwr[4], rx_pwr_all; | |
745 | u8 pwdb_all; | |
746 | u32 rssi, total_rssi = 0; | |
747 | u8 bcck_rate = 0, rf_rx_num = 0, cck_highpwr = 0; | |
748 | struct phy_cck_rx_status *pcck_buf; | |
749 | u8 sq; | |
750 | ||
751 | /* Record it for next packet processing*/ | |
752 | bcck_rate = (prframe->u.hdr.attrib.mcs_rate <= 3 ? 1 : 0); | |
753 | if (bcck_rate) { | |
754 | u8 report; | |
755 | ||
756 | /* CCK Driver info Structure is not the same as OFDM packet.*/ | |
757 | pcck_buf = (struct phy_cck_rx_status *)pphy_stat; | |
758 | /* (1)Hardware does not provide RSSI for CCK | |
dec9fcd0 | 759 | * (2)PWDB, Average PWDB calculated by hardware |
2865d42c LF |
760 | * (for rate adaptive) |
761 | */ | |
762 | if (!cck_highpwr) { | |
763 | report = pcck_buf->cck_agc_rpt & 0xc0; | |
5c7c5d80 | 764 | report >>= 6; |
2865d42c LF |
765 | switch (report) { |
766 | /* Modify the RF RNA gain value to -40, -20, | |
767 | * -2, 14 by Jenyu's suggestion | |
768 | * Note: different RF with the different | |
bef611a9 RB |
769 | * RNA gain. |
770 | */ | |
2865d42c LF |
771 | case 0x3: |
772 | rx_pwr_all = -40 - (pcck_buf->cck_agc_rpt & | |
773 | 0x3e); | |
774 | break; | |
775 | case 0x2: | |
776 | rx_pwr_all = -20 - (pcck_buf->cck_agc_rpt & | |
777 | 0x3e); | |
778 | break; | |
779 | case 0x1: | |
780 | rx_pwr_all = -2 - (pcck_buf->cck_agc_rpt & | |
781 | 0x3e); | |
782 | break; | |
783 | case 0x0: | |
784 | rx_pwr_all = 14 - (pcck_buf->cck_agc_rpt & | |
785 | 0x3e); | |
786 | break; | |
787 | } | |
788 | } else { | |
789 | report = ((u8)(le32_to_cpu(pphy_stat->phydw1) >> 8)) & | |
790 | 0x60; | |
5c7c5d80 | 791 | report >>= 5; |
2865d42c LF |
792 | switch (report) { |
793 | case 0x3: | |
794 | rx_pwr_all = -40 - ((pcck_buf->cck_agc_rpt & | |
795 | 0x1f) << 1); | |
796 | break; | |
797 | case 0x2: | |
798 | rx_pwr_all = -20 - ((pcck_buf->cck_agc_rpt & | |
799 | 0x1f) << 1); | |
800 | break; | |
801 | case 0x1: | |
802 | rx_pwr_all = -2 - ((pcck_buf->cck_agc_rpt & | |
803 | 0x1f) << 1); | |
804 | break; | |
805 | case 0x0: | |
806 | rx_pwr_all = 14 - ((pcck_buf->cck_agc_rpt & | |
807 | 0x1f) << 1); | |
808 | break; | |
809 | } | |
810 | } | |
811 | pwdb_all = query_rx_pwr_percentage(rx_pwr_all); | |
812 | /* CCK gain is smaller than OFDM/MCS gain,*/ | |
813 | /* so we add gain diff by experiences, the val is 6 */ | |
814 | pwdb_all += 6; | |
815 | if (pwdb_all > 100) | |
816 | pwdb_all = 100; | |
817 | /* modify the offset to make the same gain index with OFDM.*/ | |
818 | if (pwdb_all > 34 && pwdb_all <= 42) | |
819 | pwdb_all -= 2; | |
820 | else if (pwdb_all > 26 && pwdb_all <= 34) | |
821 | pwdb_all -= 6; | |
822 | else if (pwdb_all > 14 && pwdb_all <= 26) | |
823 | pwdb_all -= 8; | |
824 | else if (pwdb_all > 4 && pwdb_all <= 14) | |
825 | pwdb_all -= 4; | |
826 | /* | |
827 | * (3) Get Signal Quality (EVM) | |
828 | */ | |
168a2c10 | 829 | if (pwdb_all > 40) { |
2865d42c | 830 | sq = 100; |
168a2c10 | 831 | } else { |
2865d42c LF |
832 | sq = pcck_buf->sq_rpt; |
833 | if (pcck_buf->sq_rpt > 64) | |
834 | sq = 0; | |
835 | else if (pcck_buf->sq_rpt < 20) | |
836 | sq = 100; | |
837 | else | |
4ef2de5a | 838 | sq = ((64 - sq) * 100) / 44; |
2865d42c LF |
839 | } |
840 | prframe->u.hdr.attrib.signal_qual = sq; | |
841 | prframe->u.hdr.attrib.rx_mimo_signal_qual[0] = sq; | |
842 | prframe->u.hdr.attrib.rx_mimo_signal_qual[1] = -1; | |
843 | } else { | |
844 | /* (1)Get RSSI for HT rate */ | |
845 | for (i = 0; i < ((padapter->registrypriv.rf_config) & | |
77e73e8c | 846 | 0x0f); i++) { |
2865d42c LF |
847 | rf_rx_num++; |
848 | rx_pwr[i] = ((pphy_head[PHY_STAT_GAIN_TRSW_SHT + i] | |
849 | & 0x3F) * 2) - 110; | |
850 | /* Translate DBM to percentage. */ | |
851 | rssi = query_rx_pwr_percentage(rx_pwr[i]); | |
852 | total_rssi += rssi; | |
853 | } | |
dec9fcd0 | 854 | /* (2)PWDB, Average PWDB calculated by hardware (for |
bef611a9 RB |
855 | * rate adaptive) |
856 | */ | |
2865d42c LF |
857 | rx_pwr_all = (((pphy_head[PHY_STAT_PWDB_ALL_SHT]) >> 1) & 0x7f) |
858 | - 106; | |
859 | pwdb_all = query_rx_pwr_percentage(rx_pwr_all); | |
860 | ||
861 | { | |
862 | /* (3)EVM of HT rate */ | |
863 | if (prframe->u.hdr.attrib.htc && | |
864 | prframe->u.hdr.attrib.mcs_rate >= 20 && | |
865 | prframe->u.hdr.attrib.mcs_rate <= 27) { | |
866 | /* both spatial stream make sense */ | |
867 | max_spatial_stream = 2; | |
868 | } else { | |
869 | /* only spatial stream 1 makes sense */ | |
870 | max_spatial_stream = 1; | |
871 | } | |
872 | for (i = 0; i < max_spatial_stream; i++) { | |
873 | evm = evm_db2percentage((pphy_head | |
874 | [PHY_STAT_RXEVM_SHT + i]));/*dbm*/ | |
875 | prframe->u.hdr.attrib.signal_qual = | |
876 | (u8)(evm & 0xff); | |
877 | prframe->u.hdr.attrib.rx_mimo_signal_qual[i] = | |
878 | (u8)(evm & 0xff); | |
879 | } | |
880 | } | |
881 | } | |
882 | /* UI BSS List signal strength(in percentage), make it good looking, | |
883 | * from 0~100. It is assigned to the BSS List in | |
bef611a9 RB |
884 | * GetValueFromBeaconOrProbeRsp(). |
885 | */ | |
2865d42c LF |
886 | if (bcck_rate) |
887 | prframe->u.hdr.attrib.signal_strength = | |
888 | (u8)r8712_signal_scale_mapping(pwdb_all); | |
889 | else { | |
890 | if (rf_rx_num != 0) | |
891 | prframe->u.hdr.attrib.signal_strength = | |
892 | (u8)(r8712_signal_scale_mapping(total_rssi /= | |
893 | rf_rx_num)); | |
894 | } | |
895 | } | |
896 | ||
897 | static void process_link_qual(struct _adapter *padapter, | |
898 | union recv_frame *prframe) | |
899 | { | |
900 | u32 last_evm = 0, tmpVal; | |
901 | struct rx_pkt_attrib *pattrib; | |
902 | ||
903 | if (prframe == NULL || padapter == NULL) | |
904 | return; | |
905 | pattrib = &prframe->u.hdr.attrib; | |
906 | if (pattrib->signal_qual != 0) { | |
907 | /* | |
908 | * 1. Record the general EVM to the sliding window. | |
909 | */ | |
910 | if (padapter->recvpriv.signal_qual_data.total_num++ >= | |
911 | PHY_LINKQUALITY_SLID_WIN_MAX) { | |
912 | padapter->recvpriv.signal_qual_data.total_num = | |
913 | PHY_LINKQUALITY_SLID_WIN_MAX; | |
914 | last_evm = padapter->recvpriv.signal_qual_data.elements | |
915 | [padapter->recvpriv.signal_qual_data.index]; | |
916 | padapter->recvpriv.signal_qual_data.total_val -= | |
917 | last_evm; | |
918 | } | |
919 | padapter->recvpriv.signal_qual_data.total_val += | |
920 | pattrib->signal_qual; | |
921 | padapter->recvpriv.signal_qual_data.elements[padapter-> | |
922 | recvpriv.signal_qual_data.index++] = | |
923 | pattrib->signal_qual; | |
924 | if (padapter->recvpriv.signal_qual_data.index >= | |
925 | PHY_LINKQUALITY_SLID_WIN_MAX) | |
926 | padapter->recvpriv.signal_qual_data.index = 0; | |
927 | ||
928 | /* <1> Showed on UI for user, in percentage. */ | |
929 | tmpVal = padapter->recvpriv.signal_qual_data.total_val / | |
930 | padapter->recvpriv.signal_qual_data.total_num; | |
931 | padapter->recvpriv.signal = (u8)tmpVal; | |
932 | } | |
933 | } | |
934 | ||
935 | static void process_rssi(struct _adapter *padapter, union recv_frame *prframe) | |
936 | { | |
937 | u32 last_rssi, tmp_val; | |
938 | struct rx_pkt_attrib *pattrib = &prframe->u.hdr.attrib; | |
939 | ||
940 | if (padapter->recvpriv.signal_strength_data.total_num++ >= | |
941 | PHY_RSSI_SLID_WIN_MAX) { | |
942 | padapter->recvpriv.signal_strength_data.total_num = | |
943 | PHY_RSSI_SLID_WIN_MAX; | |
944 | last_rssi = padapter->recvpriv.signal_strength_data.elements | |
945 | [padapter->recvpriv.signal_strength_data.index]; | |
946 | padapter->recvpriv.signal_strength_data.total_val -= last_rssi; | |
947 | } | |
948 | padapter->recvpriv.signal_strength_data.total_val += | |
949 | pattrib->signal_strength; | |
950 | padapter->recvpriv.signal_strength_data.elements[padapter->recvpriv. | |
951 | signal_strength_data.index++] = | |
952 | pattrib->signal_strength; | |
953 | if (padapter->recvpriv.signal_strength_data.index >= | |
954 | PHY_RSSI_SLID_WIN_MAX) | |
955 | padapter->recvpriv.signal_strength_data.index = 0; | |
956 | tmp_val = padapter->recvpriv.signal_strength_data.total_val / | |
957 | padapter->recvpriv.signal_strength_data.total_num; | |
958 | padapter->recvpriv.rssi = (s8)translate2dbm(padapter, (u8)tmp_val); | |
959 | } | |
960 | ||
961 | static void process_phy_info(struct _adapter *padapter, | |
962 | union recv_frame *prframe) | |
963 | { | |
964 | query_rx_phy_status(padapter, prframe); | |
965 | process_rssi(padapter, prframe); | |
966 | process_link_qual(padapter, prframe); | |
967 | } | |
968 | ||
969 | int recv_func(struct _adapter *padapter, void *pcontext) | |
970 | { | |
971 | struct rx_pkt_attrib *pattrib; | |
972 | union recv_frame *prframe, *orig_prframe; | |
973 | int retval = _SUCCESS; | |
974 | struct __queue *pfree_recv_queue = &padapter->recvpriv.free_recv_queue; | |
975 | struct mlme_priv *pmlmepriv = &padapter->mlmepriv; | |
976 | ||
c66de311 | 977 | prframe = pcontext; |
2865d42c LF |
978 | orig_prframe = prframe; |
979 | pattrib = &prframe->u.hdr.attrib; | |
1ca96884 | 980 | if (check_fwstate(pmlmepriv, WIFI_MP_STATE)) { |
2865d42c LF |
981 | if (pattrib->crc_err == 1) |
982 | padapter->mppriv.rx_crcerrpktcount++; | |
983 | else | |
984 | padapter->mppriv.rx_pktcount++; | |
1ca96884 | 985 | if (!check_fwstate(pmlmepriv, WIFI_MP_LPBK_STATE)) { |
2865d42c LF |
986 | /* free this recv_frame */ |
987 | r8712_free_recvframe(orig_prframe, pfree_recv_queue); | |
988 | goto _exit_recv_func; | |
989 | } | |
990 | } | |
991 | /* check the frame crtl field and decache */ | |
992 | retval = r8712_validate_recv_frame(padapter, prframe); | |
993 | if (retval != _SUCCESS) { | |
994 | /* free this recv_frame */ | |
995 | r8712_free_recvframe(orig_prframe, pfree_recv_queue); | |
996 | goto _exit_recv_func; | |
997 | } | |
998 | process_phy_info(padapter, prframe); | |
999 | prframe = r8712_decryptor(padapter, prframe); | |
a667dbce | 1000 | if (!prframe) { |
2865d42c LF |
1001 | retval = _FAIL; |
1002 | goto _exit_recv_func; | |
1003 | } | |
1004 | prframe = r8712_recvframe_chk_defrag(padapter, prframe); | |
a667dbce | 1005 | if (!prframe) |
2865d42c LF |
1006 | goto _exit_recv_func; |
1007 | prframe = r8712_portctrl(padapter, prframe); | |
a667dbce | 1008 | if (!prframe) { |
2865d42c LF |
1009 | retval = _FAIL; |
1010 | goto _exit_recv_func; | |
1011 | } | |
1012 | retval = r8712_process_recv_indicatepkts(padapter, prframe); | |
1013 | if (retval != _SUCCESS) { | |
1014 | r8712_free_recvframe(orig_prframe, pfree_recv_queue); | |
1015 | goto _exit_recv_func; | |
1016 | } | |
1017 | _exit_recv_func: | |
1018 | return retval; | |
1019 | } | |
1020 | ||
1021 | static int recvbuf2recvframe(struct _adapter *padapter, struct sk_buff *pskb) | |
1022 | { | |
1023 | u8 *pbuf, shift_sz = 0; | |
1024 | u8 frag, mf; | |
1025 | uint pkt_len; | |
1026 | u32 transfer_len; | |
1027 | struct recv_stat *prxstat; | |
1028 | u16 pkt_cnt, drvinfo_sz, pkt_offset, tmp_len, alloc_sz; | |
1029 | struct __queue *pfree_recv_queue; | |
1030 | _pkt *pkt_copy = NULL; | |
1031 | union recv_frame *precvframe = NULL; | |
1032 | struct recv_priv *precvpriv = &padapter->recvpriv; | |
1033 | ||
1034 | pfree_recv_queue = &(precvpriv->free_recv_queue); | |
1035 | pbuf = pskb->data; | |
1036 | prxstat = (struct recv_stat *)pbuf; | |
4ef2de5a LB |
1037 | pkt_cnt = (le32_to_cpu(prxstat->rxdw2) >> 16) & 0xff; |
1038 | pkt_len = le32_to_cpu(prxstat->rxdw0) & 0x00003fff; | |
2865d42c LF |
1039 | transfer_len = pskb->len; |
1040 | /* Test throughput with Netgear 3700 (No security) with Chariot 3T3R | |
1041 | * pairs. The packet count will be a big number so that the containing | |
bef611a9 RB |
1042 | * packet will effect the Rx reordering. |
1043 | */ | |
2865d42c LF |
1044 | if (transfer_len < pkt_len) { |
1045 | /* In this case, it means the MAX_RECVBUF_SZ is too small to | |
bef611a9 RB |
1046 | * get the data from 8712u. |
1047 | */ | |
2865d42c LF |
1048 | return _FAIL; |
1049 | } | |
1050 | do { | |
1051 | prxstat = (struct recv_stat *)pbuf; | |
4ef2de5a | 1052 | pkt_len = le32_to_cpu(prxstat->rxdw0) & 0x00003fff; |
2865d42c LF |
1053 | /* more fragment bit */ |
1054 | mf = (le32_to_cpu(prxstat->rxdw1) >> 27) & 0x1; | |
1055 | /* ragmentation number */ | |
1056 | frag = (le32_to_cpu(prxstat->rxdw2) >> 12) & 0xf; | |
1057 | /* uint 2^3 = 8 bytes */ | |
1058 | drvinfo_sz = (le32_to_cpu(prxstat->rxdw0) & 0x000f0000) >> 16; | |
5c7c5d80 | 1059 | drvinfo_sz <<= 3; |
2865d42c LF |
1060 | if (pkt_len <= 0) |
1061 | goto _exit_recvbuf2recvframe; | |
1062 | /* Qos data, wireless lan header length is 26 */ | |
1063 | if ((le32_to_cpu(prxstat->rxdw0) >> 23) & 0x01) | |
1064 | shift_sz = 2; | |
1065 | precvframe = r8712_alloc_recvframe(pfree_recv_queue); | |
a667dbce | 1066 | if (!precvframe) |
2865d42c | 1067 | goto _exit_recvbuf2recvframe; |
534c4acd | 1068 | INIT_LIST_HEAD(&precvframe->u.hdr.list); |
2865d42c LF |
1069 | precvframe->u.hdr.precvbuf = NULL; /*can't access the precvbuf*/ |
1070 | precvframe->u.hdr.len = 0; | |
1071 | tmp_len = pkt_len + drvinfo_sz + RXDESC_SIZE; | |
fa867453 | 1072 | pkt_offset = (u16)round_up(tmp_len, 128); |
2865d42c | 1073 | /* for first fragment packet, driver need allocate 1536 + |
bef611a9 RB |
1074 | * drvinfo_sz + RXDESC_SIZE to defrag packet. |
1075 | */ | |
2865d42c | 1076 | if ((mf == 1) && (frag == 0)) |
cab46214 HE |
1077 | /*1658+6=1664, 1664 is 128 alignment.*/ |
1078 | alloc_sz = max_t(u16, tmp_len, 1658); | |
2865d42c LF |
1079 | else |
1080 | alloc_sz = tmp_len; | |
1081 | /* 2 is for IP header 4 bytes alignment in QoS packet case. | |
bef611a9 RB |
1082 | * 4 is for skb->data 4 bytes alignment. |
1083 | */ | |
2865d42c LF |
1084 | alloc_sz += 6; |
1085 | pkt_copy = netdev_alloc_skb(padapter->pnetdev, alloc_sz); | |
1086 | if (pkt_copy) { | |
2865d42c LF |
1087 | precvframe->u.hdr.pkt = pkt_copy; |
1088 | skb_reserve(pkt_copy, 4 - ((addr_t)(pkt_copy->data) | |
1089 | % 4)); | |
1090 | skb_reserve(pkt_copy, shift_sz); | |
1091 | memcpy(pkt_copy->data, pbuf, tmp_len); | |
1092 | precvframe->u.hdr.rx_head = precvframe->u.hdr.rx_data = | |
1093 | precvframe->u.hdr.rx_tail = pkt_copy->data; | |
1094 | precvframe->u.hdr.rx_end = pkt_copy->data + alloc_sz; | |
1095 | } else { | |
1096 | precvframe->u.hdr.pkt = skb_clone(pskb, GFP_ATOMIC); | |
5ca136a0 LF |
1097 | if (!precvframe->u.hdr.pkt) |
1098 | return _FAIL; | |
2865d42c LF |
1099 | precvframe->u.hdr.rx_head = pbuf; |
1100 | precvframe->u.hdr.rx_data = pbuf; | |
1101 | precvframe->u.hdr.rx_tail = pbuf; | |
1102 | precvframe->u.hdr.rx_end = pbuf + alloc_sz; | |
1103 | } | |
1104 | recvframe_put(precvframe, tmp_len); | |
1105 | recvframe_pull(precvframe, drvinfo_sz + RXDESC_SIZE); | |
1106 | /* because the endian issue, driver avoid reference to the | |
1107 | * rxstat after calling update_recvframe_attrib_from_recvstat(); | |
1108 | */ | |
1109 | update_recvframe_attrib_from_recvstat(&precvframe->u.hdr.attrib, | |
1110 | prxstat); | |
1111 | r8712_recv_entry(precvframe); | |
1112 | transfer_len -= pkt_offset; | |
1113 | pbuf += pkt_offset; | |
1114 | pkt_cnt--; | |
1115 | precvframe = NULL; | |
1116 | pkt_copy = NULL; | |
1117 | } while ((transfer_len > 0) && pkt_cnt > 0); | |
1118 | _exit_recvbuf2recvframe: | |
1119 | return _SUCCESS; | |
1120 | } | |
1121 | ||
1122 | static void recv_tasklet(void *priv) | |
1123 | { | |
1124 | struct sk_buff *pskb; | |
c66de311 | 1125 | struct _adapter *padapter = priv; |
2865d42c LF |
1126 | struct recv_priv *precvpriv = &padapter->recvpriv; |
1127 | ||
1128 | while (NULL != (pskb = skb_dequeue(&precvpriv->rx_skb_queue))) { | |
1129 | recvbuf2recvframe(padapter, pskb); | |
1130 | skb_reset_tail_pointer(pskb); | |
1131 | pskb->len = 0; | |
fa16e5ea LF |
1132 | if (!skb_cloned(pskb)) |
1133 | skb_queue_tail(&precvpriv->free_recv_skb_queue, pskb); | |
1134 | else | |
1135 | consume_skb(pskb); | |
2865d42c LF |
1136 | } |
1137 | } |