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