Skip to content

F
freeswitch
提交 fd634d6b authored 作者: Mathieu Rene's avatar Mathieu Rene
浏览文件
操作

still figuring out lib

上级 294ab388
隐藏空白字符变更
内嵌 并排
正在显示 包含 56 行增加 和 10 行删除
src/mod/endpoints/mod_media_gateway/mod_media_gateway.c
浏览文件 @ fd634d6b
...@@ -134,9 +134,6 @@ static void mgco_print_sdp(CmSdpInfoSet *sdp) ...@@ -134,9 +134,6 @@ static void mgco_print_sdp(CmSdpInfoSet *sdp)
{ {
int i; int i;
// XXX check if we can use that for debug:
// cmUnpkCmSdpInfoSet(<#CmSdpInfoSet *param#>, <#Ptr ptr#>, <#CmIntfVer intfVer#>, <#Buffer *mBuf#>);
if (sdp->numComp.pres == NOTPRSNT) { if (sdp->numComp.pres == NOTPRSNT) {
return; return;
...@@ -161,6 +158,7 @@ static void mgco_print_sdp(CmSdpInfoSet *sdp) ...@@ -161,6 +158,7 @@ static void mgco_print_sdp(CmSdpInfoSet *sdp)
for (mediaId = 0; mediaId < s->attrSet.numComp.val; mediaId++) { for (mediaId = 0; mediaId < s->attrSet.numComp.val; mediaId++) {
CmSdpAttr *a = s->attrSet.attr[mediaId]; CmSdpAttr *a = s->attrSet.attr[mediaId];
} }
} }
...@@ -177,12 +175,9 @@ static void mgco_print_sdp(CmSdpInfoSet *sdp) ...@@ -177,12 +175,9 @@ static void mgco_print_sdp(CmSdpInfoSet *sdp)
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "Port: %d\n", port); switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "Port: %d\n", port);
} }
} }
} }
} }
} }
} }
...@@ -191,6 +186,9 @@ static void mgco_print_sdp(CmSdpInfoSet *sdp) ...@@ -191,6 +186,9 @@ static void mgco_print_sdp(CmSdpInfoSet *sdp)
void handle_mgco_txn_ind(Pst *pst, SuId suId, MgMgcoMsg* msg) void handle_mgco_txn_ind(Pst *pst, SuId suId, MgMgcoMsg* msg)
{ {
size_t txnIter; size_t txnIter;
switch_memory_pool_t *pool;
switch_core_new_memory_pool(&pool);
/*TODO*/ /*TODO*/
if(msg->body.type.val == MGT_TXN) if(msg->body.type.val == MGT_TXN)
...@@ -198,6 +196,7 @@ void handle_mgco_txn_ind(Pst *pst, SuId suId, MgMgcoMsg* msg) ...@@ -198,6 +196,7 @@ void handle_mgco_txn_ind(Pst *pst, SuId suId, MgMgcoMsg* msg)
/* Loop over transaction list */ /* Loop over transaction list */
for(txnIter=0;txnIter<msg->body.u.tl.num.val;txnIter++) for(txnIter=0;txnIter<msg->body.u.tl.num.val;txnIter++)
{ {
switch(msg->body.u.tl.txns[txnIter]->type.val) { switch(msg->body.u.tl.txns[txnIter]->type.val) {
case MGT_TXNREQ: case MGT_TXNREQ:
{ {
...@@ -223,12 +222,44 @@ void handle_mgco_txn_ind(Pst *pst, SuId suId, MgMgcoMsg* msg) ...@@ -223,12 +222,44 @@ void handle_mgco_txn_ind(Pst *pst, SuId suId, MgMgcoMsg* msg)
for (cmdIter=0; cmdIter < (actnReq->cl.num.val); cmdIter++) { for (cmdIter=0; cmdIter < (actnReq->cl.num.val); cmdIter++) {
MgMgcoCommandReq *cmdReq = actnReq->cl.cmds[cmdIter]; MgMgcoCommandReq *cmdReq = actnReq->cl.cmds[cmdIter];
MgMgcoTermId *termId = NULLP; MgMgcoTermId *termId = NULLP;
/* The reply we'll send */
MgMgcoCommand mgCmd = {0};
mgCmd.peerId = msg->lcl.id;
mgCmd.transId = transId;
mgCmd.u.mgCmdInd[0] = cmdReq;
/* XXX Handle choose context before this */
mgCmd.contextId = ctxId;
mgCmd.transId = transId;
mgCmd.cmdStatus.pres = PRSNT_NODEF;
if(cmdIter == (actnReq->cl.num.val -1))
{
mgCmd.cmdStatus.val = CH_CMD_STATUS_END_OF_AXN;
if(axnIter == (txnReq->al.num.val-1))
{
mgCmd.cmdStatus.val= CH_CMD_STATUS_END_OF_TXN;
}
}
else
{
mgCmd.cmdStatus.val = CH_CMD_STATUS_PENDING;
}
/* XXX handle props */
mgCmd.cmdType.pres = PRSNT_NODEF;
mgCmd.cmdType.val = CH_CMD_TYPE_REQ;
mgCmd.u.mgCmdReq[0] = cmdReq;
sng_mgco_send_cmd(suId, &mgCmd);
switch (cmdReq->cmd.type.val) { switch (cmdReq->cmd.type.val) {
case MGT_ADD: case MGT_ADD:
{ {
MgMgcoAmmReq *addReq = &cmdReq->cmd.u.add; MgMgcoAmmReq *addReq = &cmdReq->cmd.u.add;
MgMgcoTermId termId = addReq->termId;
int descId; int descId;
for (descId = 0; descId < addReq->dl.num.val; descId++) { for (descId = 0; descId < addReq->dl.num.val; descId++) {
switch (addReq->dl.descs[descId]->type.val) { switch (addReq->dl.descs[descId]->type.val) {
...@@ -240,24 +271,28 @@ void handle_mgco_txn_ind(Pst *pst, SuId suId, MgMgcoMsg* msg) ...@@ -240,24 +271,28 @@ void handle_mgco_txn_ind(Pst *pst, SuId suId, MgMgcoMsg* msg)
switch (mediaPar->type.val) { switch (mediaPar->type.val) {
case MGT_MEDIAPAR_LOCAL: case MGT_MEDIAPAR_LOCAL:
{ {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "Textual SDP %s\n", mediaPar->u.local.sdpStr.pres ? "present" : "absent"); switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "MGT_MEDIAPAR_LOCAL");
break; break;
} }
case MGT_MEDIAPAR_REMOTE: case MGT_MEDIAPAR_REMOTE:
{ {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "MGT_MEDIAPAR_REMOTE");
break; break;
} }
case MGT_MEDIAPAR_LOCCTL: case MGT_MEDIAPAR_LOCCTL:
{ {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "MGT_MEDIAPAR_LOCCTL");
break; break;
} }
case MGT_MEDIAPAR_TERMST: case MGT_MEDIAPAR_TERMST:
{
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "MGT_MEDIAPAR_TERMST");
break; break;
}
case MGT_MEDIAPAR_STRPAR: case MGT_MEDIAPAR_STRPAR:
{ {
MgMgcoStreamDesc *mgStream = &mediaPar->u.stream; MgMgcoStreamDesc *mgStream = &mediaPar->u.stream;
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "Textual SDP %s\n", mgStream->sl.remote.sdpStr.pres ? "present" : "absent");
if (mgStream->sl.remote.pres.pres) { if (mgStream->sl.remote.pres.pres) {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Got remote stream media description:\n"); switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Got remote stream media description:\n");
...@@ -269,6 +304,7 @@ void handle_mgco_txn_ind(Pst *pst, SuId suId, MgMgcoMsg* msg) ...@@ -269,6 +304,7 @@ void handle_mgco_txn_ind(Pst *pst, SuId suId, MgMgcoMsg* msg)
mgco_print_sdp(&mgStream->sl.local.sdp); mgco_print_sdp(&mgStream->sl.local.sdp);
} }
break; break;
} }
} }
...@@ -285,6 +321,9 @@ void handle_mgco_txn_ind(Pst *pst, SuId suId, MgMgcoMsg* msg) ...@@ -285,6 +321,9 @@ void handle_mgco_txn_ind(Pst *pst, SuId suId, MgMgcoMsg* msg)
break; break;
} }
} }
break; break;
} }
case MGT_MODIFY: case MGT_MODIFY:
...@@ -316,6 +355,7 @@ void handle_mgco_txn_ind(Pst *pst, SuId suId, MgMgcoMsg* msg) ...@@ -316,6 +355,7 @@ void handle_mgco_txn_ind(Pst *pst, SuId suId, MgMgcoMsg* msg)
} }
case MGT_TXNREPLY: case MGT_TXNREPLY:
{ {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "MGT_TXNREPLY\n");
break; break;
} }
default: default:
...@@ -324,18 +364,21 @@ void handle_mgco_txn_ind(Pst *pst, SuId suId, MgMgcoMsg* msg) ...@@ -324,18 +364,21 @@ void handle_mgco_txn_ind(Pst *pst, SuId suId, MgMgcoMsg* msg)
} }
} }
} }
switch_core_destroy_memory_pool(&pool);
} }
/*****************************************************************************************************************************/ /*****************************************************************************************************************************/
void handle_mgco_cmd_ind(Pst *pst, SuId suId, MgMgcoCommand* cmd) void handle_mgco_cmd_ind(Pst *pst, SuId suId, MgMgcoCommand* cmd)
{ {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "%s\n", __PRETTY_FUNCTION__);
/*TODO*/ /*TODO*/
} }
/*****************************************************************************************************************************/ /*****************************************************************************************************************************/
void handle_mgco_sta_ind(Pst *pst, SuId suId, MgMgtSta* sta) void handle_mgco_sta_ind(Pst *pst, SuId suId, MgMgtSta* sta)
{ {
/*TODO*/ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "%s\n", __PRETTY_FUNCTION__); /*TODO*/
} }
/*****************************************************************************************************************************/ /*****************************************************************************************************************************/
...@@ -343,18 +386,21 @@ void handle_mgco_sta_ind(Pst *pst, SuId suId, MgMgtSta* sta) ...@@ -343,18 +386,21 @@ void handle_mgco_sta_ind(Pst *pst, SuId suId, MgMgtSta* sta)
void handle_mgco_txn_sta_ind(Pst *pst, SuId suId, MgMgcoInd* txn_sta_ind) void handle_mgco_txn_sta_ind(Pst *pst, SuId suId, MgMgcoInd* txn_sta_ind)
{ {
/*TODO*/ /*TODO*/
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "%s\n", __PRETTY_FUNCTION__);
} }
/*****************************************************************************************************************************/ /*****************************************************************************************************************************/
void handle_mgco_cntrl_cfm(Pst *pst, SuId suId, MgMgtCntrl* cntrl, Reason reason) void handle_mgco_cntrl_cfm(Pst *pst, SuId suId, MgMgtCntrl* cntrl, Reason reason)
{ {
/*TODO*/ /*TODO*/
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "%s\n", __PRETTY_FUNCTION__);
} }
/*****************************************************************************************************************************/ /*****************************************************************************************************************************/
void handle_mgco_audit_cfm(Pst *pst, SuId suId, MgMgtAudit* audit, Reason reason) void handle_mgco_audit_cfm(Pst *pst, SuId suId, MgMgtAudit* audit, Reason reason)
{ {
/*TODO*/ /*TODO*/
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "%s\n", __PRETTY_FUNCTION__);
} }
/*****************************************************************************************************************************/ /*****************************************************************************************************************************/
......
Markdown 格式
0% 或
您添加了 0 人 到此讨论。请谨慎行事。
请先完成此评论的编辑！
请 注册 或者 后发表评论