layerapp.cpp

map协议源代码

#endif
/*
*
*       Fun:   AppLiMatOpenInd
*
*       Desc:  This function packs
*
*       Ret:   ROK
*
*       Notes: None
*
*       File:  layerapp.c
*
*/

#ifdef ANSI
PUBLIC S16 AppLiMatOpenInd
(
Pst  *pst,
SuId suId,
MaDlgId suDlgId,
MaDlgId spDlgId,
MaOpenEv *openEv
)
#else
PUBLIC S16 AppLiMatOpenInd (pst,suId, suDlgId, spDlgId, openEv)
Pst  *pst;
SuId suId;
MaDlgId suDlgId;
MaDlgId spDlgId;
MaOpenEv *openEv;
#endif
{
    TRC2(AppLiMatOpenInd)

    MaAccMsgQElm    qElm;
    Dialog          *curDlg;

    qElm.evtType = MA_EVTABRTREQ;
    qElm.suId    = suId;
    qElm.suDlgId = suDlgId;
    qElm.spDlgId = spDlgId;
    cmCpy(openEv, &qElm.s.openEv, sizeof(MaOpenEv));

    curDlg = dlgQueue->dlgInsert(suDlgId, spDlgId);
    if (curDlg == NULLP)
    {
        AUACC_PRINT("AppLiMatOpenInd__________insert dlg failure , maDlgId = %ld\n",
            spDlgId);
        RETVALUE(ROK);
    }
    else
    {
        AUACC_PRINT("AppLiMatOpenInd_______auDlgId = %ld maDlgId = %ld\n",
            curDlg->auDlgIdGet(), curDlg->maDlgIdGet());
        curDlg->auLiMatOpenIndPrs(&qElm);
    }
    smAuSts.lAuOpenInd++;
    RETVALUE(ROK);
} /* AppLiMatOpenInd  */


#ifdef AU
/*
*
*       Fun:   IuLiIatBndCfm
*
*       Desc:  This routine confirms a bind
*
*       Ret:   ROK
*
*       Notes: None
*
*       File:  layerapp.c
*
*/

#ifdef ANSI
PUBLIC S16 AppLiMatBndCfm
(
Pst  *pst,
SuId suId,
U8   status
)
#else
PUBLIC S16 AppLiMatBndCfm (pst,suId, status)
Pst  *pst;
SuId suId;
U8   status;
#endif
{
#if 0
   Txt prntBuf[MA_PRNTBUF_SIZE];
   MaAccMsgQElm  qElm;

   TRC3(AppLiMatSteCfm)

   AUACC_PRINT("MAP Bnd Cfm. suId %d - Status %d   \n", suId, status);

   qElm.evtType = MA_EVTBNDCFM;
   qElm.suId    = suId;                            /* service user id */
   qElm.status  = status;                          /* status */

   /* queue this element on the queue */
#endif

   AUACC_PRINT("Received binf Cfm from MAP\n");

   RETVALUE(ROK);

} /* AppLiMatBndCfm  */
#endif


/*
*
*       Fun:   AppLiMatOpenCfm
*
*       Desc:  This function packs
*
*       Ret:   ROK
*
*       Notes: None
*
*       File:  layerapp.c
*
*/

#ifdef ANSI
PUBLIC S16 AppLiMatOpenCfm
(
Pst  *pst,
SuId suId,
MaDlgId suDlgId,
MaDlgId spDlgId,
MaOpenEv *openEv
)
#else
PUBLIC S16 AppLiMatOpenCfm (pst,suId,suDlgId,spDlgId,openEv)
Pst  *pst;
SuId suId;
MaDlgId suDlgId;
MaDlgId spDlgId;
MaOpenEv *openEv;
#endif
{
    TRC2(AppLiMatOpenCfm)

    MaAccMsgQElm    qElm;
    Dialog          *curDlg;

    qElm.evtType = MA_EVTOPENCFM;
    qElm.suId = suId;
    qElm.suDlgId = suDlgId;
    qElm.spDlgId = spDlgId;
    cmCpy(openEv, &qElm.s.openEv, sizeof(MaOpenEv));

#ifdef _MULTI_THREAD
    pthread_mutex_lock(&(dlgQueue->Lock));
#endif

    curDlg = dlgQueue->dlgFind(suDlgId, spDlgId);
    
#ifdef _MULTI_THREAD
    pthread_mutex_unlock(&(dlgQueue->Lock));
#endif

    if (curDlg == NULLP)
    {
        AUACC_PRINT("AppLiMatOpenCfm__________Find dlg %ld failure \n", suDlgId);
    }
    else
    {
        curDlg->auLiMatOpenCfmPrs(&qElm);
    }
    smAuSts.lAuOpenCfm++;
    RETVALUE(ROK);
} /* AppLiMatOpenCfm  */


/*
*
*       Fun:   AppLiMatCloseInd
*
*       Desc:  This function packs
*
*       Ret:   ROK
*
*       Notes: None
*
*       File:  layerapp.c
*
*/

#ifdef ANSI
PUBLIC S16 AppLiMatCloseInd
(
Pst  *pst,
SuId suId,
MaDlgId suDlgId,
MaDlgId spDlgId,
MaCloseEv *closeEv
)
#else
PUBLIC S16 AppLiMatCloseInd (pst,suId,suDlgId,spDlgId, closeEv)
Pst  *pst;
SuId suId;
MaDlgId suDlgId;
MaDlgId spDlgId;
MaCloseEv *closeEv;
#endif
{
    TRC2(AppLiMatCloseInd)

    MaAccMsgQElm        qElm;
    Dialog              *curDlg;

    smAuSts.lAuCloseInd++;
    qElm.evtType = MA_EVTCLOSEIND;
    qElm.suDlgId = suDlgId;
    qElm.spDlgId = spDlgId;
    qElm.suId    = suId;
    cmCpy(closeEv, &qElm.s.closeEv, sizeof(MaCloseEv));

#ifdef _MULTI_THREAD
    pthread_mutex_lock(&(dlgQueue->Lock));
#endif

    curDlg = dlgQueue->dlgFind(suDlgId, spDlgId);
    
#ifdef _MULTI_THREAD
    pthread_mutex_unlock(&(dlgQueue->Lock));
#endif

    if (curDlg == NULLP)
    {
        RETVALUE(ROK);
    }
    else
    {
        MaDlgId     auDlgId, maDlgId;
        auDlgId = curDlg->auDlgIdGet();
        maDlgId = curDlg->maDlgIdGet();

        AUACC_PRINT("AppLiMatCloseInd_______auDlgId = %ld maDlgId = %ld\n",
            curDlg->auDlgIdGet(), curDlg->maDlgIdGet());
        
        curDlg->auLiMatCloseIndPrs(&qElm);

        if (dlgQueue->dlgDelete(suDlgId) != ROK)
        {
            AUACC_PRINT("AppLiMatCloseInd_______dlgDelete failure \
                auDlgId = %ld maDlgId = %ld\n",
                auDlgId, maDlgId);
            
            RETVALUE(RFAILED);
        }
        else
        {
            AUACC_PRINT("AppLiMatCloseInd_______dlgDelete ok \
                auDlgId = %ld maDlgId = %ld\n",
                auDlgId, maDlgId);
        }
    }

    RETVALUE(ROK);
} /* AppLiMatCloseInd  */


/*
*
*       Fun:   AppLiMatAbrtInd
*
*       Desc:  This function packs
*
*       Ret:   ROK
*
*       Notes: None
*
*       File:  layerapp.c
*
*/

#ifdef ANSI
PUBLIC S16 AppLiMatAbrtInd
(
Pst  *pst,
SuId suId,
MaDlgId suDlgId,
MaDlgId spDlgId,
MaAbrtEv *abrtEv
)
#else
PUBLIC S16 AppLiMatAbrtInd (pst,suId,suDlgId,spDlgId,abrtEv)
Pst  *pst;
SuId suId;
MaDlgId suDlgId;
MaDlgId spDlgId;
MaAbrtEv *abrtEv;
#endif
{
#if 0
    Txt prntBuf[MA_PRNTBUF_SIZE];
    MaAccMsgQElm  qElm;
    
    TRC2(AppLiMatAbrtInd)
    
    AUACC_PRINT("MAP Abort Ind. suId %d - SuDlgId %3ld  SpDlgId %3ld \n",
        suId, suDlgId, spDlgId);

    qElm.evtType = MA_EVTABRTIND;
    qElm.suDlgId = suDlgId;
    qElm.spDlgId = spDlgId;
    qElm.suId        = suId;
    cmCpy(abrtEv, &qElm.s.abrtEv, sizeof(MaAbrtEv));
#endif

    MaAccMsgQElm        qElm;
    Dialog              *curDlg;

#ifdef _MULTI_THREAD
    pthread_mutex_lock(&(dlgQueue->Lock));
#endif

    curDlg = dlgQueue->dlgFind(suDlgId, spDlgId);
    
#ifdef _MULTI_THREAD
    pthread_mutex_unlock(&(dlgQueue->Lock));
#endif

    if (curDlg == NULLP)
    {
        AUACC_PRINT("AppLiMatAbrtInd__________Find dlg %ld failure \n",suDlgId);
    }
    else
    {
        curDlg->auLiMatAbrtIndPrs(&qElm);
    }

    RETVALUE(ROK);
} /* AppLiMatAbrtInd  */


/*
*
*       Fun:   AppLiMatNotInd
*
*       Desc:  This function packs
*
*       Ret:   ROK
*
*       Notes: None
*
*       File:  layerapp.c
*
*/

#ifdef ANSI
PUBLIC S16 AppLiMatNotInd
(
Pst  *pst,
SuId suId,
MaDlgId suDlgId,
MaDlgId spDlgId,
RCause  cause
)
#else
PUBLIC S16 AppLiMatNotInd (pst,suId,suDlgId,spDlgId,cause)
Pst  *pst;
SuId suId;
MaDlgId suDlgId;
MaDlgId spDlgId;
RCause  cause;
#endif
{
#if 0
    Txt prntBuf[MA_PRNTBUF_SIZE];
#endif
    MaAccMsgQElm  qElm;
    Dialog              *curDlg;
    
    
    TRC2(AppLiMatNotInd)

    AUACC_PRINT("MAP Not Ind. suId %d - SuDlgId %3ld  SpDlgId %3ld \n",
        suId, suDlgId, spDlgId);
    /* Queue the message event */

    qElm.evtType       = MA_EVTNOTICEIND;
    qElm.suId          = suId;
    qElm.suDlgId       = suDlgId;
    qElm.spDlgId       = spDlgId;
    
    qElm.s.notEv.cause = cause;
    
    /* Push the message on the queue */

#ifdef _MULTI_THREAD
    pthread_mutex_lock(&(dlgQueue->Lock));
#endif

    curDlg = dlgQueue->dlgFind(suDlgId, spDlgId);

#ifdef _MULTI_THREAD
    pthread_mutex_unlock(&(dlgQueue->Lock));
#endif

    if (curDlg == NULLP)
    {
        AUACC_PRINT("AppLiMatNotInd__________Find dlg %ld failure \n",suDlgId);
    }
    else
    {
        curDlg->auLiMatNotIndPrs(&qElm);
    }

    RETVALUE(ROK);
} /* AppLiMatNotInd  */


/*
*
*       Fun:   AppLiMatDlgCfm
*
*       Desc:  This function packs
*
*       Ret:   ROK
*
*       Notes: None
*
*       File:  layerapp.c
*
*/

#ifdef ANSI
PUBLIC S16 AppLiMatDlgCfm
(
Pst  *pst,
SuId suId,
MaDlgId suDlgId,
MaDlgId spDlgId
)
#else
PUBLIC S16 AppLiMatDlgCfm (pst,suId,suDlgId,spDlgId)
Pst  *pst;