cmctrlrmode.c

来自「基于h323协议的软phone」· C语言 代码 · 共 519 行 · 第 1/2 页

/***********************************************************************
        Copyright (c) 2002 RADVISION Ltd.
************************************************************************
NOTICE:
This document contains information that is confidential and proprietary
to RADVISION Ltd.. No part of this document may be reproduced in any
form whatsoever without written prior approval by RADVISION Ltd..

RADVISION Ltd. reserve the right to revise this publication and make
changes without obligation to notify any person of such revisions or
changes.
***********************************************************************/

#include "rvinternal.h"
#include "cmictrl.h"
#include "cmConf.h"
#include "caputils.h"
#include "strutils.h"
#include "cmchan.h"
#include "oidutils.h"
#include "stkutils.h"
#include "h245.h"
#include "cmCtrlMSD.h"
#include "cmdebprn.h"

#ifdef __cplusplus
extern "C" {
#endif

#define ifE(a) if(a)(a)

/* request mode________________________________________________________________________________ */


int requestMode(H245Control* ctrl, int message)
{
    HAPP               hApp=(HAPP)emaGetInstance((EMAElement)cmiGetByControl((HCONTROL)ctrl));
    HPVT               hVal;
    InRequestModeInfo* in_RM=&ctrl->inRequestMode;
    int                sq=0;
    int                nodeId;
    int                nesting;

    hVal = ((cmElem *)hApp)->hVal;

    pvtGetChildValue(hVal,message,__h245(sequenceNumber),&sq,NULL);
    in_RM->seqNum=(RvUint8)sq;

    nodeId=pvtGetChild(hVal,message,__h245(requestedModes),&sq);
    cmiCBEnter(hApp, "cmEvCallRequestMode: haCall=0x%p, hsCall=0x%p, transfer, nodeId=%d.",(HAPPCALL)emaGetApplicationHandle((EMAElement)cmiGetByControl((HCONTROL)ctrl)), cmiGetByControl((HCONTROL)ctrl), nodeId);
    nesting=emaPrepareForCallback((EMAElement)cmiGetByControl((HCONTROL)ctrl));
    ifE(((cmElem*)hApp)->cmMySessionEvent.cmEvCallRequestMode)((HAPPCALL)emaGetApplicationHandle((EMAElement)cmiGetByControl((HCONTROL)ctrl)), (HCALL)cmiGetByControl((HCONTROL)ctrl),cmReqModeRequest, nodeId);
    emaReturnFromCallback((EMAElement)cmiGetByControl((HCONTROL)ctrl),nesting);
    cmiCBExit(hApp, "cmEvCallRequestMode.");
    return RV_TRUE;
}

int requestModeAck(H245Control* ctrl, int message)
{
    HAPP                hApp=(HAPP)emaGetInstance((EMAElement)cmiGetByControl((HCONTROL)ctrl));
    HPVT                hVal;
    OutRequestModeInfo* out_RM=&ctrl->outRequestMode;
    int                 nodeId;
    int                 sq;
    int                 nesting;

    hVal = ((cmElem *)hApp)->hVal;

    pvtGetChildValue(hVal,message,__h245(sequenceNumber),&sq,NULL);

    if (out_RM->seqNum==(RvUint8)sq)
    {
        RvH323TimerCancel(cmGetTimersHandle(hApp),&out_RM->timer);
    }
    nodeId=pvtGetChild(hVal,message,__h245(response),NULL);
    cmiCBEnter(hApp, "cmEvCallRequestMode: haCall=0x%p, hsCall=0x%p, confirm, nodeId=%d.", (HAPPCALL)emaGetApplicationHandle((EMAElement)cmiGetByControl((HCONTROL)ctrl)), cmiGetByControl((HCONTROL)ctrl), nodeId);
    nesting=emaPrepareForCallback((EMAElement)cmiGetByControl((HCONTROL)ctrl));
    ifE(((cmElem*)hApp)->cmMySessionEvent.cmEvCallRequestMode)((HAPPCALL)emaGetApplicationHandle((EMAElement)cmiGetByControl((HCONTROL)ctrl)), (HCALL)cmiGetByControl((HCONTROL)ctrl), cmReqModeAccept, nodeId);
    emaReturnFromCallback((EMAElement)cmiGetByControl((HCONTROL)ctrl),nesting);
    cmiCBExit(hApp, "cmEvCallRequestMode.");
    return RV_TRUE;
}

int requestModeReject(H245Control* ctrl, int message)
{
    HAPP                hApp=(HAPP)emaGetInstance((EMAElement)cmiGetByControl((HCONTROL)ctrl));
    HPVT                hVal;
    OutRequestModeInfo* out_RM=&ctrl->outRequestMode;
    int                 nodeId;
    int                 sq;
    int                 nesting;

    hVal = ((cmElem *)hApp)->hVal;

    pvtGetChildValue(hVal,message,__h245(sequenceNumber),&sq,NULL);

    if (out_RM->seqNum==(RvUint8)sq)
    {
        RvH323TimerCancel(cmGetTimersHandle(hApp),&out_RM->timer);
    }
    nodeId=pvtGetChild(hVal,message,__h245(cause),NULL);
    cmiCBEnter(hApp, "cmEvCallRequestMode: haCall=0x%p, hsCall=0x%p, reject, nodeId=%d.", (HAPPCALL)emaGetApplicationHandle((EMAElement)cmiGetByControl((HCONTROL)ctrl)), cmiGetByControl((HCONTROL)ctrl), nodeId);
    nesting=emaPrepareForCallback((EMAElement)cmiGetByControl((HCONTROL)ctrl));
    ifE(((cmElem*)hApp)->cmMySessionEvent.cmEvCallRequestMode)((HAPPCALL)emaGetApplicationHandle((EMAElement)cmiGetByControl((HCONTROL)ctrl)), (HCALL)cmiGetByControl((HCONTROL)ctrl), cmReqModeReject, nodeId);
    emaReturnFromCallback((EMAElement)cmiGetByControl((HCONTROL)ctrl),nesting);
    cmiCBExit(hApp, "cmEvCallRequestMode.");
    return RV_TRUE;
}

int requestModeRelease(H245Control* ctrl, int message)
{
    HAPP                hApp=(HAPP)emaGetInstance((EMAElement)cmiGetByControl((HCONTROL)ctrl));
    HPVT                hVal;
    InRequestModeInfo*  in_RM=&ctrl->inRequestMode;
    int                 sq=0;
    int                 nodeId;
    int                 nesting;

    hVal = ((cmElem *)hApp)->hVal;

    pvtGetChildValue(hVal,message,__h245(sequenceNumber),&sq,NULL);
    in_RM->seqNum=(RvUint8)sq;

    nodeId=pvtGetChildValue(hVal,message,__h245(requestedModes),&sq,NULL);
    cmiCBEnter(hApp, "cmEvCallRequestMode: haCall=0x%p, hsCall=0x%p, transfer, nodeId=%d.",(HAPPCALL)emaGetApplicationHandle((EMAElement)cmiGetByControl((HCONTROL)ctrl)), cmiGetByControl((HCONTROL)ctrl), nodeId);
    nesting=emaPrepareForCallback((EMAElement)cmiGetByControl((HCONTROL)ctrl));
    ifE(((cmElem*)hApp)->cmMySessionEvent.cmEvCallRequestMode)((HAPPCALL)emaGetApplicationHandle((EMAElement)cmiGetByControl((HCONTROL)ctrl)), (HCALL)cmiGetByControl((HCONTROL)ctrl),cmReqModeRequest, nodeId);
    emaReturnFromCallback((EMAElement)cmiGetByControl((HCONTROL)ctrl),nesting);
    cmiCBExit(hApp, "cmEvCallRequestMode.");
    return RV_TRUE;
}

RvBool reqMode_TimeoutEventsHandler(void*_ctrl)
{
    H245Control*        ctrl=(H245Control*)_ctrl;
    HAPP                hApp=(HAPP)emaGetInstance((EMAElement)cmiGetByControl((HCONTROL)ctrl));
    HPVT                hVal;
    int                 message,nodeId;
    OutRequestModeInfo* out_RM=&ctrl->outRequestMode;

    if (!hApp)   return RV_FALSE;

    if (emaLock((EMAElement)cmiGetByControl((HCONTROL)ctrl)))
    {
        int nesting;

        hVal = ((cmElem *)hApp)->hVal;

        RvH323TimerClear(cmGetTimersHandle(hApp), &out_RM->timer);

        message=pvtAddRoot(hVal,((cmElem*)hApp)->synProtH245,0,NULL);
        nodeId=pvtAddBranch2(hVal,message, __h245(indication),__h245(requestModeRelease));

        sendMessageH245((HCONTROL)ctrl, message);
        pvtDelete(hVal,message);

        cmiCBEnter(hApp, "cmEvCallRequestMode: haCall=0x%p, hsCall=0x%p, release.", (HAPPCALL)emaGetApplicationHandle((EMAElement)cmiGetByControl((HCONTROL)ctrl)), cmiGetByControl((HCONTROL)ctrl));
        nesting=emaPrepareForCallback((EMAElement)cmiGetByControl((HCONTROL)ctrl));
        ifE(((cmElem*)hApp)->cmMySessionEvent.cmEvCallRequestMode) ((HAPPCALL)emaGetApplicationHandle((EMAElement)cmiGetByControl((HCONTROL)ctrl)), (HCALL)cmiGetByControl((HCONTROL)ctrl), cmReqModeReleaseOut, RV_ERROR_UNKNOWN);
        emaReturnFromCallback((EMAElement)cmiGetByControl((HCONTROL)ctrl),nesting);
        cmiCBExit(hApp, "cmEvCallRequestMode.");
        emaUnlock((EMAElement)cmiGetByControl((HCONTROL)ctrl));
    }
    return RV_FALSE;
}



RVAPI int RVCALLCONV
cmCallRequestMode(
          /* send request mode msg */
          /* Note: id shall be deleted when function returns */
          IN  HCALL hsCall,
          IN  RvInt32 modeDescriptorsId /* (requestMode.requestedModes) */
          )
{
    H245Control*        ctrl=(H245Control*)cmiGetControl(hsCall);
    HAPP                hApp=(HAPP)emaGetInstance((EMAElement)hsCall);
    int                 nodeId;
    OutRequestModeInfo* out_RM;
    int                 message, res = RV_ERROR_UNKNOWN;
    int                 iSq;
    HPVT                hVal;

    if (!hsCall || !hApp) return RV_ERROR_UNKNOWN;
    cmiAPIEnter(hApp, "cmCallRequestMode: hsCall=0x%p, id=%d.", hsCall, modeDescriptorsId);

    if (emaLock((EMAElement)hsCall))
    {
        hVal = ((cmElem *)hApp)->hVal;

        out_RM=&ctrl->outRequestMode;

        out_RM->seqNum++;
        out_RM->seqNum%=255;

        message=pvtAddRoot(hVal,((cmElem*)hApp)->synProtH245,0,NULL);
        nodeId=pvtAddBranch2(hVal,message, __h245(request),__h245(requestMode));
        iSq = out_RM->seqNum;
        pvtAdd(hVal,nodeId,__h245(sequenceNumber),iSq,NULL,NULL);
        nodeId = pvtAddBranch(hVal,nodeId,__h245(requestedModes));
        pvtMoveTree(hVal,nodeId,modeDescriptorsId);

        res = sendMessageH245((HCONTROL)ctrl, message);
        pvtDelete(hVal,message);

        if (res >= 0)
        {
            int timeout=10;
            pvtGetChildValue(hVal,((cmElem*)hApp)->h245Conf,__h245(requestModeTimeout),&(timeout),NULL);
            RvH323TimerCancel(cmGetTimersHandle(hApp),&out_RM->timer);
            out_RM->timer=RvH323TimerStart(cmGetTimersHandle(hApp),reqMode_TimeoutEventsHandler,(void*)ctrl,timeout*1000);
        }
        emaUnlock((EMAElement)hsCall);
    }

    cmiAPIExit(hApp, "cmCallRequestMode=%d", res);
    return res;
}



RVAPI int RVCALLCONV
cmCallRequestModeAck(
          /* Acknowledge the request */
          IN  HCALL hsCall,
          IN  char* responseName /* (requestModeAck.response) */
          )
{
    H245Control*       ctrl=(H245Control*)cmiGetControl(hsCall);
    HAPP               hApp=(HAPP)emaGetInstance((EMAElement)hsCall);
    int                nodeId;
    InRequestModeInfo* in_RM;
    int                message, res = RV_ERROR_UNKNOWN;
    HPVT               hVal;

    if (!hsCall || !hApp || !responseName) return RV_ERROR_UNKNOWN;

    cmiAPIEnter(hApp, "cmCallRequestModeReject: hsCall=0x%p, '%s'.", hsCall, nprn(responseName));

    if (emaLock((EMAElement)hsCall))
    {
        int iSq;

        hVal = ((cmElem *)hApp)->hVal;

        message=pvtAddRoot(hVal,((cmElem*)hApp)->synProtH245,0,NULL);
        in_RM=&ctrl->inRequestMode;
        nodeId=pvtAddBranch2(hVal,message, __h245(response),__h245(requestModeAck));
        iSq = in_RM->seqNum;
        pvtAdd(hVal,nodeId,__h245(sequenceNumber),iSq,NULL,NULL);
        pvtBuildByPath(((cmElem*)hApp)->hVal, pvtAddBranch(hVal,nodeId,__h245(response)), responseName, 0, NULL);

        res = sendMessageH245((HCONTROL)ctrl, message);
        pvtDelete(hVal,message);

        emaUnlock((EMAElement)hsCall);
    }

    cmiAPIExit(hApp, "cmCallRequestModeAck=%d", res);