WhyCan Forum(哇酷开发者社区)

这个驱动分析起来像捉迷藏一样,本着顺藤摸瓜的思路,发现开了两个tasklet:
1 tasklet_init(&precvpriv->recv_tasklet, (void(*)(unsigned long))usb_recv_tasklet,(unsigned long)padapter);
2 tasklet_init(&pxmitpriv->xmit_tasklet,(void(*)(unsigned long))rtl8188eu_xmit_tasklet,(unsigned long)padapter);
在"ifconfig wlan0 up"开了一个命令线程:rtw_start_drv_threads(padapter).
究竟是如何发送数据的呢?发送任务函数原型是这个:
void rtl8188eu_xmit_tasklet(void *priv)
{
    int ret = _FALSE;
    _adapter *padapter = (_adapter *)priv;
    struct xmit_priv *pxmitpriv = &padapter->xmitpriv;

    while (1) {
        if (RTW_CANNOT_TX(padapter)) {
            RTW_INFO("xmit_tasklet => bDriverStopped or bSurpriseRemoved or bWritePortCancel\n");
            break;
        }

        if (rtw_xmit_ac_blocked(padapter) == _TRUE)
            break;

        ret = rtl8188eu_xmitframe_complete(padapter, pxmitpriv, NULL);

        if (ret == _FALSE)
            break;
    }

}

而发送数据的函数是包括这个:
s32    rtw_hal_xmit(_adapter *padapter, struct xmit_frame *pxmitframe)
{
    return padapter->hal_func.hal_xmit(padapter, pxmitframe);
}
也就是这个:pHalFunc->hal_xmit = &rtl8188eu_hal_xmit;
s32 rtl8188eu_hal_xmit(_adapter *padapter, struct xmit_frame *pxmitframe)
{    //RTW_INFO("==> %s xmitframe 3 \n", __FUNCTION__);
    return pre_xmitframe(padapter, pxmitframe);
}
还有一串.....
static s32 pre_xmitframe(_adapter *padapter, struct xmit_frame *pxmitframe)
{
    _irqL irqL;
    s32 res;
    struct xmit_buf *pxmitbuf = NULL;
    struct xmit_priv *pxmitpriv = &padapter->xmitpriv;
    struct pkt_attrib *pattrib = &pxmitframe->attrib;
    struct mlme_priv *pmlmepriv = &padapter->mlmepriv;

    _enter_critical_bh(&pxmitpriv->lock, &irqL);

    /* RTW_INFO("==> %s\n",__FUNCTION__); */

    if (rtw_txframes_sta_ac_pending(padapter, pattrib) > 0) {
        /* RTW_INFO("enqueue AC(%d)\n",pattrib->priority); */
        goto enqueue;
    }

    if (rtw_xmit_ac_blocked(padapter) == _TRUE)
        goto enqueue;

    if (DEV_STA_LG_NUM(padapter->dvobj))
        goto enqueue;

    pxmitbuf = rtw_alloc_xmitbuf(pxmitpriv);
    if (pxmitbuf == NULL)
        goto enqueue;

    _exit_critical_bh(&pxmitpriv->lock, &irqL);

    pxmitframe->pxmitbuf = pxmitbuf;
    pxmitframe->buf_addr = pxmitbuf->pbuf;
    pxmitbuf->priv_data = pxmitframe;

    if (xmitframe_direct(padapter, pxmitframe) != _SUCCESS) {
        rtw_free_xmitbuf(pxmitpriv, pxmitbuf);
        rtw_free_xmitframe(pxmitpriv, pxmitframe);
    }

    return _TRUE;

enqueue:
    res = rtw_xmitframe_enqueue(padapter, pxmitframe);
    _exit_critical_bh(&pxmitpriv->lock, &irqL);

    if (res != _SUCCESS) {
        rtw_free_xmitframe(pxmitpriv, pxmitframe);

        pxmitpriv->tx_drop++;
        return _TRUE;
    }

    return _FALSE;
}

static s32 xmitframe_direct(_adapter *padapter, struct xmit_frame *pxmitframe)
{
    s32 res = _SUCCESS;
    /* RTW_INFO("==> %s\n",__FUNCTION__); */

    res = rtw_xmitframe_coalesce(padapter, pxmitframe->pkt, pxmitframe);
    if (res == _SUCCESS)
        rtw_dump_xframe(padapter, pxmitframe);//mark
    else
        RTW_INFO("==> %s xmitframe_coalsece failed\n", __FUNCTION__);

    return res;
}

怎么就勾搭上了?
勾搭
#ifdef CONFIG_USB_TX_AGGREGATION
#define IDEA_CONDITION 1    /* check all packets before enqueue */
s32 rtl8188eu_xmitframe_complete(_adapter *padapter, struct xmit_priv *pxmitpriv, struct xmit_buf *pxmitbuf)
{
    HAL_DATA_TYPE    *pHalData = GET_HAL_DATA(padapter);
    struct xmit_frame *pxmitframe = NULL;
    struct xmit_frame *pfirstframe = NULL;

    /* aggregate variable */
    struct hw_xmit *phwxmit;
    struct sta_info *psta = NULL;
    struct tx_servq *ptxservq = NULL;

    _irqL irqL;
    _list *xmitframe_plist = NULL, *xmitframe_phead = NULL;

    u32    pbuf;    /* next pkt address */
    u32    pbuf_tail;    /* last pkt tail */
    u32    len;    /* packet length, except TXDESC_SIZE and PKT_OFFSET */

    u32    bulkSize = pHalData->UsbBulkOutSize;
    u8    descCount;
    u32    bulkPtr;

    /* dump frame variable */
    u32 ff_hwaddr;

    _list *sta_plist, *sta_phead;
    u8 single_sta_in_queue = _FALSE;

#ifndef IDEA_CONDITION
    int res = _SUCCESS;
#endif

    /* check xmitbuffer is ok */
    if (pxmitbuf == NULL) {
        pxmitbuf = rtw_alloc_xmitbuf(pxmitpriv);
        if (pxmitbuf == NULL) {
            /* RTW_INFO("%s #1, connot alloc xmitbuf!!!!\n",__FUNCTION__); */
            return _FALSE;
        }
    }

    /* RTW_INFO("%s =====================================\n",__FUNCTION__); */
    /* 3 1. pick up first frame */
    do {
        rtw_free_xmitframe(pxmitpriv, pxmitframe);

        pxmitframe = rtw_dequeue_xframe(pxmitpriv, pxmitpriv->hwxmits, pxmitpriv->hwxmit_entry);
        if (pxmitframe == NULL) {
            /* no more xmit frame, release xmit buffer */
            /* RTW_INFO("no more xmit frame ,return\n"); */
            rtw_free_xmitbuf(pxmitpriv, pxmitbuf);
            return _FALSE;
        }

#ifndef IDEA_CONDITION
        if (pxmitframe->frame_tag != DATA_FRAMETAG) {
            /*            rtw_free_xmitframe(pxmitpriv, pxmitframe); */
            continue;
        }

        /* TID 0~15 */
        if ((pxmitframe->attrib.priority < 0) ||
            (pxmitframe->attrib.priority > 15)) {
            /*            rtw_free_xmitframe(pxmitpriv, pxmitframe); */
            continue;
        }
#endif
        /* RTW_INFO("==> pxmitframe->attrib.priority:%d\n",pxmitframe->attrib.priority); */
        pxmitframe->pxmitbuf = pxmitbuf;
        pxmitframe->buf_addr = pxmitbuf->pbuf;
        pxmitbuf->priv_data = pxmitframe;

        pxmitframe->agg_num = 1; /* alloc xmitframe should assign to 1. */
#ifdef CONFIG_TX_EARLY_MODE
        pxmitframe->pkt_offset = (PACKET_OFFSET_SZ / 8) + 1; /* 2; */ /* first frame of aggregation, reserve one offset for EM info ,another for usb bulk-out block check */
#else
        pxmitframe->pkt_offset = (PACKET_OFFSET_SZ / 8); /* 1; */ /* first frame of aggregation, reserve offset */
#endif

        if (rtw_xmitframe_coalesce(padapter, pxmitframe->pkt, pxmitframe) == _FALSE) {
            RTW_INFO("%s coalesce 1st xmitframe failed\n", __FUNCTION__);
            continue;
        }

        /* always return ndis_packet after rtw_xmitframe_coalesce */
        rtw_os_xmit_complete(padapter, pxmitframe);

        break;
    } while (1);

    /* 3 2. aggregate same priority and same DA(AP or STA) frames */
    pfirstframe = pxmitframe;
    len = rtw_wlan_pkt_size(pfirstframe) + TXDESC_SIZE + (pfirstframe->pkt_offset * PACKET_OFFSET_SZ);
    pbuf_tail = len;
    pbuf = _RND8(pbuf_tail);

    /* check pkt amount in one bulk */
    descCount = 0;
    bulkPtr = bulkSize;
    if (pbuf < bulkPtr) {
        descCount++;
        if (descCount == pHalData->UsbTxAggDescNum)
            goto agg_end;
    } else {
        descCount = 0;
        bulkPtr = ((pbuf / bulkSize) + 1) * bulkSize; /* round to next bulkSize */
    }

    /* dequeue same priority packet from station tx queue */
    /* psta = pfirstframe->attrib.psta; */
    psta = rtw_get_stainfo(&padapter->stapriv, pfirstframe->attrib.ra);
    if (pfirstframe->attrib.psta != psta)
        RTW_INFO("%s, pattrib->psta(%p) != psta(%p)\n", __func__, pfirstframe->attrib.psta, psta);
    if (psta == NULL)
        RTW_INFO("rtw_xmit_classifier: psta == NULL\n");
    if (!(psta->state & _FW_LINKED))
        RTW_INFO("%s, psta->state(0x%x) != _FW_LINKED\n", __func__, psta->state);

    switch (pfirstframe->attrib.priority) {
    case 1:
    case 2:
        ptxservq = &(psta->sta_xmitpriv.bk_q);
        phwxmit = pxmitpriv->hwxmits + 3;
        break;

    case 4:
    case 5:
        ptxservq = &(psta->sta_xmitpriv.vi_q);
        phwxmit = pxmitpriv->hwxmits + 1;
        break;

    case 6:
    case 7:
        ptxservq = &(psta->sta_xmitpriv.vo_q);
        phwxmit = pxmitpriv->hwxmits;
        break;

    case 0:
    case 3:
    default:
        ptxservq = &(psta->sta_xmitpriv.be_q);
        phwxmit = pxmitpriv->hwxmits + 2;
        break;
    }
    /* RTW_INFO("==> pkt_no=%d,pkt_len=%d,len=%d,RND8_LEN=%d,pkt_offset=0x%02x\n", */
    /* pxmitframe->agg_num,pxmitframe->attrib.last_txcmdsz,len,pbuf,pxmitframe->pkt_offset ); */

    _enter_critical_bh(&pxmitpriv->lock, &irqL);

    sta_phead = get_list_head(phwxmit->sta_queue);
    sta_plist = get_next(sta_phead);
    single_sta_in_queue = rtw_end_of_queue_search(sta_phead, get_next(sta_plist));

    xmitframe_phead = get_list_head(&ptxservq->sta_pending);
    xmitframe_plist = get_next(xmitframe_phead);

    while (rtw_end_of_queue_search(xmitframe_phead, xmitframe_plist) == _FALSE) {
        pxmitframe = LIST_CONTAINOR(xmitframe_plist, struct xmit_frame, list);
        xmitframe_plist = get_next(xmitframe_plist);

        if (_FAIL == rtw_hal_busagg_qsel_check(padapter, pfirstframe->attrib.qsel, pxmitframe->attrib.qsel))
            break;

        pxmitframe->agg_num = 0; /* not first frame of aggregation */
#ifdef CONFIG_TX_EARLY_MODE
        pxmitframe->pkt_offset = 1;/* not first frame of aggregation,reserve offset for EM Info */
#else
        pxmitframe->pkt_offset = 0; /* not first frame of aggregation, no need to reserve offset */
#endif

        len = rtw_wlan_pkt_size(pxmitframe) + TXDESC_SIZE + (pxmitframe->pkt_offset * PACKET_OFFSET_SZ);

        if (_RND8(pbuf + len) > MAX_XMITBUF_SZ) {
            /* RTW_INFO("%s....len> MAX_XMITBUF_SZ\n",__FUNCTION__); */
            pxmitframe->agg_num = 1;
            pxmitframe->pkt_offset = 1;
            break;
        }
        rtw_list_delete(&pxmitframe->list);
        ptxservq->qcnt--;
        phwxmit->accnt--;

#ifndef IDEA_CONDITION
        /* suppose only data frames would be in queue */
        if (pxmitframe->frame_tag != DATA_FRAMETAG) {
            rtw_free_xmitframe(pxmitpriv, pxmitframe);
            continue;
        }

        /* TID 0~15 */
        if ((pxmitframe->attrib.priority < 0) ||
            (pxmitframe->attrib.priority > 15)) {
            rtw_free_xmitframe(pxmitpriv, pxmitframe);
            continue;
        }
#endif

        /*        pxmitframe->pxmitbuf = pxmitbuf; */
        pxmitframe->buf_addr = pxmitbuf->pbuf + pbuf;

        if (rtw_xmitframe_coalesce(padapter, pxmitframe->pkt, pxmitframe) == _FALSE) {
            RTW_INFO("%s coalesce failed\n", __FUNCTION__);
            rtw_free_xmitframe(pxmitpriv, pxmitframe);
            continue;
        }

        RTW_INFO("==> pxmitframe->attrib.priority:%d\n",pxmitframe->attrib.priority);
        /* always return ndis_packet after rtw_xmitframe_coalesce */
        rtw_os_xmit_complete(padapter, pxmitframe);

        /* (len - TXDESC_SIZE) == pxmitframe->attrib.last_txcmdsz */
        update_txdesc(pxmitframe, pxmitframe->buf_addr, pxmitframe->attrib.last_txcmdsz, _TRUE);

        /* don't need xmitframe any more */
        rtw_free_xmitframe(pxmitpriv, pxmitframe);

        /* handle pointer and stop condition */
        pbuf_tail = pbuf + len;
        pbuf = _RND8(pbuf_tail);

        pfirstframe->agg_num++;
#ifdef CONFIG_TX_EARLY_MODE
        pxmitpriv->agg_pkt[pfirstframe->agg_num - 1].offset = _RND8(len);
        pxmitpriv->agg_pkt[pfirstframe->agg_num - 1].pkt_len = pxmitframe->attrib.last_txcmdsz;
#endif
        if (MAX_TX_AGG_PACKET_NUMBER == pfirstframe->agg_num)
            break;

        if (pbuf < bulkPtr) {
            descCount++;
            if (descCount == pHalData->UsbTxAggDescNum)
                break;
        } else {
            descCount = 0;
            bulkPtr = ((pbuf / bulkSize) + 1) * bulkSize;
        }
    } /* end while( aggregate same priority and same DA(AP or STA) frames) */
    if (_rtw_queue_empty(&ptxservq->sta_pending) == _TRUE)
        rtw_list_delete(&ptxservq->tx_pending);
    else if (single_sta_in_queue == _FALSE) {
        /* Re-arrange the order of stations in this ac queue to balance the service for these stations */
        rtw_list_delete(&ptxservq->tx_pending);
        rtw_list_insert_tail(&ptxservq->tx_pending, get_list_head(phwxmit->sta_queue));
    }

    _exit_critical_bh(&pxmitpriv->lock, &irqL);

agg_end:

#ifdef CONFIG_80211N_HT
    if ((pfirstframe->attrib.ether_type != 0x0806) &&
        (pfirstframe->attrib.ether_type != 0x888e) &&
        (pfirstframe->attrib.ether_type != 0x88b4) &&
        (pfirstframe->attrib.dhcp_pkt != 1))
        rtw_issue_addbareq_cmd(padapter, pfirstframe);
#endif /* CONFIG_80211N_HT */
#ifndef CONFIG_USE_USB_BUFFER_ALLOC_TX
    /* 3 3. update first frame txdesc */
    if ((PACKET_OFFSET_SZ != 0) && ((pbuf_tail % bulkSize) == 0)) {
        /* remove pkt_offset */
        pbuf_tail -= PACKET_OFFSET_SZ;
        pfirstframe->buf_addr += PACKET_OFFSET_SZ;
        pfirstframe->pkt_offset--;
        /* RTW_INFO("$$$$$ buf size equal to USB block size $$$$$$\n"); */
    }
#endif /* CONFIG_USE_USB_BUFFER_ALLOC_TX */

    update_txdesc(pfirstframe, pfirstframe->buf_addr, pfirstframe->attrib.last_txcmdsz, _TRUE);

#ifdef CONFIG_TX_EARLY_MODE
    /* prepare EM info for first frame, agg_num value start from 1 */
    pxmitpriv->agg_pkt[0].offset = _RND8(pfirstframe->attrib.last_txcmdsz + TXDESC_SIZE + (pfirstframe->pkt_offset * PACKET_OFFSET_SZ));
    pxmitpriv->agg_pkt[0].pkt_len = pfirstframe->attrib.last_txcmdsz;/* get from rtw_xmitframe_coalesce             */

    UpdateEarlyModeInfo8188E(pxmitpriv, pxmitbuf);
#endif

    /* 3 4. write xmit buffer to USB FIFO */
    ff_hwaddr = rtw_get_ff_hwaddr(pfirstframe);
    /* RTW_INFO("%s ===================================== write port,buf_size(%d)\n",__FUNCTION__,pbuf_tail); */
    /* xmit address == ((xmit_frame*)pxmitbuf->priv_data)->buf_addr */

#ifdef CONFIG_XMIT_THREAD_MODE
    pxmitbuf->len = pbuf_tail;
    pxmitbuf->ff_hwaddr = ff_hwaddr;

    if (pfirstframe->attrib.qsel == QSLT_BEACON)
        /* download rsvd page*/
        rtw_write_port(padapter, ff_hwaddr, pbuf_tail, (u8 *)pxmitbuf);
    else
        enqueue_pending_xmitbuf(pxmitpriv, pxmitbuf);
#else
    rtw_write_port(padapter, ff_hwaddr, pbuf_tail, (u8 *)pxmitbuf);
#endif

    /* 3 5. update statisitc */
    pbuf_tail -= (pfirstframe->agg_num * TXDESC_SIZE);
    pbuf_tail -= (pfirstframe->pkt_offset * PACKET_OFFSET_SZ);

    rtw_count_tx_stats(padapter, pfirstframe, pbuf_tail);

#ifdef CONFIG_XMIT_THREAD_MODE
    if (pfirstframe->attrib.qsel == QSLT_BEACON)
#endif
    rtw_free_xmitframe(pxmitpriv, pfirstframe);

    return _TRUE;
}

#else

s32 rtl8188eu_xmitframe_complete(_adapter *padapter, struct xmit_priv *pxmitpriv, struct xmit_buf *pxmitbuf)
{

    struct hw_xmit *phwxmits;
    sint hwentry;
    struct xmit_frame *pxmitframe = NULL;
    int res = _SUCCESS, xcnt = 0;

    phwxmits = pxmitpriv->hwxmits;
    hwentry = pxmitpriv->hwxmit_entry;

    if (pxmitbuf == NULL) {
        pxmitbuf = rtw_alloc_xmitbuf(pxmitpriv);
        if (!pxmitbuf)
            return _FALSE;
    }

    do {
        pxmitframe =  rtw_dequeue_xframe(pxmitpriv, phwxmits, hwentry);

        if (pxmitframe) {
            pxmitframe->pxmitbuf = pxmitbuf;

            pxmitframe->buf_addr = pxmitbuf->pbuf;

            pxmitbuf->priv_data = pxmitframe;

            if ((pxmitframe->frame_tag & 0x0f) == DATA_FRAMETAG) {
                if (pxmitframe->attrib.priority <= 15) /* TID0~15 */
                    res = rtw_xmitframe_coalesce(padapter, pxmitframe->pkt, pxmitframe);
                /*RTW_INFO("==> pxmitframe->attrib.priority:%d\n",pxmitframe->attrib.priority);  */
                rtw_os_xmit_complete(padapter, pxmitframe);/* always return ndis_packet after rtw_xmitframe_coalesce             */
            }

            if (res == _SUCCESS){
                rtw_dump_xframe(padapter, pxmitframe);
                RTW_INFO("==> %s xmitframe 1 \n", __FUNCTION__);
            }
            else {
                rtw_free_xmitbuf(pxmitpriv, pxmitbuf);
                rtw_free_xmitframe(pxmitpriv, pxmitframe);
            }

            xcnt++;

        } else {
            rtw_free_xmitbuf(pxmitpriv, pxmitbuf);
            return _FALSE;
        }

        break;

    } while (0/*xcnt < (NR_XMITFRAME >> 3)*/);

    return _TRUE;

}
#endif
勾搭
/* for non-agg data frame or  management frame */
static s32 rtw_dump_xframe(_adapter *padapter, struct xmit_frame *pxmitframe)
{
    s32 ret = _SUCCESS;
    s32 inner_ret = _SUCCESS;
    int t, sz, w_sz, pull = 0;
    u8 *mem_addr;
    u32 ff_hwaddr;
    struct xmit_buf *pxmitbuf = pxmitframe->pxmitbuf;
    struct pkt_attrib *pattrib = &pxmitframe->attrib;
    struct xmit_priv *pxmitpriv = &padapter->xmitpriv;
    struct security_priv *psecuritypriv = &padapter->securitypriv;
#ifdef CONFIG_80211N_HT
    if ((pxmitframe->frame_tag == DATA_FRAMETAG) &&
        (pxmitframe->attrib.ether_type != 0x0806) &&
        (pxmitframe->attrib.ether_type != 0x888e) &&
        (pxmitframe->attrib.ether_type != 0x88b4) &&
        (pxmitframe->attrib.dhcp_pkt != 1))
        rtw_issue_addbareq_cmd(padapter, pxmitframe);
#endif /* CONFIG_80211N_HT */
    mem_addr = pxmitframe->buf_addr;

    for (t = 0; t < pattrib->nr_frags; t++) {
        if (inner_ret != _SUCCESS && ret == _SUCCESS)
            ret = _FAIL;

        if (t != (pattrib->nr_frags - 1)) {

            sz = pxmitpriv->frag_len;
            sz = sz - 4 - (psecuritypriv->sw_encrypt ? 0 : pattrib->icv_len);
        } else /* no frag */
            sz = pattrib->last_txcmdsz;

        pull = update_txdesc(pxmitframe, mem_addr, sz, _FALSE);

        if (pull) {
            mem_addr += PACKET_OFFSET_SZ; /* pull txdesc head */

            /* pxmitbuf->pbuf = mem_addr;             */
            pxmitframe->buf_addr = mem_addr;

            w_sz = sz + TXDESC_SIZE;
        } else
            w_sz = sz + TXDESC_SIZE + PACKET_OFFSET_SZ;
#ifdef CONFIG_IOL_IOREG_CFG_DBG
        rtw_IOL_cmd_buf_dump(padapter, w_sz, pxmitframe->buf_addr);
#endif
        ff_hwaddr = rtw_get_ff_hwaddr(pxmitframe);

#ifdef CONFIG_XMIT_THREAD_MODE
        pxmitbuf->len = w_sz;
        pxmitbuf->ff_hwaddr = ff_hwaddr;

        if (pxmitframe->attrib.qsel == QSLT_BEACON)
            /* download rsvd page*/
            rtw_write_port(padapter, ff_hwaddr, w_sz, (u8 *)pxmitbuf);
        else
            enqueue_pending_xmitbuf(pxmitpriv, pxmitbuf);
#else
            RTW_INFO("%s:  rtw_write_port size =%d\n", __func__,w_sz);
        inner_ret = rtw_write_port(padapter, ff_hwaddr, w_sz, (unsigned char *)pxmitbuf);
#endif

        rtw_count_tx_stats(padapter, pxmitframe, sz);

         RTW_INFO("rtw_write_port, w_sz=%d, sz=%d, txdesc_sz=%d, tid=%d\n", w_sz, sz, w_sz-sz, pattrib->priority); 

        mem_addr += w_sz;

        mem_addr = (u8 *)RND4(((SIZE_PTR)(mem_addr)));

    }

#ifdef CONFIG_XMIT_THREAD_MODE
    if (pxmitframe->attrib.qsel == QSLT_BEACON)
#endif
    rtw_free_xmitframe(pxmitpriv, pxmitframe);

    if (ret != _SUCCESS)
        rtw_sctx_done_err(&pxmitbuf->sctx, RTW_SCTX_DONE_UNKNOWN);

    return ret;
}

最近编辑记录 whyabc666 (2021-02-28 15:07:05)