1 /******************************************************************************
2 *
3 * Copyright(c) 2007 - 2012 Realtek Corporation. All rights reserved.
4 *
5 * This program is free software; you can redistribute it and/or modify it
6 * under the terms of version 2 of the GNU General Public License as
7 * published by the Free Software Foundation.
8 *
9 * This program is distributed in the hope that it will be useful, but WITHOUT
10 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
12 * more details.
13 *
14 ******************************************************************************/
15 #define _RTL8723BS_RECV_C_
16
17 #include <drv_types.h>
18 #include <rtw_debug.h>
19 #include <rtl8723b_hal.h>
20
21
initrecvbuf(struct recv_buf * precvbuf,struct adapter * padapter)22 static s32 initrecvbuf(struct recv_buf *precvbuf, struct adapter *padapter)
23 {
24 INIT_LIST_HEAD(&precvbuf->list);
25 spin_lock_init(&precvbuf->recvbuf_lock);
26
27 precvbuf->adapter = padapter;
28
29 return _SUCCESS;
30 }
31
update_recvframe_attrib(struct adapter * padapter,union recv_frame * precvframe,struct recv_stat * prxstat)32 static void update_recvframe_attrib(
33 struct adapter *padapter, union recv_frame *precvframe, struct recv_stat *prxstat
34 )
35 {
36 struct rx_pkt_attrib *pattrib;
37 struct recv_stat report;
38 PRXREPORT prxreport = (PRXREPORT)&report;
39
40 report.rxdw0 = prxstat->rxdw0;
41 report.rxdw1 = prxstat->rxdw1;
42 report.rxdw2 = prxstat->rxdw2;
43 report.rxdw3 = prxstat->rxdw3;
44 report.rxdw4 = prxstat->rxdw4;
45 report.rxdw5 = prxstat->rxdw5;
46
47 pattrib = &precvframe->u.hdr.attrib;
48 memset(pattrib, 0, sizeof(struct rx_pkt_attrib));
49
50 /* update rx report to recv_frame attribute */
51 pattrib->pkt_rpt_type = prxreport->c2h_ind?C2H_PACKET:NORMAL_RX;
52 /* DBG_871X("%s: pkt_rpt_type =%d\n", __func__, pattrib->pkt_rpt_type); */
53
54 if (pattrib->pkt_rpt_type == NORMAL_RX) {
55 /* Normal rx packet */
56 /* update rx report to recv_frame attribute */
57 pattrib->pkt_len = (u16)prxreport->pktlen;
58 pattrib->drvinfo_sz = (u8)(prxreport->drvinfosize << 3);
59 pattrib->physt = (u8)prxreport->physt;
60
61 pattrib->crc_err = (u8)prxreport->crc32;
62 pattrib->icv_err = (u8)prxreport->icverr;
63
64 pattrib->bdecrypted = (u8)(prxreport->swdec ? 0 : 1);
65 pattrib->encrypt = (u8)prxreport->security;
66
67 pattrib->qos = (u8)prxreport->qos;
68 pattrib->priority = (u8)prxreport->tid;
69
70 pattrib->amsdu = (u8)prxreport->amsdu;
71
72 pattrib->seq_num = (u16)prxreport->seq;
73 pattrib->frag_num = (u8)prxreport->frag;
74 pattrib->mfrag = (u8)prxreport->mf;
75 pattrib->mdata = (u8)prxreport->md;
76
77 pattrib->data_rate = (u8)prxreport->rx_rate;
78 } else
79 pattrib->pkt_len = (u16)prxreport->pktlen;
80 }
81
82 /*
83 * Notice:
84 *Before calling this function,
85 *precvframe->u.hdr.rx_data should be ready!
86 */
update_recvframe_phyinfo(union recv_frame * precvframe,struct phy_stat * pphy_status)87 static void update_recvframe_phyinfo(
88 union recv_frame *precvframe, struct phy_stat *pphy_status
89 )
90 {
91 struct adapter *padapter = precvframe->u.hdr.adapter;
92 struct rx_pkt_attrib *pattrib = &precvframe->u.hdr.attrib;
93 struct hal_com_data *pHalData = GET_HAL_DATA(padapter);
94 PODM_PHY_INFO_T pPHYInfo = (PODM_PHY_INFO_T)(&pattrib->phy_info);
95
96 u8 *wlanhdr;
97 ODM_PACKET_INFO_T pkt_info;
98 u8 *sa = NULL;
99 /* _irqL irqL; */
100 struct sta_priv *pstapriv;
101 struct sta_info *psta;
102
103 pkt_info.bPacketMatchBSSID = false;
104 pkt_info.bPacketToSelf = false;
105 pkt_info.bPacketBeacon = false;
106
107
108 wlanhdr = get_recvframe_data(precvframe);
109
110 pkt_info.bPacketMatchBSSID = ((!IsFrameTypeCtrl(wlanhdr)) &&
111 !pattrib->icv_err && !pattrib->crc_err &&
112 !memcmp(get_hdr_bssid(wlanhdr), get_bssid(&padapter->mlmepriv), ETH_ALEN));
113
114 pkt_info.bPacketToSelf = pkt_info.bPacketMatchBSSID && (!memcmp(get_ra(wlanhdr), myid(&padapter->eeprompriv), ETH_ALEN));
115
116 pkt_info.bPacketBeacon = pkt_info.bPacketMatchBSSID && (GetFrameSubType(wlanhdr) == WIFI_BEACON);
117
118 sa = get_ta(wlanhdr);
119
120 pkt_info.StationID = 0xFF;
121
122 pstapriv = &padapter->stapriv;
123 psta = rtw_get_stainfo(pstapriv, sa);
124 if (psta) {
125 pkt_info.StationID = psta->mac_id;
126 /* DBG_8192C("%s ==> StationID(%d)\n", __func__, pkt_info.StationID); */
127 }
128 pkt_info.DataRate = pattrib->data_rate;
129
130 /* rtl8723b_query_rx_phy_status(precvframe, pphy_status); */
131 /* spin_lock_bh(&pHalData->odm_stainfo_lock); */
132 ODM_PhyStatusQuery(&pHalData->odmpriv, pPHYInfo, (u8 *)pphy_status, &(pkt_info));
133 if (psta)
134 psta->rssi = pattrib->phy_info.RecvSignalPower;
135 /* spin_unlock_bh(&pHalData->odm_stainfo_lock); */
136 precvframe->u.hdr.psta = NULL;
137 if (
138 pkt_info.bPacketMatchBSSID &&
139 (check_fwstate(&padapter->mlmepriv, WIFI_AP_STATE) == true)
140 ) {
141 if (psta) {
142 precvframe->u.hdr.psta = psta;
143 rtl8723b_process_phy_info(padapter, precvframe);
144 }
145 } else if (pkt_info.bPacketToSelf || pkt_info.bPacketBeacon) {
146 if (check_fwstate(&padapter->mlmepriv, WIFI_ADHOC_STATE|WIFI_ADHOC_MASTER_STATE) == true)
147 if (psta)
148 precvframe->u.hdr.psta = psta;
149 rtl8723b_process_phy_info(padapter, precvframe);
150 }
151 }
152
rtl8723bs_c2h_packet_handler(struct adapter * padapter,u8 * pbuf,u16 length)153 static void rtl8723bs_c2h_packet_handler(struct adapter *padapter, u8 *pbuf, u16 length)
154 {
155 u8 *tmpBuf = NULL;
156 u8 res = false;
157
158 if (length == 0)
159 return;
160
161 /* DBG_871X("+%s() length =%d\n", __func__, length); */
162
163 tmpBuf = rtw_zmalloc(length);
164 if (tmpBuf == NULL)
165 return;
166
167 memcpy(tmpBuf, pbuf, length);
168
169 res = rtw_c2h_packet_wk_cmd(padapter, tmpBuf, length);
170
171 if (res == false)
172 kfree(tmpBuf);
173
174 /* DBG_871X("-%s res(%d)\n", __func__, res); */
175
176 return;
177 }
178
rtl8723bs_recv_tasklet(void * priv)179 static void rtl8723bs_recv_tasklet(void *priv)
180 {
181 struct adapter *padapter;
182 struct hal_com_data *pHalData;
183 struct recv_priv *precvpriv;
184 struct recv_buf *precvbuf;
185 union recv_frame *precvframe;
186 struct rx_pkt_attrib *pattrib;
187 u8 *ptr;
188 u32 pkt_offset, skb_len, alloc_sz;
189 _pkt *pkt_copy = NULL;
190 u8 shift_sz = 0, rx_report_sz = 0;
191
192
193 padapter = priv;
194 pHalData = GET_HAL_DATA(padapter);
195 precvpriv = &padapter->recvpriv;
196
197 do {
198 precvbuf = rtw_dequeue_recvbuf(&precvpriv->recv_buf_pending_queue);
199 if (NULL == precvbuf)
200 break;
201
202 ptr = precvbuf->pdata;
203
204 while (ptr < precvbuf->ptail) {
205 precvframe = rtw_alloc_recvframe(&precvpriv->free_recv_queue);
206 if (precvframe == NULL) {
207 DBG_8192C("%s: no enough recv frame!\n", __func__);
208 rtw_enqueue_recvbuf_to_head(precvbuf, &precvpriv->recv_buf_pending_queue);
209
210 /* The case of can't allocte recvframe should be temporary, */
211 /* schedule again and hope recvframe is available next time. */
212 tasklet_schedule(&precvpriv->recv_tasklet);
213 return;
214 }
215
216 /* rx desc parsing */
217 update_recvframe_attrib(padapter, precvframe, (struct recv_stat *)ptr);
218
219 pattrib = &precvframe->u.hdr.attrib;
220
221 /* fix Hardware RX data error, drop whole recv_buffer */
222 if ((!(pHalData->ReceiveConfig & RCR_ACRC32)) && pattrib->crc_err) {
223 DBG_8192C("%s()-%d: RX Warning! rx CRC ERROR !!\n", __func__, __LINE__);
224 rtw_free_recvframe(precvframe, &precvpriv->free_recv_queue);
225 break;
226 }
227
228 rx_report_sz = RXDESC_SIZE + pattrib->drvinfo_sz;
229 pkt_offset = rx_report_sz + pattrib->shift_sz + pattrib->pkt_len;
230
231 if ((ptr + pkt_offset) > precvbuf->ptail) {
232 DBG_8192C("%s()-%d: : next pkt len(%p,%d) exceed ptail(%p)!\n", __func__, __LINE__, ptr, pkt_offset, precvbuf->ptail);
233 rtw_free_recvframe(precvframe, &precvpriv->free_recv_queue);
234 break;
235 }
236
237 if ((pattrib->crc_err) || (pattrib->icv_err)) {
238 {
239 DBG_8192C("%s: crc_err =%d icv_err =%d, skip!\n", __func__, pattrib->crc_err, pattrib->icv_err);
240 }
241 rtw_free_recvframe(precvframe, &precvpriv->free_recv_queue);
242 } else {
243 /* Modified by Albert 20101213 */
244 /* For 8 bytes IP header alignment. */
245 if (pattrib->qos) /* Qos data, wireless lan header length is 26 */
246 shift_sz = 6;
247 else
248 shift_sz = 0;
249
250 skb_len = pattrib->pkt_len;
251
252 /* for first fragment packet, driver need allocate 1536+drvinfo_sz+RXDESC_SIZE to defrag packet. */
253 /* modify alloc_sz for recvive crc error packet by thomas 2011-06-02 */
254 if ((pattrib->mfrag == 1) && (pattrib->frag_num == 0)) {
255 if (skb_len <= 1650)
256 alloc_sz = 1664;
257 else
258 alloc_sz = skb_len + 14;
259 } else {
260 alloc_sz = skb_len;
261 /* 6 is for IP header 8 bytes alignment in QoS packet case. */
262 /* 8 is for skb->data 4 bytes alignment. */
263 alloc_sz += 14;
264 }
265
266 pkt_copy = rtw_skb_alloc(alloc_sz);
267
268 if (pkt_copy) {
269 pkt_copy->dev = padapter->pnetdev;
270 precvframe->u.hdr.pkt = pkt_copy;
271 skb_reserve(pkt_copy, 8 - ((SIZE_PTR)(pkt_copy->data) & 7));/* force pkt_copy->data at 8-byte alignment address */
272 skb_reserve(pkt_copy, shift_sz);/* force ip_hdr at 8-byte alignment address according to shift_sz. */
273 memcpy(pkt_copy->data, (ptr + rx_report_sz + pattrib->shift_sz), skb_len);
274 precvframe->u.hdr.rx_head = pkt_copy->head;
275 precvframe->u.hdr.rx_data = precvframe->u.hdr.rx_tail = pkt_copy->data;
276 precvframe->u.hdr.rx_end = skb_end_pointer(pkt_copy);
277 } else {
278 if ((pattrib->mfrag == 1) && (pattrib->frag_num == 0)) {
279 DBG_8192C("%s: alloc_skb fail, drop frag frame\n", __func__);
280 rtw_free_recvframe(precvframe, &precvpriv->free_recv_queue);
281 break;
282 }
283
284 precvframe->u.hdr.pkt = rtw_skb_clone(precvbuf->pskb);
285 if (precvframe->u.hdr.pkt) {
286 _pkt *pkt_clone = precvframe->u.hdr.pkt;
287
288 pkt_clone->data = ptr + rx_report_sz + pattrib->shift_sz;
289 skb_reset_tail_pointer(pkt_clone);
290 precvframe->u.hdr.rx_head = precvframe->u.hdr.rx_data = precvframe->u.hdr.rx_tail
291 = pkt_clone->data;
292 precvframe->u.hdr.rx_end = pkt_clone->data + skb_len;
293 } else {
294 DBG_8192C("%s: rtw_skb_clone fail\n", __func__);
295 rtw_free_recvframe(precvframe, &precvpriv->free_recv_queue);
296 break;
297 }
298 }
299
300 recvframe_put(precvframe, skb_len);
301 /* recvframe_pull(precvframe, drvinfo_sz + RXDESC_SIZE); */
302
303 if (pHalData->ReceiveConfig & RCR_APPFCS)
304 recvframe_pull_tail(precvframe, IEEE80211_FCS_LEN);
305
306 /* move to drv info position */
307 ptr += RXDESC_SIZE;
308
309 /* update drv info */
310 if (pHalData->ReceiveConfig & RCR_APP_BA_SSN) {
311 /* rtl8723s_update_bassn(padapter, pdrvinfo); */
312 ptr += 4;
313 }
314
315 if (pattrib->pkt_rpt_type == NORMAL_RX) { /* Normal rx packet */
316 if (pattrib->physt)
317 update_recvframe_phyinfo(precvframe, (struct phy_stat *)ptr);
318
319 if (rtw_recv_entry(precvframe) != _SUCCESS) {
320 RT_TRACE(_module_rtl871x_recv_c_, _drv_dump_, ("%s: rtw_recv_entry(precvframe) != _SUCCESS\n", __func__));
321 }
322 } else if (pattrib->pkt_rpt_type == C2H_PACKET) {
323 C2H_EVT_HDR C2hEvent;
324
325 u16 len_c2h = pattrib->pkt_len;
326 u8 *pbuf_c2h = precvframe->u.hdr.rx_data;
327 u8 *pdata_c2h;
328
329 C2hEvent.CmdID = pbuf_c2h[0];
330 C2hEvent.CmdSeq = pbuf_c2h[1];
331 C2hEvent.CmdLen = (len_c2h-2);
332 pdata_c2h = pbuf_c2h+2;
333
334 if (C2hEvent.CmdID == C2H_CCX_TX_RPT)
335 CCX_FwC2HTxRpt_8723b(padapter, pdata_c2h, C2hEvent.CmdLen);
336 else
337 rtl8723bs_c2h_packet_handler(padapter, precvframe->u.hdr.rx_data, pattrib->pkt_len);
338
339 rtw_free_recvframe(precvframe, &precvpriv->free_recv_queue);
340
341 }
342 }
343
344 pkt_offset = _RND8(pkt_offset);
345 precvbuf->pdata += pkt_offset;
346 ptr = precvbuf->pdata;
347 precvframe = NULL;
348 pkt_copy = NULL;
349 }
350
351 rtw_enqueue_recvbuf(precvbuf, &precvpriv->free_recv_buf_queue);
352 } while (1);
353
354 }
355
356 /*
357 * Initialize recv private variable for hardware dependent
358 * 1. recv buf
359 * 2. recv tasklet
360 *
361 */
rtl8723bs_init_recv_priv(struct adapter * padapter)362 s32 rtl8723bs_init_recv_priv(struct adapter *padapter)
363 {
364 s32 res;
365 u32 i, n;
366 struct recv_priv *precvpriv;
367 struct recv_buf *precvbuf;
368
369
370 res = _SUCCESS;
371 precvpriv = &padapter->recvpriv;
372
373 /* 3 1. init recv buffer */
374 _rtw_init_queue(&precvpriv->free_recv_buf_queue);
375 _rtw_init_queue(&precvpriv->recv_buf_pending_queue);
376
377 n = NR_RECVBUFF * sizeof(struct recv_buf) + 4;
378 precvpriv->pallocated_recv_buf = rtw_zmalloc(n);
379 if (precvpriv->pallocated_recv_buf == NULL) {
380 res = _FAIL;
381 RT_TRACE(_module_rtl871x_recv_c_, _drv_err_, ("alloc recv_buf fail!\n"));
382 goto exit;
383 }
384
385 precvpriv->precv_buf = (u8 *)N_BYTE_ALIGMENT((SIZE_PTR)(precvpriv->pallocated_recv_buf), 4);
386
387 /* init each recv buffer */
388 precvbuf = (struct recv_buf *)precvpriv->precv_buf;
389 for (i = 0; i < NR_RECVBUFF; i++) {
390 res = initrecvbuf(precvbuf, padapter);
391 if (res == _FAIL)
392 break;
393
394 if (precvbuf->pskb == NULL) {
395 SIZE_PTR tmpaddr = 0;
396 SIZE_PTR alignment = 0;
397
398 precvbuf->pskb = rtw_skb_alloc(MAX_RECVBUF_SZ + RECVBUFF_ALIGN_SZ);
399
400 if (precvbuf->pskb) {
401 precvbuf->pskb->dev = padapter->pnetdev;
402
403 tmpaddr = (SIZE_PTR)precvbuf->pskb->data;
404 alignment = tmpaddr & (RECVBUFF_ALIGN_SZ-1);
405 skb_reserve(precvbuf->pskb, (RECVBUFF_ALIGN_SZ - alignment));
406 }
407
408 if (precvbuf->pskb == NULL) {
409 DBG_871X("%s: alloc_skb fail!\n", __func__);
410 }
411 }
412
413 list_add_tail(&precvbuf->list, &precvpriv->free_recv_buf_queue.queue);
414
415 precvbuf++;
416 }
417 precvpriv->free_recv_buf_queue_cnt = i;
418
419 if (res == _FAIL)
420 goto initbuferror;
421
422 /* 3 2. init tasklet */
423 tasklet_init(
424 &precvpriv->recv_tasklet,
425 (void(*)(unsigned long))rtl8723bs_recv_tasklet,
426 (unsigned long)padapter
427 );
428
429 goto exit;
430
431 initbuferror:
432 precvbuf = (struct recv_buf *)precvpriv->precv_buf;
433 if (precvbuf) {
434 n = precvpriv->free_recv_buf_queue_cnt;
435 precvpriv->free_recv_buf_queue_cnt = 0;
436 for (i = 0; i < n ; i++) {
437 list_del_init(&precvbuf->list);
438 rtw_os_recvbuf_resource_free(padapter, precvbuf);
439 precvbuf++;
440 }
441 precvpriv->precv_buf = NULL;
442 }
443
444 if (precvpriv->pallocated_recv_buf) {
445 n = NR_RECVBUFF * sizeof(struct recv_buf) + 4;
446 kfree(precvpriv->pallocated_recv_buf);
447 precvpriv->pallocated_recv_buf = NULL;
448 }
449
450 exit:
451 return res;
452 }
453
454 /*
455 * Free recv private variable of hardware dependent
456 * 1. recv buf
457 * 2. recv tasklet
458 *
459 */
rtl8723bs_free_recv_priv(struct adapter * padapter)460 void rtl8723bs_free_recv_priv(struct adapter *padapter)
461 {
462 u32 i, n;
463 struct recv_priv *precvpriv;
464 struct recv_buf *precvbuf;
465
466
467 precvpriv = &padapter->recvpriv;
468
469 /* 3 1. kill tasklet */
470 tasklet_kill(&precvpriv->recv_tasklet);
471
472 /* 3 2. free all recv buffers */
473 precvbuf = (struct recv_buf *)precvpriv->precv_buf;
474 if (precvbuf) {
475 n = NR_RECVBUFF;
476 precvpriv->free_recv_buf_queue_cnt = 0;
477 for (i = 0; i < n ; i++) {
478 list_del_init(&precvbuf->list);
479 rtw_os_recvbuf_resource_free(padapter, precvbuf);
480 precvbuf++;
481 }
482 precvpriv->precv_buf = NULL;
483 }
484
485 if (precvpriv->pallocated_recv_buf) {
486 n = NR_RECVBUFF * sizeof(struct recv_buf) + 4;
487 kfree(precvpriv->pallocated_recv_buf);
488 precvpriv->pallocated_recv_buf = NULL;
489 }
490 }
491