Skip to content
项目
群组
代码片段
帮助
正在加载...
登录
切换导航
F
freeswitch
项目
项目
详情
活动
周期分析
仓库
仓库
文件
提交
分支
标签
贡献者
分枝图
比较
统计图
议题
0
议题
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
CI / CD
CI / CD
流水线
作业
日程
统计图
Wiki
Wiki
代码片段
代码片段
成员
成员
折叠边栏
关闭边栏
活动
分枝图
统计图
创建新议题
作业
提交
议题看板
打开侧边栏
张华
freeswitch
Commits
94e92fe2
提交
94e92fe2
authored
6月 25, 2007
作者:
Anthony Minessale
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
sync
git-svn-id:
http://svn.openzap.org/svn/openzap/trunk@289
a93c3328-9c30-0410-af19-c9cd2b2d52af
上级
dffaad2a
隐藏空白字符变更
内嵌
并排
正在显示
6 个修改的文件
包含
80 行增加
和
75 行删除
+80
-75
openzap.h
libs/freetdm/src/include/openzap.h
+1
-2
testanalog.c
libs/freetdm/src/testanalog.c
+3
-1
testisdn.c
libs/freetdm/src/testisdn.c
+4
-2
zap_analog.c
libs/freetdm/src/zap_analog.c
+21
-19
zap_io.c
libs/freetdm/src/zap_io.c
+2
-6
zap_isdn.c
libs/freetdm/src/zap_isdn.c
+49
-45
没有找到文件。
libs/freetdm/src/include/openzap.h
浏览文件 @
94e92fe2
...
@@ -408,8 +408,7 @@ struct zap_span {
...
@@ -408,8 +408,7 @@ struct zap_span {
zap_trunk_type_t
trunk_type
;
zap_trunk_type_t
trunk_type
;
zap_analog_start_type_t
start_type
;
zap_analog_start_type_t
start_type
;
zap_signal_type_t
signal_type
;
zap_signal_type_t
signal_type
;
struct
zap_isdn_data
*
isdn_data
;
void
*
signal_data
;
struct
zap_analog_data
*
analog_data
;
zap_event_t
event_header
;
zap_event_t
event_header
;
char
last_error
[
256
];
char
last_error
[
256
];
char
tone_map
[
ZAP_TONEMAP_INVALID
+
1
][
ZAP_TONEMAP_LEN
];
char
tone_map
[
ZAP_TONEMAP_INVALID
+
1
][
ZAP_TONEMAP_LEN
];
...
...
libs/freetdm/src/testanalog.c
浏览文件 @
94e92fe2
...
@@ -62,6 +62,7 @@ int main(int argc, char *argv[])
...
@@ -62,6 +62,7 @@ int main(int argc, char *argv[])
{
{
zap_span_t
*
span
;
zap_span_t
*
span
;
int
span_id
;
int
span_id
;
zap_analog_data_t
*
analog_data
;
if
(
argc
<
2
)
{
if
(
argc
<
2
)
{
printf
(
"usage %s <spanno>
\n
"
,
argv
[
0
]);
printf
(
"usage %s <spanno>
\n
"
,
argv
[
0
]);
...
@@ -88,9 +89,10 @@ int main(int argc, char *argv[])
...
@@ -88,9 +89,10 @@ int main(int argc, char *argv[])
zap_log
(
ZAP_LOG_ERROR
,
"Error configuring OpenZAP span
\n
"
);
zap_log
(
ZAP_LOG_ERROR
,
"Error configuring OpenZAP span
\n
"
);
goto
done
;
goto
done
;
}
}
analog_data
=
span
->
signal_data
;
zap_analog_start
(
span
);
zap_analog_start
(
span
);
while
(
zap_test_flag
(
span
->
analog_data
,
ZAP_ANALOG_RUNNING
))
{
while
(
zap_test_flag
(
analog_data
,
ZAP_ANALOG_RUNNING
))
{
zap_sleep
(
1
*
1000
);
zap_sleep
(
1
*
1000
);
}
}
...
...
libs/freetdm/src/testisdn.c
浏览文件 @
94e92fe2
...
@@ -9,7 +9,8 @@ static ZIO_SIGNAL_CB_FUNCTION(on_signal)
...
@@ -9,7 +9,8 @@ static ZIO_SIGNAL_CB_FUNCTION(on_signal)
int
main
(
int
argc
,
char
*
argv
[])
int
main
(
int
argc
,
char
*
argv
[])
{
{
zap_span_t
*
span
;
zap_span_t
*
span
;
zap_isdn_data_t
*
data
;
zap_global_set_default_logger
(
ZAP_LOG_LEVEL_DEBUG
);
zap_global_set_default_logger
(
ZAP_LOG_LEVEL_DEBUG
);
if
(
argc
<
2
)
{
if
(
argc
<
2
)
{
...
@@ -31,13 +32,14 @@ int main(int argc, char *argv[])
...
@@ -31,13 +32,14 @@ int main(int argc, char *argv[])
if
(
zap_isdn_configure_span
(
span
,
Q931_TE
,
Q931_Dialect_National
,
on_signal
)
==
ZAP_SUCCESS
)
{
if
(
zap_isdn_configure_span
(
span
,
Q931_TE
,
Q931_Dialect_National
,
on_signal
)
==
ZAP_SUCCESS
)
{
data
=
span
->
signal_data
;
zap_isdn_start
(
span
);
zap_isdn_start
(
span
);
}
else
{
}
else
{
fprintf
(
stderr
,
"Error starting ISDN D-Channel
\n
"
);
fprintf
(
stderr
,
"Error starting ISDN D-Channel
\n
"
);
goto
done
;
goto
done
;
}
}
while
(
zap_test_flag
(
span
->
isdn_
data
,
ZAP_ISDN_RUNNING
))
{
while
(
zap_test_flag
(
data
,
ZAP_ISDN_RUNNING
))
{
zap_sleep
(
1
*
1000
);
zap_sleep
(
1
*
1000
);
}
}
...
...
libs/freetdm/src/zap_analog.c
浏览文件 @
94e92fe2
...
@@ -74,7 +74,7 @@ static ZIO_CHANNEL_OUTGOING_CALL_FUNCTION(analog_fxs_outgoing_call)
...
@@ -74,7 +74,7 @@ static ZIO_CHANNEL_OUTGOING_CALL_FUNCTION(analog_fxs_outgoing_call)
zap_status_t
zap_analog_configure_span
(
zap_span_t
*
span
,
char
*
tonemap
,
uint32_t
digit_timeout
,
uint32_t
max_dialstr
,
zio_signal_cb_t
sig_cb
)
zap_status_t
zap_analog_configure_span
(
zap_span_t
*
span
,
char
*
tonemap
,
uint32_t
digit_timeout
,
uint32_t
max_dialstr
,
zio_signal_cb_t
sig_cb
)
{
{
zap_analog_data_t
*
analog_data
;
assert
(
sig_cb
!=
NULL
);
assert
(
sig_cb
!=
NULL
);
if
(
span
->
signal_type
)
{
if
(
span
->
signal_type
)
{
...
@@ -90,14 +90,15 @@ zap_status_t zap_analog_configure_span(zap_span_t *span, char *tonemap, uint32_t
...
@@ -90,14 +90,15 @@ zap_status_t zap_analog_configure_span(zap_span_t *span, char *tonemap, uint32_t
max_dialstr
=
11
;
max_dialstr
=
11
;
}
}
span
->
analog_data
=
malloc
(
sizeof
(
*
span
->
analog_data
));
analog_data
=
malloc
(
sizeof
(
*
analog_data
));
memset
(
span
->
analog_data
,
0
,
sizeof
(
*
span
->
analog_data
));
memset
(
analog_data
,
0
,
sizeof
(
*
analog_data
));
assert
(
span
->
analog_data
!=
NULL
);
assert
(
analog_data
!=
NULL
);
span
->
analog_data
->
digit_timeout
=
digit_timeout
;
analog_data
->
digit_timeout
=
digit_timeout
;
span
->
analog_data
->
max_dialstr
=
max_dialstr
;
analog_data
->
max_dialstr
=
max_dialstr
;
span
->
analog_data
->
sig_cb
=
sig_cb
;
analog_data
->
sig_cb
=
sig_cb
;
span
->
signal_type
=
ZAP_SIGTYPE_ANALOG
;
span
->
signal_type
=
ZAP_SIGTYPE_ANALOG
;
span
->
signal_data
=
analog_data
;
span
->
outgoing_call
=
span
->
trunk_type
==
ZAP_TRUNK_FXS
?
analog_fxs_outgoing_call
:
analog_fxo_outgoing_call
;
span
->
outgoing_call
=
span
->
trunk_type
==
ZAP_TRUNK_FXS
?
analog_fxs_outgoing_call
:
analog_fxo_outgoing_call
;
zap_span_load_tones
(
span
,
tonemap
);
zap_span_load_tones
(
span
,
tonemap
);
...
@@ -173,7 +174,7 @@ static void *zap_analog_channel_run(zap_thread_t *me, void *obj)
...
@@ -173,7 +174,7 @@ static void *zap_analog_channel_run(zap_thread_t *me, void *obj)
zap_tone_type_t
tt
=
ZAP_TONE_DTMF
;
zap_tone_type_t
tt
=
ZAP_TONE_DTMF
;
char
dtmf
[
128
]
=
""
;
char
dtmf
[
128
]
=
""
;
zap_size_t
dtmf_offset
=
0
;
zap_size_t
dtmf_offset
=
0
;
zap_analog_data_t
*
data
=
zchan
->
span
->
analog
_data
;
zap_analog_data_t
*
analog_data
=
zchan
->
span
->
signal
_data
;
zap_channel_t
*
closed_chan
;
zap_channel_t
*
closed_chan
;
uint32_t
state_counter
=
0
,
elapsed
=
0
,
interval
=
0
,
last_digit
=
0
,
indicate
=
0
,
dial_timeout
=
30000
;
uint32_t
state_counter
=
0
,
elapsed
=
0
,
interval
=
0
,
last_digit
=
0
,
indicate
=
0
,
dial_timeout
=
30000
;
zap_sigmsg_t
sig
;
zap_sigmsg_t
sig
;
...
@@ -368,7 +369,7 @@ static void *zap_analog_channel_run(zap_thread_t *me, void *obj)
...
@@ -368,7 +369,7 @@ static void *zap_analog_channel_run(zap_thread_t *me, void *obj)
sig
.
event_id
=
ZAP_SIGEVENT_UP
;
sig
.
event_id
=
ZAP_SIGEVENT_UP
;
}
}
data
->
sig_cb
(
&
sig
);
analog_
data
->
sig_cb
(
&
sig
);
continue
;
continue
;
}
}
break
;
break
;
...
@@ -388,7 +389,7 @@ static void *zap_analog_channel_run(zap_thread_t *me, void *obj)
...
@@ -388,7 +389,7 @@ static void *zap_analog_channel_run(zap_thread_t *me, void *obj)
zap_set_string
(
zchan
->
caller_data
.
dnis
,
dtmf
);
zap_set_string
(
zchan
->
caller_data
.
dnis
,
dtmf
);
}
}
data
->
sig_cb
(
&
sig
);
analog_
data
->
sig_cb
(
&
sig
);
continue
;
continue
;
}
}
break
;
break
;
...
@@ -396,7 +397,7 @@ static void *zap_analog_channel_run(zap_thread_t *me, void *obj)
...
@@ -396,7 +397,7 @@ static void *zap_analog_channel_run(zap_thread_t *me, void *obj)
{
{
zap_channel_done
(
zchan
);
zap_channel_done
(
zchan
);
sig
.
event_id
=
ZAP_SIGEVENT_STOP
;
sig
.
event_id
=
ZAP_SIGEVENT_STOP
;
data
->
sig_cb
(
&
sig
);
analog_
data
->
sig_cb
(
&
sig
);
goto
done
;
goto
done
;
}
}
break
;
break
;
...
@@ -479,7 +480,7 @@ static void *zap_analog_channel_run(zap_thread_t *me, void *obj)
...
@@ -479,7 +480,7 @@ static void *zap_analog_channel_run(zap_thread_t *me, void *obj)
}
}
if
(
last_digit
&&
((
elapsed
-
last_digit
>
data
->
digit_timeout
)
||
strlen
(
dtmf
)
>
data
->
max_dialstr
))
{
if
(
last_digit
&&
((
elapsed
-
last_digit
>
analog_data
->
digit_timeout
)
||
strlen
(
dtmf
)
>
analog_
data
->
max_dialstr
))
{
zap_log
(
ZAP_LOG_DEBUG
,
"Number obtained [%s]
\n
"
,
dtmf
);
zap_log
(
ZAP_LOG_DEBUG
,
"Number obtained [%s]
\n
"
,
dtmf
);
zap_set_state_locked
(
zchan
,
ZAP_CHANNEL_STATE_IDLE
);
zap_set_state_locked
(
zchan
,
ZAP_CHANNEL_STATE_IDLE
);
last_digit
=
0
;
last_digit
=
0
;
...
@@ -511,7 +512,7 @@ static void *zap_analog_channel_run(zap_thread_t *me, void *obj)
...
@@ -511,7 +512,7 @@ static void *zap_analog_channel_run(zap_thread_t *me, void *obj)
if
(
zchan
->
detected_tones
[
i
])
{
if
(
zchan
->
detected_tones
[
i
])
{
zap_log
(
ZAP_LOG_DEBUG
,
"Detected tone %s
\n
"
,
zap_tonemap2str
(
zchan
->
detected_tones
[
i
]));
zap_log
(
ZAP_LOG_DEBUG
,
"Detected tone %s
\n
"
,
zap_tonemap2str
(
zchan
->
detected_tones
[
i
]));
sig
.
raw_data
=
&
i
;
sig
.
raw_data
=
&
i
;
data
->
sig_cb
(
&
sig
);
analog_
data
->
sig_cb
(
&
sig
);
}
}
}
}
...
@@ -608,7 +609,7 @@ static void *zap_analog_channel_run(zap_thread_t *me, void *obj)
...
@@ -608,7 +609,7 @@ static void *zap_analog_channel_run(zap_thread_t *me, void *obj)
static
__inline__
zap_status_t
process_event
(
zap_span_t
*
span
,
zap_event_t
*
event
)
static
__inline__
zap_status_t
process_event
(
zap_span_t
*
span
,
zap_event_t
*
event
)
{
{
zap_sigmsg_t
sig
;
zap_sigmsg_t
sig
;
zap_analog_data_t
*
data
=
event
->
channel
->
span
->
analog
_data
;
zap_analog_data_t
*
analog_data
=
event
->
channel
->
span
->
signal
_data
;
memset
(
&
sig
,
0
,
sizeof
(
sig
));
memset
(
&
sig
,
0
,
sizeof
(
sig
));
sig
.
chan_id
=
event
->
channel
->
chan_id
;
sig
.
chan_id
=
event
->
channel
->
chan_id
;
...
@@ -655,7 +656,7 @@ static __inline__ zap_status_t process_event(zap_span_t *span, zap_event_t *even
...
@@ -655,7 +656,7 @@ static __inline__ zap_status_t process_event(zap_span_t *span, zap_event_t *even
zap_set_state_locked
(
event
->
channel
,
ZAP_CHANNEL_STATE_UP
);
zap_set_state_locked
(
event
->
channel
,
ZAP_CHANNEL_STATE_UP
);
}
else
{
}
else
{
sig
.
event_id
=
ZAP_SIGEVENT_FLASH
;
sig
.
event_id
=
ZAP_SIGEVENT_FLASH
;
data
->
sig_cb
(
&
sig
);
analog_
data
->
sig_cb
(
&
sig
);
if
(
event
->
channel
->
token_count
==
1
)
{
if
(
event
->
channel
->
token_count
==
1
)
{
zap_set_flag_locked
(
event
->
channel
,
ZAP_CHANNEL_HOLD
);
zap_set_flag_locked
(
event
->
channel
,
ZAP_CHANNEL_HOLD
);
zap_set_state_locked
(
event
->
channel
,
ZAP_CHANNEL_STATE_DIALTONE
);
zap_set_state_locked
(
event
->
channel
,
ZAP_CHANNEL_STATE_DIALTONE
);
...
@@ -693,11 +694,11 @@ static __inline__ zap_status_t process_event(zap_span_t *span, zap_event_t *even
...
@@ -693,11 +694,11 @@ static __inline__ zap_status_t process_event(zap_span_t *span, zap_event_t *even
static
void
*
zap_analog_run
(
zap_thread_t
*
me
,
void
*
obj
)
static
void
*
zap_analog_run
(
zap_thread_t
*
me
,
void
*
obj
)
{
{
zap_span_t
*
span
=
(
zap_span_t
*
)
obj
;
zap_span_t
*
span
=
(
zap_span_t
*
)
obj
;
zap_analog_data_t
*
data
=
span
->
analog
_data
;
zap_analog_data_t
*
analog_data
=
span
->
signal
_data
;
zap_log
(
ZAP_LOG_DEBUG
,
"ANALOG thread starting.
\n
"
);
zap_log
(
ZAP_LOG_DEBUG
,
"ANALOG thread starting.
\n
"
);
while
(
zap_test_flag
(
data
,
ZAP_ANALOG_RUNNING
))
{
while
(
zap_test_flag
(
analog_
data
,
ZAP_ANALOG_RUNNING
))
{
int
waitms
=
10
;
int
waitms
=
10
;
zap_status_t
status
;
zap_status_t
status
;
...
@@ -731,7 +732,7 @@ static void *zap_analog_run(zap_thread_t *me, void *obj)
...
@@ -731,7 +732,7 @@ static void *zap_analog_run(zap_thread_t *me, void *obj)
end:
end:
zap_clear_flag
(
data
,
ZAP_ANALOG_RUNNING
);
zap_clear_flag
(
analog_
data
,
ZAP_ANALOG_RUNNING
);
zap_log
(
ZAP_LOG_DEBUG
,
"ANALOG thread ending.
\n
"
);
zap_log
(
ZAP_LOG_DEBUG
,
"ANALOG thread ending.
\n
"
);
...
@@ -742,7 +743,8 @@ static void *zap_analog_run(zap_thread_t *me, void *obj)
...
@@ -742,7 +743,8 @@ static void *zap_analog_run(zap_thread_t *me, void *obj)
zap_status_t
zap_analog_start
(
zap_span_t
*
span
)
zap_status_t
zap_analog_start
(
zap_span_t
*
span
)
{
{
zap_set_flag
(
span
->
analog_data
,
ZAP_ANALOG_RUNNING
);
zap_analog_data_t
*
analog_data
=
span
->
signal_data
;
zap_set_flag
(
analog_data
,
ZAP_ANALOG_RUNNING
);
return
zap_thread_create_detached
(
zap_analog_run
,
span
);
return
zap_thread_create_detached
(
zap_analog_run
,
span
);
}
}
...
...
libs/freetdm/src/zap_io.c
浏览文件 @
94e92fe2
...
@@ -319,12 +319,8 @@ zap_status_t zap_span_close_all(void)
...
@@ -319,12 +319,8 @@ zap_status_t zap_span_close_all(void)
if
(
span
->
mutex
)
{
if
(
span
->
mutex
)
{
zap_mutex_destroy
(
&
span
->
mutex
);
zap_mutex_destroy
(
&
span
->
mutex
);
}
}
if
(
span
->
isdn_data
)
{
free
(
span
->
isdn_data
);
zap_safe_free
(
span
->
signal_data
);
}
if
(
span
->
analog_data
)
{
free
(
span
->
isdn_data
);
}
}
}
zap_mutex_unlock
(
globals
.
mutex
);
zap_mutex_unlock
(
globals
.
mutex
);
...
...
libs/freetdm/src/zap_isdn.c
浏览文件 @
94e92fe2
...
@@ -65,14 +65,14 @@ static L3INT zap_isdn_931_err(void *pvt, L3INT id, L3INT p1, L3INT p2)
...
@@ -65,14 +65,14 @@ static L3INT zap_isdn_931_err(void *pvt, L3INT id, L3INT p1, L3INT p2)
static
L3INT
zap_isdn_931_34
(
void
*
pvt
,
L2UCHAR
*
msg
,
L2INT
mlen
)
static
L3INT
zap_isdn_931_34
(
void
*
pvt
,
L2UCHAR
*
msg
,
L2INT
mlen
)
{
{
zap_span_t
*
span
=
(
zap_span_t
*
)
pvt
;
zap_span_t
*
span
=
(
zap_span_t
*
)
pvt
;
zap_isdn_data_t
*
data
=
span
->
isdn
_data
;
zap_isdn_data_t
*
isdn_data
=
span
->
signal
_data
;
Q931mes_Generic
*
gen
=
(
Q931mes_Generic
*
)
msg
;
Q931mes_Generic
*
gen
=
(
Q931mes_Generic
*
)
msg
;
Q931ie_ChanID
*
chanid
=
Q931GetIEPtr
(
gen
->
ChanID
,
gen
->
buf
);
Q931ie_ChanID
*
chanid
=
Q931GetIEPtr
(
gen
->
ChanID
,
gen
->
buf
);
int
chan_id
=
chanid
->
ChanSlot
;
int
chan_id
=
chanid
->
ChanSlot
;
zap_channel_t
*
zchan
=
NULL
;
zap_channel_t
*
zchan
=
NULL
;
assert
(
span
!=
NULL
);
assert
(
span
!=
NULL
);
assert
(
data
!=
NULL
);
assert
(
isdn_
data
!=
NULL
);
if
(
chan_id
)
{
if
(
chan_id
)
{
zchan
=
&
span
->
channels
[
chan_id
];
zchan
=
&
span
->
channels
[
chan_id
];
...
@@ -181,6 +181,8 @@ static int zap_isdn_921_21(void *pvt, L2UCHAR *msg, L2INT mlen)
...
@@ -181,6 +181,8 @@ static int zap_isdn_921_21(void *pvt, L2UCHAR *msg, L2INT mlen)
{
{
zap_span_t
*
span
=
(
zap_span_t
*
)
pvt
;
zap_span_t
*
span
=
(
zap_span_t
*
)
pvt
;
zap_size_t
len
=
(
zap_size_t
)
mlen
;
zap_size_t
len
=
(
zap_size_t
)
mlen
;
zap_isdn_data_t
*
isdn_data
=
span
->
signal_data
;
#ifdef IODEBUG
#ifdef IODEBUG
//char bb[4096] = "";
//char bb[4096] = "";
//print_hex_bytes(msg, len, bb, sizeof(bb));
//print_hex_bytes(msg, len, bb, sizeof(bb));
...
@@ -190,13 +192,13 @@ static int zap_isdn_921_21(void *pvt, L2UCHAR *msg, L2INT mlen)
...
@@ -190,13 +192,13 @@ static int zap_isdn_921_21(void *pvt, L2UCHAR *msg, L2INT mlen)
#endif
#endif
assert
(
span
!=
NULL
);
assert
(
span
!=
NULL
);
return
zap_channel_write
(
span
->
isdn_data
->
dchan
,
msg
,
len
,
&
len
)
==
ZAP_SUCCESS
?
0
:
-
1
;
return
zap_channel_write
(
isdn_data
->
dchan
,
msg
,
len
,
&
len
)
==
ZAP_SUCCESS
?
0
:
-
1
;
}
}
static
__inline__
void
state_advance
(
zap_channel_t
*
zchan
)
static
__inline__
void
state_advance
(
zap_channel_t
*
zchan
)
{
{
Q931mes_Generic
*
gen
=
(
Q931mes_Generic
*
)
zchan
->
caller_data
.
raw_data
;
Q931mes_Generic
*
gen
=
(
Q931mes_Generic
*
)
zchan
->
caller_data
.
raw_data
;
zap_isdn_data_t
*
data
=
zchan
->
span
->
isdn
_data
;
zap_isdn_data_t
*
isdn_data
=
zchan
->
span
->
signal
_data
;
zap_sigmsg_t
sig
;
zap_sigmsg_t
sig
;
zap_status_t
status
;
zap_status_t
status
;
...
@@ -218,12 +220,12 @@ static __inline__ void state_advance(zap_channel_t *zchan)
...
@@ -218,12 +220,12 @@ static __inline__ void state_advance(zap_channel_t *zchan)
{
{
if
(
zap_test_flag
(
zchan
,
ZAP_CHANNEL_OUTBOUND
))
{
if
(
zap_test_flag
(
zchan
,
ZAP_CHANNEL_OUTBOUND
))
{
sig
.
event_id
=
ZAP_SIGEVENT_PROGRESS
;
sig
.
event_id
=
ZAP_SIGEVENT_PROGRESS
;
if
((
status
=
data
->
sig_cb
(
&
sig
)
!=
ZAP_SUCCESS
))
{
if
((
status
=
isdn_
data
->
sig_cb
(
&
sig
)
!=
ZAP_SUCCESS
))
{
zap_set_state_locked
(
zchan
,
ZAP_CHANNEL_STATE_HANGUP
);
zap_set_state_locked
(
zchan
,
ZAP_CHANNEL_STATE_HANGUP
);
}
}
}
else
{
}
else
{
gen
->
MesType
=
Q931mes_PROGRESS
;
gen
->
MesType
=
Q931mes_PROGRESS
;
Q931Rx43
(
&
data
->
q931
,
(
void
*
)
gen
,
gen
->
Size
);
Q931Rx43
(
&
isdn_
data
->
q931
,
(
void
*
)
gen
,
gen
->
Size
);
}
}
}
}
break
;
break
;
...
@@ -231,7 +233,7 @@ static __inline__ void state_advance(zap_channel_t *zchan)
...
@@ -231,7 +233,7 @@ static __inline__ void state_advance(zap_channel_t *zchan)
{
{
if
(
!
zap_test_flag
(
zchan
,
ZAP_CHANNEL_OUTBOUND
))
{
if
(
!
zap_test_flag
(
zchan
,
ZAP_CHANNEL_OUTBOUND
))
{
sig
.
event_id
=
ZAP_SIGEVENT_START
;
sig
.
event_id
=
ZAP_SIGEVENT_START
;
if
((
status
=
data
->
sig_cb
(
&
sig
)
!=
ZAP_SUCCESS
))
{
if
((
status
=
isdn_
data
->
sig_cb
(
&
sig
)
!=
ZAP_SUCCESS
))
{
zap_set_state_locked
(
zchan
,
ZAP_CHANNEL_STATE_HANGUP
);
zap_set_state_locked
(
zchan
,
ZAP_CHANNEL_STATE_HANGUP
);
}
}
}
}
...
@@ -248,12 +250,12 @@ static __inline__ void state_advance(zap_channel_t *zchan)
...
@@ -248,12 +250,12 @@ static __inline__ void state_advance(zap_channel_t *zchan)
{
{
if
(
zap_test_flag
(
zchan
,
ZAP_CHANNEL_OUTBOUND
))
{
if
(
zap_test_flag
(
zchan
,
ZAP_CHANNEL_OUTBOUND
))
{
sig
.
event_id
=
ZAP_SIGEVENT_PROGRESS_MEDIA
;
sig
.
event_id
=
ZAP_SIGEVENT_PROGRESS_MEDIA
;
if
((
status
=
data
->
sig_cb
(
&
sig
)
!=
ZAP_SUCCESS
))
{
if
((
status
=
isdn_
data
->
sig_cb
(
&
sig
)
!=
ZAP_SUCCESS
))
{
zap_set_state_locked
(
zchan
,
ZAP_CHANNEL_STATE_HANGUP
);
zap_set_state_locked
(
zchan
,
ZAP_CHANNEL_STATE_HANGUP
);
}
}
}
else
{
}
else
{
gen
->
MesType
=
Q931mes_ALERTING
;
gen
->
MesType
=
Q931mes_ALERTING
;
Q931Rx43
(
&
data
->
q931
,
(
void
*
)
gen
,
gen
->
Size
);
Q931Rx43
(
&
isdn_
data
->
q931
,
(
void
*
)
gen
,
gen
->
Size
);
}
}
}
}
break
;
break
;
...
@@ -261,13 +263,13 @@ static __inline__ void state_advance(zap_channel_t *zchan)
...
@@ -261,13 +263,13 @@ static __inline__ void state_advance(zap_channel_t *zchan)
{
{
if
(
zap_test_flag
(
zchan
,
ZAP_CHANNEL_OUTBOUND
))
{
if
(
zap_test_flag
(
zchan
,
ZAP_CHANNEL_OUTBOUND
))
{
sig
.
event_id
=
ZAP_SIGEVENT_UP
;
sig
.
event_id
=
ZAP_SIGEVENT_UP
;
if
((
status
=
data
->
sig_cb
(
&
sig
)
!=
ZAP_SUCCESS
))
{
if
((
status
=
isdn_
data
->
sig_cb
(
&
sig
)
!=
ZAP_SUCCESS
))
{
zap_set_state_locked
(
zchan
,
ZAP_CHANNEL_STATE_HANGUP
);
zap_set_state_locked
(
zchan
,
ZAP_CHANNEL_STATE_HANGUP
);
}
}
}
else
{
}
else
{
gen
->
MesType
=
Q931mes_CONNECT
;
gen
->
MesType
=
Q931mes_CONNECT
;
gen
->
BearerCap
=
0
;
gen
->
BearerCap
=
0
;
Q931Rx43
(
&
data
->
q931
,
(
void
*
)
gen
,
zchan
->
caller_data
.
raw_data_len
);
Q931Rx43
(
&
isdn_
data
->
q931
,
(
void
*
)
gen
,
zchan
->
caller_data
.
raw_data_len
);
}
}
}
}
break
;
break
;
...
@@ -344,7 +346,7 @@ static __inline__ void state_advance(zap_channel_t *zchan)
...
@@ -344,7 +346,7 @@ static __inline__ void state_advance(zap_channel_t *zchan)
zap_copy_string
((
char
*
)
ptrCalledNum
->
Digit
,
zchan
->
caller_data
.
ani
,
strlen
(
zchan
->
caller_data
.
ani
)
+
1
);
zap_copy_string
((
char
*
)
ptrCalledNum
->
Digit
,
zchan
->
caller_data
.
ani
,
strlen
(
zchan
->
caller_data
.
ani
)
+
1
);
//gen->Size += strlen(zchan->caller_data.ani);
//gen->Size += strlen(zchan->caller_data.ani);
Q931Rx43
(
&
data
->
q931
,
(
L3UCHAR
*
)
gen
,
gen
->
Size
);
Q931Rx43
(
&
isdn_
data
->
q931
,
(
L3UCHAR
*
)
gen
,
gen
->
Size
);
}
}
break
;
break
;
case
ZAP_CHANNEL_STATE_HANGUP
:
case
ZAP_CHANNEL_STATE_HANGUP
:
...
@@ -360,15 +362,15 @@ static __inline__ void state_advance(zap_channel_t *zchan)
...
@@ -360,15 +362,15 @@ static __inline__ void state_advance(zap_channel_t *zchan)
cause
.
Value
=
(
unsigned
char
)
zchan
->
caller_data
.
hangup_cause
;
cause
.
Value
=
(
unsigned
char
)
zchan
->
caller_data
.
hangup_cause
;
*
cause
.
Diag
=
'\0'
;
*
cause
.
Diag
=
'\0'
;
gen
->
Cause
=
Q931AppendIE
((
L3UCHAR
*
)
gen
,
(
L3UCHAR
*
)
&
cause
);
gen
->
Cause
=
Q931AppendIE
((
L3UCHAR
*
)
gen
,
(
L3UCHAR
*
)
&
cause
);
Q931Rx43
(
&
data
->
q931
,
(
L3UCHAR
*
)
gen
,
gen
->
Size
);
Q931Rx43
(
&
isdn_
data
->
q931
,
(
L3UCHAR
*
)
gen
,
gen
->
Size
);
}
}
break
;
break
;
case
ZAP_CHANNEL_STATE_TERMINATING
:
case
ZAP_CHANNEL_STATE_TERMINATING
:
{
{
sig
.
event_id
=
ZAP_SIGEVENT_STOP
;
sig
.
event_id
=
ZAP_SIGEVENT_STOP
;
status
=
data
->
sig_cb
(
&
sig
);
status
=
isdn_
data
->
sig_cb
(
&
sig
);
gen
->
MesType
=
Q931mes_RELEASE
;
gen
->
MesType
=
Q931mes_RELEASE
;
Q931Rx43
(
&
data
->
q931
,
(
void
*
)
gen
,
gen
->
Size
);
Q931Rx43
(
&
isdn_
data
->
q931
,
(
void
*
)
gen
,
gen
->
Size
);
}
}
default:
default:
break
;
break
;
...
@@ -392,7 +394,7 @@ static __inline__ void check_state(zap_span_t *span)
...
@@ -392,7 +394,7 @@ static __inline__ void check_state(zap_span_t *span)
static
__inline__
zap_status_t
process_event
(
zap_span_t
*
span
,
zap_event_t
*
event
)
static
__inline__
zap_status_t
process_event
(
zap_span_t
*
span
,
zap_event_t
*
event
)
{
{
zap_sigmsg_t
sig
;
zap_sigmsg_t
sig
;
zap_isdn_data_t
*
data
=
span
->
isdn
_data
;
zap_isdn_data_t
*
isdn_data
=
span
->
signal
_data
;
memset
(
&
sig
,
0
,
sizeof
(
sig
));
memset
(
&
sig
,
0
,
sizeof
(
sig
));
sig
.
chan_id
=
event
->
channel
->
chan_id
;
sig
.
chan_id
=
event
->
channel
->
chan_id
;
...
@@ -411,7 +413,7 @@ static __inline__ zap_status_t process_event(zap_span_t *span, zap_event_t *even
...
@@ -411,7 +413,7 @@ static __inline__ zap_status_t process_event(zap_span_t *span, zap_event_t *even
}
}
zap_set_flag
(
event
->
channel
,
ZAP_CHANNEL_SUSPENDED
);
zap_set_flag
(
event
->
channel
,
ZAP_CHANNEL_SUSPENDED
);
zap_channel_get_alarms
(
event
->
channel
);
zap_channel_get_alarms
(
event
->
channel
);
data
->
sig_cb
(
&
sig
);
isdn_
data
->
sig_cb
(
&
sig
);
zap_log
(
ZAP_LOG_WARNING
,
"channel %d:%d (%d:%d) has alarms [%s]
\n
"
,
zap_log
(
ZAP_LOG_WARNING
,
"channel %d:%d (%d:%d) has alarms [%s]
\n
"
,
event
->
channel
->
span_id
,
event
->
channel
->
chan_id
,
event
->
channel
->
span_id
,
event
->
channel
->
chan_id
,
event
->
channel
->
physical_span_id
,
event
->
channel
->
physical_chan_id
,
event
->
channel
->
physical_span_id
,
event
->
channel
->
physical_chan_id
,
...
@@ -423,7 +425,7 @@ static __inline__ zap_status_t process_event(zap_span_t *span, zap_event_t *even
...
@@ -423,7 +425,7 @@ static __inline__ zap_status_t process_event(zap_span_t *span, zap_event_t *even
sig
.
event_id
=
ZAP_OOB_ALARM_CLEAR
;
sig
.
event_id
=
ZAP_OOB_ALARM_CLEAR
;
zap_clear_flag
(
event
->
channel
,
ZAP_CHANNEL_SUSPENDED
);
zap_clear_flag
(
event
->
channel
,
ZAP_CHANNEL_SUSPENDED
);
zap_channel_get_alarms
(
event
->
channel
);
zap_channel_get_alarms
(
event
->
channel
);
data
->
sig_cb
(
&
sig
);
isdn_
data
->
sig_cb
(
&
sig
);
}
}
break
;
break
;
}
}
...
@@ -465,7 +467,7 @@ static __inline__ void check_events(zap_span_t *span)
...
@@ -465,7 +467,7 @@ static __inline__ void check_events(zap_span_t *span)
static
void
*
zap_isdn_run
(
zap_thread_t
*
me
,
void
*
obj
)
static
void
*
zap_isdn_run
(
zap_thread_t
*
me
,
void
*
obj
)
{
{
zap_span_t
*
span
=
(
zap_span_t
*
)
obj
;
zap_span_t
*
span
=
(
zap_span_t
*
)
obj
;
zap_isdn_data_t
*
data
=
span
->
isdn
_data
;
zap_isdn_data_t
*
isdn_data
=
span
->
signal
_data
;
unsigned
char
buf
[
1024
];
unsigned
char
buf
[
1024
];
zap_size_t
len
=
sizeof
(
buf
);
zap_size_t
len
=
sizeof
(
buf
);
int
errs
=
0
;
int
errs
=
0
;
...
@@ -476,13 +478,13 @@ static void *zap_isdn_run(zap_thread_t *me, void *obj)
...
@@ -476,13 +478,13 @@ static void *zap_isdn_run(zap_thread_t *me, void *obj)
zap_log
(
ZAP_LOG_DEBUG
,
"ISDN thread starting.
\n
"
);
zap_log
(
ZAP_LOG_DEBUG
,
"ISDN thread starting.
\n
"
);
Q921Start
(
&
data
->
q921
);
Q921Start
(
&
isdn_
data
->
q921
);
while
(
zap_test_flag
(
data
,
ZAP_ISDN_RUNNING
))
{
while
(
zap_test_flag
(
isdn_
data
,
ZAP_ISDN_RUNNING
))
{
zap_wait_flag_t
flags
=
ZAP_READ
;
zap_wait_flag_t
flags
=
ZAP_READ
;
zap_status_t
status
=
zap_channel_wait
(
data
->
dchan
,
&
flags
,
100
);
zap_status_t
status
=
zap_channel_wait
(
isdn_
data
->
dchan
,
&
flags
,
100
);
Q921TimerTick
(
&
data
->
q921
);
Q921TimerTick
(
&
isdn_
data
->
q921
);
check_state
(
span
);
check_state
(
span
);
check_events
(
span
);
check_events
(
span
);
...
@@ -499,7 +501,7 @@ static void *zap_isdn_run(zap_thread_t *me, void *obj)
...
@@ -499,7 +501,7 @@ static void *zap_isdn_run(zap_thread_t *me, void *obj)
case
ZAP_TIMEOUT
:
case
ZAP_TIMEOUT
:
{
{
/*zap_log(ZAP_LOG_DEBUG, "Timeout!\n");*/
/*zap_log(ZAP_LOG_DEBUG, "Timeout!\n");*/
/*Q931TimeTick(data->q931, L3ULONG ms);*/
/*Q931TimeTick(
isdn_
data->q931, L3ULONG ms);*/
errs
=
0
;
errs
=
0
;
}
}
break
;
break
;
...
@@ -508,7 +510,7 @@ static void *zap_isdn_run(zap_thread_t *me, void *obj)
...
@@ -508,7 +510,7 @@ static void *zap_isdn_run(zap_thread_t *me, void *obj)
errs
=
0
;
errs
=
0
;
if
(
flags
&
ZAP_READ
)
{
if
(
flags
&
ZAP_READ
)
{
len
=
sizeof
(
buf
);
len
=
sizeof
(
buf
);
if
(
zap_channel_read
(
data
->
dchan
,
buf
,
&
len
)
==
ZAP_SUCCESS
)
{
if
(
zap_channel_read
(
isdn_
data
->
dchan
,
buf
,
&
len
)
==
ZAP_SUCCESS
)
{
#ifdef IODEBUG
#ifdef IODEBUG
//char bb[4096] = "";
//char bb[4096] = "";
//print_hex_bytes(buf, len, bb, sizeof(bb));
//print_hex_bytes(buf, len, bb, sizeof(bb));
...
@@ -517,8 +519,8 @@ static void *zap_isdn_run(zap_thread_t *me, void *obj)
...
@@ -517,8 +519,8 @@ static void *zap_isdn_run(zap_thread_t *me, void *obj)
//zap_log(ZAP_LOG_DEBUG, "READ %d\n%s\n%s\n\n", (int)len, LINE, bb);
//zap_log(ZAP_LOG_DEBUG, "READ %d\n%s\n%s\n\n", (int)len, LINE, bb);
#endif
#endif
Q921QueueHDLCFrame
(
&
data
->
q921
,
buf
,
(
int
)
len
);
Q921QueueHDLCFrame
(
&
isdn_
data
->
q921
,
buf
,
(
int
)
len
);
Q921Rx12
(
&
data
->
q921
);
Q921Rx12
(
&
isdn_
data
->
q921
);
}
}
}
else
{
}
else
{
zap_log
(
ZAP_LOG_DEBUG
,
"No Read FLAG!
\n
"
);
zap_log
(
ZAP_LOG_DEBUG
,
"No Read FLAG!
\n
"
);
...
@@ -531,9 +533,9 @@ static void *zap_isdn_run(zap_thread_t *me, void *obj)
...
@@ -531,9 +533,9 @@ static void *zap_isdn_run(zap_thread_t *me, void *obj)
done:
done:
zap_channel_close
(
&
data
->
dchans
[
0
]);
zap_channel_close
(
&
isdn_
data
->
dchans
[
0
]);
zap_channel_close
(
&
data
->
dchans
[
1
]);
zap_channel_close
(
&
isdn_
data
->
dchans
[
1
]);
zap_clear_flag
(
span
->
isdn_data
,
ZAP_ISDN_RUNNING
);
zap_clear_flag
(
isdn_data
,
ZAP_ISDN_RUNNING
);
#ifdef WIN32
#ifdef WIN32
timeEndPeriod
(
1
);
timeEndPeriod
(
1
);
...
@@ -554,7 +556,8 @@ zap_status_t zap_isdn_init(void)
...
@@ -554,7 +556,8 @@ zap_status_t zap_isdn_init(void)
zap_status_t
zap_isdn_start
(
zap_span_t
*
span
)
zap_status_t
zap_isdn_start
(
zap_span_t
*
span
)
{
{
zap_set_flag
(
span
->
isdn_data
,
ZAP_ISDN_RUNNING
);
zap_isdn_data_t
*
isdn_data
=
span
->
signal_data
;
zap_set_flag
(
isdn_data
,
ZAP_ISDN_RUNNING
);
return
zap_thread_create_detached
(
zap_isdn_run
,
span
);
return
zap_thread_create_detached
(
zap_isdn_run
,
span
);
}
}
...
@@ -572,7 +575,7 @@ zap_status_t zap_isdn_configure_span(zap_span_t *span, Q921NetUser_t mode, Q931D
...
@@ -572,7 +575,7 @@ zap_status_t zap_isdn_configure_span(zap_span_t *span, Q921NetUser_t mode, Q931D
{
{
uint32_t
i
,
x
=
0
;
uint32_t
i
,
x
=
0
;
zap_channel_t
*
dchans
[
2
]
=
{
0
};
zap_channel_t
*
dchans
[
2
]
=
{
0
};
zap_isdn_data_t
*
isdn_data
;
if
(
span
->
signal_type
)
{
if
(
span
->
signal_type
)
{
snprintf
(
span
->
last_error
,
sizeof
(
span
->
last_error
),
"Span is already configured for signalling [%d]."
,
span
->
signal_type
);
snprintf
(
span
->
last_error
,
sizeof
(
span
->
last_error
),
"Span is already configured for signalling [%d]."
,
span
->
signal_type
);
return
ZAP_FAIL
;
return
ZAP_FAIL
;
...
@@ -598,16 +601,16 @@ zap_status_t zap_isdn_configure_span(zap_span_t *span, Q921NetUser_t mode, Q931D
...
@@ -598,16 +601,16 @@ zap_status_t zap_isdn_configure_span(zap_span_t *span, Q921NetUser_t mode, Q931D
}
}
span
->
isdn_data
=
malloc
(
sizeof
(
*
span
->
isdn_data
));
isdn_data
=
malloc
(
sizeof
(
*
isdn_data
));
assert
(
span
->
isdn_data
!=
NULL
);
assert
(
isdn_data
!=
NULL
);
memset
(
span
->
isdn_data
,
0
,
sizeof
(
*
span
->
isdn_data
));
memset
(
isdn_data
,
0
,
sizeof
(
*
isdn_data
));
span
->
isdn_data
->
sig_cb
=
sig_cb
;
isdn_data
->
sig_cb
=
sig_cb
;
span
->
isdn_data
->
dchans
[
0
]
=
dchans
[
0
];
isdn_data
->
dchans
[
0
]
=
dchans
[
0
];
span
->
isdn_data
->
dchans
[
1
]
=
dchans
[
1
];
isdn_data
->
dchans
[
1
]
=
dchans
[
1
];
span
->
isdn_data
->
dchan
=
span
->
isdn_data
->
dchans
[
0
];
isdn_data
->
dchan
=
isdn_data
->
dchans
[
0
];
Q921_InitTrunk
(
&
span
->
isdn_data
->
q921
,
Q921_InitTrunk
(
&
isdn_data
->
q921
,
0
,
0
,
0
,
0
,
mode
,
mode
,
...
@@ -615,20 +618,21 @@ zap_status_t zap_isdn_configure_span(zap_span_t *span, Q921NetUser_t mode, Q931D
...
@@ -615,20 +618,21 @@ zap_status_t zap_isdn_configure_span(zap_span_t *span, Q921NetUser_t mode, Q931D
zap_isdn_921_21
,
zap_isdn_921_21
,
(
Q921TxCB_t
)
zap_isdn_921_23
,
(
Q921TxCB_t
)
zap_isdn_921_23
,
span
,
span
,
&
span
->
isdn_data
->
q931
);
&
isdn_data
->
q931
);
Q931Api_InitTrunk
(
&
span
->
isdn_data
->
q931
,
Q931Api_InitTrunk
(
&
isdn_data
->
q931
,
dialect
,
dialect
,
mode
,
mode
,
span
->
trunk_type
,
span
->
trunk_type
,
zap_isdn_931_34
,
zap_isdn_931_34
,
(
Q931TxCB_t
)
q931_rx_32
,
(
Q931TxCB_t
)
q931_rx_32
,
zap_isdn_931_err
,
zap_isdn_931_err
,
&
span
->
isdn_data
->
q921
,
&
isdn_data
->
q921
,
span
);
span
);
span
->
isdn_data
->
q931
.
autoRestartAck
=
1
;
isdn_data
->
q931
.
autoRestartAck
=
1
;
span
->
isdn_data
->
q931
.
autoConnectAck
=
1
;
isdn_data
->
q931
.
autoConnectAck
=
1
;
span
->
signal_data
=
isdn_data
;
span
->
signal_type
=
ZAP_SIGTYPE_ISDN
;
span
->
signal_type
=
ZAP_SIGTYPE_ISDN
;
span
->
outgoing_call
=
isdn_outgoing_call
;
span
->
outgoing_call
=
isdn_outgoing_call
;
...
...
编写
预览
Markdown
格式
0%
重试
或
添加新文件
添加附件
取消
您添加了
0
人
到此讨论。请谨慎行事。
请先完成此评论的编辑!
取消
请
注册
或者
登录
后发表评论