#include <sys/cdefs.h>
#include <dev/pms/config.h>
#include <dev/pms/freebsd/driver/common/osenv.h>
#include <dev/pms/freebsd/driver/common/ostypes.h>
#include <dev/pms/freebsd/driver/common/osdebug.h>
#include <dev/pms/RefTisa/sallsdk/api/sa.h>
#include <dev/pms/RefTisa/sallsdk/api/saapi.h>
#include <dev/pms/RefTisa/sallsdk/api/saosapi.h>
#include <dev/pms/RefTisa/tisa/api/titypes.h>
#include <dev/pms/RefTisa/tisa/api/ostiapi.h>
#include <dev/pms/RefTisa/tisa/api/tiapi.h>
#include <dev/pms/RefTisa/tisa/api/tiglobal.h>
#ifdef FDS_SM
#include <dev/pms/RefTisa/sat/api/sm.h>
#include <dev/pms/RefTisa/sat/api/smapi.h>
#include <dev/pms/RefTisa/sat/api/tdsmapi.h>
#endif
#ifdef FDS_DM
#include <dev/pms/RefTisa/discovery/api/dm.h>
#include <dev/pms/RefTisa/discovery/api/dmapi.h>
#include <dev/pms/RefTisa/discovery/api/tddmapi.h>
#endif
#include <dev/pms/RefTisa/tisa/sassata/sas/common/tdtypes.h>
#include <dev/pms/freebsd/driver/common/osstring.h>
#include <dev/pms/RefTisa/tisa/sassata/common/tdutil.h>
#ifdef INITIATOR_DRIVER
#include <dev/pms/RefTisa/tisa/sassata/sas/ini/itdtypes.h>
#include <dev/pms/RefTisa/tisa/sassata/sas/ini/itddefs.h>
#include <dev/pms/RefTisa/tisa/sassata/sas/ini/itdglobl.h>
#endif
#ifdef TARGET_DRIVER
#include <dev/pms/RefTisa/tisa/sassata/sas/tgt/ttdglobl.h>
#include <dev/pms/RefTisa/tisa/sassata/sas/tgt/ttdxchg.h>
#include <dev/pms/RefTisa/tisa/sassata/sas/tgt/ttdtypes.h>
#endif
#include <dev/pms/RefTisa/tisa/sassata/common/tdsatypes.h>
#include <dev/pms/RefTisa/tisa/sassata/common/tdproto.h>
osGLOBAL void
tiCOMTimerTick (
tiRoot_t * tiRoot
)
{
tdsaRoot_t *tdsaRoot = (tdsaRoot_t *)(tiRoot->tdData);
agsaRoot_t *agRoot = &tdsaRoot->tdsaAllShared.agRootNonInt;
#ifdef FDS_DM
dmRoot_t *dmRoot = &tdsaRoot->tdsaAllShared.dmRoot;
#endif
#ifdef FDS_SM_NOT_YET
smRoot_t *smRoot = &tdsaRoot->tdsaAllShared.smRoot;
#endif
saTimerTick(agRoot);
#ifdef FDS_DM
dmTimerTick(dmRoot);
#endif
#ifdef FDS_SM_NOT_YET
smTimerTick(smRoot);
#endif
tdsaProcessTimers(tiRoot);
}
osGLOBAL void
tdsaInitTimerRequest(
tiRoot_t *tiRoot,
tdsaTimerRequest_t *timerRequest
)
{
timerRequest->timeout = 0;
timerRequest->timerCBFunc = agNULL;
timerRequest->timerData1 = agNULL;
timerRequest->timerData2 = agNULL;
timerRequest->timerData3 = agNULL;
TDLIST_INIT_ELEMENT((&timerRequest->timerLink));
}
osGLOBAL void
tdsaSetTimerRequest(
tiRoot_t *tiRoot,
tdsaTimerRequest_t *timerRequest,
bit32 timeout,
tdsaTimerCBFunc_t CBFunc,
void *timerData1,
void *timerData2,
void *timerData3
)
{
timerRequest->timeout = timeout;
timerRequest->timerCBFunc = CBFunc;
timerRequest->timerData1 = timerData1;
timerRequest->timerData2 = timerData2;
timerRequest->timerData3 = timerData3;
}
osGLOBAL void
tdsaAddTimer(
tiRoot_t *tiRoot,
tdList_t *timerListHdr,
tdsaTimerRequest_t *timerRequest
)
{
tdsaSingleThreadedEnter(tiRoot, TD_TIMER_LOCK);
TDLIST_ENQUEUE_AT_TAIL(&(timerRequest->timerLink), timerListHdr);
timerRequest->timerRunning = agTRUE;
tdsaSingleThreadedLeave(tiRoot, TD_TIMER_LOCK);
}
osGLOBAL void
tdsaKillTimer(
tiRoot_t *tiRoot,
tdsaTimerRequest_t *timerRequest
)
{
tdsaSingleThreadedEnter(tiRoot, TD_TIMER_LOCK);
timerRequest->timerRunning = agFALSE;
TDLIST_DEQUEUE_THIS(&(timerRequest->timerLink));
tdsaSingleThreadedLeave(tiRoot, TD_TIMER_LOCK);
}
osGLOBAL void
tdsaProcessTimers(
tiRoot_t *tiRoot
)
{
tdsaRoot_t *tdsaRoot = (tdsaRoot_t *)(tiRoot->tdData);
tdsaContext_t *tdsaAllShared = (tdsaContext_t *)&tdsaRoot->tdsaAllShared;
tdsaTimerRequest_t *timerRequest_to_process = agNULL;
tdList_t *timerlist_to_process, *nexttimerlist = agNULL;
timerlist_to_process = &tdsaAllShared->timerlist;
timerlist_to_process = timerlist_to_process->flink;
while ((timerlist_to_process != agNULL) && (timerlist_to_process != &tdsaAllShared->timerlist))
{
nexttimerlist = timerlist_to_process->flink;
tdsaSingleThreadedEnter(tiRoot, TD_TIMER_LOCK);
timerRequest_to_process = TDLIST_OBJECT_BASE(tdsaTimerRequest_t, timerLink, timerlist_to_process);
tdsaSingleThreadedLeave(tiRoot, TD_TIMER_LOCK);
if (timerRequest_to_process == agNULL)
{
TI_DBG1(("tdsaProcessTimers: timerRequest_to_process is NULL! Error!!!\n"));
return;
}
timerRequest_to_process->timeout--;
if (timerRequest_to_process->timeout == 0)
{
tdsaSingleThreadedEnter(tiRoot, TD_TIMER_LOCK);
if (timerRequest_to_process->timerRunning == agTRUE)
{
timerRequest_to_process->timerRunning = agFALSE;
TDLIST_DEQUEUE_THIS(timerlist_to_process);
}
tdsaSingleThreadedLeave(tiRoot, TD_TIMER_LOCK);
(timerRequest_to_process->timerCBFunc)(tiRoot,
timerRequest_to_process->timerData1,
timerRequest_to_process->timerData2,
timerRequest_to_process->timerData3
);
}
timerlist_to_process = nexttimerlist;
}
return;
}