?? faststart.c
字號:
{
getGoodAddressForCall((HCALL)call,rtp);
cmTAToVt_H245(hVal,tmpNodeId, rtp);
}
else
pvtDelete(hVal, tmpNodeId);
tmpNodeId = pvtAddBranch(hVal, h2250ParametersNodeId, __h245(mediaControlChannel));
if ((rtcp != NULL) && (rtcp->ip || rtcp->port))
{
getGoodAddressForCall((HCALL)call,rtcp);
cmTAToVt_H245(hVal,tmpNodeId, rtcp);
}
else
pvtDelete(hVal, pvtGetChild(hVal, h2250ParametersNodeId, __h245(mediaControlChannel), NULL));
}
}
ret = outOLCNodeId;
emaUnlock((EMAElement)hsCall);
}
cmiAPIExit(hApp, "cmFastStartChannelsAckIndex: [%d]", ret);
return ret;
}
RVAPI int RVCALLCONV
cmFastStartChannelsAck(
IN HCALL hsCall,
IN cmFastStartChannel* pFastChannel)
{
int ret=1;
callElem* call=(callElem*)hsCall;
HAPP hApp=(HAPP)emaGetInstance((EMAElement)call);
if (!hsCall || !hApp) return RV_ERROR_UNKNOWN;
cmiAPIEnter(hApp, "cmFastStartChannelsAck: hsCall=0x%p",hsCall);
if (emaLock((EMAElement)hsCall))
{
ret = cmFastStartChannelsAckIndex(hsCall,pFastChannel->index, &(pFastChannel->rtcp), &(pFastChannel->rtp));
emaUnlock((EMAElement)hsCall);
}
cmiAPIExit(hApp, "cmFastStartChannelsAck: [%d]",ret);
return ret;
}
RVAPI int RVCALLCONV
cmFastStartChannelsReady(IN HCALL hsCall)
{
callElem* call=(callElem*)hsCall;
HAPP hApp=(HAPP)emaGetInstance((EMAElement)call);
if (!hsCall || !hApp) return RV_ERROR_UNKNOWN;
cmiAPIEnter(hApp, "cmFastStartChannelsReady: hsCall=0x%p",hsCall);
if (emaLock((EMAElement)hsCall))
{
H245Control *ctrl = (H245Control *)cmiGetControl(hsCall);
int fastStartPrpd[2*MAX_FS_SESSION_ID];
int i;
int limit = RvMin(call->fastStartNodesAckCount, (2*MAX_FS_SESSION_ID));
memset(fastStartPrpd, 0xff, sizeof(fastStartPrpd));
for(i=0; i<limit; i++)
{
fastStartPrpd[i] = call->fastStartNodes[call->fastStartIndexes[i]];
}
if (cmCallFastStartOpenChannels((HCALL)hsCall, fastStartPrpd, call->fastStartNodesAck, RV_FALSE) >= 0)
{
/* Notify the application that the fast staart procedure is complete */
cmiReportControl(hsCall,cmControlStateFastStartComplete,(cmControlStateMode)0);
}
m_callset(call, fastStartFinished, RV_TRUE);
cmcReadyEvent(ctrl);
emaUnlock((EMAElement)hsCall);
}
cmiAPIExit(hApp, "cmFastStartChannelsReady: [OK]");
return RV_TRUE;
}
RVAPI int RVCALLCONV
cmFastStartChannelsRefuse(IN HCALL hsCall)
{
callElem* call=(callElem*)hsCall;
HAPP hApp=(HAPP)emaGetInstance((EMAElement)call);
if ((hsCall == NULL) || (hApp == NULL))
return RV_ERROR_NULLPTR;
cmiAPIEnter(hApp, "cmFastStartChannelsRefuse: hsCall=0x%p",hsCall);
if (emaLock((EMAElement)hsCall))
{
H245Control *ctrl = (H245Control *)cmiGetControl(hsCall);
call->fastStartState = fssRej;
m_callset(call, fastStartFinished, RV_TRUE);
cmcReadyEvent(ctrl);
emaUnlock((EMAElement)hsCall);
}
cmiAPIExit(hApp, "cmFastStartChannelsRefuse: [OK]");
return RV_TRUE;
}
/******************************************************************************************
* cmFastStartReply
*
* Purpose: This function is called from the CM whenever a response message after SETUP
* is received (CallProceeding, Alerting, Connect, Facility and Progress).
* It checks for FastStart response. If such exists, it processes it and opens
* the relevant channels.
*
* Input: call - call object instance
* uuNodeId - UserUser node ID of the message
*
* Reurned Value: Non-negative value on success
* Negative value on failure
****************************************************************************************/
int cmFastStartReply(
IN callElem* call,
IN int uuNodeId)
{
cmElem*app=(cmElem*)emaGetInstance((EMAElement)call);
H245Control *ctrl=(H245Control *)cmiGetControl((HCALL)call);
HPVT hVal=app->hVal;
int fsNodeId;
RvBool fsChannelsExist;
int rc;
/* Are we in the right fast-start state? */
if ((call->fastStartState==fssAck) || (call->fastStartState==fssRej))
return RV_ERROR_UNKNOWN;
/* Make sure we've got fast start information here and get the first one */
fsNodeId=pvtGetChild(hVal,uuNodeId,__q931(fastStart),NULL);
fsChannelsExist = (fsNodeId >= 0);
fsNodeId=pvtChild(hVal, fsNodeId);
/* Loop through all of the acknowledgements and put them into the call's structure */
while (fsNodeId >= 0)
{
RvUint8* encodeBuffer;
int length;
int decoded_length;
int chanMsgId;
int decodingResult;
/* Decode a single OLC.Ack message */
chanMsgId = pvtAddRoot(hVal, app->synOLC, 0, NULL);
getEncodeDecodeBuffer(app->encodeBufferSize, &encodeBuffer);
length=pvtGetString(hVal, fsNodeId, app->encodeBufferSize, (char*)encodeBuffer);
decodingResult = cmEmDecode(hVal, chanMsgId, encodeBuffer, length, &decoded_length);
if (decodingResult < 0)
{
pvtDelete(hVal, chanMsgId);
chanMsgId = -1;
}
RvH323CmPrintMessage(&app->logFastStart, "Accepted faststart channel decoded:",
hVal, chanMsgId, encodeBuffer, decoded_length, RV_TRUE);
if (decodingResult >= 0)
{
/* Add the decoded OLC.Ack into the fast start acknowledgments of the call */
call->fastStartNodesAck[call->fastStartNodesAckCount++] = chanMsgId;
}
/* Goto the next one in the next entry to the while loop */
if (call->fastStartNodesAckCount == app->maxFsAccepted)
/* array is maxFsAccepted+1 size, must leave the last one -1 */
break;
fsNodeId=pvtBrother(hVal, fsNodeId);
}
if (fsChannelsExist)
{
rc = cmCallFastStartOpenChannels((HCALL)call, call->fastStartNodes, call->fastStartNodesAck, RV_TRUE);
/* Notify the application that the fast staart procedure is complete */
cmiReportControl((HCALL)call,cmControlStateFastStartComplete,(cmControlStateMode)0);
m_callset(call, fastStartFinished, RV_TRUE);
cmcReadyEvent(ctrl);
}
else
rc = RV_ERROR_UNKNOWN;
return rc;
}
void deleteFastStart(callElem*call)
{
cmElem*app=(cmElem*)emaGetInstance((EMAElement)call);
int i;
for (i=0;i<call->fastStartNodesCount;i++)
{
pvtDelete(app->hVal,call->fastStartNodes[i]);
call->fastStartNodes[i]=RV_ERROR_UNKNOWN;
}
call->fastStartNodesCount=0;
for (i=0;i<call->fastStartNodesAckCount;i++)
{
pvtDelete(app->hVal,call->fastStartNodesAck[i]);
call->fastStartNodesAck[i]=RV_ERROR_UNKNOWN;
}
call->fastStartNodesAckCount=0;
}
/******************************************************************************************
* addFastStart
*
* Purpose: This function adds the fast start messages that are stored on the call
* to an outgoing message
*
* Input: call - call object instance
* message - message's root node ID to add fast start information to
*
* Reurned Value: none
****************************************************************************************/
void addFastStart(
IN callElem* call,
IN int message)
{
cmElem*app=(cmElem*)emaGetInstance((EMAElement)call);
HPVT hVal=app->hVal;
int nodeCount,*nodes;
/* See which side is it - we need to know which fast start node to add */
if (m_callget(call, callInitiator))
{
/* Initiator of the call */
nodeCount = call->fastStartNodesCount;
nodes = call->fastStartNodes;
/* Make sure it's a setup message - otherwise we shouldn't add the fast start nodes */
if (pvtGetChildTagByPath(hVal,message,"message",1) != cmQ931setup)
return;
}
else
{
if(call->fastStartState == fssRej)
{
int tmpNodeId;
/* reject the fast start - was approved with no channels */
__pvtBuildByFieldIds(tmpNodeId, hVal, message,
{_q931(message)
_anyField
_q931(userUser)
_q931(h323_UserInformation)
_q931(h323_uu_pdu)
_q931(h323_message_body)
_anyField
_q931(fastConnectRefused)
LAST_TOKEN},0,NULL);
return;
}
/* Destination of the call sends Ack nodes */
nodeCount = call->fastStartNodesAckCount;
nodes = call->fastStartNodesAck;
}
if (nodeCount > 0)
{
/* We have fast start nodes - go through them and add them in */
int i;
RvPvtNodeId tmpNodeId;
/* first, we'll check if we already have a fast start field in the message */
__pvtGetByFieldIds(tmpNodeId, hVal, message,
{_q931(message) _anyField _q931(userUser) _q931(h323_UserInformation) _q931(h323_uu_pdu)
_q931(h323_message_body) _anyField _q931(fastStart) LAST_TOKEN},NULL,NULL,NULL);
if (RV_PVT_NODEID_IS_VALID(tmpNodeId))
{
/* we have a FS element in the message already. this may be because the call was transferred,
or it may be because the user used setParam() to set a faststart element. we can do one of
two things: either delete the node and put our own FS content, or we could keep the existing
FS and return. adding to the current FS message is out of the question. */
#if 1
/* we assume that the user will not use both setParam() and FS functions, or that this is a
transfer, and we better update our information */
pvtDelete(hVal, tmpNodeId);
#else
/* we assume that we should keep whatever was set, and leave things up to the user */
return;
#endif
}
/* Build the fast start SEQUENCE OF node */
__pvtBuildByFieldIds(tmpNodeId, hVal, message,
{_q931(message)
_anyField
_q931(userUser)
_q931(h323_UserInformation)
_q931(h323_uu_pdu)
_q931(h323_message_body)
_anyField
_q931(fastStart)
LAST_TOKEN},0,NULL);
for (i = 0; i < nodeCount; i++)
{
int iBufLen;
RvUint8* encodeBuffer;
getEncodeDecodeBuffer(app->encodeBufferSize, &encodeBuffer);
/* Encode a faststart proposal/acceptance */
if (cmEmEncode(hVal, nodes[i], encodeBuffer, app->encodeBufferSize, &iBufLen) >= 0)
{
/* That's it, now we can add the encoded OLC message to the SETUP message */
pvtAdd(hVal, tmpNodeId, -800, iBufLen, (char*)encodeBuffer, NULL);
}
else
iBufLen = -1;
RvH323CmPrintMessage(&app->logFastStart,
m_callget(call,callInitiator) ? "Suggested faststart channel encoded:":"Accepted faststart channel encoded:",
hVal, nodes[i], encodeBuffer, iBufLen, RV_FALSE);
}
}
}
/************************************************************************
* cmCallFastStartOpenChannels
* purpose: Set the answered information to be sent for a fast start
* proposal and open the channels on the destination side of the
* call. This function should be called after receiving
* cmEvCallFastStart() or cmEvCallFastStartSetup().
* It is automatically called on the initiator of the call.
* input : hsCall - Call to use
* proposed - List of proposed channels. This list is searched for
* their RTP and RTCP addresses.
* Each parameter in this list is a root node of an
* OpenLogicalChannel message to propose in faststart
* The last element in this list should be a negative value.
* accepted - List of accepted channels.
* Each paramenter in this list is a root node of an
* OpenLogicalChannel message sent to the origin of the call
* by this endpoint.
* The last element in this list should be a negative value.
* origin - RV_TRUE if this application is the origin of the call
* RV_FALSE if this application is not the origin of the call
* output : none
* return : non-negative value on success
* negative value on failure
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -