summaryrefslogtreecommitdiff
path: root/bridges
diff options
context:
space:
mode:
authorJenkins2 <jenkins2@gerrit.asterisk.org>2017-12-19 11:12:22 -0600
committerGerrit Code Review <gerrit2@gerrit.digium.api>2017-12-19 11:12:22 -0600
commit7384abc5c10c61d23639b2abe60453b48cc905d9 (patch)
tree75b2207e57696dc91bfa3e3d310d89fc1879095e /bridges
parent6bd25cad8642b456bf0cd251b5a24453500e7e52 (diff)
parentea4179599f8fc853a98c9850ed08efd3b7845c12 (diff)
Merge "bridge_softmix.c: Don't match dead streams."
Diffstat (limited to 'bridges')
-rw-r--r--bridges/bridge_softmix.c28
1 files changed, 12 insertions, 16 deletions
diff --git a/bridges/bridge_softmix.c b/bridges/bridge_softmix.c
index 13f98eaea..83b1a8337 100644
--- a/bridges/bridge_softmix.c
+++ b/bridges/bridge_softmix.c
@@ -418,8 +418,9 @@ static void softmix_bridge_unsuspend(struct ast_bridge *bridge, struct ast_bridg
*/
static int is_video_source(const struct ast_stream *stream)
{
- if (ast_stream_get_type(stream) == AST_MEDIA_TYPE_VIDEO &&
- strncmp(ast_stream_get_name(stream), SOFTBRIDGE_VIDEO_DEST_PREFIX,
+ if (ast_stream_get_state(stream) != AST_STREAM_STATE_REMOVED
+ && ast_stream_get_type(stream) == AST_MEDIA_TYPE_VIDEO
+ && strncmp(ast_stream_get_name(stream), SOFTBRIDGE_VIDEO_DEST_PREFIX,
SOFTBRIDGE_VIDEO_DEST_LEN)) {
return 1;
}
@@ -448,40 +449,35 @@ static int is_video_dest(const struct ast_stream *stream, const char *source_cha
char *dest_video_name;
size_t dest_video_name_len;
- if (ast_stream_get_type(stream) != AST_MEDIA_TYPE_VIDEO) {
+ if (ast_stream_get_state(stream) == AST_STREAM_STATE_REMOVED
+ || ast_stream_get_type(stream) != AST_MEDIA_TYPE_VIDEO) {
return 0;
}
dest_video_name_len = SOFTBRIDGE_VIDEO_DEST_LEN + 1;
-
if (!ast_strlen_zero(source_channel_name)) {
dest_video_name_len += strlen(source_channel_name) + 1;
if (!ast_strlen_zero(source_stream_name)) {
dest_video_name_len += strlen(source_stream_name) + 1;
}
- }
- dest_video_name = ast_alloca(dest_video_name_len);
- if (!ast_strlen_zero(source_channel_name)) {
+ dest_video_name = ast_alloca(dest_video_name_len);
if (!ast_strlen_zero(source_stream_name)) {
+ /* We are looking for an exact stream name */
snprintf(dest_video_name, dest_video_name_len, "%s%c%s%c%s",
SOFTBRIDGE_VIDEO_DEST_PREFIX, SOFTBRIDGE_VIDEO_DEST_SEPARATOR,
source_channel_name, SOFTBRIDGE_VIDEO_DEST_SEPARATOR,
source_stream_name);
return !strcmp(ast_stream_get_name(stream), dest_video_name);
- } else {
- snprintf(dest_video_name, dest_video_name_len, "%s%c%s",
- SOFTBRIDGE_VIDEO_DEST_PREFIX, SOFTBRIDGE_VIDEO_DEST_SEPARATOR,
- source_channel_name);
- return !strncmp(ast_stream_get_name(stream), dest_video_name, dest_video_name_len - 1);
}
+ snprintf(dest_video_name, dest_video_name_len, "%s%c%s",
+ SOFTBRIDGE_VIDEO_DEST_PREFIX, SOFTBRIDGE_VIDEO_DEST_SEPARATOR,
+ source_channel_name);
} else {
- snprintf(dest_video_name, dest_video_name_len, "%s",
- SOFTBRIDGE_VIDEO_DEST_PREFIX);
- return !strncmp(ast_stream_get_name(stream), dest_video_name, dest_video_name_len - 1);
+ dest_video_name = SOFTBRIDGE_VIDEO_DEST_PREFIX;
}
- return 0;
+ return !strncmp(ast_stream_get_name(stream), dest_video_name, dest_video_name_len - 1);
}
static int append_source_streams(struct ast_stream_topology *dest,