[Unit-tests] Improve test stability

This commit is contained in:
Andrey Volk 2022-08-24 17:19:20 +03:00
parent 56fc995325
commit 0eb356b444
7 changed files with 57 additions and 47 deletions

View File

@ -146,7 +146,7 @@ FST_TEST_BEGIN(tts_time)
} while (status == SWITCH_STATUS_SUCCESS); } while (status == SWITCH_STATUS_SUCCESS);
fst_check(read = sample_rate / interval * 3); // samples of 3 second fst_check(read = sample_rate / interval * 3); // samples of 3 second
fst_check_duration(3000, 750); fst_check_duration(3000, 1000);
switch_core_speech_close(&sh, &flags); switch_core_speech_close(&sh, &flags);
} }
FST_TEST_END() FST_TEST_END()

View File

@ -596,7 +596,7 @@
<condition> <condition>
<action application="info"/> <action application="info"/>
<action application="answer" /> <action application="answer" />
<action application="voicemail" data="default $${domain} 1001"/> <!--action application="voicemail" data="default $${domain} 1001"/-->
</condition> </condition>
</extension> </extension>

View File

@ -128,7 +128,7 @@ static void unregister_gw()
static int start_sipp_uac(const char *ip, int remote_port, const char *dialed_number, const char *scenario_uac, const char *extra) static int start_sipp_uac(const char *ip, int remote_port, const char *dialed_number, const char *scenario_uac, const char *extra)
{ {
char *cmd = switch_mprintf("sipp %s:%d -nr -p 5062 -m 1 -s %s -recv_timeout 10000 -timeout 10s -sf %s -bg %s", ip, remote_port, dialed_number, scenario_uac, extra); char *cmd = switch_mprintf("sipp %s:%d -nr -p 5062 -m 1 -s %s -recv_timeout 30000 -timeout 30s -sf %s -bg %s", ip, remote_port, dialed_number, scenario_uac, extra);
int sys_ret = switch_system(cmd, SWITCH_TRUE); int sys_ret = switch_system(cmd, SWITCH_TRUE);
printf("%s\n", cmd); printf("%s\n", cmd);
@ -140,7 +140,7 @@ static int start_sipp_uac(const char *ip, int remote_port, const char *dialed_nu
static int start_sipp_uas(const char *ip, int listen_port, const char *scenario_uas, const char *extra) static int start_sipp_uas(const char *ip, int listen_port, const char *scenario_uas, const char *extra)
{ {
char *cmd = switch_mprintf("sipp %s -p %d -nr -m 1 -s 1001 -recv_timeout 10000 -timeout 10s -sf %s -bg %s", ip, listen_port, scenario_uas, extra); char *cmd = switch_mprintf("sipp %s -p %d -nr -m 1 -s 1001 -recv_timeout 30000 -timeout 30s -sf %s -bg %s", ip, listen_port, scenario_uas, extra);
int sys_ret = switch_system(cmd, SWITCH_TRUE); int sys_ret = switch_system(cmd, SWITCH_TRUE);
printf("%s\n", cmd); printf("%s\n", cmd);
@ -151,7 +151,7 @@ static int start_sipp_uas(const char *ip, int listen_port, const char *scenario_
} }
static int run_sipp(const char *ip, int remote_port, int listen_port, const char *dialed_number, const char *scenario_uac, const char *auth_password, const char *extra) static int run_sipp(const char *ip, int remote_port, int listen_port, const char *dialed_number, const char *scenario_uac, const char *auth_password, const char *extra)
{ {
char *cmd = switch_mprintf("sipp %s:%d -nr -p %d -m 1 -s %s -recv_timeout 10000 -timeout 10s -sf %s -au %s -ap %s -bg %s", ip, remote_port, listen_port, dialed_number, scenario_uac, dialed_number, auth_password, extra); char *cmd = switch_mprintf("sipp %s:%d -nr -p %d -m 1 -s %s -recv_timeout 30000 -timeout 30s -sf %s -au %s -ap %s -bg %s", ip, remote_port, listen_port, dialed_number, scenario_uac, dialed_number, auth_password, extra);
int sys_ret = switch_system(cmd, SWITCH_TRUE); int sys_ret = switch_system(cmd, SWITCH_TRUE);
printf("%s\n", cmd); printf("%s\n", cmd);
@ -216,6 +216,8 @@ static void event_handler_reg_fail(switch_event_t *event)
show_event(event); show_event(event);
} }
switch_interval_time_t delay_start_ms = 5000;
FST_CORE_EX_BEGIN("./conf-sipp", SCF_VG | SCF_USE_SQL) FST_CORE_EX_BEGIN("./conf-sipp", SCF_VG | SCF_USE_SQL)
{ {
FST_MODULE_BEGIN(mod_sofia, uac-uas) FST_MODULE_BEGIN(mod_sofia, uac-uas)
@ -224,6 +226,13 @@ FST_CORE_EX_BEGIN("./conf-sipp", SCF_VG | SCF_USE_SQL)
{ {
switch_stream_handle_t stream = { 0 }; switch_stream_handle_t stream = { 0 };
SWITCH_STANDARD_STREAM(stream); SWITCH_STANDARD_STREAM(stream);
/* Give mod_sofia time to spinup profile threads */
if (delay_start_ms) {
switch_sleep(delay_start_ms * 1000);
delay_start_ms = 0;
}
switch_api_execute("sofia", "global siptrace on", NULL, &stream); switch_api_execute("sofia", "global siptrace on", NULL, &stream);
if (test_sofia_debug) { if (test_sofia_debug) {
switch_api_execute("sofia", "loglevel all 9", NULL, &stream); switch_api_execute("sofia", "loglevel all 9", NULL, &stream);
@ -366,10 +375,10 @@ FST_CORE_EX_BEGIN("./conf-sipp", SCF_VG | SCF_USE_SQL)
FST_TEST_BEGIN(uac_digest_leak_udp) FST_TEST_BEGIN(uac_digest_leak_udp)
{ {
switch_core_session_t *session; switch_core_session_t *session = NULL;
switch_call_cause_t cause; switch_call_cause_t cause;
switch_status_t status; switch_status_t status;
switch_channel_t *channel; switch_channel_t *channel = NULL;
const char *local_ip_v4 = switch_core_get_variable("local_ip_v4"); const char *local_ip_v4 = switch_core_get_variable("local_ip_v4");
int sipp_ret; int sipp_ret;
@ -397,30 +406,25 @@ FST_CORE_EX_BEGIN("./conf-sipp", SCF_VG | SCF_USE_SQL)
} }
} }
switch_sleep(5000 * 1000);
switch_channel_hangup(channel, SWITCH_CAUSE_NORMAL_CLEARING);
switch_core_session_rwunlock(session);
switch_sleep(1000 * 1000);
switch_event_unbind_callback(event_handler);
/* sipp should timeout, attempt kill, just in case.*/ /* sipp should timeout, attempt kill, just in case.*/
kill_sipp(); kill_sipp();
fst_check(test_success); fst_check(test_success);
} }
} }
if (channel) switch_channel_hangup(channel, SWITCH_CAUSE_NORMAL_CLEARING);
if (session) switch_core_session_rwunlock(session);
switch_event_unbind_callback(event_handler);
test_success = 0; test_success = 0;
} }
FST_TEST_END() FST_TEST_END()
FST_TEST_BEGIN(uac_digest_leak_tcp) FST_TEST_BEGIN(uac_digest_leak_tcp)
{ {
switch_core_session_t *session; switch_core_session_t *session = NULL;
switch_call_cause_t cause; switch_call_cause_t cause;
switch_status_t status; switch_status_t status;
switch_channel_t *channel; switch_channel_t *channel = NULL;
const char *local_ip_v4 = switch_core_get_variable("local_ip_v4"); const char *local_ip_v4 = switch_core_get_variable("local_ip_v4");
int sipp_ret; int sipp_ret;
@ -448,29 +452,24 @@ FST_CORE_EX_BEGIN("./conf-sipp", SCF_VG | SCF_USE_SQL)
} }
} }
switch_sleep(5000 * 1000);
switch_channel_hangup(channel, SWITCH_CAUSE_NORMAL_CLEARING);
switch_core_session_rwunlock(session);
switch_sleep(1000 * 1000);
switch_event_unbind_callback(event_handler);
/* sipp should timeout, attempt kill, just in case.*/ /* sipp should timeout, attempt kill, just in case.*/
kill_sipp(); kill_sipp();
fst_check(test_success); fst_check(test_success);
} }
if (channel) switch_channel_hangup(channel, SWITCH_CAUSE_NORMAL_CLEARING);
if (session) switch_core_session_rwunlock(session);
switch_event_unbind_callback(event_handler);
test_success = 0; test_success = 0;
} }
FST_TEST_END() FST_TEST_END()
FST_TEST_BEGIN(uac_digest_leak_udp_ipv6) FST_TEST_BEGIN(uac_digest_leak_udp_ipv6)
{ {
switch_core_session_t *session; switch_core_session_t *session = NULL;
switch_call_cause_t cause; switch_call_cause_t cause;
switch_status_t status; switch_status_t status;
switch_channel_t *channel; switch_channel_t *channel = NULL;
const char *local_ip_v6 = switch_core_get_variable("local_ip_v6"); const char *local_ip_v6 = switch_core_get_variable("local_ip_v6");
int sipp_ret; int sipp_ret;
char *ipv6 = NULL; char *ipv6 = NULL;
@ -511,20 +510,15 @@ FST_CORE_EX_BEGIN("./conf-sipp", SCF_VG | SCF_USE_SQL)
} }
} }
switch_sleep(5000 * 1000);
switch_channel_hangup(channel, SWITCH_CAUSE_NORMAL_CLEARING);
switch_core_session_rwunlock(session);
switch_sleep(1000 * 1000);
switch_event_unbind_callback(event_handler);
/* sipp should timeout, attempt kill, just in case.*/ /* sipp should timeout, attempt kill, just in case.*/
kill_sipp(); kill_sipp();
switch_safe_free(ipv6); switch_safe_free(ipv6);
fst_check(test_success); fst_check(test_success);
} }
skiptest: skiptest:
if (channel) switch_channel_hangup(channel, SWITCH_CAUSE_NORMAL_CLEARING);
if (session) switch_core_session_rwunlock(session);
switch_event_unbind_callback(event_handler);
test_success = 0; test_success = 0;
} }
FST_TEST_END() FST_TEST_END()
@ -546,12 +540,12 @@ skiptest:
switch_sleep(5000 * 1000); switch_sleep(5000 * 1000);
switch_event_unbind_callback(event_handler_reg_ok);
/* sipp should timeout, attempt kill, just in case.*/ /* sipp should timeout, attempt kill, just in case.*/
kill_sipp(); kill_sipp();
fst_check(test_success); fst_check(test_success);
} }
switch_event_unbind_callback(event_handler_reg_ok);
test_success = 0; test_success = 0;
} }
FST_TEST_END() FST_TEST_END()
@ -571,14 +565,13 @@ skiptest:
register_gw(); register_gw();
switch_sleep(5000 * 1000); switch_sleep(10000 * 1000);
switch_event_unbind_callback(event_handler_reg_fail);
/* sipp should timeout, attempt kill, just in case.*/ /* sipp should timeout, attempt kill, just in case.*/
kill_sipp(); kill_sipp();
fst_check(test_success); fst_check(test_success);
} }
switch_event_unbind_callback(event_handler_reg_fail);
test_success = 0; test_success = 0;
} }
FST_TEST_END() FST_TEST_END()
@ -651,13 +644,12 @@ skiptest:
switch_sleep(1000 * 1000); switch_sleep(1000 * 1000);
switch_event_unbind_callback(event_handler_reg_ok);
/* sipp should timeout, attempt kill, just in case.*/ /* sipp should timeout, attempt kill, just in case.*/
kill_sipp(); kill_sipp();
fst_check(test_success); fst_check(test_success);
} }
switch_event_unbind_callback(event_handler_reg_ok);
test_success = 0; test_success = 0;
} }
FST_TEST_END() FST_TEST_END()

View File

@ -77,7 +77,7 @@
<!-- Test with SIP hardware phone: must use WWW-Authenticate instead of Proxy-Authenticate. <!-- Test with SIP hardware phone: must use WWW-Authenticate instead of Proxy-Authenticate.
You could also try with SIP/2.0 401 Unauthorized. --> You could also try with SIP/2.0 401 Unauthorized. -->
<send> <send retrans="500">
<![CDATA[ <![CDATA[
SIP/2.0 407 Proxy Authentication Required SIP/2.0 407 Proxy Authentication Required

View File

@ -1,12 +1,21 @@
#include <switch.h> #include <switch.h>
#include <test/switch_test.h> #include <test/switch_test.h>
int timeout_sec = 10;
switch_interval_time_t delay_start_ms = 5000;
FST_CORE_DB_BEGIN("./conf_test") FST_CORE_DB_BEGIN("./conf_test")
{ {
FST_SUITE_BEGIN(switch_hold) FST_SUITE_BEGIN(switch_hold)
{ {
FST_SETUP_BEGIN() FST_SETUP_BEGIN()
{ {
/* Give mod_sofia time to spinup profile threads */
if (delay_start_ms) {
switch_sleep(delay_start_ms * 1000);
delay_start_ms = 0;
}
fst_requires_module("mod_sofia"); fst_requires_module("mod_sofia");
fst_requires_module("mod_commands"); fst_requires_module("mod_commands");
} }
@ -23,7 +32,7 @@ FST_SUITE_BEGIN(switch_hold)
switch_status_t status; switch_status_t status;
switch_call_cause_t cause; switch_call_cause_t cause;
status = switch_ivr_originate(NULL, &session, &cause, "{ignore_early_media=true}sofia/gateway/test_gateway/+15553332900", 2, NULL, NULL, NULL, NULL, NULL, SOF_NONE, NULL, NULL); status = switch_ivr_originate(NULL, &session, &cause, "{ignore_early_media=true}sofia/gateway/test_gateway/+15553332900", timeout_sec, NULL, NULL, NULL, NULL, NULL, SOF_NONE, NULL, NULL);
fst_requires(session); fst_requires(session);
fst_check(status == SWITCH_STATUS_SUCCESS); fst_check(status == SWITCH_STATUS_SUCCESS);

View File

@ -482,7 +482,7 @@ FST_CORE_BEGIN("./conf")
switch_dial_handle_destroy(&dh); switch_dial_handle_destroy(&dh);
fst_check_duration(3000, 500); fst_check_duration(3000, 600);
} }
FST_TEST_END() FST_TEST_END()
@ -513,7 +513,7 @@ FST_CORE_BEGIN("./conf")
switch_dial_handle_destroy(&dh); switch_dial_handle_destroy(&dh);
fst_check_duration(3000, 500); fst_check_duration(3000, 600);
} }
FST_TEST_END() FST_TEST_END()

View File

@ -1,12 +1,21 @@
#include <switch.h> #include <switch.h>
#include <test/switch_test.h> #include <test/switch_test.h>
int timeout_sec = 10;
switch_interval_time_t delay_start_ms = 5000;
FST_CORE_DB_BEGIN("./conf_sip") FST_CORE_DB_BEGIN("./conf_sip")
{ {
FST_SUITE_BEGIN(switch_sip) FST_SUITE_BEGIN(switch_sip)
{ {
FST_SETUP_BEGIN() FST_SETUP_BEGIN()
{ {
/* Give mod_sofia time to spinup profile threads */
if (delay_start_ms) {
switch_sleep(delay_start_ms * 1000);
delay_start_ms = 0;
}
fst_requires_module("mod_sofia"); fst_requires_module("mod_sofia");
fst_requires_module("mod_hash"); fst_requires_module("mod_hash");
} }
@ -24,7 +33,7 @@ FST_SUITE_BEGIN(switch_sip)
const char *data = "eyJhbGciOiJFUzI1NiIsInBwdCI6InNoYWtlbiI;info=<https://cert.sticr.att.net:8443/certs/att/a937bb15-38b9-45f1-aac0-8cd3f8fe0648>"; const char *data = "eyJhbGciOiJFUzI1NiIsInBwdCI6InNoYWtlbiI;info=<https://cert.sticr.att.net:8443/certs/att/a937bb15-38b9-45f1-aac0-8cd3f8fe0648>";
char *originate_str = switch_mprintf("{sip_h_Identity=%s}sofia/gateway/test_gateway/+15553332901", data); char *originate_str = switch_mprintf("{sip_h_Identity=%s}sofia/gateway/test_gateway/+15553332901", data);
switch_ivr_originate(NULL, &session, &cause, originate_str, 2, NULL, NULL, NULL, NULL, NULL, SOF_NONE, NULL, NULL); switch_ivr_originate(NULL, &session, &cause, originate_str, timeout_sec, NULL, NULL, NULL, NULL, NULL, SOF_NONE, NULL, NULL);
switch_safe_free(originate_str); switch_safe_free(originate_str);
fst_requires(session); fst_requires(session);
@ -60,7 +69,7 @@ FST_SUITE_BEGIN(switch_sip)
const char *data = "eyJhbGciOiJFUzI1NiIsInBwdCI6InNoYWtlbiI;info=<https://cert.sticr.att.net:8443/certs/att/a937bb15-38b9-45f1-aac0-8cd3f8fe0648>;alg=ES256;ppt=shaken"; const char *data = "eyJhbGciOiJFUzI1NiIsInBwdCI6InNoYWtlbiI;info=<https://cert.sticr.att.net:8443/certs/att/a937bb15-38b9-45f1-aac0-8cd3f8fe0648>;alg=ES256;ppt=shaken";
char *originate_str = switch_mprintf("{sip_h_Identity=%s}sofia/gateway/test_gateway/+15553332901", data); char *originate_str = switch_mprintf("{sip_h_Identity=%s}sofia/gateway/test_gateway/+15553332901", data);
switch_ivr_originate(NULL, &session, &cause, originate_str, 2, NULL, NULL, NULL, NULL, NULL, SOF_NONE, NULL, NULL); switch_ivr_originate(NULL, &session, &cause, originate_str, timeout_sec, NULL, NULL, NULL, NULL, NULL, SOF_NONE, NULL, NULL);
switch_safe_free(originate_str); switch_safe_free(originate_str);
fst_requires(session); fst_requires(session);