diff options
Diffstat (limited to 'wl1271/stad/src/Data_link/rx.c')
| -rw-r--r-- | wl1271/stad/src/Data_link/rx.c | 2083 |
1 files changed, 0 insertions, 2083 deletions
diff --git a/wl1271/stad/src/Data_link/rx.c b/wl1271/stad/src/Data_link/rx.c deleted file mode 100644 index c1979635..00000000 --- a/wl1271/stad/src/Data_link/rx.c +++ /dev/null @@ -1,2083 +0,0 @@ -/* - * rx.c - * - * Copyright(c) 1998 - 2010 Texas Instruments. All rights reserved. - * All rights reserved. - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions - * are met: - * - * * Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * * Redistributions in binary form must reproduce the above copyright - * notice, this list of conditions and the following disclaimer in - * the documentation and/or other materials provided with the - * distribution. - * * Neither the name Texas Instruments nor the names of its - * contributors may be used to endorse or promote products derived - * from this software without specific prior written permission. - * - * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS - * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT - * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR - * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT - * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, - * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT - * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, - * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY - * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT - * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE - * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - */ - -/***************************************************************************/ -/* */ -/* MODULE: Rx.c */ -/* PURPOSE: Rx module functions */ -/* */ -/***************************************************************************/ -#define __FILE_ID__ FILE_ID_54 -#include "tidef.h" -#include "paramOut.h" -#include "rx.h" -#include "osApi.h" -#include "timer.h" -#include "DataCtrl_Api.h" -#include "Ctrl.h" -#include "802_11Defs.h" -#include "Ethernet.h" -#include "report.h" -#include "rate.h" -#include "mlmeApi.h" -#include "rsnApi.h" -#include "smeApi.h" -#include "siteMgrApi.h" -#include "GeneralUtil.h" -#include "EvHandler.h" -#ifdef XCC_MODULE_INCLUDED -#include "XCCMngr.h" -#endif -#include "TWDriver.h" -#include "RxBuf.h" -#include "DrvMainModules.h" -#include "bmtrace_api.h" -#include "PowerMgr_API.h" - - -#define EAPOL_PACKET 0x888E -#define IAPP_PACKET 0x0000 -#define PREAUTH_EAPOL_PACKET 0x88C7 - - -#define RX_DATA_FILTER_FLAG_NO_BIT_MASK 0 -#define RX_DATA_FILTER_FLAG_USE_BIT_MASK 1 -#define RX_DATA_FILTER_FLAG_IP_HEADER 0 -#define RX_DATA_FILTER_FLAG_ETHERNET_HEADER 2 -#define RX_DATA_FILTER_ETHERNET_HEADER_BOUNDARY 14 - -#define PADDING_ETH_PACKET_SIZE 2 - -/* CallBack for recieving packet from rxXfer */ -static void rxData_ReceivePacket (TI_HANDLE hRxData, void *pBuffer); - -static ERxBufferStatus rxData_RequestForBuffer (TI_HANDLE hRxData, void **pBuf, TI_UINT16 aLength, TI_UINT32 uEncryptionFlag,PacketClassTag_e ePacketClassTag); - -#if 0 -static TI_STATUS rxData_checkBssIdAndBssType(TI_HANDLE hRxData, - dot11_header_t* dot11_header, - TMacAddr **rxBssid, - ScanBssType_e *currBssType, - TMacAddr *currBssId); -#endif -static TI_STATUS rxData_convertWlanToEthHeader (TI_HANDLE hRxData, void *pBuffer, TI_UINT16 * etherType); -static TI_STATUS rxData_ConvertAmsduToEthPackets (TI_HANDLE hRxData, void *pBuffer, TRxAttr* pRxAttr); -static void rxData_dataPacketDisptcher (TI_HANDLE hRxData, void *pBuffer, TRxAttr* pRxAttr); -static void rxData_discardPacket (TI_HANDLE hRxData, void *pBuffer, TRxAttr* pRxAttr); -static void rxData_discardPacketVlan (TI_HANDLE hRxData, void *pBuffer, TRxAttr* pRxAttr); -static void rxData_rcvPacketInOpenNotify (TI_HANDLE hRxData, void *pBuffer, TRxAttr* pRxAttr); -static void rxData_rcvPacketEapol (TI_HANDLE hRxData, void *pBuffer, TRxAttr* pRxAttr); -static void rxData_rcvPacketData (TI_HANDLE hRxData, void *pBuffer, TRxAttr* pRxAttr); - -static TI_STATUS rxData_enableDisableRxDataFilters(TI_HANDLE hRxData, TI_BOOL enabled); -static TI_STATUS rxData_addRxDataFilter(TI_HANDLE hRxData, TRxDataFilterRequest* request); -static TI_STATUS rxData_removeRxDataFilter(TI_HANDLE hRxData, TRxDataFilterRequest* request); - - -#ifdef XCC_MODULE_INCLUDED -static void rxData_rcvPacketIapp(TI_HANDLE hRxData, void *pBuffer, TRxAttr* pRxAttr); -#endif -#ifdef TI_DBG -static void rxData_printRxThroughput(TI_HANDLE hRxData, TI_BOOL bTwdInitOccured); -#endif - -static void rxData_StartReAuthActiveTimer(TI_HANDLE hRxData); -static void reAuthTimeout(TI_HANDLE hRxData, TI_BOOL bTwdInitOccured); -static void rxData_ReauthEnablePriority(TI_HANDLE hRxData); - - -/************************************************************************* -* rxData_create * -************************************************************************** -* DESCRIPTION: This function initializes the Rx data module. -* -* INPUT: hOs - handle to Os Abstraction Layer -* -* OUTPUT: -* -* RETURN: Handle to the allocated Rx data control block -************************************************************************/ -TI_HANDLE rxData_create (TI_HANDLE hOs) -{ - rxData_t *pRxData; - - /* check parameters validity */ - if (hOs == NULL) - { - WLAN_OS_REPORT(("FATAL ERROR: rxData_create(): OS handle Error - Aborting\n")); - return NULL; - } - - - /* alocate Rx module control block */ - pRxData = os_memoryAlloc(hOs, (sizeof(rxData_t))); - - if (!pRxData) - { - WLAN_OS_REPORT(("FATAL ERROR: rxData_create(): Error Creating Rx Module - Aborting\n")); - return NULL; - } - - /* reset Rx control block */ - os_memoryZero (hOs, pRxData, (sizeof(rxData_t))); - - pRxData->RxEventDistributor = DistributorMgr_Create (hOs, MAX_RX_NOTIF_REQ_ELMENTS); - - pRxData->hOs = hOs; - - return (TI_HANDLE)pRxData; -} - -/*************************************************************************** -* rxData_config * -**************************************************************************** -* DESCRIPTION: This function configures the Rx Data module -* -* INPUTS: pStadHandles - The driver modules handles -* -* OUTPUT: -* -* RETURNS: void -***************************************************************************/ -void rxData_init (TStadHandlesList *pStadHandles) -{ - rxData_t *pRxData = (rxData_t *)(pStadHandles->hRxData); - - pRxData->hCtrlData = pStadHandles->hCtrlData; - pRxData->hTWD = pStadHandles->hTWD; - pRxData->hMlme = pStadHandles->hMlmeSm; - pRxData->hRsn = pStadHandles->hRsn; - pRxData->hSiteMgr = pStadHandles->hSiteMgr; - pRxData->hOs = pStadHandles->hOs; - pRxData->hReport = pStadHandles->hReport; - pRxData->hXCCMgr = pStadHandles->hXCCMngr; - pRxData->hEvHandler = pStadHandles->hEvHandler; - pRxData->hTimer = pStadHandles->hTimer; - pRxData->hPowerMgr = pStadHandles->hPowerMgr; - - pRxData->rxDataExcludeUnencrypted = DEF_EXCLUDE_UNENCYPTED; - pRxData->rxDataExludeBroadcastUnencrypted = DEF_EXCLUDE_UNENCYPTED; - pRxData->rxDataEapolDestination = DEF_EAPOL_DESTINATION; - pRxData->rxDataPortStatus = DEF_RX_PORT_STATUS; - pRxData->genericEthertype = EAPOL_PACKET; - - /* - * configure rx data dispatcher - */ - - /* port status close */ - pRxData->rxData_dispatchBuffer[CLOSE][DATA_DATA_PACKET] = &rxData_discardPacket; /* data */ - pRxData->rxData_dispatchBuffer[CLOSE][DATA_EAPOL_PACKET] = &rxData_discardPacket; /* eapol */ - pRxData->rxData_dispatchBuffer[CLOSE][DATA_IAPP_PACKET] = &rxData_discardPacket; /* Iapp */ - pRxData->rxData_dispatchBuffer[CLOSE][DATA_VLAN_PACKET] = &rxData_discardPacketVlan; /* VLAN */ - - /* port status open notify */ - pRxData->rxData_dispatchBuffer[OPEN_NOTIFY][DATA_DATA_PACKET] = &rxData_rcvPacketInOpenNotify; /* data */ - pRxData->rxData_dispatchBuffer[OPEN_NOTIFY][DATA_EAPOL_PACKET] = &rxData_rcvPacketInOpenNotify; /* eapol */ - pRxData->rxData_dispatchBuffer[OPEN_NOTIFY][DATA_IAPP_PACKET] = &rxData_rcvPacketInOpenNotify; /* Iapp */ - pRxData->rxData_dispatchBuffer[OPEN_NOTIFY][DATA_VLAN_PACKET] = &rxData_discardPacketVlan; /* VLAN */ - - /* port status open eapol */ - pRxData->rxData_dispatchBuffer[OPEN_EAPOL][DATA_DATA_PACKET] = &rxData_discardPacket; /* data */ - pRxData->rxData_dispatchBuffer[OPEN_EAPOL][DATA_EAPOL_PACKET] = &rxData_rcvPacketEapol; /* eapol */ - pRxData->rxData_dispatchBuffer[OPEN_EAPOL][DATA_IAPP_PACKET] = &rxData_discardPacket; /* Iapp */ - pRxData->rxData_dispatchBuffer[OPEN_EAPOL][DATA_VLAN_PACKET] = &rxData_discardPacketVlan; /* VLAN */ - - /* port status open */ - pRxData->rxData_dispatchBuffer[OPEN][DATA_DATA_PACKET] = &rxData_rcvPacketData; /* data */ - pRxData->rxData_dispatchBuffer[OPEN][DATA_EAPOL_PACKET] = &rxData_rcvPacketEapol; /* eapol */ -#ifdef XCC_MODULE_INCLUDED - pRxData->rxData_dispatchBuffer[OPEN][DATA_IAPP_PACKET] = &rxData_rcvPacketIapp; /* Iapp */ -#else - pRxData->rxData_dispatchBuffer[OPEN][DATA_IAPP_PACKET] = &rxData_rcvPacketData; /* Iapp */ -#endif - pRxData->rxData_dispatchBuffer[OPEN][DATA_VLAN_PACKET] = &rxData_discardPacketVlan;/* VLAN */ - - /* register CB's for request buffer and receive CB to the lower layers */ - TWD_RegisterCb (pRxData->hTWD, - TWD_EVENT_RX_RECEIVE_PACKET, - (void *)rxData_ReceivePacket, - pStadHandles->hRxData); - - TWD_RegisterCb (pRxData->hTWD, - TWD_EVENT_RX_REQUEST_FOR_BUFFER, - (void*)rxData_RequestForBuffer, - pStadHandles->hRxData); -} - - -TI_STATUS rxData_SetDefaults (TI_HANDLE hRxData, rxDataInitParams_t * rxDataInitParams) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - int i; - - /* init rx data filters */ - pRxData->filteringEnabled = rxDataInitParams->rxDataFiltersEnabled; - pRxData->filteringDefaultAction = rxDataInitParams->rxDataFiltersDefaultAction; - TWD_CfgEnableRxDataFilter (pRxData->hTWD, pRxData->filteringEnabled, pRxData->filteringDefaultAction); - - for (i = 0; i < MAX_DATA_FILTERS; ++i) - { - if (rxDataInitParams->rxDataFilterRequests[i].maskLength > 0) - { - if (rxData_addRxDataFilter(hRxData, &rxDataInitParams->rxDataFilterRequests[i]) != TI_OK) - { - TRACE1(pRxData->hReport, REPORT_SEVERITY_ERROR, ": Invalid Rx Data Filter configured at init stage (at index %d)!\n", i); - } - } - } - - pRxData->reAuthActiveTimer = tmr_CreateTimer (pRxData->hTimer); - if (pRxData->reAuthActiveTimer == NULL) - { - WLAN_OS_REPORT(("rxData_SetDefaults(): Failed to create reAuthActiveTimer!\n")); - return TI_NOK; - } - - pRxData->reAuthActiveTimeout = rxDataInitParams->reAuthActiveTimeout; - - rxData_SetReAuthInProgress(pRxData, TI_FALSE); - -#ifdef TI_DBG - /* reset counters */ - rxData_resetCounters(pRxData); - rxData_resetDbgCounters(pRxData); - - /* allocate timer for debug throughput */ - pRxData->hThroughputTimer = tmr_CreateTimer (pRxData->hTimer); - if (pRxData->hThroughputTimer == NULL) - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_ERROR, "rxData_SetDefaults(): Failed to create hThroughputTimer!\n"); - return TI_NOK; - } - pRxData->rxThroughputTimerEnable = TI_FALSE; -#endif - - - TRACE0(pRxData->hReport, REPORT_SEVERITY_INIT, ".....Rx Data configured successfully\n"); - - return TI_OK; -} - -/*************************************************************************** -* rxData_unLoad * -**************************************************************************** -* DESCRIPTION: This function unload the Rx data module. -* -* INPUTS: hRxData - the object -* -* OUTPUT: -* -* RETURNS: TI_OK - Unload succesfull -* TI_NOK - Unload unsuccesfull -***************************************************************************/ -TI_STATUS rxData_unLoad(TI_HANDLE hRxData) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - /* check parameters validity */ - if (pRxData == NULL) - { - return TI_NOK; - } - - DistributorMgr_Destroy(pRxData->RxEventDistributor); - -#ifdef TI_DBG - /* destroy periodic rx throughput timer */ - if (pRxData->hThroughputTimer) - { - tmr_DestroyTimer (pRxData->hThroughputTimer); - } - #endif - - if (pRxData->reAuthActiveTimer) - { - tmr_DestroyTimer (pRxData->reAuthActiveTimer); - } - - /* free Rx Data controll block */ - os_memoryFree(pRxData->hOs, pRxData, sizeof(rxData_t)); - - return TI_OK; -} - - -/*************************************************************************** -* rxData_stop * -**************************************************************************** -* DESCRIPTION: this function stop the rx data. -* -* INPUTS: hRxData - the object -* -* OUTPUT: -* -* RETURNS: TI_OK - stop succesfull -* TI_NOK - stop unsuccesfull -***************************************************************************/ -TI_STATUS rxData_stop (TI_HANDLE hRxData) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - /* check parameters validity */ - if (pRxData == NULL) - { - return TI_NOK; - } - - pRxData->rxDataExcludeUnencrypted = DEF_EXCLUDE_UNENCYPTED; - pRxData->rxDataExludeBroadcastUnencrypted = DEF_EXCLUDE_UNENCYPTED; - pRxData->rxDataEapolDestination = DEF_EAPOL_DESTINATION; - pRxData->rxDataPortStatus = DEF_RX_PORT_STATUS; - - #ifdef TI_DBG - /* reset counters */ - /*rxData_resetCounters(pRxData);*/ - /*rxData_resetDbgCounters(pRxData);*/ - - /* stop throughput timer */ - if (pRxData->rxThroughputTimerEnable) - { - tmr_StopTimer (pRxData->hThroughputTimer); - pRxData->rxThroughputTimerEnable = TI_FALSE; - } - #endif - - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_stop() : Succeeded.\n"); - - return TI_OK; - -} - -/*************************************************************************** -* rxData_getParam * -**************************************************************************** -* DESCRIPTION: get a specific parameter -* -* INPUTS: hRxData - the object -* -* OUTPUT: pParamInfo - structure which include the value of -* the requested parameter -* -* RETURNS: TI_OK -* TI_NOK -***************************************************************************/ -TI_STATUS rxData_getParam(TI_HANDLE hRxData, paramInfo_t *pParamInfo) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - /* check handle validity */ - if (pRxData == NULL) - { - return TI_NOK; - } - - switch (pParamInfo->paramType) - { - case RX_DATA_EXCLUDE_UNENCRYPTED_PARAM: - pParamInfo->content.rxDataExcludeUnencrypted = pRxData->rxDataExcludeUnencrypted; - break; - - case RX_DATA_EAPOL_DESTINATION_PARAM: - pParamInfo->content.rxDataEapolDestination = pRxData->rxDataEapolDestination; - break; - - case RX_DATA_PORT_STATUS_PARAM: - pParamInfo->content.rxDataPortStatus = pRxData->rxDataPortStatus; - break; - - case RX_DATA_COUNTERS_PARAM: - pParamInfo->content.siteMgrTiWlanCounters.RecvOk = pRxData->rxDataCounters.RecvOk; - pParamInfo->content.siteMgrTiWlanCounters.DirectedBytesRecv = pRxData->rxDataCounters.DirectedBytesRecv; - pParamInfo->content.siteMgrTiWlanCounters.DirectedFramesRecv = pRxData->rxDataCounters.DirectedFramesRecv; - pParamInfo->content.siteMgrTiWlanCounters.MulticastBytesRecv = pRxData->rxDataCounters.MulticastBytesRecv; - pParamInfo->content.siteMgrTiWlanCounters.MulticastFramesRecv = pRxData->rxDataCounters.MulticastFramesRecv; - pParamInfo->content.siteMgrTiWlanCounters.BroadcastBytesRecv = pRxData->rxDataCounters.BroadcastBytesRecv; - pParamInfo->content.siteMgrTiWlanCounters.BroadcastFramesRecv = pRxData->rxDataCounters.BroadcastFramesRecv; - break; - - case RX_DATA_GET_RX_DATA_FILTERS_STATISTICS: - TWD_ItrDataFilterStatistics (pRxData->hTWD, - pParamInfo->content.interogateCmdCBParams.fCb, - pParamInfo->content.interogateCmdCBParams.hCb, - pParamInfo->content.interogateCmdCBParams.pCb); - break; - - case RX_DATA_RATE_PARAM: - pParamInfo->content.siteMgrCurrentRxRate = pRxData->uLastDataPktRate; - break; - - default: - TRACE0(pRxData->hReport, REPORT_SEVERITY_ERROR, " rxData_getParam() : PARAMETER NOT SUPPORTED \n"); - return (PARAM_NOT_SUPPORTED); - } - - return TI_OK; -} - -/*************************************************************************** -* rxData_setParam * -**************************************************************************** -* DESCRIPTION: set a specific parameter -* -* INPUTS: hRxData - the object -* pParamInfo - structure which include the value to set for -* the requested parameter -* -* OUTPUT: -* -* RETURNS: TI_OK -* TI_NOK -***************************************************************************/ -TI_STATUS rxData_setParam(TI_HANDLE hRxData, paramInfo_t *pParamInfo) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - /* check handle validity */ - if( pRxData == NULL ) - { - return TI_NOK; - } - - switch (pParamInfo->paramType) - { - case RX_DATA_EXCLUDE_UNENCRYPTED_PARAM: - pRxData->rxDataExcludeUnencrypted = pParamInfo->content.rxDataExcludeUnencrypted; - break; - case RX_DATA_EXCLUDE_BROADCAST_UNENCRYPTED_PARAM: - pRxData->rxDataExludeBroadcastUnencrypted = pParamInfo->content.rxDataExcludeUnencrypted; - break; - case RX_DATA_EAPOL_DESTINATION_PARAM: - pRxData->rxDataEapolDestination = pParamInfo->content.rxDataEapolDestination; - break; - - case RX_DATA_PORT_STATUS_PARAM: - pRxData->rxDataPortStatus = pParamInfo->content.rxDataPortStatus; - break; - - case RX_DATA_ENABLE_DISABLE_RX_DATA_FILTERS: - return rxData_enableDisableRxDataFilters(hRxData, pParamInfo->content.rxDataFilterEnableDisable); - - case RX_DATA_ADD_RX_DATA_FILTER: - { - TRxDataFilterRequest* pRequest = &pParamInfo->content.rxDataFilterRequest; - - return rxData_addRxDataFilter(hRxData, pRequest); - } - - case RX_DATA_REMOVE_RX_DATA_FILTER: - { - TRxDataFilterRequest* pRequest = &pParamInfo->content.rxDataFilterRequest; - - return rxData_removeRxDataFilter(hRxData, pRequest); - } - - case RX_DATA_GENERIC_ETHERTYPE_PARAM: - pRxData->genericEthertype = pParamInfo->content.rxGenericEthertype; - break; - - default: - TRACE0(pRxData->hReport, REPORT_SEVERITY_ERROR, " rxData_setParam() : PARAMETER NOT SUPPORTED \n"); - return (PARAM_NOT_SUPPORTED); - } - - return TI_OK; -} - -/*************************************************************************** -* rxData_enableDisableRxDataFilters * -**************************************************************************** -* DESCRIPTION: -* -* -* INPUTS: -* -* -* -* OUTPUT: -* -* RETURNS: -* -***************************************************************************/ -static TI_STATUS rxData_enableDisableRxDataFilters(TI_HANDLE hRxData, TI_BOOL enabled) -{ - rxData_t * pRxData = (rxData_t *) hRxData; - - /* assert 0 or 1 */ - if (enabled != TI_FALSE) - enabled = 1; - - if (enabled == pRxData->filteringEnabled) - return TI_OK; - - pRxData->filteringEnabled = enabled; - - return TWD_CfgEnableRxDataFilter (pRxData->hTWD, pRxData->filteringEnabled, pRxData->filteringDefaultAction); -} - -/*************************************************************************** -* findFilterRequest * -**************************************************************************** -* DESCRIPTION: -* -* -* INPUTS: -* -* -* -* OUTPUT: -* -* RETURNS: -* -***************************************************************************/ -static int findFilterRequest(TI_HANDLE hRxData, TRxDataFilterRequest* request) -{ - rxData_t * pRxData = (rxData_t *) hRxData; - int i; - - for (i = 0; i < MAX_DATA_FILTERS; ++i) - { - if (pRxData->isFilterSet[i]) - { - if ((pRxData->filterRequests[i].offset == request->offset) && - (pRxData->filterRequests[i].maskLength == request->maskLength) && - (pRxData->filterRequests[i].patternLength == request->patternLength)) - { - if ((os_memoryCompare(pRxData->hOs, pRxData->filterRequests[i].mask, request->mask, request->maskLength) == 0) && - (os_memoryCompare(pRxData->hOs, pRxData->filterRequests[i].pattern, request->pattern, request->patternLength) == 0)) - return i; - } - } - } - - return -1; -} - -/*************************************************************************** -* closeFieldPattern * -**************************************************************************** -* DESCRIPTION: -* -* -* INPUTS: -* -* -* -* OUTPUT: -* -* RETURNS: -* -***************************************************************************/ -static void closeFieldPattern (rxData_t * pRxData, rxDataFilterFieldPattern_t * fieldPattern, TI_UINT8 * fieldPatterns, TI_UINT8 * lenFieldPatterns) -{ - //fieldPatterns[*lenFieldPatterns] = fieldPattern->offset; - os_memoryCopy(pRxData->hOs, fieldPatterns + *lenFieldPatterns, (TI_UINT8 *)&fieldPattern->offset, sizeof(fieldPattern->offset)); - *lenFieldPatterns += sizeof(fieldPattern->offset); - - fieldPatterns[*lenFieldPatterns] = fieldPattern->length; - *lenFieldPatterns += sizeof(fieldPattern->length); - - fieldPatterns[*lenFieldPatterns] = fieldPattern->flag; - *lenFieldPatterns += sizeof(fieldPattern->flag); - - os_memoryCopy(pRxData->hOs, fieldPatterns + *lenFieldPatterns, fieldPattern->pattern, fieldPattern->length); - *lenFieldPatterns += fieldPattern->length; - - /* if the pattern bit mask is enabled add it to the end of the request */ - if ((fieldPattern->flag & RX_DATA_FILTER_FLAG_USE_BIT_MASK) == RX_DATA_FILTER_FLAG_USE_BIT_MASK) - { - os_memoryCopy(pRxData->hOs, fieldPatterns + *lenFieldPatterns, fieldPattern->mask, fieldPattern->length); - *lenFieldPatterns += fieldPattern->length; - } - - TRACE3(pRxData->hReport, REPORT_SEVERITY_INFORMATION, ": Closed field pattern, length = %d, total length = %d, pattern bit mask = %d.\n", fieldPattern->length, *lenFieldPatterns, ((fieldPattern->flag & RX_DATA_FILTER_FLAG_USE_BIT_MASK) == RX_DATA_FILTER_FLAG_USE_BIT_MASK)); -} - - -/*************************************************************************** -* parseRxDataFilterRequest * -**************************************************************************** -* DESCRIPTION: -* -* -* INPUTS: -* -* -* -* OUTPUT: -* -* RETURNS: -* -***************************************************************************/ -static int parseRxDataFilterRequest(TI_HANDLE hRxData, TRxDataFilterRequest* request, TI_UINT8 * numFieldPatterns, TI_UINT8 * lenFieldPatterns, TI_UINT8 * fieldPatterns) -{ - rxData_t * pRxData = (rxData_t *) hRxData; - - int maskIter; - int patternIter = 0; - - /* used to store field patterns while they are built */ - TI_BOOL isBuildingFieldPattern = TI_FALSE; - rxDataFilterFieldPattern_t fieldPattern; - - for (maskIter = 0; maskIter < request->maskLength * 8; ++maskIter) - { - /* which byte in the mask and which bit in the byte we're at */ - int bit = maskIter % 8; - int byte = maskIter / 8; - - /* is the bit in the mask set */ - TI_BOOL isSet = ((request->mask[byte] & (1 << bit)) == (1 << bit)); - - TRACE4(pRxData->hReport, REPORT_SEVERITY_INFORMATION, ": MaskIter = %d, Byte = %d, Bit = %d, isSet = %d\n", maskIter, byte, bit, isSet); - - /* if we're in the midst of building a field pattern, we need to close in case */ - /* the current bit is not set or we've reached the ethernet header boundary */ - if (isBuildingFieldPattern) - { - if ((isSet == TI_FALSE) || (request->offset + maskIter == RX_DATA_FILTER_ETHERNET_HEADER_BOUNDARY)) - { - closeFieldPattern(hRxData, &fieldPattern, fieldPatterns, lenFieldPatterns); - - isBuildingFieldPattern = TI_FALSE; - } - } - - /* nothing to do in case the bit is not set */ - if (isSet) - { - /* if not already building a field pattern, create a new one */ - if (isBuildingFieldPattern == TI_FALSE) - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, ": Creating a new field pattern.\n"); - - isBuildingFieldPattern = TI_TRUE; - ++(*numFieldPatterns); - - if (*numFieldPatterns > RX_DATA_FILTER_MAX_FIELD_PATTERNS) - { - TRACE1(pRxData->hReport, REPORT_SEVERITY_ERROR, ": Invalid filter, too many field patterns, maximum of %u is allowed!\n", RX_DATA_FILTER_MAX_FIELD_PATTERNS); - - return TI_NOK; - } - - fieldPattern.offset = request->offset + maskIter; - fieldPattern.length = 0; - - /* we don't support the mask per bit feature yet. */ - fieldPattern.flag = RX_DATA_FILTER_FLAG_NO_BIT_MASK; - - /* first 14 bits are used for the Ethernet header, rest for the IP header */ - if (fieldPattern.offset < RX_DATA_FILTER_ETHERNET_HEADER_BOUNDARY) - { - fieldPattern.flag |= RX_DATA_FILTER_FLAG_ETHERNET_HEADER; - } - else - { - fieldPattern.flag |= RX_DATA_FILTER_FLAG_IP_HEADER; - fieldPattern.offset -= RX_DATA_FILTER_ETHERNET_HEADER_BOUNDARY; - } - - TRACE2(pRxData->hReport, REPORT_SEVERITY_INFORMATION, ": offset = %d, flag = %d.\n", fieldPattern.offset, fieldPattern.flag); - } - - /* check that the pattern is long enough */ - if (patternIter > request->patternLength) - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_ERROR, ": Invalid filter, mask and pattern length are not consistent!\n"); - - return TI_NOK; - } - - /* add the current pattern byte to the field pattern */ - fieldPattern.pattern[fieldPattern.length++] = request->pattern[patternIter++]; - - /* check pattern matching boundary */ - if (fieldPattern.offset + fieldPattern.length >= RX_DATA_FILTER_FILTER_BOUNDARY) - { - TRACE1(pRxData->hReport, REPORT_SEVERITY_ERROR, ": Invalid filter, pattern matching cannot exceed first %u characters.\n", RX_DATA_FILTER_FILTER_BOUNDARY); - - return TI_NOK; - } - } - } - - /* check that the pattern is long enough */ - if (patternIter != request->patternLength) - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_ERROR, ": Invalid filter, mask and pattern lengths are not consistent!\n"); - - return TI_NOK; - } - - /* close the last field pattern if needed */ - if (isBuildingFieldPattern) - { - closeFieldPattern (hRxData, &fieldPattern, fieldPatterns, lenFieldPatterns); - } - - return TI_OK; -} - - -/*************************************************************************** -* rxData_setRxDataFilter * -**************************************************************************** -* DESCRIPTION: -* -* -* INPUTS: -* -* -* -* OUTPUT: -* -* RETURNS: -* -***************************************************************************/ -static TI_STATUS rxData_addRxDataFilter (TI_HANDLE hRxData, TRxDataFilterRequest* request) -{ - rxData_t * pRxData = (rxData_t *) hRxData; - - /* firmware request fields */ - TI_UINT8 index = 0; - TI_UINT8 numFieldPatterns = 0; - TI_UINT8 lenFieldPatterns = 0; - TI_UINT8 fieldPatterns[MAX_DATA_FILTER_SIZE]; - - /* does the filter already exist? */ - if (findFilterRequest(hRxData, request) >= 0) - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, ": Filter already exists.\n"); - - return RX_FILTER_ALREADY_EXISTS; - } - - /* find place for insertion */ - for (index = 0; index < MAX_DATA_FILTERS; ++index) - { - if (pRxData->isFilterSet[index] == TI_FALSE) - break; - } - - /* are all filter slots taken? */ - if (index == MAX_DATA_FILTERS) - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_ERROR, ": No place to insert filter!\n"); - - return RX_NO_AVAILABLE_FILTERS; - } - - TRACE1(pRxData->hReport, REPORT_SEVERITY_INFORMATION, ": Inserting filter at index %d.\n", index); - - /* parse the filter request into discrete field patterns */ - if (parseRxDataFilterRequest(hRxData, request, &numFieldPatterns, &lenFieldPatterns, fieldPatterns) != TI_OK) - return TI_NOK; - - if (numFieldPatterns == 0) - return TI_NOK; - - /* Store configuration for future manipulation */ - pRxData->isFilterSet[index] = TI_TRUE; - os_memoryCopy(pRxData->hOs, &pRxData->filterRequests[index], request, sizeof(pRxData->filterRequests[index])); - - /* Send configuration to firmware */ - return TWD_CfgRxDataFilter (pRxData->hTWD, - index, - ADD_FILTER, - FILTER_SIGNAL, - numFieldPatterns, - lenFieldPatterns, - fieldPatterns); - -} - -/*************************************************************************** -* rxData_removeRxDataFilter * -**************************************************************************** -* DESCRIPTION: -* -* -* INPUTS: -* -* -* -* OUTPUT: -* -* RETURNS: -* -***************************************************************************/ -static TI_STATUS rxData_removeRxDataFilter (TI_HANDLE hRxData, TRxDataFilterRequest* request) -{ - rxData_t * pRxData = (rxData_t *) hRxData; - - int index = findFilterRequest(hRxData, request); - - /* does the filter exist? */ - if (index < 0) - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_WARNING, ": Remove data filter request received but the specified filter was not found!"); - - return RX_FILTER_DOES_NOT_EXIST; - } - - TRACE1(pRxData->hReport, REPORT_SEVERITY_INFORMATION, ": Removing filter at index %d.", index); - - pRxData->isFilterSet[index] = TI_FALSE; - - return TWD_CfgRxDataFilter (pRxData->hTWD, - index, - REMOVE_FILTER, - FILTER_SIGNAL, - 0, - 0, - NULL); -} - -/*************************************************************************** -* rxData_DistributorRxEvent * -**************************************************************************** -* DESCRIPTION: -* -* -* INPUTS: -* -* -* -* OUTPUT: -* -* RETURNS: -* -***************************************************************************/ -static void rxData_DistributorRxEvent (rxData_t *pRxData, TI_UINT16 Mask, int DataLen) -{ - DistributorMgr_EventCall (pRxData->RxEventDistributor, Mask, DataLen); -} - -/*************************************************************************** -* rxData_RegNotif * -****************************************************************************/ -TI_HANDLE rxData_RegNotif (TI_HANDLE hRxData, TI_UINT16 EventMask, GeneralEventCall_t CallBack, TI_HANDLE context, TI_UINT32 Cookie) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - if (!hRxData) - return NULL; - - return DistributorMgr_Reg (pRxData->RxEventDistributor, EventMask, (TI_HANDLE)CallBack, context, Cookie); -} - -/*************************************************************************** -* rxData_AddToNotifMask * -****************************************************************************/ -TI_STATUS rxData_AddToNotifMask (TI_HANDLE hRxData, TI_HANDLE Notifh, TI_UINT16 EventMask) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - if (!hRxData) - return TI_NOK; - - return DistributorMgr_AddToMask (pRxData->RxEventDistributor, Notifh, EventMask); -} - - -/*************************************************************************** -* rxData_UnRegNotif * -****************************************************************************/ -TI_STATUS rxData_UnRegNotif(TI_HANDLE hRxData,TI_HANDLE RegEventHandle) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - if (!hRxData) - return TI_NOK; - - return DistributorMgr_UnReg (pRxData->RxEventDistributor, RegEventHandle); -} - - -/*************************************************************************** -* rxData_receivePacketFromWlan * -**************************************************************************** -* DESCRIPTION: this function is called by the GWSI for each received Buffer. -* It filter and distribute the received Buffer. -* -* INPUTS: hRxData - the object -* pBuffer - the received Buffer. -* pRxAttr - Rx attributes -* -* OUTPUT: -* -* RETURNS: -***************************************************************************/ -void rxData_receivePacketFromWlan (TI_HANDLE hRxData, void *pBuffer, TRxAttr* pRxAttr) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - TMacAddr address3; - dot11_header_t *pDot11Hdr; - - TRACE1(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_receivePacketFromWlan() : pRxAttr->packetType = %d\n", pRxAttr->ePacketType); - - switch (pRxAttr->ePacketType) - { - case TAG_CLASS_MANAGEMENT: - case TAG_CLASS_BCN_PRBRSP: - - TRACE1(pRxData->hReport, REPORT_SEVERITY_INFORMATION, "rxData_receivePacketFromWlan(): Received management Buffer len = %d\n", RX_BUF_LEN(pBuffer)); - - /* update siteMngr - * - * the BSSID in mgmt frames is always addr3 in the header - * must copy address3 since Buffer is freed in mlmeParser_recv - */ - pDot11Hdr = (dot11_header_t*)RX_BUF_DATA(pBuffer); - - os_memoryCopy(pRxData->hOs, &address3, &pDot11Hdr->address3, sizeof(address3)); - - /* distribute mgmt pBuffer to mlme */ - if( mlmeParser_recv(pRxData->hMlme, pBuffer, pRxAttr) != TI_OK ) - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_ERROR, " rxData_receivePacketFromWlan() : MLME returned error \n"); - } - break; - - case TAG_CLASS_DATA: - case TAG_CLASS_QOS_DATA: - case TAG_CLASS_AMSDU: - case TAG_CLASS_EAPOL: - { - CL_TRACE_START_L3(); - TRACE1(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_receivePacketFromWlan() : Received Data Buffer len = %d\n", RX_BUF_LEN(pBuffer)); - - /* send pBuffer to data dispatcher */ - rxData_dataPacketDisptcher(hRxData, pBuffer, pRxAttr); - CL_TRACE_END_L3("tiwlan_drv.ko", "INHERIT", "RX", ".DataPacket"); - break; - } - - default: - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_receivePacketFromWlan(): Received unspecified packet type !!! \n"); - RxBufFree(pRxData->hOs, pBuffer); - break; - } -} - -/*************************************************************************** -* rxData_dataPacketDisptcher * -**************************************************************************** -* DESCRIPTION: this function is called upon receving data Buffer, -* it dispatches the packet to the approciate function according to -* data packet type and rx port status. -* -* INPUTS: hRxData - the object -* pBuffer - the received Buffer. -* pRxAttr - Rx attributes -* -* OUTPUT: -* -* RETURNS: -***************************************************************************/ - -static void rxData_dataPacketDisptcher (TI_HANDLE hRxData, void *pBuffer, TRxAttr* pRxAttr) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - portStatus_e DataPortStatus; - rxDataPacketType_e DataPacketType; - - /* get rx port status */ - DataPortStatus = pRxData->rxDataPortStatus; - - /* discard data packets received while rx data port is closed */ - if (DataPortStatus == CLOSE) - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_dataPacketDisptcher() : Received Data Buffer while Rx data port is closed \n"); - - rxData_discardPacket (hRxData, pBuffer, pRxAttr); - return; - } - - /* get data packet type */ - - pRxData->uLastDataPktRate = pRxAttr->Rate; /* save Rx packet rate for statistics */ - -#ifdef XCC_MODULE_INCLUDED - if (XCCMngr_isIappPacket (pRxData->hXCCMgr, pBuffer) == TI_TRUE) - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_dataPacketDisptcher() : Received Iapp Buffer \n"); - - DataPacketType = DATA_IAPP_PACKET; - - /* dispatch Buffer according to packet type and current rx data port status */ - pRxData->rxData_dispatchBuffer[DataPortStatus][DataPacketType] (hRxData, pBuffer, pRxAttr); - } - else -#endif - { - /* A-MSDU ? */ - if (TAG_CLASS_AMSDU == pRxAttr->ePacketType) - { - rxData_ConvertAmsduToEthPackets (hRxData, pBuffer, pRxAttr); - } - else - { - TI_UINT16 etherType = 0; - TEthernetHeader * pEthernetHeader; - - /* - * if Host processes received packets, the header translation - * from WLAN to ETH is done here. The conversion has been moved - * here so that IAPP packets aren't converted. - */ - rxData_convertWlanToEthHeader (hRxData, pBuffer, ðerType); - - pEthernetHeader = (TEthernetHeader *)RX_ETH_PKT_DATA(pBuffer); - - if (etherType == ETHERTYPE_802_1D) - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_dataPacketDisptcher() : Received VLAN packet \n"); - - DataPacketType = DATA_VLAN_PACKET; - } - else if ((HTOWLANS(pEthernetHeader->type) == EAPOL_PACKET) || - (HTOWLANS(pEthernetHeader->type) == pRxData->genericEthertype)) - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_dataPacketDisptcher() : Received Eapol packet \n"); - - if (rxData_IsReAuthInProgress(pRxData)) - { - /* ReAuth already in progress, restart timer */ - rxData_StopReAuthActiveTimer(pRxData); - rxData_StartReAuthActiveTimer(pRxData); - } - else - { - if (PowerMgr_getReAuthActivePriority(pRxData->hPowerMgr)) - { - /* ReAuth not in progress yet, force active, set flag, restart timer, send event */ - rxData_SetReAuthInProgress(pRxData, TI_TRUE); - rxData_StartReAuthActiveTimer(pRxData); - rxData_ReauthEnablePriority(pRxData); - EvHandlerSendEvent(pRxData->hEvHandler, IPC_EVENT_RE_AUTH_STARTED, NULL, 0); - } - } - - DataPacketType = DATA_EAPOL_PACKET; - } - else - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_dataPacketDisptcher() : Received Data packet \n"); - - DataPacketType = DATA_DATA_PACKET; - } - - /* dispatch Buffer according to packet type and current rx data port status */ - pRxData->rxData_dispatchBuffer[DataPortStatus][DataPacketType] (hRxData, pBuffer, pRxAttr); - } - } - -} - -/*************************************************************************** -* rxData_discardPacket * -**************************************************************************** -* DESCRIPTION: this function is called to discard Buffer -* -* INPUTS: hRxData - the object -* pBuffer - the received Buffer. -* pRxAttr - Rx attributes -* -* OUTPUT: -* -* RETURNS: -***************************************************************************/ -static void rxData_discardPacket (TI_HANDLE hRxData, void *pBuffer, TRxAttr* pRxAttr) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - TRACE2(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_discardPacket: rx port status = %d , Buffer status = %d \n", pRxData->rxDataPortStatus, pRxAttr->status); - - pRxData->rxDataDbgCounters.excludedFrameCounter++; - - /* free Buffer */ - RxBufFree(pRxData->hOs, pBuffer); - -} - -/*************************************************************************** -* rxData_discardPacketVlan * -**************************************************************************** -* DESCRIPTION: this function is called to discard Buffer -* -* INPUTS: hRxData - the object -* pBuffer - the received Buffer. -* pRxAttr - Rx attributes -* -* OUTPUT: -* -* RETURNS: -***************************************************************************/ -static void rxData_discardPacketVlan (TI_HANDLE hRxData, void *pBuffer, TRxAttr* pRxAttr) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - TRACE0(pRxData->hReport, REPORT_SEVERITY_WARNING, " rxData_discardPacketVlan : drop packet that contains VLAN tag\n"); - - pRxData->rxDataDbgCounters.rxDroppedDueToVLANIncludedCnt++; - - /* free Buffer */ - RxBufFree(pRxData->hOs, pBuffer); -} - - -/*************************************************************************** -* rxData_rcvPacketInOpenNotify * -**************************************************************************** -* DESCRIPTION: this function is called upon receving data Eapol packet type -* while rx port status is "open notify" -* -* INPUTS: hRxData - the object -* pBuffer - the received Buffer. -* pRxAttr - Rx attributes -* -* OUTPUT: -* -* RETURNS: -***************************************************************************/ -static void rxData_rcvPacketInOpenNotify (TI_HANDLE hRxData, void *pBuffer, TRxAttr* pRxAttr) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - TRACE0(pRxData->hReport, REPORT_SEVERITY_ERROR, " rxData_rcvPacketInOpenNotify: receiving data packet while in rx port status is open notify\n"); - - pRxData->rxDataDbgCounters.rcvUnicastFrameInOpenNotify++; - - /* free Buffer */ - RxBufFree(pRxData->hOs, pBuffer); -} - - -/*************************************************************************** -* rxData_rcvPacketEapol * -**************************************************************************** -* DESCRIPTION: this function is called upon receving data Eapol packet type -* while rx port status is "open eapol" -* -* INPUTS: hRxData - the object -* pBuffer - the received Buffer. -* pRxAttr - Rx attributes -* -* OUTPUT: -* -* RETURNS: -***************************************************************************/ -static void rxData_rcvPacketEapol(TI_HANDLE hRxData, void *pBuffer, TRxAttr* pRxAttr) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_rcvPacketEapol() : Received an EAPOL frame tranferred to OS\n"); - - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_rcvPacketEapol() : Received an EAPOL frame tranferred to OS\n"); - - EvHandlerSendEvent (pRxData->hEvHandler, IPC_EVENT_EAPOL, NULL, 0); - os_receivePacket (pRxData->hOs, (struct RxIfDescriptor_t*)pBuffer, pBuffer, (TI_UINT16)RX_ETH_PKT_LEN(pBuffer)); - -} - -/*************************************************************************** -* rxData_rcvPacketData * -**************************************************************************** -* DESCRIPTION: this function is called upon receving data "data" packet type -* while rx port status is "open" -* -* INPUTS: hRxData - the object -* pBuffer - the received Buffer. -* pRxAttr - Rx attributes -* -* OUTPUT: -* -* RETURNS: -***************************************************************************/ -static void rxData_rcvPacketData(TI_HANDLE hRxData, void *pBuffer, TRxAttr* pRxAttr) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - TEthernetHeader *pEthernetHeader; - TI_UINT16 EventMask = 0; - TFwInfo *pFwInfo; - - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_rcvPacketData() : Received DATA frame tranferred to OS\n"); - - /* check encryption status */ - pEthernetHeader = (TEthernetHeader *)RX_ETH_PKT_DATA(pBuffer); - if (!MAC_MULTICAST (pEthernetHeader->dst)) - { /* unicast frame */ - if((pRxData->rxDataExcludeUnencrypted) && (!(pRxAttr->packetInfo & RX_DESC_ENCRYPT_MASK))) - { - pRxData->rxDataDbgCounters.excludedFrameCounter++; - /* free Buffer */ - TRACE0(pRxData->hReport, REPORT_SEVERITY_WARNING, " rxData_rcvPacketData() : exclude unicast unencrypted is TI_TRUE & packet encryption is OFF\n"); - - RxBufFree(pRxData->hOs, pBuffer); - return; - } - } - else - { /* broadcast frame */ - if ((pRxData->rxDataExludeBroadcastUnencrypted) && (!(pRxAttr->packetInfo & RX_DESC_ENCRYPT_MASK))) - { - pRxData->rxDataDbgCounters.excludedFrameCounter++; - /* free Buffer */ - TRACE0(pRxData->hReport, REPORT_SEVERITY_WARNING, " rxData_rcvPacketData() : exclude broadcast unencrypted is TI_TRUE & packet encryption is OFF\n"); - - RxBufFree(pRxData->hOs, pBuffer); - return; - } - - /* - * Discard multicast/broadcast frames that we sent ourselves. - * Per IEEE 802.11-2007 section 9.2.7: "STAs shall filter out - * broadcast/multicast messages that contain their address as - * the source address." - */ - pFwInfo = TWD_GetFWInfo (pRxData->hTWD); - if (MAC_EQUAL(pFwInfo->macAddress, pEthernetHeader->src)) - { - pRxData->rxDataDbgCounters.excludedFrameCounter++; - /* free Buffer */ - RxBufFree(pRxData->hOs, pBuffer); - return; - } - } - - /* update traffic monitor parameters */ - pRxData->rxDataCounters.RecvOk++; - EventMask |= RECV_OK; - - if (!MAC_MULTICAST (pEthernetHeader->dst)) - { - /* Directed frame */ - pRxData->rxDataCounters.DirectedFramesRecv++; - pRxData->rxDataCounters.DirectedBytesRecv += RX_ETH_PKT_LEN(pBuffer); - EventMask |= DIRECTED_BYTES_RECV; - EventMask |= DIRECTED_FRAMES_RECV; - } - else if (MAC_BROADCAST (pEthernetHeader->dst)) - { - /* Broadcast frame */ - pRxData->rxDataCounters.BroadcastFramesRecv++; - pRxData->rxDataCounters.BroadcastBytesRecv += RX_ETH_PKT_LEN(pBuffer); - EventMask |= BROADCAST_BYTES_RECV; - EventMask |= BROADCAST_FRAMES_RECV; - } - else - { - /* Multicast Address */ - pRxData->rxDataCounters.MulticastFramesRecv++; - pRxData->rxDataCounters.MulticastBytesRecv += RX_ETH_PKT_LEN(pBuffer); - EventMask |= MULTICAST_BYTES_RECV; - EventMask |= MULTICAST_FRAMES_RECV; - } - pRxData->rxDataCounters.LastSecBytesRecv += RX_ETH_PKT_LEN(pBuffer); - - /*Handle PREAUTH_EAPOL_PACKET*/ - if (HTOWLANS(pEthernetHeader->type) == PREAUTH_EAPOL_PACKET) - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_rcvPacketData() : Received an Pre-Auth EAPOL frame tranferred to OS\n"); - } - - rxData_DistributorRxEvent (pRxData, EventMask, RX_ETH_PKT_LEN(pBuffer)); - - /* deliver packet to os */ - os_receivePacket (pRxData->hOs, (struct RxIfDescriptor_t*)pBuffer, pBuffer, (TI_UINT16)RX_ETH_PKT_LEN(pBuffer)); -} - - -/*************************************************************************** -* rxData_rcvPacketIapp * -**************************************************************************** -* DESCRIPTION: this function is called upon receving data IAPP packet type -* while rx port status is "open" -* -* INPUTS: hRxData - the object -* pBuffer - the received Buffer. -* pRxAttr - Rx attributes -* -* OUTPUT: -* -* RETURNS: -***************************************************************************/ -#ifdef XCC_MODULE_INCLUDED - -static void rxData_rcvPacketIapp(TI_HANDLE hRxData, void *pBuffer, TRxAttr* pRxAttr) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_rcvPacketIapp() : Received IAPP frame tranferred to XCCMgr\n"); - - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_rcvPacketIapp() : Received IAPP frame tranferred to XCCMgr\n"); - - /* tranfer packet to XCCMgr */ - XCCMngr_recvIAPPPacket (pRxData->hXCCMgr, pBuffer, pRxAttr); - - /* free Buffer */ - RxBufFree(pRxData->hOs, pBuffer); -} - -#endif - - -/**************************************************************************** -* rxData_convertWlanToEthHeader * -***************************************************************************** -* DESCRIPTION: this function convert the Packet header from 802.11 header -* format to ethernet format -* -* INPUTS: hRxData - the object -* pBuffer - the received pBuffer in 802.11 format -* -* OUTPUT: pEthPacket - pointer to the received pBuffer in ethernet format -* uEthLength - ethernet packet length -* -* RETURNS: TI_OK/TI_NOK -***************************************************************************/ -static TI_STATUS rxData_convertWlanToEthHeader (TI_HANDLE hRxData, void *pBuffer, TI_UINT16 * etherType) -{ - TEthernetHeader EthHeader; - Wlan_LlcHeader_T *pWlanSnapHeader; - TI_UINT8 *dataBuf; - dot11_header_t *pDot11Header; - TI_UINT32 lengthDelta; - TI_UINT16 swapedTypeLength; - TI_UINT32 headerLength; - TI_UINT8 createEtherIIHeader; - rxData_t *pRxData = (rxData_t *)hRxData; - - dataBuf = (TI_UINT8 *)RX_BUF_DATA(pBuffer); - - /* Setting the mac header len according to the received FrameControl field in the Mac Header */ - GET_MAX_HEADER_SIZE (dataBuf, &headerLength); - pDot11Header = (dot11_header_t*) dataBuf; - pWlanSnapHeader = (Wlan_LlcHeader_T*)((TI_UINT32)dataBuf + (TI_UINT32)headerLength); - - swapedTypeLength = WLANTOHS (pWlanSnapHeader->Type); - *etherType = swapedTypeLength; - - /* Prepare the Ethernet header. */ - if( ENDIAN_HANDLE_WORD(pDot11Header->fc) & DOT11_FC_FROM_DS) - { /* Infrastructure bss */ - MAC_COPY (EthHeader.dst, pDot11Header->address1); - MAC_COPY (EthHeader.src, pDot11Header->address3); - } - else - { /* Independent bss */ - MAC_COPY (EthHeader.dst, pDot11Header->address1); - MAC_COPY (EthHeader.src, pDot11Header->address2); - } - - createEtherIIHeader = TI_FALSE; - /* See if the LLC header in the frame shows the SAP SNAP... */ - if((SNAP_CHANNEL_ID == pWlanSnapHeader->DSAP) && - (SNAP_CHANNEL_ID == pWlanSnapHeader->SSAP) && - (LLC_CONTROL_UNNUMBERED_INFORMATION == pWlanSnapHeader->Control)) - { - /* Check for the Bridge Tunnel OUI in the SNAP Header... */ - if((SNAP_OUI_802_1H_BYTE0 == pWlanSnapHeader->OUI[ 0 ]) && - (SNAP_OUI_802_1H_BYTE1 == pWlanSnapHeader->OUI[ 1 ]) && - (SNAP_OUI_802_1H_BYTE2 == pWlanSnapHeader->OUI[ 2 ])) - { - /* Strip the SNAP header by skipping over it. */ - /* Start moving data from the Ethertype field in the SNAP */ - /* header. Move to the TypeLength field in the 802.3 header. */ - createEtherIIHeader = TI_TRUE; - } - /* Check for the RFC 1042 OUI in the SNAP Header */ - else - { - /* Check for the RFC 1042 OUI in the SNAP Header */ - if( (SNAP_OUI_RFC1042_BYTE0 == pWlanSnapHeader->OUI[ 0 ]) && - (SNAP_OUI_RFC1042_BYTE1 == pWlanSnapHeader->OUI[ 1 ]) && - (SNAP_OUI_RFC1042_BYTE2 == pWlanSnapHeader->OUI[ 2 ])) - { - /* See if the Ethertype is in our selective translation table */ - /* (Appletalk AARP and DIX II IPX are the two protocols in */ - /* our 'table') */ - if((ETHERTYPE_APPLE_AARP != swapedTypeLength) && - (ETHERTYPE_DIX_II_IPX != swapedTypeLength)) - { - /* Strip the SNAP header by skipping over it. */ - createEtherIIHeader = TI_TRUE; - } - } - } - } - - if( createEtherIIHeader == TI_TRUE ) - { - /* The LEN/TYPE bytes are set to TYPE, the entire WLAN+SNAP is removed.*/ - lengthDelta = headerLength + WLAN_SNAP_HDR_LEN - ETHERNET_HDR_LEN; - EthHeader.type = pWlanSnapHeader->Type; - } - else - { - /* The LEN/TYPE bytes are set to frame LEN, only the WLAN header is removed, */ - /* the entire 802.3 or 802.2 header is not removed.*/ - lengthDelta = headerLength - ETHERNET_HDR_LEN; - EthHeader.type = WLANTOHS((TI_UINT16)(RX_BUF_LEN(pBuffer) - headerLength)); - } - - /* Replace the 802.11 header and the LLC with Ethernet packet. */ - dataBuf += lengthDelta; - os_memoryCopy (pRxData->hOs, dataBuf, (void*)&EthHeader, ETHERNET_HDR_LEN); - RX_ETH_PKT_DATA(pBuffer) = dataBuf; - RX_ETH_PKT_LEN(pBuffer) = RX_BUF_LEN(pBuffer) - lengthDelta; - - return TI_OK; -} - - -/** - * \brief convert A-MSDU to several ethernet packets - * - * \param hRxData - the object - * \param pBuffer - the received Buffer in A-MSDU 802.11n format - * \param pRxAttr - Rx attributes - * \return TI_OK on success or TI_NOK on failure - * - * \par Description - * Static function - * This function convert the A-MSDU Packet from A-MSDU 802.11n packet - * format to several ethernet packets format and pass them to the OS layer - * - * \sa - */ -static TI_STATUS rxData_ConvertAmsduToEthPackets (TI_HANDLE hRxData, void *pBuffer, TRxAttr* pRxAttr) -{ - - TEthernetHeader *pMsduEthHeader; - TEthernetHeader *pEthHeader; - Wlan_LlcHeader_T *pWlanSnapHeader; - TI_UINT8 *pAmsduDataBuf; - TI_UINT16 uAmsduDataLen; - void *pDataBuf; - TI_UINT16 uDataLen; - TI_UINT32 lengthDelta; - TI_UINT16 swapedTypeLength; - TI_UINT32 headerLength; - rxDataPacketType_e DataPacketType; - rxData_t *pRxData = (rxData_t *)hRxData; - - /* total AMPDU header */ - pAmsduDataBuf = (TI_UINT8 *)RX_BUF_DATA(pBuffer); - /* Setting the mac header len according to the received FrameControl field in the Mac Header */ - GET_MAX_HEADER_SIZE (pAmsduDataBuf, &headerLength); - - /* - * init loop setting - */ - /* total AMPDU size */ - uAmsduDataLen = (TI_UINT16)(RX_BUF_LEN(pBuffer) - headerLength); - /* ETH header */ - pMsduEthHeader = (TEthernetHeader *)(pAmsduDataBuf + headerLength); - /* ETH length, in A-MSDU the MSDU header type contain the MSDU length and not the type */ - uDataLen = WLANTOHS(pMsduEthHeader->type); - - TRACE1(pRxData->hReport, REPORT_SEVERITY_INFORMATION, "rxData_ConvertAmsduToEthPackets(): A-MSDU received in length %d \n",uAmsduDataLen); - - /* if we have another packet at the AMSDU */ - while((uDataLen < uAmsduDataLen) && (uAmsduDataLen > ETHERNET_HDR_LEN + FCS_SIZE)) - { - /* allocate a new buffer */ - /* RxBufAlloc() add an extra word for alignment the MAC payload */ - rxData_RequestForBuffer (hRxData, &pDataBuf, sizeof(RxIfDescriptor_t) + WLAN_SNAP_HDR_LEN + ETHERNET_HDR_LEN + uDataLen, 0, TAG_CLASS_AMSDU); - if (NULL == pDataBuf) - { - TRACE1(pRxData->hReport, REPORT_SEVERITY_ERROR, "rxData_ConvertAmsduToEthPackets(): cannot alloc MSDU packet. length %d \n",uDataLen); - rxData_discardPacket (hRxData, pBuffer, pRxAttr); - return TI_NOK; - } - - /* read packet type from LLC */ - pWlanSnapHeader = (Wlan_LlcHeader_T*)((TI_UINT8*)pMsduEthHeader + ETHERNET_HDR_LEN); - swapedTypeLength = WLANTOHS (pWlanSnapHeader->Type); - - /* copy the RxIfDescriptor */ - os_memoryCopy (pRxData->hOs, pDataBuf, pBuffer, sizeof(RxIfDescriptor_t)); - - /* update length, in the RxIfDescriptor the Len in words (4B) */ - ((RxIfDescriptor_t *)pDataBuf)->length = (sizeof(RxIfDescriptor_t) + WLAN_SNAP_HDR_LEN + ETHERNET_HDR_LEN + uDataLen) >> 2; - ((RxIfDescriptor_t *)pDataBuf)->extraBytes = 4 - ((sizeof(RxIfDescriptor_t) + WLAN_SNAP_HDR_LEN + ETHERNET_HDR_LEN + uDataLen) & 0x3); - - /* Prepare the Ethernet header pointer. */ - /* add padding in the start of the buffer in order to align ETH payload */ - pEthHeader = (TEthernetHeader *)((TI_UINT8 *)(RX_BUF_DATA(pDataBuf)) + - WLAN_SNAP_HDR_LEN + - PADDING_ETH_PACKET_SIZE); - - /* copy the Ethernet header */ - os_memoryCopy (pRxData->hOs, pEthHeader, pMsduEthHeader, ETHERNET_HDR_LEN); - - /* The LEN/TYPE bytes are set to TYPE */ - pEthHeader->type = pWlanSnapHeader->Type; - - /* Delta length for the next packet */ - lengthDelta = ETHERNET_HDR_LEN + uDataLen; - - /* copy the packet payload */ - if (uDataLen > WLAN_SNAP_HDR_LEN) - os_memoryCopy (pRxData->hOs, - (((TI_UINT8*)pEthHeader) + ETHERNET_HDR_LEN), - ((TI_UINT8*)pMsduEthHeader) + ETHERNET_HDR_LEN + WLAN_SNAP_HDR_LEN, - uDataLen - WLAN_SNAP_HDR_LEN); - - /* set the packet type */ - if (swapedTypeLength == ETHERTYPE_802_1D) - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_ConvertAmsduToEthPackets() : Received VLAN Buffer \n"); - - DataPacketType = DATA_VLAN_PACKET; - } - else if (HTOWLANS(pEthHeader->type) == EAPOL_PACKET) - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_ConvertAmsduToEthPackets() : Received Eapol pBuffer \n"); - - DataPacketType = DATA_EAPOL_PACKET; - } - else - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, " rxData_ConvertAmsduToEthPackets() : Received Data pBuffer \n"); - - DataPacketType = DATA_DATA_PACKET; - } - - /* update buffer setting */ - /* save the ETH packet address */ - RX_ETH_PKT_DATA(pDataBuf) = pEthHeader; - /* save the ETH packet size */ - RX_ETH_PKT_LEN(pDataBuf) = uDataLen + ETHERNET_HDR_LEN - WLAN_SNAP_HDR_LEN; - - /* star of MSDU packet always align acceding to 11n spec */ - lengthDelta = (lengthDelta + ALIGN_4BYTE_MASK) & ~ALIGN_4BYTE_MASK; - pMsduEthHeader = (TEthernetHeader *)(((TI_UINT8*)pMsduEthHeader) + lengthDelta); - - if(uAmsduDataLen > lengthDelta) - { - /* swich to the next MSDU */ - uAmsduDataLen = uAmsduDataLen - lengthDelta; - - /* Clear the EndOfBurst flag for all packets except the last one */ - ((RxIfDescriptor_t *)pDataBuf)->driverFlags &= ~DRV_RX_FLAG_END_OF_BURST; - } - else - { - /* no more MSDU */ - uAmsduDataLen = 0; - } - - - /* in A-MSDU the MSDU header type contain the MSDU length and not the type */ - uDataLen = WLANTOHS(pMsduEthHeader->type); - - - /* dispatch Buffer according to packet type and current rx data port status */ - pRxData->rxData_dispatchBuffer[pRxData->rxDataPortStatus][DataPacketType] (hRxData, pDataBuf, pRxAttr); - - } /* while end */ - - - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION, "rxData_ConvertAmsduToEthPackets(): A-MSDU Packe conversion done.\n"); - - /* free the A-MSDU packet */ - RxBufFree(pRxData->hOs, pBuffer); - - return TI_OK; -} - -/**************************************************************************************** - * rxData_ReceivePacket * - **************************************************************************************** -DESCRIPTION: receive packet CB from RxXfer. - parse the status and other parameters and forward the frame to - rxData_receivePacketFromWlan() - -INPUT: Rx frame with its parameters - -OUTPUT: - -RETURN: - -************************************************************************/ -static void rxData_ReceivePacket (TI_HANDLE hRxData, - void *pBuffer) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - TRACE1(pRxData->hReport, REPORT_SEVERITY_INFORMATION, "rxData_ReceivePacket: Received BUF %x\n", pBuffer); - - if (pBuffer) - { - RxIfDescriptor_t *pRxParams = (RxIfDescriptor_t*)pBuffer; - TRxAttr RxAttr; - ERate appRate; - dot11_header_t *pHdr; - - /* - * First thing we do is getting the dot11_header, and than we check the status, since the header is - * needed for RX_MIC_FAILURE_ERROR - */ - - pHdr = (dot11_header_t *)RX_BUF_DATA(pBuffer); - - /* Check status */ - switch (pRxParams->status & RX_DESC_STATUS_MASK) - { - case RX_DESC_STATUS_SUCCESS: - break; - - case RX_DESC_STATUS_DECRYPT_FAIL: - { - /* This error is not important before the Connection, so we ignore it when portStatus is not OPEN */ - if (pRxData->rxDataPortStatus == OPEN) - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_WARNING, "rxData_ReceivePacket: Received Packet with RX_DESC_DECRYPT_FAIL\n"); - } - - RxBufFree(pRxData->hOs, pBuffer); - return; - } - case RX_DESC_STATUS_MIC_FAIL: - { - TI_UINT8 uKeyType; - paramInfo_t Param; - TMacAddr* pMac = &pHdr->address1; /* hold the first mac address */ - /* Get BSS type */ - Param.paramType = SITE_MGR_CURRENT_BSS_TYPE_PARAM; - siteMgr_getParam (pRxData->hSiteMgr, &Param); - - /* For multicast/broadcast frames or in IBSS the key used is GROUP, else - it's Pairwise */ - if (MAC_MULTICAST(*pMac) || Param.content.siteMgrCurrentBSSType == BSS_INDEPENDENT) - { - uKeyType = (TI_UINT8)KEY_TKIP_MIC_GROUP; - TRACE0(pRxData->hReport, REPORT_SEVERITY_ERROR, "rxData_ReceivePacket: Received Packet MIC failure. Type = Group\n"); - } - /* Unicast on infrastructure */ - else - { - uKeyType = (TI_UINT8)KEY_TKIP_MIC_PAIRWISE; - TRACE0(pRxData->hReport, REPORT_SEVERITY_ERROR, "rxData_ReceivePacket: Received Packet MIC failure. Type = Pairwise\n"); - } - - - rsn_reportMicFailure (pRxData->hRsn, &uKeyType, sizeof(uKeyType)); - RxBufFree(pRxData->hOs, pBuffer); - return; - } - - case RX_DESC_STATUS_DRIVER_RX_Q_FAIL: - { - /* Rx queue error - free packet and return */ - TRACE0(pRxData->hReport, REPORT_SEVERITY_ERROR, "rxData_ReceivePacket: Received Packet with Rx queue error \n"); - - RxBufFree(pRxData->hOs, pBuffer); - return; - } - - default: - /* Unknown error - free packet and return */ - TRACE1(pRxData->hReport, REPORT_SEVERITY_ERROR, "rxData_ReceivePacket: Received Packet with unknown status = %d\n", (pRxParams->status & RX_DESC_STATUS_MASK)); - - RxBufFree(pRxData->hOs, pBuffer); - return; - } - - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION , "Receive good Packet\n"); - - if (rate_PolicyToDrv ((ETxRateClassId)(pRxParams->rate), &appRate) != TI_OK) - { - TRACE1(pRxData->hReport, REPORT_SEVERITY_ERROR , "rxData_ReceivePacket: can't convert hwRate=0x%x\n", pRxParams->rate); - } - - /* - * Set rx attributes - */ - RxAttr.channel = pRxParams->channel; - RxAttr.packetInfo = pRxParams->flags; - RxAttr.ePacketType= pRxParams->packet_class_tag; - RxAttr.Rate = appRate; - RxAttr.Rssi = pRxParams->rx_level; - RxAttr.SNR = pRxParams->rx_snr; - RxAttr.status = pRxParams->status & RX_DESC_STATUS_MASK; - /* for now J band not implemented */ - RxAttr.band = ((pRxParams->flags & RX_DESC_BAND_MASK) == RX_DESC_BAND_A) ? - RADIO_BAND_5_0_GHZ : RADIO_BAND_2_4_GHZ ; - RxAttr.eScanTag = (EScanResultTag)(pRxParams->proccess_id_tag); - /* timestamp is 32 bit so do bytes copy to avoid exception in case the RxInfo is in 2 bytes offset */ - os_memoryCopy (pRxData->hOs, - (void *)&(RxAttr.TimeStamp), - (void *)&(pRxParams->timestamp), - sizeof(pRxParams->timestamp) ); - RxAttr.TimeStamp = ENDIAN_HANDLE_LONG(RxAttr.TimeStamp); - - TRACE8(pRxData->hReport, REPORT_SEVERITY_INFORMATION, "rxData_ReceivePacket: channel=%d, info=0x%x, type=%d, rate=0x%x, RSSI=%d, SNR=%d, status=%d, scan tag=%d\n", RxAttr.channel, RxAttr.packetInfo, RxAttr.ePacketType, RxAttr.Rate, RxAttr.Rssi, RxAttr.SNR, RxAttr.status, RxAttr.eScanTag); - - rxData_receivePacketFromWlan (hRxData, pBuffer, &RxAttr); - - /* - * Buffer MUST be freed until now - */ - } - else - { - TRACE0(pRxData->hReport, REPORT_SEVERITY_ERROR , "rxData_ReceivePacket: null Buffer received"); - } -} - - -/**************************************************************************************** - * rxData_RequestForBuffer * - **************************************************************************************** -DESCRIPTION: RX request for buffer - uEncryptionflag API are for GWSI use. -INPUT: - -OUTPUT: - -RETURN: - -************************************************************************/ -static ERxBufferStatus rxData_RequestForBuffer (TI_HANDLE hRxData, - void **pBuf, - TI_UINT16 aLength, - TI_UINT32 uEncryptionflag, - PacketClassTag_e ePacketClassTag) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - TRACE1(pRxData->hReport, REPORT_SEVERITY_INFORMATION , " RequestForBuffer, length = %d \n",aLength); - - *pBuf = RxBufAlloc (pRxData->hOs, aLength, ePacketClassTag); - - if (*pBuf) - { - return RX_BUF_ALLOC_COMPLETE; - } - else - { - return RX_BUF_ALLOC_OUT_OF_MEM; - } -} - - -/******************************************************************* -* DEBUG FUNCTIONS * -*******************************************************************/ - -#ifdef TI_DBG - -/*************************************************************************** -* rxData_resetCounters * -**************************************************************************** -* DESCRIPTION: This function reset the Rx Data module counters -* -* INPUTS: hRxData - the object -* -* OUTPUT: -* -* RETURNS: void -***************************************************************************/ -void rxData_resetCounters(TI_HANDLE hRxData) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - os_memoryZero(pRxData->hOs, &pRxData->rxDataCounters, sizeof(rxDataCounters_t)); -} - -/*************************************************************************** -* rxData_resetDbgCounters * -**************************************************************************** -* DESCRIPTION: This function reset the Rx Data module debug counters -* -* INPUTS: hRxData - the object -* -* OUTPUT: -* -* RETURNS: void -***************************************************************************/ - -void rxData_resetDbgCounters(TI_HANDLE hRxData) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - os_memoryZero(pRxData->hOs, &pRxData->rxDataDbgCounters, sizeof(rxDataDbgCounters_t)); -} - - -/*************************************************************************** -* test functions * -***************************************************************************/ -void rxData_printRxCounters (TI_HANDLE hRxData) -{ -#ifdef REPORT_LOG - rxData_t *pRxData = (rxData_t *)hRxData; - - if (pRxData) - { - WLAN_OS_REPORT(("RecvOk = %d\n", pRxData->rxDataCounters.RecvOk)); - WLAN_OS_REPORT(("DirectedBytesRecv = %d\n", pRxData->rxDataCounters.DirectedBytesRecv)); - WLAN_OS_REPORT(("DirectedFramesRecv = %d\n", pRxData->rxDataCounters.DirectedFramesRecv)); - WLAN_OS_REPORT(("MulticastBytesRecv = %d\n", pRxData->rxDataCounters.MulticastBytesRecv)); - WLAN_OS_REPORT(("MulticastFramesRecv = %d\n", pRxData->rxDataCounters.MulticastFramesRecv)); - WLAN_OS_REPORT(("BroadcastBytesRecv = %d\n", pRxData->rxDataCounters.BroadcastBytesRecv)); - WLAN_OS_REPORT(("BroadcastFramesRecv = %d\n", pRxData->rxDataCounters.BroadcastFramesRecv)); - - /* debug counters */ - WLAN_OS_REPORT(("excludedFrameCounter = %d\n", pRxData->rxDataDbgCounters.excludedFrameCounter)); - WLAN_OS_REPORT(("rxDroppedDueToVLANIncludedCnt = %d\n", pRxData->rxDataDbgCounters.rxDroppedDueToVLANIncludedCnt)); - WLAN_OS_REPORT(("rxWrongBssTypeCounter = %d\n", pRxData->rxDataDbgCounters.rxWrongBssTypeCounter)); - WLAN_OS_REPORT(("rxWrongBssIdCounter = %d\n", pRxData->rxDataDbgCounters.rxWrongBssIdCounter)); - WLAN_OS_REPORT(("rcvUnicastFrameInOpenNotify = %d\n", pRxData->rxDataDbgCounters.rcvUnicastFrameInOpenNotify)); - } -#endif -} - - -void rxData_printRxBlock(TI_HANDLE hRxData) -{ -#ifdef REPORT_LOG - rxData_t *pRxData = (rxData_t *)hRxData; - - WLAN_OS_REPORT(("hCtrlData = 0x%X\n", pRxData->hCtrlData)); - WLAN_OS_REPORT(("hMlme = 0x%X\n", pRxData->hMlme)); - WLAN_OS_REPORT(("hOs = 0x%X\n", pRxData->hOs)); - WLAN_OS_REPORT(("hReport = 0x%X\n", pRxData->hReport)); - WLAN_OS_REPORT(("hRsn = 0x%X\n", pRxData->hRsn)); - WLAN_OS_REPORT(("hSiteMgr = 0x%X\n", pRxData->hSiteMgr)); - - WLAN_OS_REPORT(("hCtrlData = 0x%X\n", pRxData->hCtrlData)); - WLAN_OS_REPORT(("hMlme = 0x%X\n", pRxData->hMlme)); - WLAN_OS_REPORT(("hOs = 0x%X\n", pRxData->hOs)); - WLAN_OS_REPORT(("hReport = 0x%X\n", pRxData->hReport)); - WLAN_OS_REPORT(("hRsn = 0x%X\n", pRxData->hRsn)); - WLAN_OS_REPORT(("hSiteMgr = 0x%X\n", pRxData->hSiteMgr)); - - WLAN_OS_REPORT(("rxDataPortStatus = %d\n", pRxData->rxDataPortStatus)); - WLAN_OS_REPORT(("rxDataExcludeUnencrypted = %d\n", pRxData->rxDataExcludeUnencrypted)); - WLAN_OS_REPORT(("rxDataEapolDestination = %d\n", pRxData->rxDataEapolDestination)); -#endif -} - - -void rxData_startRxThroughputTimer (TI_HANDLE hRxData) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - if (!pRxData->rxThroughputTimerEnable) - { - /* reset throughput counter */ - pRxData->rxDataCounters.LastSecBytesRecv = 0; - pRxData->rxThroughputTimerEnable = TI_TRUE; - - /* start 1 sec throughput timer */ - tmr_StartTimer (pRxData->hThroughputTimer, - rxData_printRxThroughput, - (TI_HANDLE)pRxData, - 1000, - TI_TRUE); - } -} - - -void rxData_stopRxThroughputTimer (TI_HANDLE hRxData) -{ - - rxData_t *pRxData = (rxData_t *)hRxData; - - if (pRxData->rxThroughputTimerEnable) - { - tmr_StopTimer (pRxData->hThroughputTimer); - pRxData->rxThroughputTimerEnable = TI_FALSE; - } -} - - -static void rxData_printRxThroughput (TI_HANDLE hRxData, TI_BOOL bTwdInitOccured) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - WLAN_OS_REPORT (("\n")); - WLAN_OS_REPORT (("-------------- Rx Throughput Statistics ---------------\n")); - WLAN_OS_REPORT (("Throughput = %d KBits/sec\n", pRxData->rxDataCounters.LastSecBytesRecv * 8 / 1024)); - - /* reset throughput counter */ - pRxData->rxDataCounters.LastSecBytesRecv = 0; -} - -void rxData_printRxDataFilter (TI_HANDLE hRxData) -{ - TI_UINT32 index; - rxData_t *pRxData = (rxData_t *)hRxData; - - for (index=0; index<MAX_DATA_FILTERS; index++) - { - if (pRxData->isFilterSet[index]) - { - WLAN_OS_REPORT (("index=%d, pattern & mask\n", index)); - report_PrintDump(pRxData->filterRequests[index].pattern, pRxData->filterRequests[index].patternLength); - report_PrintDump(pRxData->filterRequests[index].mask, pRxData->filterRequests[index].maskLength); - } - else - { - WLAN_OS_REPORT (("No Filter defined for index-%d\n", index)); - } - } -} - -#endif /*TI_DBG*/ - -/**************************************************************************** - * rxData_SetReAuthInProgress() - **************************************************************************** - * DESCRIPTION: Sets the ReAuth flag value - * - * INPUTS: hRxData - the object - * value - value to set the flag to - * - * OUTPUT: None - * - * RETURNS: OK or NOK - ****************************************************************************/ -void rxData_SetReAuthInProgress(TI_HANDLE hRxData, TI_BOOL value) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - TRACE1(pRxData->hReport, REPORT_SEVERITY_INFORMATION , "Set ReAuth flag to %d\n", value); - - pRxData->reAuthInProgress = value; -} - -/**************************************************************************** - * rxData_IsReAuthInProgress() - **************************************************************************** - * DESCRIPTION: Returns the ReAuth flag value - * - * INPUTS: hRxData - the object - * - * OUTPUT: None - * - * RETURNS: ReAuth flag value - ****************************************************************************/ -TI_BOOL rxData_IsReAuthInProgress(TI_HANDLE hRxData) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - return pRxData->reAuthInProgress; -} - -/**************************************************************************** -* rxData_StartReAuthActiveTimer * -***************************************************************************** -* DESCRIPTION: this function starts the ReAuthActive timer -* -* INPUTS: hRxData - the object -* -* OUTPUT: None -* -* RETURNS: None -***************************************************************************/ -static void rxData_StartReAuthActiveTimer(TI_HANDLE hRxData) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION , "Start ReAuth Active Timer\n"); - tmr_StartTimer (pRxData->reAuthActiveTimer, - reAuthTimeout, - (TI_HANDLE)pRxData, - pRxData->reAuthActiveTimeout, - TI_FALSE); -} - -/**************************************************************************** -* rxData_StopReAuthActiveTimer * -***************************************************************************** -* DESCRIPTION: this function stops the ReAuthActive timer -* -* INPUTS: hRxData - the object -* -* OUTPUT: None -* -* RETURNS: None -***************************************************************************/ -void rxData_StopReAuthActiveTimer(TI_HANDLE hRxData) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION , "Stop ReAuth Active Timer\n"); - tmr_StopTimer (pRxData->reAuthActiveTimer); -} - -/**************************************************************************** -* reAuthTimeout * -***************************************************************************** -* DESCRIPTION: this function ia called when the ReAuthActive timer elapses -* It resets the Reauth flag and restore the PS state. -* It also sends RE_AUTH_TERMINATED event to upper layer. -* -* INPUTS: hRxData - the object -* -* OUTPUT: None -* -* RETURNS: None -***************************************************************************/ -static void reAuthTimeout(TI_HANDLE hRxData, TI_BOOL bTwdInitOccured) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - - TRACE0(pRxData->hReport, REPORT_SEVERITY_INFORMATION , "ReAuth Active Timeout\n"); - rxData_SetReAuthInProgress(pRxData, TI_FALSE); - rxData_ReauthDisablePriority(pRxData); - EvHandlerSendEvent(pRxData->hEvHandler, IPC_EVENT_RE_AUTH_TERMINATED, NULL, 0); -} - -void rxData_ReauthEnablePriority(TI_HANDLE hRxData) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - paramInfo_t param; - - param.paramType = POWER_MGR_ENABLE_PRIORITY; - param.content.powerMngPriority = POWER_MANAGER_REAUTH_PRIORITY; - powerMgr_setParam(pRxData->hPowerMgr,¶m); -} - -void rxData_ReauthDisablePriority(TI_HANDLE hRxData) -{ - rxData_t *pRxData = (rxData_t *)hRxData; - paramInfo_t param; - - param.paramType = POWER_MGR_DISABLE_PRIORITY; - param.content.powerMngPriority = POWER_MANAGER_REAUTH_PRIORITY; - powerMgr_setParam(pRxData->hPowerMgr,¶m); -} |