From 8abd936ded9608b7b368299b26ab58f08804e864 Mon Sep 17 00:00:00 2001 From: Dragos Oancea Date: Mon, 18 May 2020 18:58:48 +0100 Subject: [PATCH] [unit-tests] [mod_sndfile] parallelize unit-tests, each audio extension test in its own session. --- .../formats/mod_sndfile/test/test_sndfile.c | 655 +++++++++++------- 1 file changed, 402 insertions(+), 253 deletions(-) diff --git a/src/mod/formats/mod_sndfile/test/test_sndfile.c b/src/mod/formats/mod_sndfile/test/test_sndfile.c index a9783ffa15..d2eb2b4f34 100644 --- a/src/mod/formats/mod_sndfile/test/test_sndfile.c +++ b/src/mod/formats/mod_sndfile/test/test_sndfile.c @@ -95,6 +95,313 @@ char *extensions[] = { "r32", "ul", "ulaw", "al", "alaw", "gsm", "vox", "oga", "ogg"}; +static switch_thread_t *thread_list[sizeof(extensions) / sizeof(extensions[0])]; + +static int duration = 3000; /*ms*/ +static int timeout_sec = 2; + +typedef struct { + char *ext; /*in*/ + switch_status_t status; /*out*/ + char *err_detail; /*out*/ + switch_status_t jstatus; +} test_params_t; + +#define thread_bail_out(x, msg) if (!x) {params->status = SWITCH_STATUS_FALSE; params->err_detail = strdup(msg); return NULL;} + +static void *SWITCH_THREAD_FUNC sndfile_write_read_mono_thread_run(switch_thread_t *thread, void *obj) +{ + /* play mono, record mono, open mono */ + test_params_t *params = (test_params_t *) obj; + switch_core_session_t *session = NULL; + switch_channel_t *channel = NULL; + switch_status_t status; + switch_call_cause_t cause; + static char play_filename[] = "../sounds/hi.wav"; + char path[4096]; + switch_file_handle_t fh = { 0 }; + int16_t *audiobuf; + switch_size_t len; + switch_size_t rd; + char *recording; + + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Started thread [%lu] Testing media file extension: [%s]\n", switch_thread_self(), params->ext); + + sprintf(path, "%s%s%s", SWITCH_GLOBAL_dirs.conf_dir, SWITCH_PATH_SEPARATOR, play_filename); + + status = switch_ivr_originate(NULL, &session, &cause, "null/+15553334444", timeout_sec, NULL, NULL, NULL, NULL, NULL, SOF_NONE, NULL, NULL); + thread_bail_out(session, "no session"); + + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_ivr_originate() status != SWITCH_STATUS_SUCCESS"); + + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Testing media file extension: [%s]\n", params->ext); + + recording = switch_mprintf("/tmp/%s.%s", switch_core_session_get_uuid(session), params->ext); + status = switch_ivr_record_session(session, recording, duration, NULL); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_ivr_record_session() status != SWITCH_STATUS_SUCCESS"); + + status = switch_ivr_play_file(session, NULL, path, NULL); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_ivr_play_file() status != SWITCH_STATUS_SUCCESS"); + + switch_sleep(1000 * duration); // wait for audio to finish playing + + switch_ivr_stop_record_session(session, "all"); + + status = switch_core_file_open(&fh, recording, 1, 8000, SWITCH_FILE_FLAG_READ | SWITCH_FILE_DATA_SHORT, NULL); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_core_file_open() status != SWITCH_STATUS_SUCCESS"); + + rd = 320; // samples + len = rd * sizeof(*audiobuf); + switch_zmalloc(audiobuf, len); + + status = switch_core_file_read(&fh, audiobuf, &rd); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_core_file_read() status != SWITCH_STATUS_SUCCESS"); + + thread_bail_out((rd == 320), " rd != 320 "); // check that we read the wanted number of samples + + status = switch_core_file_close(&fh); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_core_file_close() status != SWITCH_STATUS_SUCCESS"); + + switch_safe_free(audiobuf); + + unlink(recording); + + switch_safe_free(recording); + + switch_sleep(1000000); + + channel = switch_core_session_get_channel(session); + thread_bail_out(channel, "switch_core_session_get_channel() channel should not be NULL"); + + switch_channel_hangup(channel, SWITCH_CAUSE_NORMAL_CLEARING); + thread_bail_out(!switch_channel_ready(channel), "switch_channel_ready(channel) should not return TRUE") + + switch_core_session_rwunlock(session); + + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Finished thread [%lu]\n", switch_thread_self()); + + return NULL; +} + + +static void *SWITCH_THREAD_FUNC sndfile_write_read_m2s_thread_run(switch_thread_t *thread, void *obj) +{ + /* play mono file, record mono, open stereo */ + test_params_t *params = (test_params_t *) obj; + switch_core_session_t *session = NULL; + switch_channel_t *channel = NULL; + switch_status_t status; + switch_call_cause_t cause; + static char play_filename[] = "../sounds/hi.wav"; + char path[4096]; + switch_file_handle_t fh = { 0 }; + int16_t *audiobuf; + switch_size_t len, rd; + char *recording; + int channels = 2; + + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Started thread [%lu] Testing media file extension: [%s]\n", switch_thread_self(), params->ext); + + sprintf(path, "%s%s%s", SWITCH_GLOBAL_dirs.conf_dir, SWITCH_PATH_SEPARATOR, play_filename); + + status = switch_ivr_originate(NULL, &session, &cause, "null/+15553334444", timeout_sec, NULL, NULL, NULL, NULL, NULL, SOF_NONE, NULL, NULL); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_ivr_originate() status != SWITCH_STATUS_SUCCESS"); + + recording = switch_mprintf("/tmp/%s.%s", switch_core_session_get_uuid(session), params->ext); + + status = switch_ivr_record_session(session, recording, duration, NULL); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_ivr_record_session() status != SWITCH_STATUS_SUCCESS"); + + status = switch_ivr_play_file(session, NULL, path, NULL); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_ivr_play_file() status != SWITCH_STATUS_SUCCESS"); + + switch_sleep(1000 * duration); // wait for audio to finish playing + + switch_ivr_stop_record_session(session, "all"); + + channel = switch_core_session_get_channel(session); + thread_bail_out(channel, "switch_core_session_get_channel() channel should not be NULL"); + + switch_channel_hangup(channel, SWITCH_CAUSE_NORMAL_CLEARING); + thread_bail_out(!switch_channel_ready(channel), "switch_channel_ready(channel) should not return TRUE") + + switch_core_session_rwunlock(session); + + status = switch_core_file_open(&fh, recording, channels, 8000, SWITCH_FILE_FLAG_READ | SWITCH_FILE_DATA_SHORT, NULL); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_core_file_open() status != SWITCH_STATUS_SUCCESS"); + + rd = 320; // samples + len = rd * sizeof(*audiobuf) * channels; + switch_zmalloc(audiobuf, len); + + status = switch_core_file_read(&fh, audiobuf, &rd); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_core_file_read() status != SWITCH_STATUS_SUCCESS"); + + thread_bail_out((rd == 320), " rd != 320 "); // check that we read the wanted number of samples + + status = switch_core_file_close(&fh); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_core_file_close() status != SWITCH_STATUS_SUCCESS"); + + switch_safe_free(audiobuf); + + unlink(recording); + + switch_safe_free(recording); + + switch_sleep(1000000); + + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Finished thread [%lu]\n", switch_thread_self()); + + return NULL; +} + +static void *SWITCH_THREAD_FUNC sndfile_write_read_s2m_thread_run(switch_thread_t *thread, void *obj) +{ + /* play stereo wav, record stereo, open stereo file */ + test_params_t *params = (test_params_t *) obj; + switch_core_session_t *session = NULL; + switch_channel_t *channel = NULL; + switch_status_t status; + switch_call_cause_t cause; + static char play_filename[] = "../sounds/hello_stereo.wav"; + char path[4096]; + switch_file_handle_t fh = { 0 }; + int16_t *audiobuf; + switch_size_t len, rd; + char *recording, *rec_path; + int channels = 2; + + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Started thread [%lu] Testing media file extension: [%s]\n", switch_thread_self(), params->ext); + + sprintf(path, "%s%s%s", SWITCH_GLOBAL_dirs.conf_dir, SWITCH_PATH_SEPARATOR, play_filename); + + status = switch_ivr_originate(NULL, &session, &cause, "null/+15553334444", timeout_sec, NULL, NULL, NULL, NULL, NULL, SOF_NONE, NULL, NULL); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_ivr_originate() status != SWITCH_STATUS_SUCCESS"); + + rec_path = switch_mprintf("/tmp/%s.%s", switch_core_session_get_uuid(session), params->ext); + recording = switch_mprintf("{force_channels=2}%s", rec_path); + + channel = switch_core_session_get_channel(session); + thread_bail_out(channel, "switch_core_session_get_channel() channel should not be NULL"); + + switch_channel_set_variable(channel, "enable_file_write_buffering", "true"); + + status = switch_ivr_record_session(session, recording, duration, NULL); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_ivr_record_session() status != SWITCH_STATUS_SUCCESS"); + + status = switch_ivr_play_file(session, NULL, path, NULL); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_ivr_play_file() status != SWITCH_STATUS_SUCCESS"); + + switch_sleep(1000 * duration); // wait for audio to finish playing + + switch_ivr_stop_record_session(session, "all"); + + switch_channel_hangup(channel, SWITCH_CAUSE_NORMAL_CLEARING); + thread_bail_out(!switch_channel_ready(channel), "switch_channel_ready(channel) should not return TRUE") + + switch_core_session_rwunlock(session); + + status = switch_core_file_open(&fh, recording, channels, 8000, SWITCH_FILE_FLAG_READ | SWITCH_FILE_DATA_SHORT, NULL); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_core_file_open() status != SWITCH_STATUS_SUCCESS"); + + rd = 320; // samples + len = rd * sizeof(*audiobuf) * channels; + switch_zmalloc(audiobuf, len); + + status = switch_core_file_read(&fh, audiobuf, &rd); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_core_file_read() status != SWITCH_STATUS_SUCCESS"); + + thread_bail_out((rd == 320), " rd != 320 "); // check that we read the wanted number of samples + + status = switch_core_file_close(&fh); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_core_file_close() status != SWITCH_STATUS_SUCCESS"); + + switch_safe_free(audiobuf); + + unlink(rec_path); + + switch_safe_free(rec_path); + switch_safe_free(recording); + + switch_sleep(1000000); + + return NULL; +} + +static void *SWITCH_THREAD_FUNC sndfile_write_read_stereo_thread_run(switch_thread_t *thread, void *obj) +{ + /* play stereo wav, record stereo, open stereo file */ + test_params_t *params = (test_params_t *) obj; + switch_core_session_t *session = NULL; + switch_channel_t *channel = NULL; + switch_status_t status; + switch_call_cause_t cause; + static char play_filename[] = "../sounds/hello_stereo.wav"; + char path[4096]; + switch_file_handle_t fh = { 0 }; + int16_t *audiobuf; + switch_size_t len, rd; + char *recording, *rec_path; + int channels = 2; + + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Started thread [%lu] Testing media file extension: [%s]\n", switch_thread_self(), params->ext); + + sprintf(path, "%s%s%s", SWITCH_GLOBAL_dirs.conf_dir, SWITCH_PATH_SEPARATOR, play_filename); + + status = switch_ivr_originate(NULL, &session, &cause, "null/+15553334444", timeout_sec, NULL, NULL, NULL, NULL, NULL, SOF_NONE, NULL, NULL); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_ivr_play_file() status != SWITCH_STATUS_SUCCESS"); + + rec_path = switch_mprintf("/tmp/%s.%s", switch_core_session_get_uuid(session), params->ext); + recording = switch_mprintf("{force_channels=2}%s", rec_path); + + channel = switch_core_session_get_channel(session); + thread_bail_out(channel, "switch_core_session_get_channel() channel should not be NULL"); + + switch_channel_set_variable(channel, "RECORD_STEREO", "true"); + switch_channel_set_variable(channel, "enable_file_write_buffering", "true"); + + status = switch_ivr_record_session(session, recording, duration, NULL); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_ivr_record_session() status != SWITCH_STATUS_SUCCESS"); + + status = switch_ivr_play_file(session, NULL, path, NULL); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_ivr_play_file() status != SWITCH_STATUS_SUCCESS"); + + switch_sleep(1000 * duration); // wait for audio to finish playing + + switch_ivr_stop_record_session(session, "all"); + + switch_channel_hangup(channel, SWITCH_CAUSE_NORMAL_CLEARING); + thread_bail_out(!switch_channel_ready(channel), "switch_channel_ready(channel) should not return TRUE") + + switch_core_session_rwunlock(session); + + status = switch_core_file_open(&fh, recording, channels, 8000, SWITCH_FILE_FLAG_READ | SWITCH_FILE_DATA_SHORT, NULL); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_core_file_open() status != SWITCH_STATUS_SUCCESS"); + + rd = 320; // samples + len = rd * sizeof(*audiobuf) * channels; + switch_zmalloc(audiobuf, len); + + status = switch_core_file_read(&fh, audiobuf, &rd); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_core_file_read() status != SWITCH_STATUS_SUCCESS"); + + thread_bail_out((rd == 320), " rd != 320 "); // check that we read the wanted number of samples + + status = switch_core_file_close(&fh); + thread_bail_out(status == SWITCH_STATUS_SUCCESS, "switch_core_file_close() status != SWITCH_STATUS_SUCCESS"); + + switch_safe_free(audiobuf); + + unlink(rec_path); + + switch_safe_free(rec_path); + switch_safe_free(recording); + + switch_sleep(1000000); + + return NULL; +} + FST_CORE_BEGIN("test_formats_and_muxing") { FST_SUITE_BEGIN(test_sndfile) @@ -113,329 +420,171 @@ FST_CORE_BEGIN("test_formats_and_muxing") FST_TEST_BEGIN(sndfile_write_read_mono) { - /* play mono, record mono, open mono */ - switch_core_session_t *session = NULL; - switch_channel_t *channel = NULL; - switch_status_t status; - switch_call_cause_t cause; - static char play_filename[] = "../sounds/hi.wav"; - char path[4096]; - switch_file_handle_t fh = { 0 }; - int16_t *audiobuf; - switch_size_t len, rd; - char *recording; - int i, exlen, timeout_sec = 2, duration = 3000; /*ms*/ + int i, exlen; switch_stream_handle_t stream = { 0 }; - - sprintf(path, "%s%s%s", SWITCH_GLOBAL_dirs.conf_dir, SWITCH_PATH_SEPARATOR, play_filename); + test_params_t params[(sizeof(extensions) / sizeof(extensions[0]))] = { 0 }; SWITCH_STANDARD_STREAM(stream); - switch_api_execute("sndfile_debug", "on", session, &stream); + switch_api_execute("sndfile_debug", "on", NULL, &stream); switch_safe_free(stream.data); exlen = (sizeof(extensions) / sizeof(extensions[0])); - status = switch_ivr_originate(NULL, &session, &cause, "null/+15553334444", timeout_sec, NULL, NULL, NULL, NULL, NULL, SOF_NONE, NULL, NULL); - fst_requires(session); - fst_check(status == SWITCH_STATUS_SUCCESS); - for (i = 0; i < exlen; i++) { + switch_threadattr_t *thd_attr = NULL; - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Testing media file extension: [%s]\n", extensions[i]); - - recording = switch_mprintf("/tmp/%s.%s", switch_core_session_get_uuid(session), extensions[i]); - status = switch_ivr_record_session(session, recording, duration, NULL); - fst_check(status == SWITCH_STATUS_SUCCESS); - - status = switch_ivr_play_file(session, NULL, path, NULL); - fst_check(status == SWITCH_STATUS_SUCCESS); - - switch_sleep(1000 * duration); // wait for audio to finish playing - - switch_ivr_stop_record_session(session, "all"); - - status = switch_core_file_open(&fh, recording, 1, 8000, SWITCH_FILE_FLAG_READ | SWITCH_FILE_DATA_SHORT, NULL); - fst_requires(status == SWITCH_STATUS_SUCCESS); - - rd = 320; // samples - len = rd * sizeof(*audiobuf); - switch_zmalloc(audiobuf, len); - - status = switch_core_file_read(&fh, audiobuf, &rd); - fst_requires(status == SWITCH_STATUS_SUCCESS); - fst_check(rd = 320); // check that we read the wanted number of samples - - status = switch_core_file_close(&fh); - fst_requires(status == SWITCH_STATUS_SUCCESS); - - switch_safe_free(audiobuf); - - unlink(recording); - - switch_safe_free(recording); - - switch_sleep(1000000); + params[i].ext = extensions[i]; + switch_threadattr_create(&thd_attr, fst_pool); + switch_threadattr_stacksize_set(thd_attr, SWITCH_THREAD_STACKSIZE); + // slow down to avoid this: "[CRIT] switch_time.c:1243 Over Session Rate of 30!" + switch_thread_create(&thread_list[i], thd_attr, sndfile_write_read_mono_thread_run, (void *)¶ms[i], fst_pool); + switch_sleep(100000); } - channel = switch_core_session_get_channel(session); - fst_requires(channel); + for (i = 0; i < exlen; i++) { + switch_thread_join(¶ms[i].jstatus, thread_list[i]); + fst_requires(params[i].jstatus == SWITCH_STATUS_SUCCESS); + } - switch_channel_hangup(channel, SWITCH_CAUSE_NORMAL_CLEARING); - fst_check(!switch_channel_ready(channel)); + for (i = 0; i < exlen; i++) { + if (params[i].err_detail) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Extension [%s] Result: [%s]\n", extensions[i], params[i].err_detail); + switch_safe_free(params[i].err_detail); + } + fst_requires(params[i].status == SWITCH_STATUS_SUCCESS); + } + switch_sleep(1000000); - switch_core_session_rwunlock(session); } FST_TEST_END() FST_TEST_BEGIN(sndfile_write_read_m2s) { - /* play mono file, record mono, open stereo */ - switch_core_session_t *session = NULL; - switch_channel_t *channel = NULL; - switch_status_t status; - switch_call_cause_t cause; - static char play_filename[] = "../sounds/hi.wav"; - char path[4096]; - switch_file_handle_t fh = { 0 }; - int16_t *audiobuf; - switch_size_t len, rd; - char *recording; - int i, exlen, channels = 2, timeout_sec = 2, duration = 3000; /*ms*/ + int i, exlen; switch_stream_handle_t stream = { 0 }; - - sprintf(path, "%s%s%s", SWITCH_GLOBAL_dirs.conf_dir, SWITCH_PATH_SEPARATOR, play_filename); + test_params_t params[(sizeof(extensions) / sizeof(extensions[0]))] = { 0 }; SWITCH_STANDARD_STREAM(stream); - switch_api_execute("sndfile_debug", "on", session, &stream); + switch_api_execute("sndfile_debug", "on", NULL, &stream); switch_safe_free(stream.data); exlen = (sizeof(extensions) / sizeof(extensions[0])); for (i = 0; i < exlen; i++) { + switch_threadattr_t *thd_attr = NULL; - status = switch_ivr_originate(NULL, &session, &cause, "null/+15553334444", timeout_sec, NULL, NULL, NULL, NULL, NULL, SOF_NONE, NULL, NULL); - fst_requires(session); - fst_check(status == SWITCH_STATUS_SUCCESS); - - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Testing media file extension: [%s]\n", extensions[i]); - - recording = switch_mprintf("/tmp/%s.%s", switch_core_session_get_uuid(session), extensions[i]); - - status = switch_ivr_record_session(session, recording, duration, NULL); - fst_check(status == SWITCH_STATUS_SUCCESS); - - status = switch_ivr_play_file(session, NULL, path, NULL); - fst_check(status == SWITCH_STATUS_SUCCESS); - - switch_sleep(1000 * duration); // wait for audio to finish playing - - switch_ivr_stop_record_session(session, "all"); - - channel = switch_core_session_get_channel(session); - fst_requires(channel); - - switch_channel_hangup(channel, SWITCH_CAUSE_NORMAL_CLEARING); - fst_check(!switch_channel_ready(channel)); - - switch_core_session_rwunlock(session); - - status = switch_core_file_open(&fh, recording, channels, 8000, SWITCH_FILE_FLAG_READ | SWITCH_FILE_DATA_SHORT, NULL); - fst_requires(status == SWITCH_STATUS_SUCCESS); - - rd = 320; // samples - len = rd * sizeof(*audiobuf) * channels; - switch_zmalloc(audiobuf, len); - - status = switch_core_file_read(&fh, audiobuf, &rd); - fst_requires(status == SWITCH_STATUS_SUCCESS); - fst_check(rd = 320); // check that we read the wanted number of samples - - status = switch_core_file_close(&fh); - fst_requires(status == SWITCH_STATUS_SUCCESS); - - switch_safe_free(audiobuf); - - unlink(recording); - - switch_safe_free(recording); - - switch_sleep(1000000); + params[i].ext = extensions[i]; + switch_threadattr_create(&thd_attr, fst_pool); + switch_threadattr_stacksize_set(thd_attr, SWITCH_THREAD_STACKSIZE); + // slow down to avoid this: "[CRIT] switch_time.c:1243 Over Session Rate of 30!" + switch_thread_create(&thread_list[i], thd_attr, sndfile_write_read_m2s_thread_run, (void *)¶ms[i], fst_pool); + switch_sleep(100000); } + + for (i = 0; i < exlen; i++) { + switch_thread_join(¶ms[i].jstatus, thread_list[i]); + fst_requires(params[i].jstatus == SWITCH_STATUS_SUCCESS); + } + + for (i = 0; i < exlen; i++) { + if (params[i].err_detail) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Extension [%s] Result: [%s]\n", extensions[i], params[i].err_detail); + switch_safe_free(params[i].err_detail); + } + fst_requires(params[i].status == SWITCH_STATUS_SUCCESS); + } + switch_sleep(1000000); } FST_TEST_END() FST_TEST_BEGIN(sndfile_write_read_s2m) { - /* play stereo wav, record stereo, open stereo file */ - switch_core_session_t *session = NULL; - switch_channel_t *channel = NULL; - switch_status_t status; - switch_call_cause_t cause; - static char play_filename[] = "../sounds/hello_stereo.wav"; - char path[4096]; - switch_file_handle_t fh = { 0 }; - int16_t *audiobuf; - switch_size_t len, rd; - char *recording, *rec_path; - int i, exlen, channels = 2, timeout_sec = 2, duration = 3000; /*ms*/ + int i, exlen; switch_stream_handle_t stream = { 0 }; + test_params_t params[(sizeof(extensions) / sizeof(extensions[0]))] = { 0 }; - sprintf(path, "%s%s%s", SWITCH_GLOBAL_dirs.conf_dir, SWITCH_PATH_SEPARATOR, play_filename); - SWITCH_STANDARD_STREAM(stream); - switch_api_execute("sndfile_debug", "on", session, &stream); + switch_api_execute("sndfile_debug", "on", NULL, &stream); switch_safe_free(stream.data); exlen = (sizeof(extensions) / sizeof(extensions[0])); for (i = 0; i < exlen; i++) { + switch_threadattr_t *thd_attr = NULL; - status = switch_ivr_originate(NULL, &session, &cause, "null/+15553334444", timeout_sec, NULL, NULL, NULL, NULL, NULL, SOF_NONE, NULL, NULL); + params[i].ext = extensions[i]; + switch_threadattr_create(&thd_attr, fst_pool); + switch_threadattr_stacksize_set(thd_attr, SWITCH_THREAD_STACKSIZE); + // slow down to avoid this: "[CRIT] switch_time.c:1243 Over Session Rate of 30!" + switch_thread_create(&thread_list[i], thd_attr, sndfile_write_read_s2m_thread_run, (void *)¶ms[i], fst_pool); + switch_sleep(10000); - fst_requires(session); - fst_check(status == SWITCH_STATUS_SUCCESS); - - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Testing media file extension: [%s]\n", extensions[i]); - - rec_path = switch_mprintf("/tmp/%s.%s", switch_core_session_get_uuid(session), extensions[i]); - recording = switch_mprintf("{force_channels=2}%s", rec_path); - - channel = switch_core_session_get_channel(session); - fst_requires(channel); - - switch_channel_set_variable(channel, "enable_file_write_buffering", "true"); - - status = switch_ivr_record_session(session, recording, duration, NULL); - fst_check(status == SWITCH_STATUS_SUCCESS); - - status = switch_ivr_play_file(session, NULL, path, NULL); - fst_check(status == SWITCH_STATUS_SUCCESS); - - switch_sleep(1000 * duration); // wait for audio to finish playing - - switch_ivr_stop_record_session(session, "all"); - - switch_channel_hangup(channel, SWITCH_CAUSE_NORMAL_CLEARING); - fst_check(!switch_channel_ready(channel)); - - switch_core_session_rwunlock(session); - - status = switch_core_file_open(&fh, recording, channels, 8000, SWITCH_FILE_FLAG_READ | SWITCH_FILE_DATA_SHORT, NULL); - fst_requires(status == SWITCH_STATUS_SUCCESS); - - rd = 320; // samples - len = rd * sizeof(*audiobuf) * channels; - switch_zmalloc(audiobuf, len); - - status = switch_core_file_read(&fh, audiobuf, &rd); - fst_requires(status == SWITCH_STATUS_SUCCESS); - fst_check(rd = 320); // check that we read the wanted number of samples - - status = switch_core_file_close(&fh); - fst_requires(status == SWITCH_STATUS_SUCCESS); - - switch_safe_free(audiobuf); - - unlink(rec_path); - - switch_safe_free(rec_path); - switch_safe_free(recording); - - switch_sleep(1000000); } + + for (i = 0; i < exlen; i++) { + switch_thread_join(¶ms[i].jstatus, thread_list[i]); + fst_requires(params[i].jstatus == SWITCH_STATUS_SUCCESS); + } + + for (i = 0; i < exlen; i++) { + if (params[i].err_detail) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Extension [%s] Result: [%s]\n", extensions[i], params[i].err_detail); + switch_safe_free(params[i].err_detail); + } + fst_requires(params[i].status == SWITCH_STATUS_SUCCESS); + } + switch_sleep(1000000); } FST_TEST_END() FST_TEST_BEGIN(sndfile_write_read_stereo) { - /* play stereo wav, record stereo, open stereo file */ - switch_core_session_t *session = NULL; - switch_channel_t *channel = NULL; - switch_status_t status; - switch_call_cause_t cause; - static char play_filename[] = "../sounds/hello_stereo.wav"; - char path[4096]; - switch_file_handle_t fh = { 0 }; - int16_t *audiobuf; - switch_size_t len, rd; - char *recording, *rec_path; - int i, exlen, channels = 2, timeout_sec = 2, duration = 3000; /*ms*/ + int i, exlen; switch_stream_handle_t stream = { 0 }; - - sprintf(path, "%s%s%s", SWITCH_GLOBAL_dirs.conf_dir, SWITCH_PATH_SEPARATOR, play_filename); + test_params_t params[(sizeof(extensions) / sizeof(extensions[0]))] = { 0 }; SWITCH_STANDARD_STREAM(stream); - switch_api_execute("sndfile_debug", "on", session, &stream); + switch_api_execute("sndfile_debug", "on", NULL, &stream); switch_safe_free(stream.data); exlen = (sizeof(extensions) / sizeof(extensions[0])); for (i = 0; i < exlen; i++) { + switch_threadattr_t *thd_attr = NULL; - status = switch_ivr_originate(NULL, &session, &cause, "null/+15553334444", timeout_sec, NULL, NULL, NULL, NULL, NULL, SOF_NONE, NULL, NULL); - fst_requires(session); - fst_check(status == SWITCH_STATUS_SUCCESS); - - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "Testing media file extension: [%s]\n", extensions[i]); - - rec_path = switch_mprintf("/tmp/%s.%s", switch_core_session_get_uuid(session), extensions[i]); - recording = switch_mprintf("{force_channels=2}%s", rec_path); - - channel = switch_core_session_get_channel(session); - fst_requires(channel); - - switch_channel_set_variable(channel, "RECORD_STEREO", "true"); - switch_channel_set_variable(channel, "enable_file_write_buffering", "true"); - - status = switch_ivr_record_session(session, recording, duration, NULL); - fst_check(status == SWITCH_STATUS_SUCCESS); - - status = switch_ivr_play_file(session, NULL, path, NULL); - fst_check(status == SWITCH_STATUS_SUCCESS); - - switch_sleep(1000 * duration); // wait for audio to finish playing - - switch_ivr_stop_record_session(session, "all"); - - switch_channel_hangup(channel, SWITCH_CAUSE_NORMAL_CLEARING); - fst_check(!switch_channel_ready(channel)); - - switch_core_session_rwunlock(session); - - status = switch_core_file_open(&fh, recording, channels, 8000, SWITCH_FILE_FLAG_READ | SWITCH_FILE_DATA_SHORT, NULL); - fst_requires(status == SWITCH_STATUS_SUCCESS); - - rd = 320; // samples - len = rd * sizeof(*audiobuf) * channels; - switch_zmalloc(audiobuf, len); - - status = switch_core_file_read(&fh, audiobuf, &rd); - fst_requires(status == SWITCH_STATUS_SUCCESS); - fst_check(rd = 320); // check that we read the wanted number of samples - - status = switch_core_file_close(&fh); - fst_requires(status == SWITCH_STATUS_SUCCESS); - - switch_safe_free(audiobuf); - - unlink(rec_path); - - switch_safe_free(rec_path); - switch_safe_free(recording); - - switch_sleep(1000000); + params[i].ext = extensions[i]; + switch_threadattr_create(&thd_attr, fst_pool); + switch_threadattr_stacksize_set(thd_attr, SWITCH_THREAD_STACKSIZE); + // slow down to avoid this: "[CRIT] switch_time.c:1243 Over Session Rate of 30!" + switch_thread_create(&thread_list[i], thd_attr, sndfile_write_read_stereo_thread_run, (void *)¶ms[i], fst_pool); + switch_sleep(100000); } + + for (i = 0; i < exlen; i++) { + switch_thread_join(¶ms[i].jstatus, thread_list[i]); + fst_requires(params[i].jstatus == SWITCH_STATUS_SUCCESS); + } + + for (i = 0; i < exlen; i++) { + if (params[i].err_detail) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Extension [%s] Result: [%s]\n", extensions[i], params[i].err_detail); + switch_safe_free(params[i].err_detail); + } + fst_requires(params[i].status == SWITCH_STATUS_SUCCESS); + } + switch_sleep(1000000); } + FST_TEST_END() FST_TEST_BEGIN(unload_mod_sndfile)