/*
* connIbss.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.
*/
/** \file connIbss.c
* \brief IBSS connection implementation
*
* \see connIbss.h
*/
/***************************************************************************/
/* */
/* MODULE: connIbss.c */
/* PURPOSE: IBSS connection implementation */
/* */
/***************************************************************************/
#define __FILE_ID__ FILE_ID_26
#include "tidef.h"
#include "report.h"
#include "osApi.h"
#include "conn.h"
#include "connIbss.h"
#include "timer.h"
#include "fsm.h"
#include "siteMgrApi.h"
#include "sme.h"
#include "rsnApi.h"
#include "DataCtrl_Api.h"
#include "paramOut.h"
#include "connApi.h"
#include "EvHandler.h"
#include "currBss.h"
#include "TrafficMonitorAPI.h"
#include "healthMonitor.h"
#include "TWDriver.h"
/* Local functions prototypes */
/* Local functions prototypes */
static TI_STATUS waitDisconnToCmplt_to_idle (void *pData);
static TI_STATUS idle_to_selfWait(void *pData);
static TI_STATUS idle_to_rsnWait(void *pData);
static TI_STATUS selfWait_to_waitToDisconnCmplt(void *pData);
static TI_STATUS rsnWait_to_waitToDisconnCmplt(void *pData);
static TI_STATUS connected_to_waitToDisconnCmplt(void *pData);
static TI_STATUS selfWait_to_rsnWait(void *pData);
static TI_STATUS rsnWait_to_connected(void *pData);
static TI_STATUS actionUnexpected(void *pData);
static TI_STATUS actionNop(void *pData);
static TI_STATUS selfw_merge_rsnw(void *pData);
static TI_STATUS rsnw_merge_rsnw(void *pData);
static TI_STATUS conn_merge_conn(void *pData);
/********************************************/
/* Functions Implementations */
/********************************************/
/***********************************************************************
* conn_ibssConfig
***********************************************************************
DESCRIPTION: IBSS Connection configuration function, called by the conection set param function
in the selection phase. Configures the connection state machine to IBSS connection mode
INPUT: hConn - Connection handle.
OUTPUT:
RETURN: TI_OK on success, TI_NOK otherwise
************************************************************************/
TI_STATUS conn_ibssConfig(conn_t *pConn)
{
fsm_actionCell_t smMatrix[CONN_IBSS_NUM_STATES][CONN_IBSS_NUM_EVENTS] =
{
/* next state and actions for IDLE state */
{ {STATE_CONN_IBSS_SELF_WAIT, idle_to_selfWait }, /* CONN_IBSS_CREATE */
{STATE_CONN_IBSS_RSN_WAIT, idle_to_rsnWait }, /* CONN_IBSS_CONNECT */
{STATE_CONN_IBSS_IDLE, actionNop }, /* CONN_IBSS_DISCONNECT */
{STATE_CONN_IBSS_IDLE, actionUnexpected }, /* CONN_IBSS_RSN_SUCC */
{STATE_CONN_IBSS_IDLE, actionUnexpected }, /* CONN_IBSS_STA_JOINED */
{STATE_CONN_IBSS_IDLE, actionUnexpected }, /* CONN_IBSS_MERGE */
{STATE_CONN_IBSS_IDLE, actionUnexpected } /* CONN_IBSS_DISCONN_COMPLETE */
},
/* next state and actions for SELF_WAIT state */
{ {STATE_CONN_IBSS_SELF_WAIT, actionUnexpected }, /* CONN_IBSS_CREATE */
{STATE_CONN_IBSS_SELF_WAIT, actionUnexpected }, /* CONN_IBSS_CONNECT */
{STATE_CONN_IBSS_WAIT_DISCONN_CMPLT, selfWait_to_waitToDisconnCmplt }, /* CONN_IBSS_DISCONNECT */
{STATE_CONN_IBSS_SELF_WAIT, actionUnexpected }, /* CONN_IBSS_RSN_SUCC */
{STATE_CONN_IBSS_RSN_WAIT, selfWait_to_rsnWait }, /* CONN_IBSS_STA_JOINED */
{STATE_CONN_IBSS_RSN_WAIT, selfw_merge_rsnw }, /* CONN_IBSS_MERGE */
{STATE_CONN_IBSS_SELF_WAIT, actionUnexpected } /* CONN_IBSS_DISCONN_COMPLETE */
},
/* next state and actions for RSN_WAIT state */
{ {STATE_CONN_IBSS_RSN_WAIT, actionUnexpected }, /* CONN_IBSS_CREATE */
{STATE_CONN_IBSS_RSN_WAIT, actionUnexpected }, /* CONN_IBSS_CONNECT */
{STATE_CONN_IBSS_WAIT_DISCONN_CMPLT, rsnWait_to_waitToDisconnCmplt }, /* CONN_IBSS_DISCONNECT */
{STATE_CONN_IBSS_CONNECTED, rsnWait_to_connected }, /* CONN_IBSS_RSN_SUCC */
{STATE_CONN_IBSS_RSN_WAIT, actionUnexpected }, /* CONN_IBSS_STA_JOINED */
{STATE_CONN_IBSS_RSN_WAIT, rsnw_merge_rsnw }, /* CONN_IBSS_MERGE */
{STATE_CONN_IBSS_RSN_WAIT, actionUnexpected } /* CONN_IBSS_DISCONN_COMPLETE */
},
/* next state and actions for CONNECTED state */
{ {STATE_CONN_IBSS_CONNECTED, actionUnexpected }, /* CONN_IBSS_CREATE */
{STATE_CONN_IBSS_CONNECTED, actionUnexpected }, /* CONN_IBSS_CONNECT */
{STATE_CONN_IBSS_WAIT_DISCONN_CMPLT, connected_to_waitToDisconnCmplt }, /* CONN_IBSS_DISCONNECT */
{STATE_CONN_IBSS_CONNECTED, actionUnexpected }, /* CONN_IBSS_RSN_SUCC */
{STATE_CONN_IBSS_CONNECTED, actionUnexpected }, /* CONN_IBSS_STA_JOINED */
{STATE_CONN_IBSS_CONNECTED, conn_merge_conn }, /* CONN_IBSS_MERGE */
{STATE_CONN_IBSS_CONNECTED, actionUnexpected } /* CONN_IBSS_DISCONN_COMPLETE */
},
/* next state and actions for STATE_CONN_IBSS_WAIT_DISCONN_CMPLT state */
{ {STATE_CONN_IBSS_WAIT_DISCONN_CMPLT, actionUnexpected }, /* CONN_IBSS_CREATE */
{STATE_CONN_IBSS_WAIT_DISCONN_CMPLT, actionUnexpected }, /* CONN_IBSS_CONNECT */
{STATE_CONN_IBSS_WAIT_DISCONN_CMPLT, actionUnexpected }, /* CONN_IBSS_DISCONNECT */
{STATE_CONN_IBSS_WAIT_DISCONN_CMPLT, actionUnexpected }, /* CONN_IBSS_RSN_SUCC */
{STATE_CONN_IBSS_WAIT_DISCONN_CMPLT, actionUnexpected }, /* CONN_IBSS_STA_JOINED */
{STATE_CONN_IBSS_WAIT_DISCONN_CMPLT, actionUnexpected }, /* CONN_IBSS_MERGE */
{STATE_CONN_IBSS_IDLE, waitDisconnToCmplt_to_idle } /* CONN_IBSS_DISCONN_COMPLETE */
}
};
return fsm_Config(pConn->ibss_pFsm, (fsm_Matrix_t)smMatrix, CONN_IBSS_NUM_STATES, CONN_IBSS_NUM_EVENTS, conn_ibssSMEvent, pConn->hOs);
}
/***********************************************************************
* conn_ibssSMEvent
***********************************************************************
DESCRIPTION: IBSS Connection SM event processing function, called by the connection API
Perform the following:
- Print the state movement as a result from the event
- Calls the generic state machine event processing function which preform the following:
- Calls the correspoding callback function
- Move to next state
INPUT: currentState - Pointer to the connection current state.
event - Received event
pConn - Connection handle
OUTPUT:
RETURN: TI_OK on success, TI_NOK otherwise
************************************************************************/
TI_STATUS conn_ibssSMEvent(TI_UINT8 *currentState, TI_UINT8 event, TI_HANDLE hConn)
{
conn_t *pConn = (conn_t *)hConn;
TI_STATUS status;
TI_UINT8 nextState;
status = fsm_GetNextState(pConn->ibss_pFsm, *currentState, event, &nextState);
if (status != TI_OK)
{
TRACE0(pConn->hReport, REPORT_SEVERITY_SM, "IBSS State machine error, failed getting next state\n");
return(TI_NOK);
}
TRACE3( pConn->hReport, REPORT_SEVERITY_INFORMATION, "conn_ibssSMEvent: <currentState = %d, event = %d> --> nextState = %d\n", *currentState, event, nextState);
status = fsm_Event(pConn->ibss_pFsm, currentState, event, (void *)pConn);
return status;
}
void connIbss_DisconnectComplete (conn_t *pConn, TI_UINT8 *data, TI_UINT8 dataLength)
{
/* send an DISCONNECT COMPLETE event to the SM */
conn_ibssSMEvent(&pConn->state, CONN_IBSS_DISCONN_COMPLETE, (TI_HANDLE) pConn);
}
/************************************************************************************************************/
/* In the following section are listed the callback function used by the IBSS connection state machine */
/************************************************************************************************************/
/***********************************************************************
* selfWait_to_rsnWait
***********************************************************************
DESCRIPTION:
INPUT:
OUTPUT:
RETURN: TI_OK on success, TI_NOK otherwise
************************************************************************/
static TI_STATUS selfWait_to_rsnWait (void *pData)
{
conn_t *pConn = (conn_t *)pData;
paramInfo_t param;
tmr_StopTimer (pConn->hConnTimer);
param.paramType = RX_DATA_PORT_STATUS_PARAM;
param.content.rxDataPortStatus = OPEN_EAPOL;
rxData_setParam (pConn->hRxData, ¶m);
/* Update TxMgmtQueue SM to enable EAPOL packets. */
txMgmtQ_SetConnState (pConn->hTxMgmtQ, TX_CONN_STATE_EAPOL);
return rsn_start (pConn->hRsn);
}
/***********************************************************************
* rsnWait_to_connected
***********************************************************************
DESCRIPTION:
INPUT:
OUTPUT:
RETURN: TI_OK on success, TI_NOK otherwise
************************************************************************/
static TI_STATUS rsnWait_to_connected(void *pData)
{
paramInfo_t param;
conn_t *pConn=(conn_t *)pData;
TrafficMonitor_Start( pConn->hTrafficMonitor );
healthMonitor_setState(pConn->hHealthMonitor, HEALTH_MONITOR_STATE_CONNECTED);
siteMgr_start(pConn->hSiteMgr);
param.paramType = RX_DATA_PORT_STATUS_PARAM;
param.content.rxDataPortStatus = OPEN;
rxData_setParam(((conn_t *)pData)->hRxData, ¶m);
/* Update TxMgmtQueue SM to open Tx path to all packets. */
txMgmtQ_SetConnState (((conn_t *)pData)->hTxMgmtQ, TX_CONN_STATE_OPEN);
/* Update current BSS connection type and mode */
currBSS_updateConnectedState(pConn->hCurrBss, TI_TRUE, BSS_INDEPENDENT);
sme_ReportConnStatus(((conn_t *)pData)->hSmeSm, STATUS_SUCCESSFUL, 0);
return TI_OK;
}
static TI_STATUS selfw_merge_rsnw(void *pData)
{
conn_t *pConn=(conn_t *)pData;
paramInfo_t param;
os_printf("IBSS selfw_merge_rsnw!!!!!!!!!!\n");
tmr_StopTimer (pConn->hConnTimer);
siteMgr_join(pConn->hSiteMgr);
param.paramType = RX_DATA_PORT_STATUS_PARAM;
param.content.rxDataPortStatus = OPEN_EAPOL;
rxData_setParam (pConn->hRxData, ¶m);
/* Update TxMgmtQueue SM to enable EAPOL packets. */
txMgmtQ_SetConnState (pConn->hTxMgmtQ, TX_CONN_STATE_EAPOL);
return rsn_start (pConn->hRsn);
}
static TI_STATUS rsnw_merge_rsnw(void *pData)
{
conn_t *pConn=(conn_t *)pData;
os_printf("IBSS rsnw_merge_rsnw!!!!!!!!!!\n");
siteMgr_join(pConn->hSiteMgr);
return TI_OK;
}
static TI_STATUS conn_merge_conn(void *pData)
{
conn_t *pConn=(conn_t *)pData;
os_printf("IBSS conn_merge_conn!!!!!!!!!!\n");
siteMgr_join(pConn->hSiteMgr);
return TI_OK;
}
static TI_STATUS waitDisconnToCmplt_to_idle (void *pData)
{
conn_t *pConn = (conn_t *)pData;
/* Inform the SME about the connection lost */
/* we use this status at SME, if != 0 means that assoc frame sent */
sme_ReportConnStatus(pConn->hSmeSm, STATUS_UNSPECIFIED, 1);
return TI_OK;
}
/***********************************************************************
* actionUnexpected
***********************************************************************
DESCRIPTION:
INPUT:
OUTPUT:
RETURN: TI_OK on success, TI_NOK otherwise
************************************************************************/
static TI_STATUS actionUnexpected(void *pData)
{
#ifdef TI_DBG
conn_t *pConn = (conn_t *)pData;
TRACE0(pConn->hReport, REPORT_SEVERITY_SM, "State machine error, unexpected Event\n\n");
#endif /*TI_DBG*/
return TI_OK;
}
/***********************************************************************
* actionNop
***********************************************************************
DESCRIPTION:
INPUT:
OUTPUT:
RETURN: TI_OK on success, TI_NOK otherwise
************************************************************************/
static TI_STATUS actionNop(void *pData)
{
return TI_OK;
}
/***********************************************************************
* selfWait_to_waitToDisconnCmplt
***********************************************************************
DESCRIPTION:
INPUT:
OUTPUT:
RETURN: TI_OK on success, TI_NOK otherwise
************************************************************************/
static TI_STATUS selfWait_to_waitToDisconnCmplt (void *pData)
{
conn_t *pConn = (conn_t *)pData;
paramInfo_t param;
tmr_StopTimer (pConn->hConnTimer);
siteMgr_removeSelfSite(pConn->hSiteMgr);
/* Update current BSS connection type and mode */
currBSS_updateConnectedState(pConn->hCurrBss, TI_FALSE, BSS_INDEPENDENT);
/* stop beacon generation */
param.paramType = RX_DATA_PORT_STATUS_PARAM;
param.content.rxDataPortStatus = CLOSE;
rxData_setParam(pConn->hRxData, ¶m);
/* Update TxMgmtQueue SM to close Tx path. */
txMgmtQ_SetConnState (pConn->hTxMgmtQ, TX_CONN_STATE_CLOSE);
TWD_CmdFwDisconnect (pConn->hTWD, DISCONNECT_IMMEDIATE, STATUS_UNSPECIFIED);
return TI_OK;
}
/***********************************************************************
* rsnWait_to_waitToDisconnCmplt
***********************************************************************
DESCRIPTION:
INPUT:
OUTPUT:
RETURN: TI_OK on success, TI_NOK otherwise
************************************************************************/
static TI_STATUS rsnWait_to_waitToDisconnCmplt(void *pData)
{
paramInfo_t param;
TI_STATUS tStatus;
tStatus = rsn_stop(((conn_t *)pData)->hRsn, TI_FALSE);
param.paramType = RX_DATA_PORT_STATUS_PARAM;
param.content.rxDataPortStatus = CLOSE;
rxData_setParam(((conn_t *)pData)->hRxData, ¶m);
/* Update TxMgmtQueue SM to close Tx path. */
txMgmtQ_SetConnState (((conn_t *)pData)->hTxMgmtQ, TX_CONN_STATE_CLOSE);
/* Update current BSS connection type and mode */
currBSS_updateConnectedState(((conn_t *)pData)->hCurrBss, TI_FALSE, BSS_INDEPENDENT);
/* Stop beacon generation */
TWD_CmdFwDisconnect (((conn_t *)pData)->hTWD, DISCONNECT_IMMEDIATE, STATUS_UNSPECIFIED);
return tStatus;
}
/***********************************************************************
* connected_to_waitToDisconnCmplt
***********************************************************************
DESCRIPTION:
INPUT:
OUTPUT:
RETURN: TI_OK on success, TI_NOK otherwise
************************************************************************/
static TI_STATUS connected_to_waitToDisconnCmplt(void *pData)
{
conn_t *pConn=(conn_t *)pData;
TrafficMonitor_Stop(pConn->hTrafficMonitor);
healthMonitor_setState(pConn->hHealthMonitor, HEALTH_MONITOR_STATE_DISCONNECTED);
/* The logic of this action is identical to rsnWait_to_idle */
return rsnWait_to_waitToDisconnCmplt(pConn);
}
/***********************************************************************
* idle_to_selfWait
***********************************************************************
DESCRIPTION:
INPUT:
OUTPUT:
RETURN: TI_OK on success, TI_NOK otherwise
************************************************************************/
static TI_STATUS idle_to_selfWait (void *pData)
{
conn_t *pConn = (conn_t *)pData;
TI_UINT16 randomTime;
siteMgr_join (pConn->hSiteMgr);
/* get a randomTime that is constructed of the lower 13 bits ot the system time to
get a MS random time of ~8000 ms */
randomTime = os_timeStampMs (pConn->hOs) & 0x1FFF;
/* Update current BSS connection type and mode */
currBSS_updateConnectedState (pConn->hCurrBss, TI_TRUE, BSS_INDEPENDENT);
tmr_StartTimer (pConn->hConnTimer,
conn_timeout,
(TI_HANDLE)pConn,
pConn->timeout + randomTime,
TI_FALSE);
/* Notify that the driver is associated to the supplicant\IP stack. */
EvHandlerSendEvent (pConn->hEvHandler, IPC_EVENT_ASSOCIATED, NULL, 0);
return TI_OK;
}
/***********************************************************************
* idle_to_rsnWait
***********************************************************************
DESCRIPTION:
INPUT:
OUTPUT:
RETURN: TI_OK on success, TI_NOK otherwise
************************************************************************/
static TI_STATUS idle_to_rsnWait(void *pData)
{
paramInfo_t param;
siteMgr_join(((conn_t *)pData)->hSiteMgr);
param.paramType = RX_DATA_PORT_STATUS_PARAM;
param.content.rxDataPortStatus = OPEN_EAPOL;
rxData_setParam(((conn_t *)pData)->hRxData, ¶m);
/* Update TxMgmtQueue SM to enable EAPOL packets. */
txMgmtQ_SetConnState (((conn_t *)pData)->hTxMgmtQ, TX_CONN_STATE_EAPOL);
/*
* Notify that the driver is associated to the supplicant\IP stack.
*/
EvHandlerSendEvent(((conn_t *)pData)->hEvHandler, IPC_EVENT_ASSOCIATED, NULL,0);
/* Update current BSS connection type and mode */
currBSS_updateConnectedState(((conn_t *)pData)->hCurrBss, TI_TRUE, BSS_INDEPENDENT);
return rsn_start(((conn_t *)pData)->hRsn);
}