kenmirrors/asterisk
1
0
Fork 0
mirror of https://github.com/asterisk/asterisk.git synced 2025-09-03 11:25:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

stream: Add unit tests for channel stream usage.

Browse Source 
This change adds unit tests cover the following:

1. That retrieving the first media stream of a specific media
type from a stream topology retrieves the expected media
stream.

2. That setting the native formats of a channel which does
not support streams results in the creation of streams on
its behalf according to the formats of the channel.

3. That setting a stream topology on a channel which supports
streams sets the topology to the provided one.

ASTERISK-26790

Change-Id: Ic53176dd3e4532e8c3e97d9e22f8a4b66a2bb755
This commit is contained in:
Joshua Colp
2017-02-14 18:33:57 +00:00
parent bf2f091bbb
commit a9c15a0e4c
1 changed files with 248 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

248
tests/test_stream.c
View File

@@ -37,6 +37,7 @@
#include "asterisk/format.h"
#include "asterisk/format_cap.h"
#include "asterisk/format_cache.h"
#include "asterisk/channel.h"
AST_TEST_DEFINE(stream_create)
{
@@ -611,6 +612,247 @@ AST_TEST_DEFINE(stream_topology_create_from_format_cap)
return AST_TEST_PASS;
}
AST_TEST_DEFINE(stream_topology_get_first_stream_by_type)
{
RAII_VAR(struct ast_stream_topology *, topology, NULL, ast_stream_topology_destroy);
struct ast_stream *first_stream, *second_stream, *third_stream, *fourth_stream;
switch (cmd) {
case TEST_INIT:
info->name = "stream_topology_get_first_stream_by_type";
info->category = "/main/stream/";
info->summary = "stream topology getting first stream by type unit test";
info->description =
"Test that getting the first stream by type from a topology actually returns the first stream";
return AST_TEST_NOT_RUN;
case TEST_EXECUTE:
break;
}
topology = ast_stream_topology_create();
if (!topology) {
ast_test_status_update(test, "Failed to create media stream topology\n");
return AST_TEST_FAIL;
}
first_stream = ast_stream_create("audio", AST_MEDIA_TYPE_AUDIO);
if (!first_stream) {
ast_test_status_update(test, "Failed to create an audio stream for testing stream topology\n");
return AST_TEST_FAIL;
}
if (ast_stream_topology_append_stream(topology, first_stream) == -1) {
ast_test_status_update(test, "Failed to append a perfectly good stream to a topology\n");
ast_stream_destroy(first_stream);
return AST_TEST_FAIL;
}
second_stream = ast_stream_create("audio2", AST_MEDIA_TYPE_AUDIO);
if (!second_stream) {
ast_test_status_update(test, "Failed to create a second audio stream for testing stream topology\n");
return AST_TEST_FAIL;
}
if (ast_stream_topology_append_stream(topology, second_stream) == -1) {
ast_test_status_update(test, "Failed to append a perfectly good stream to a topology\n");
ast_stream_destroy(second_stream);
return AST_TEST_FAIL;
}
third_stream = ast_stream_create("video", AST_MEDIA_TYPE_VIDEO);
if (!third_stream) {
ast_test_status_update(test, "Failed to create a video stream for testing stream topology\n");
return AST_TEST_FAIL;
}
if (ast_stream_topology_append_stream(topology, third_stream) == -1) {
ast_test_status_update(test, "Failed to append a perfectly good stream to a topology\n");
ast_stream_destroy(third_stream);
return AST_TEST_FAIL;
}
fourth_stream = ast_stream_create("video2", AST_MEDIA_TYPE_VIDEO);
if (!fourth_stream) {
ast_test_status_update(test, "Failed to create a second video stream for testing stream topology\n");
return AST_TEST_FAIL;
}
if (ast_stream_topology_append_stream(topology, fourth_stream) == -1) {
ast_test_status_update(test, "Failed to append a perfectly good stream to a topology\n");
ast_stream_destroy(fourth_stream);
return AST_TEST_FAIL;
}
if (ast_stream_topology_get_first_stream_by_type(topology, AST_MEDIA_TYPE_AUDIO) != first_stream) {
ast_test_status_update(test, "Retrieved first audio stream from topology but it is not the correct one\n");
return AST_TEST_FAIL;
}
if (ast_stream_topology_get_first_stream_by_type(topology, AST_MEDIA_TYPE_VIDEO) != third_stream) {
ast_test_status_update(test, "Retrieved first video stream from topology but it is not the correct one\n");
return AST_TEST_FAIL;
}
return AST_TEST_PASS;
}
static const struct ast_channel_tech mock_channel_tech = {
};
AST_TEST_DEFINE(stream_topology_create_from_channel_nativeformats)
{
RAII_VAR(struct ast_stream_topology *, topology, NULL, ast_stream_topology_destroy);
RAII_VAR(struct ast_format_cap *, caps, NULL, ao2_cleanup);
struct ast_channel *mock_channel;
enum ast_test_result_state res = AST_TEST_FAIL;
struct ast_str *codec_have_buf = ast_str_alloca(AST_FORMAT_CAP_NAMES_LEN);
struct ast_str *codec_wanted_buf = ast_str_alloca(AST_FORMAT_CAP_NAMES_LEN);
switch (cmd) {
case TEST_INIT:
info->name = "stream_topology_create_from_channel_nativeformats";
info->category = "/main/stream/";
info->summary = "stream topology creation from channel native formats unit test";
info->description =
"Test that creating a stream topology from the setting of channel nativeformats results in the expected streams";
return AST_TEST_NOT_RUN;
case TEST_EXECUTE:
break;
}
caps = ast_format_cap_alloc(AST_FORMAT_CAP_FLAG_DEFAULT);
if (!caps) {
ast_test_status_update(test, "Could not allocate an empty format capabilities structure\n");
return AST_TEST_FAIL;
}
if (ast_format_cap_append(caps, ast_format_ulaw, 0)) {
ast_test_status_update(test, "Failed to append a ulaw format to capabilities for channel nativeformats\n");
return AST_TEST_FAIL;
}
if (ast_format_cap_append(caps, ast_format_alaw, 0)) {
ast_test_status_update(test, "Failed to append an alaw format to capabilities for channel nativeformats\n");
return AST_TEST_FAIL;
}
if (ast_format_cap_append(caps, ast_format_h264, 0)) {
ast_test_status_update(test, "Failed to append an h264 format to capabilities for channel nativeformats\n");
return AST_TEST_FAIL;
}
mock_channel = ast_channel_alloc(0, AST_STATE_DOWN, NULL, NULL, NULL, NULL, NULL, NULL, NULL, 0, "TestChannel");
if (!mock_channel) {
ast_test_status_update(test, "Failed to create a mock channel for testing\n");
return AST_TEST_FAIL;
}
ast_channel_tech_set(mock_channel, &mock_channel_tech);
ast_channel_nativeformats_set(mock_channel, caps);
if (!ast_channel_get_stream_topology(mock_channel)) {
ast_test_status_update(test, "Set nativeformats with ulaw, alaw, and h264 on channel but it did not create a topology\n");
goto end;
}
if (ast_stream_topology_get_count(ast_channel_get_stream_topology(mock_channel)) != 2) {
ast_test_status_update(test, "Set nativeformats on a channel to ulaw, alaw, and h264 and received '%d' streams instead of expected 2\n",
ast_stream_topology_get_count(ast_channel_get_stream_topology(mock_channel)));
goto end;
}
if (ast_stream_get_type(ast_stream_topology_get_stream(ast_channel_get_stream_topology(mock_channel), 0)) != AST_MEDIA_TYPE_AUDIO) {
ast_test_status_update(test, "First stream on channel is of %s when it should be audio\n",
ast_codec_media_type2str(ast_stream_get_type(ast_stream_topology_get_stream(ast_channel_get_stream_topology(mock_channel), 0))));
goto end;
}
ast_format_cap_remove_by_type(caps, AST_MEDIA_TYPE_VIDEO);
if (!ast_format_cap_identical(ast_stream_get_formats(ast_stream_topology_get_stream(ast_channel_get_stream_topology(mock_channel), 0)), caps)) {
ast_test_status_update(test, "Formats on audio stream of channel are '%s' when they should be '%s'\n",
ast_format_cap_get_names(ast_stream_get_formats(ast_stream_topology_get_stream(ast_channel_get_stream_topology(mock_channel), 0)), &codec_have_buf),
ast_format_cap_get_names(caps, &codec_wanted_buf));
goto end;
}
if (ast_stream_get_type(ast_stream_topology_get_stream(ast_channel_get_stream_topology(mock_channel), 1)) != AST_MEDIA_TYPE_VIDEO) {
ast_test_status_update(test, "Second stream on channel is of type %s when it should be video\n",
ast_codec_media_type2str(ast_stream_get_type(ast_stream_topology_get_stream(ast_channel_get_stream_topology(mock_channel), 1))));
goto end;
}
ast_format_cap_remove_by_type(caps, AST_MEDIA_TYPE_AUDIO);
if (ast_format_cap_append(caps, ast_format_h264, 0)) {
ast_test_status_update(test, "Failed to append h264 video codec to capabilities for capabilities comparison\n");
goto end;
}
if (!ast_format_cap_identical(ast_stream_get_formats(ast_stream_topology_get_stream(ast_channel_get_stream_topology(mock_channel), 1)), caps)) {
ast_test_status_update(test, "Formats on video stream of channel are '%s' when they should be '%s'\n",
ast_format_cap_get_names(ast_stream_get_formats(ast_stream_topology_get_stream(ast_channel_get_stream_topology(mock_channel), 1)), &codec_wanted_buf),
ast_format_cap_get_names(caps, &codec_wanted_buf));
goto end;
}
res = AST_TEST_PASS;
end:
ast_channel_unlock(mock_channel);
ast_hangup(mock_channel);
return res;
}
static const struct ast_channel_tech mock_stream_channel_tech = {
.properties = AST_CHAN_TP_MULTISTREAM,
};
AST_TEST_DEFINE(stream_topology_channel_set)
{
RAII_VAR(struct ast_stream_topology *, topology, NULL, ast_stream_topology_destroy);
struct ast_channel *mock_channel;
enum ast_test_result_state res = AST_TEST_PASS;
switch (cmd) {
case TEST_INIT:
info->name = "stream_topology_channel_set";
info->category = "/main/stream/";
info->summary = "stream topology setting on a channel unit test";
info->description =
"Test that setting a stream topology on a channel works";
return AST_TEST_NOT_RUN;
case TEST_EXECUTE:
break;
}
topology = ast_stream_topology_create();
if (!topology) {
ast_test_status_update(test, "Failed to create media stream topology\n");
return AST_TEST_FAIL;
}
mock_channel = ast_channel_alloc(0, AST_STATE_DOWN, NULL, NULL, NULL, NULL, NULL, NULL, NULL, 0, "TestChannel");
if (!mock_channel) {
ast_test_status_update(test, "Failed to create a mock channel for testing\n");
return AST_TEST_FAIL;
}
ast_channel_tech_set(mock_channel, &mock_stream_channel_tech);
ast_channel_set_stream_topology(mock_channel, topology);
if (ast_channel_get_stream_topology(mock_channel) != topology) {
ast_test_status_update(test, "Set an explicit stream topology on a channel but the returned one did not match it\n");
res = AST_TEST_FAIL;
}
topology = NULL;
ast_channel_unlock(mock_channel);
ast_hangup(mock_channel);
return res;
}
static int unload_module(void)
{
AST_TEST_UNREGISTER(stream_create);
@@ -624,6 +866,9 @@ static int unload_module(void)
AST_TEST_UNREGISTER(stream_topology_append_stream);
AST_TEST_UNREGISTER(stream_topology_set_stream);
AST_TEST_UNREGISTER(stream_topology_create_from_format_cap);
AST_TEST_UNREGISTER(stream_topology_get_first_stream_by_type);
AST_TEST_UNREGISTER(stream_topology_create_from_channel_nativeformats);
AST_TEST_UNREGISTER(stream_topology_channel_set);
return 0;
}
@@ -639,6 +884,9 @@ static int load_module(void)
AST_TEST_REGISTER(stream_topology_append_stream);
AST_TEST_REGISTER(stream_topology_set_stream);
AST_TEST_REGISTER(stream_topology_create_from_format_cap);
AST_TEST_REGISTER(stream_topology_get_first_stream_by_type);
AST_TEST_REGISTER(stream_topology_create_from_channel_nativeformats);
AST_TEST_REGISTER(stream_topology_channel_set);
return AST_MODULE_LOAD_SUCCESS;
}