drivers/staging/rtl8723bs/hal/rtl8723bs_recv.c

   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
  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
  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  */
  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
 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
 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  */
 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  */
 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 }