Skip to content
项目
群组
代码片段
帮助
正在加载...
登录
切换导航
F
freeswitch
项目
项目
详情
活动
周期分析
仓库
仓库
文件
提交
分支
标签
贡献者
分枝图
比较
统计图
议题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
日程
统计图
Wiki
Wiki
代码片段
代码片段
成员
成员
折叠边栏
关闭边栏
活动
分枝图
统计图
创建新议题
作业
提交
议题看板
打开侧边栏
张华
freeswitch
Commits
2fd70942
提交
2fd70942
authored
6月 11, 2010
作者:
Konrad Hammel
提交者:
Moises Silva
6月 18, 2010
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
-> working...
上级
024ce241
显示空白字符变更
内嵌
并排
正在显示
3 个修改的文件
包含
54 行增加
和
71 行删除
+54
-71
ftmod_sangoma_ss7_cntrl.c
...tdm/src/ftmod/ftmod_sangoma_ss7/ftmod_sangoma_ss7_cntrl.c
+1
-1
ftmod_sangoma_ss7_in.c
...reetdm/src/ftmod/ftmod_sangoma_ss7/ftmod_sangoma_ss7_in.c
+8
-24
ftmod_sangoma_ss7_main.c
...etdm/src/ftmod/ftmod_sangoma_ss7/ftmod_sangoma_ss7_main.c
+45
-46
没有找到文件。
libs/freetdm/src/ftmod/ftmod_sangoma_ss7/ftmod_sangoma_ss7_cntrl.c
浏览文件 @
2fd70942
...
@@ -175,7 +175,7 @@ static void handle_entsi_alarm(sng_alrm_t alarm)
...
@@ -175,7 +175,7 @@ static void handle_entsi_alarm(sng_alrm_t alarm)
case
(
LCM_EVENT_TIMEOUT
):
case
(
LCM_EVENT_TIMEOUT
):
/* this event always has the circuit value embedded */
/* this event always has the circuit value embedded */
SS7_WARN
(
"[ISUP] Timer %d expired on CIC %d
\n
"
,
SS7_WARN
(
"[ISUP] Timer %d expired on CIC %d
\n
"
,
(
alarm
.
eventParm
[
1
]
>
0
)
?
alarm
.
eventParm
[
1
]
:
alarm
.
eventParm
[
8
],
alarm
.
eventParm
[
8
],
g_ftdm_sngss7_data
.
cfg
.
isupCircuit
[
alarm
.
eventParm
[
0
]].
cic
);
g_ftdm_sngss7_data
.
cfg
.
isupCircuit
[
alarm
.
eventParm
[
0
]].
cic
);
break
;
break
;
/**************************************************************************/
/**************************************************************************/
...
...
libs/freetdm/src/ftmod/ftmod_sangoma_ss7/ftmod_sangoma_ss7_in.c
浏览文件 @
2fd70942
...
@@ -172,7 +172,7 @@ void sngss7_con_ind(uint32_t suInstId, uint32_t spInstId, uint32_t circuit, SiCo
...
@@ -172,7 +172,7 @@ void sngss7_con_ind(uint32_t suInstId, uint32_t spInstId, uint32_t circuit, SiCo
break
;
break
;
/**************************************************************************/
/**************************************************************************/
case
(
FTDM_CHANNEL_STATE_DIALING
):
/* glare */
case
(
FTDM_CHANNEL_STATE_DIALING
):
/* glare */
SS7_ERROR
(
"Got IAM in DIALING state...glare...
queueing incoming call
\n
"
);
SS7_ERROR
(
"Got IAM in DIALING state...glare...queueing incoming call
\n
"
);
/* the flag the channel as having a collision */
/* the flag the channel as having a collision */
sngss7_set_flag
(
sngss7_info
,
FLAG_GLARE
);
sngss7_set_flag
(
sngss7_info
,
FLAG_GLARE
);
...
@@ -186,7 +186,10 @@ void sngss7_con_ind(uint32_t suInstId, uint32_t spInstId, uint32_t circuit, SiCo
...
@@ -186,7 +186,10 @@ void sngss7_con_ind(uint32_t suInstId, uint32_t spInstId, uint32_t circuit, SiCo
break
;
break
;
/**************************************************************************/
/**************************************************************************/
default:
/* should not have gotten an IAM while in this state */
default:
/* should not have gotten an IAM while in this state */
SS7_ERROR
(
"Got IAM in an invalid state!
\n
"
);
SS7_ERROR
(
"Got IAM in an invalid state (%s) on span=%d, chan=%d!
\n
"
,
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_chan_id
);
/* move the state of the channel to RESTART to force a reset */
/* move the state of the channel to RESTART to force a reset */
ftdm_set_state_locked
(
ftdmchan
,
FTDM_CHANNEL_STATE_RESTART
);
ftdm_set_state_locked
(
ftdmchan
,
FTDM_CHANNEL_STATE_RESTART
);
...
@@ -824,30 +827,11 @@ static ftdm_status_t handle_reattempt(uint32_t suInstId, uint32_t spInstId, uint
...
@@ -824,30 +827,11 @@ static ftdm_status_t handle_reattempt(uint32_t suInstId, uint32_t spInstId, uint
return
FTDM_FAIL
;
return
FTDM_FAIL
;
};
};
/* glare, throw the flag, go to down state*/
switch
(
ftdmchan
->
state
)
{
sngss7_set_flag
(
sngss7_info
,
FLAG_GLARE
);
/**************************************************************************/
case
FTDM_CHANNEL_STATE_DIALING
:
/* glare, go to down state*/
ftdm_set_state_locked
(
ftdmchan
,
FTDM_CHANNEL_STATE_DOWN
);
ftdm_set_state_locked
(
ftdmchan
,
FTDM_CHANNEL_STATE_DOWN
);
break
;
/**************************************************************************/
default:
/* fuck...this shouldn't happen */
SS7_ERROR
(
"Received reattempt indication on CIC %d in invalid state %s
\n
"
,
sngss7_info
->
circuit
->
cic
,
ftdm_channel_state2str
(
ftdmchan
->
state
));
/* throw the channel into reset */
sngss7_set_flag
(
sngss7_info
,
FLAG_RESET_TX
);
ftdm_set_state_locked
(
ftdmchan
,
FTDM_CHANNEL_STATE_RESTART
);
break
;
/**************************************************************************/
}
/* unlock the channel again before we exit */
/* unlock the channel again before we exit */
ftdm_mutex_unlock
(
ftdmchan
->
mutex
);
ftdm_mutex_unlock
(
ftdmchan
->
mutex
);
...
...
libs/freetdm/src/ftmod/ftmod_sangoma_ss7/ftmod_sangoma_ss7_main.c
浏览文件 @
2fd70942
...
@@ -252,8 +252,8 @@ static void *ftdm_sangoma_ss7_run(ftdm_thread_t *me, void *obj)
...
@@ -252,8 +252,8 @@ static void *ftdm_sangoma_ss7_run(ftdm_thread_t *me, void *obj)
ftdm_sangoma_ss7_process_state_change
(
ftdmchan
);
ftdm_sangoma_ss7_process_state_change
(
ftdmchan
);
}
else
{
}
else
{
SS7_ERROR
(
"ftdm_core reported state change, but state change flag not set on ft-span = %d, ft-chan = %d
\n
"
,
SS7_ERROR
(
"ftdm_core reported state change, but state change flag not set on ft-span = %d, ft-chan = %d
\n
"
,
ftdmchan
->
span_id
,
ftdmchan
->
physical_
span_id
,
ftdmchan
->
chan_id
);
ftdmchan
->
physical_
chan_id
);
}
}
}
/* while ((ftdmchan = ftdm_queue_dequeue(span->pendingchans))) */
}
/* while ((ftdmchan = ftdm_queue_dequeue(span->pendingchans))) */
...
@@ -318,7 +318,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -318,7 +318,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
/**************************************************************************/
/**************************************************************************/
case
FTDM_CHANNEL_STATE_COLLECT
:
/* IAM received but wating on digits */
case
FTDM_CHANNEL_STATE_COLLECT
:
/* IAM received but wating on digits */
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
...
@@ -385,7 +385,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -385,7 +385,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
/**************************************************************************/
/**************************************************************************/
case
FTDM_CHANNEL_STATE_RING
:
/*incoming call request*/
case
FTDM_CHANNEL_STATE_RING
:
/*incoming call request*/
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
...
@@ -406,7 +406,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -406,7 +406,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
/**************************************************************************/
/**************************************************************************/
case
FTDM_CHANNEL_STATE_DIALING
:
/*outgoing call request*/
case
FTDM_CHANNEL_STATE_DIALING
:
/*outgoing call request*/
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
...
@@ -420,7 +420,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -420,7 +420,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
/**************************************************************************/
/**************************************************************************/
case
FTDM_CHANNEL_STATE_PROGRESS
:
case
FTDM_CHANNEL_STATE_PROGRESS
:
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
...
@@ -443,7 +443,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -443,7 +443,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
/**************************************************************************/
/**************************************************************************/
case
FTDM_CHANNEL_STATE_PROGRESS_MEDIA
:
case
FTDM_CHANNEL_STATE_PROGRESS_MEDIA
:
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
...
@@ -455,7 +455,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -455,7 +455,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
/**************************************************************************/
/**************************************************************************/
case
FTDM_CHANNEL_STATE_UP
:
/*call is accpeted...both incoming and outgoing*/
case
FTDM_CHANNEL_STATE_UP
:
/*call is accpeted...both incoming and outgoing*/
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
...
@@ -476,14 +476,14 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -476,14 +476,14 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
/**************************************************************************/
/**************************************************************************/
case
FTDM_CHANNEL_STATE_CANCEL
:
case
FTDM_CHANNEL_STATE_CANCEL
:
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
break
;
break
;
}
}
SS7_ERROR
(
"Hanging up call before informing user on span = %d, chan = %d!
\n
"
,
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
SS7_ERROR
(
"Hanging up call before informing user on span = %d, chan = %d!
\n
"
,
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
/*now go to the HANGUP complete state*/
/*now go to the HANGUP complete state*/
ftdm_set_state_locked
(
ftdmchan
,
FTDM_CHANNEL_STATE_HANGUP
);
ftdm_set_state_locked
(
ftdmchan
,
FTDM_CHANNEL_STATE_HANGUP
);
...
@@ -492,7 +492,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -492,7 +492,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
/**************************************************************************/
/**************************************************************************/
case
FTDM_CHANNEL_STATE_TERMINATING
:
/*call is hung up remotely*/
case
FTDM_CHANNEL_STATE_TERMINATING
:
/*call is hung up remotely*/
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
...
@@ -510,7 +510,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -510,7 +510,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
/**************************************************************************/
/**************************************************************************/
case
FTDM_CHANNEL_STATE_HANGUP
:
/*call is hung up locally*/
case
FTDM_CHANNEL_STATE_HANGUP
:
/*call is hung up locally*/
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
...
@@ -536,7 +536,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -536,7 +536,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
/**************************************************************************/
/**************************************************************************/
case
FTDM_CHANNEL_STATE_HANGUP_COMPLETE
:
case
FTDM_CHANNEL_STATE_HANGUP_COMPLETE
:
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
...
@@ -568,7 +568,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -568,7 +568,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
/**************************************************************************/
/**************************************************************************/
case
FTDM_CHANNEL_STATE_DOWN
:
/*the call is finished and removed*/
case
FTDM_CHANNEL_STATE_DOWN
:
/*the call is finished and removed*/
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
if
(
ftdmchan
->
last_state
==
FTDM_CHANNEL_STATE_SUSPENDED
)
{
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
SS7_DEBUG
(
"re-entering state from processing block/unblock request ... do nothing
\n
"
);
...
@@ -598,8 +598,8 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -598,8 +598,8 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
/* check if the circuit has the glare flag up */
/* check if the circuit has the glare flag up */
if
(
sngss7_test_flag
(
sngss7_info
,
FLAG_GLARE
))
{
if
(
sngss7_test_flag
(
sngss7_info
,
FLAG_GLARE
))
{
SS7_DEBUG
(
"Glare flag is up....spoofing incoming call on span=%, chan=%d
\n
"
,
SS7_DEBUG
(
"Glare flag is up....spoofing incoming call on span=%
d
, chan=%d
\n
"
,
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
/* clear all the call specific data */
/* clear all the call specific data */
sngss7_info
->
suInstId
=
0
;
sngss7_info
->
suInstId
=
0
;
sngss7_info
->
spInstId
=
0
;
sngss7_info
->
spInstId
=
0
;
...
@@ -639,7 +639,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -639,7 +639,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
/**************************************************************************/
/**************************************************************************/
case
FTDM_CHANNEL_STATE_RESTART
:
/* CICs needs a Reset */
case
FTDM_CHANNEL_STATE_RESTART
:
/* CICs needs a Reset */
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
if
(
ftdm_test_flag
(
ftdmchan
,
FTDM_CHANNEL_INUSE
))
{
if
(
ftdm_test_flag
(
ftdmchan
,
FTDM_CHANNEL_INUSE
))
{
/* bring the call down first...then process the rest of the reset */
/* bring the call down first...then process the rest of the reset */
...
@@ -694,11 +694,11 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -694,11 +694,11 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
/**************************************************************************/
/**************************************************************************/
case
FTDM_CHANNEL_STATE_SUSPENDED
:
/* circuit has been blocked */
case
FTDM_CHANNEL_STATE_SUSPENDED
:
/* circuit has been blocked */
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
/**********************************************************************/
/**********************************************************************/
if
(
sngss7_test_flag
(
sngss7_info
,
FLAG_INFID_PAUSED
))
{
if
(
sngss7_test_flag
(
sngss7_info
,
FLAG_INFID_PAUSED
))
{
SS7_DEBUG
(
"processing pause for span = %, chan = %d
\n
"
,
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
SS7_DEBUG
(
"processing pause for span = %, chan = %d
\n
"
,
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
/* bring the channel signaling status to down */
/* bring the channel signaling status to down */
status
=
FTDM_SIG_STATE_DOWN
;
status
=
FTDM_SIG_STATE_DOWN
;
sigev
.
event_id
=
FTDM_SIGEVENT_SIGSTATUS_CHANGED
;
sigev
.
event_id
=
FTDM_SIGEVENT_SIGSTATUS_CHANGED
;
...
@@ -709,7 +709,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -709,7 +709,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
ftdm_set_state_locked
(
ftdmchan
,
ftdmchan
->
last_state
);
ftdm_set_state_locked
(
ftdmchan
,
ftdmchan
->
last_state
);
}
}
if
(
sngss7_test_flag
(
sngss7_info
,
FLAG_INFID_RESUME
))
{
if
(
sngss7_test_flag
(
sngss7_info
,
FLAG_INFID_RESUME
))
{
SS7_DEBUG
(
"processing resume for span = %, chan = %d
\n
"
,
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
SS7_DEBUG
(
"processing resume for span = %, chan = %d
\n
"
,
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
/* we just resumed...throw the channel into reset */
/* we just resumed...throw the channel into reset */
sngss7_set_flag
(
sngss7_info
,
FLAG_RESET_TX
);
sngss7_set_flag
(
sngss7_info
,
FLAG_RESET_TX
);
...
@@ -721,7 +721,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -721,7 +721,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
}
}
/**********************************************************************/
/**********************************************************************/
if
(
sngss7_test_flag
(
sngss7_info
,
FLAG_CKT_MN_BLOCK_RX
))
{
if
(
sngss7_test_flag
(
sngss7_info
,
FLAG_CKT_MN_BLOCK_RX
))
{
SS7_DEBUG
(
"processing rx Mn ckt block for span = %, chan = %d
\n
"
,
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
SS7_DEBUG
(
"processing rx Mn ckt block for span = %, chan = %d
\n
"
,
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
/* bring the channel signaling status to down */
/* bring the channel signaling status to down */
status
=
FTDM_SIG_STATE_DOWN
;
status
=
FTDM_SIG_STATE_DOWN
;
sigev
.
event_id
=
FTDM_SIGEVENT_SIGSTATUS_CHANGED
;
sigev
.
event_id
=
FTDM_SIGEVENT_SIGSTATUS_CHANGED
;
...
@@ -735,7 +735,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -735,7 +735,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
ftdm_set_state_locked
(
ftdmchan
,
ftdmchan
->
last_state
);
ftdm_set_state_locked
(
ftdmchan
,
ftdmchan
->
last_state
);
}
}
if
(
sngss7_test_flag
(
sngss7_info
,
FLAG_CKT_MN_UNBLK_RX
))
{
if
(
sngss7_test_flag
(
sngss7_info
,
FLAG_CKT_MN_UNBLK_RX
))
{
SS7_DEBUG
(
"processing rx Mn ckt unblock for span = %, chan = %d
\n
"
,
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
SS7_DEBUG
(
"processing rx Mn ckt unblock for span = %, chan = %d
\n
"
,
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
/* bring the channel signaling status to up */
/* bring the channel signaling status to up */
status
=
FTDM_SIG_STATE_UP
;
status
=
FTDM_SIG_STATE_UP
;
sigev
.
event_id
=
FTDM_SIGEVENT_SIGSTATUS_CHANGED
;
sigev
.
event_id
=
FTDM_SIGEVENT_SIGSTATUS_CHANGED
;
...
@@ -753,7 +753,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -753,7 +753,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
}
}
/**********************************************************************/
/**********************************************************************/
if
(
sngss7_test_flag
(
sngss7_info
,
FLAG_CKT_MN_BLOCK_TX
))
{
if
(
sngss7_test_flag
(
sngss7_info
,
FLAG_CKT_MN_BLOCK_TX
))
{
SS7_DEBUG
(
"processing tx Mn ckt block for span = %, chan = %d
\n
"
,
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
SS7_DEBUG
(
"processing tx Mn ckt block for span = %, chan = %d
\n
"
,
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
/* bring the channel signaling status to down */
/* bring the channel signaling status to down */
status
=
FTDM_SIG_STATE_DOWN
;
status
=
FTDM_SIG_STATE_DOWN
;
sigev
.
event_id
=
FTDM_SIGEVENT_SIGSTATUS_CHANGED
;
sigev
.
event_id
=
FTDM_SIGEVENT_SIGSTATUS_CHANGED
;
...
@@ -767,7 +767,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -767,7 +767,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
ftdm_set_state_locked
(
ftdmchan
,
ftdmchan
->
last_state
);
ftdm_set_state_locked
(
ftdmchan
,
ftdmchan
->
last_state
);
}
}
if
(
sngss7_test_flag
(
sngss7_info
,
FLAG_CKT_MN_UNBLK_TX
))
{
if
(
sngss7_test_flag
(
sngss7_info
,
FLAG_CKT_MN_UNBLK_TX
))
{
SS7_DEBUG
(
"processing tx Mn ckt unblock for span = %, chan = %d
\n
"
,
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
SS7_DEBUG
(
"processing tx Mn ckt unblock for span = %, chan = %d
\n
"
,
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
/* bring the channel signaling status to up */
/* bring the channel signaling status to up */
status
=
FTDM_SIG_STATE_UP
;
status
=
FTDM_SIG_STATE_UP
;
sigev
.
event_id
=
FTDM_SIGEVENT_SIGSTATUS_CHANGED
;
sigev
.
event_id
=
FTDM_SIGEVENT_SIGSTATUS_CHANGED
;
...
@@ -789,7 +789,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -789,7 +789,7 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
/**************************************************************************/
/**************************************************************************/
case
FTDM_CHANNEL_STATE_IN_LOOP
:
/* COT test */
case
FTDM_CHANNEL_STATE_IN_LOOP
:
/* COT test */
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 processing state %s on span=%u,chan=%u
\n
"
,
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
/* send the lpa */
/* send the lpa */
ft_to_sngss7_lpa
(
ftdmchan
);
ft_to_sngss7_lpa
(
ftdmchan
);
...
@@ -806,13 +806,13 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
...
@@ -806,13 +806,13 @@ static void ftdm_sangoma_ss7_process_state_change(ftdm_channel_t *ftdmchan)
case
FTDM_CHANNEL_STATE_IDLE
:
case
FTDM_CHANNEL_STATE_IDLE
:
case
FTDM_CHANNEL_STATE_INVALID
:
case
FTDM_CHANNEL_STATE_INVALID
:
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 does not support state %s on span=%u,chan=%u
\n
"
,
ftdm_log
(
FTDM_LOG_DEBUG
,
"ftmod_sangoma_ss7 does not support state %s on span=%u,chan=%u
\n
"
,
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
break
;
break
;
/**************************************************************************/
/**************************************************************************/
default:
default:
/*this is bad...we're in an unknown state...should we kill this channel???*/
/*this is bad...we're in an unknown state...should we kill this channel???*/
ftdm_log
(
FTDM_LOG_ERROR
,
"ftmod_sangoma_ss7 in unknown state %s on span=%u,chan=%u
\n
"
,
ftdm_log
(
FTDM_LOG_ERROR
,
"ftmod_sangoma_ss7 in unknown state %s on span=%u,chan=%u
\n
"
,
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
break
;
break
;
}
/*switch (ftdmchan->state)*/
}
/*switch (ftdmchan->state)*/
...
@@ -845,7 +845,7 @@ static FIO_CHANNEL_OUTGOING_CALL_FUNCTION(ftdm_sangoma_ss7_outgoing_call)
...
@@ -845,7 +845,7 @@ static FIO_CHANNEL_OUTGOING_CALL_FUNCTION(ftdm_sangoma_ss7_outgoing_call)
* glare or for the network to acknowledge the call
* glare or for the network to acknowledge the call
*/
*/
c
=
0
;
c
=
0
;
while
(
c
<
2
0
)
{
while
(
c
<
10
0
)
{
/* lock the channel while we check whether it is availble */
/* lock the channel while we check whether it is availble */
ftdm_mutex_lock
(
ftdmchan
->
mutex
);
ftdm_mutex_lock
(
ftdmchan
->
mutex
);
...
@@ -854,11 +854,9 @@ static FIO_CHANNEL_OUTGOING_CALL_FUNCTION(ftdm_sangoma_ss7_outgoing_call)
...
@@ -854,11 +854,9 @@ static FIO_CHANNEL_OUTGOING_CALL_FUNCTION(ftdm_sangoma_ss7_outgoing_call)
sngss7_info
=
(
sngss7_chan_data_t
*
)
ftdmchan
->
call_data
;
sngss7_info
=
(
sngss7_chan_data_t
*
)
ftdmchan
->
call_data
;
if
(
sngss7_test_flag
(
sngss7_info
,
FLAG_GLARE
))
{
if
(
sngss7_test_flag
(
sngss7_info
,
FLAG_GLARE
))
{
SS7_ERROR
(
"Glare flag on span=%d,
chan=%d
\n
"
,
SS7_ERROR
(
"Glare flag on span=%d,chan=%d
\n
"
,
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
/* move the channel to DOWN to clear the existing channel allocations */
ftdm_set_state_locked
(
ftdmchan
,
FTDM_CHANNEL_STATE_DOWN
);
goto
outgoing_glare
;
goto
outgoing_glare
;
}
}
...
@@ -870,17 +868,15 @@ static FIO_CHANNEL_OUTGOING_CALL_FUNCTION(ftdm_sangoma_ss7_outgoing_call)
...
@@ -870,17 +868,15 @@ static FIO_CHANNEL_OUTGOING_CALL_FUNCTION(ftdm_sangoma_ss7_outgoing_call)
case
FTDM_CHANNEL_STATE_PROGRESS
:
case
FTDM_CHANNEL_STATE_PROGRESS
:
case
FTDM_CHANNEL_STATE_PROGRESS_MEDIA
:
case
FTDM_CHANNEL_STATE_PROGRESS_MEDIA
:
case
FTDM_CHANNEL_STATE_UP
:
case
FTDM_CHANNEL_STATE_UP
:
SS7_DEBUG
(
"Outgoing call request successful on span=%d, chan=%d
\n
"
,
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
goto
outgoing_successful
;
goto
outgoing_successful
;
break
;
break
;
/******************************************************************/
/******************************************************************/
default:
default:
SS7_ERROR
(
"Channel in invalid state (%s) on span=%d,
chan=%d...should not happen
\n
"
,
SS7_ERROR
(
"Channel in invalid state (%s) on span=%d,
chan=%d...glare
\n
"
,
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdm_channel_state2str
(
ftdmchan
->
state
),
ftdmchan
->
span_id
,
ftdmchan
->
physical_
span_id
,
ftdmchan
->
chan_id
);
ftdmchan
->
physical_
chan_id
);
goto
outgoing_
fail
;
goto
outgoing_
glare
;
break
;
break
;
/******************************************************************/
/******************************************************************/
}
}
...
@@ -889,7 +885,7 @@ static FIO_CHANNEL_OUTGOING_CALL_FUNCTION(ftdm_sangoma_ss7_outgoing_call)
...
@@ -889,7 +885,7 @@ static FIO_CHANNEL_OUTGOING_CALL_FUNCTION(ftdm_sangoma_ss7_outgoing_call)
ftdm_mutex_unlock
(
ftdmchan
->
mutex
);
ftdm_mutex_unlock
(
ftdmchan
->
mutex
);
/* sleep for a bit to let the state change */
/* sleep for a bit to let the state change */
ftdm_sleep
(
5
0
);
ftdm_sleep
(
1
0
);
/* increment the timeout counter */
/* increment the timeout counter */
c
++
;
c
++
;
...
@@ -897,8 +893,8 @@ static FIO_CHANNEL_OUTGOING_CALL_FUNCTION(ftdm_sangoma_ss7_outgoing_call)
...
@@ -897,8 +893,8 @@ static FIO_CHANNEL_OUTGOING_CALL_FUNCTION(ftdm_sangoma_ss7_outgoing_call)
}
/* while (c < 4) */
}
/* while (c < 4) */
/* if we got here we have timed-out waiting for acknowledgment, kill the call */
/* if we got here we have timed-out waiting for acknowledgment, kill the call */
SS7_DEBUG
(
"Timeout waiting for outgoing call to be accepted by network, ok'ing outgoing call on span=%d,
chan=%d
\n
"
,
SS7_DEBUG
(
"Timeout waiting for outgoing call to be accepted by network, ok'ing outgoing call on span=%d,chan=%d
\n
"
,
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
/* consider the call good .... for now */
/* consider the call good .... for now */
goto
outgoing_successful
;
goto
outgoing_successful
;
...
@@ -907,8 +903,8 @@ static FIO_CHANNEL_OUTGOING_CALL_FUNCTION(ftdm_sangoma_ss7_outgoing_call)
...
@@ -907,8 +903,8 @@ static FIO_CHANNEL_OUTGOING_CALL_FUNCTION(ftdm_sangoma_ss7_outgoing_call)
/**************************************************************************/
/**************************************************************************/
default:
default:
/* the channel is already used...this can't be, end the request */
/* the channel is already used...this can't be, end the request */
SS7_ERROR
(
"Outgoing call requested channel in already in use...indicating glare on span=%d,
chan=%d
\n
"
,
SS7_ERROR
(
"Outgoing call requested channel in already in use...indicating glare on span=%d,chan=%d
\n
"
,
ftdmchan
->
span_id
,
ftdmchan
->
chan_id
);
ftdmchan
->
physical_span_id
,
ftdmchan
->
physical_
chan_id
);
goto
outgoing_glare
;
goto
outgoing_glare
;
break
;
break
;
/**************************************************************************/
/**************************************************************************/
...
@@ -917,17 +913,20 @@ static FIO_CHANNEL_OUTGOING_CALL_FUNCTION(ftdm_sangoma_ss7_outgoing_call)
...
@@ -917,17 +913,20 @@ static FIO_CHANNEL_OUTGOING_CALL_FUNCTION(ftdm_sangoma_ss7_outgoing_call)
/* we should not get to this here...all exit points above use goto */
/* we should not get to this here...all exit points above use goto */
SS7_ERROR
(
"WE SHOULD NOT HERE HERE!!!!
\n
"
);
SS7_ERROR
(
"WE SHOULD NOT HERE HERE!!!!
\n
"
);
outgoing_fail:
SS7_DEBUG
(
"Call Request on span=%d, chan=%d failed
\n
"
);
/* unlock the channel */
/* unlock the channel */
ftdm_mutex_unlock
(
ftdmchan
->
mutex
);
ftdm_mutex_unlock
(
ftdmchan
->
mutex
);
return
FTDM_FAIL
;
return
FTDM_FAIL
;
outgoing_glare:
outgoing_glare:
SS7_DEBUG
(
"Indicating glare on span=%d, chan=%d
\n
"
);
/* unlock the channel */
/* unlock the channel */
ftdm_mutex_unlock
(
ftdmchan
->
mutex
);
ftdm_mutex_unlock
(
ftdmchan
->
mutex
);
return
FTDM_BREAK
;
return
FTDM_BREAK
;
outgoing_successful:
outgoing_successful:
SS7_DEBUG
(
"Call Request on span=%d, chan=%d successful
\n
"
);
/* unlock the channel */
/* unlock the channel */
ftdm_mutex_unlock
(
ftdmchan
->
mutex
);
ftdm_mutex_unlock
(
ftdmchan
->
mutex
);
return
FTDM_SUCCESS
;
return
FTDM_SUCCESS
;
...
...
编写
预览
Markdown
格式
0%
重试
或
添加新文件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
请先完成此评论的编辑!
取消
请
注册
或者
登录
后发表评论