Sapian
/
asterisk
mirror of http://gerrit.asterisk.org/asterisk
3
0
Fork 0
Code Issues Releases Wiki Activity

bridge_softmix: Reduce topology cloning and improve renegotiation.

Browse Source 
As channels join and leave an SFU the bridge_softmix module
needs to renegotiate to add and remove their streams from
the other participants. Previously this was done by constructing
the ideal stream topology every time but in the case of leave
this was incomplete.

This change makes it so bridge_softmix keeps an ideal stream
topology for each channel and uses it when making changes. This
ensures that when we request a renegotiation we are always
certain that we are aiming for the best stream topology
possible. In the case of a channel leaving this ensures that
we try to have an existing participant fill their place if
a participant has a fixed limit on the maximum number of video
streams they allow.

ASTERISK-27354

Change-Id: I58070f421ddeadd2844a33b869b052630cf2e514
changes/21/6821/1
Joshua Colp 9 years ago
parent 3a2b132411
commit 5d8c517960
2 changed files with 38 additions and 105 deletions
Show Stats Download Patch File Download Diff File

141
bridges/bridge_softmix.c
Unescape View File

@ -573,27 +573,24 @@ static int append_all_streams(struct ast_stream_topology *dest,
*/
static void sfu_topologies_on_join(struct ast_bridge_channel *joiner, struct ast_bridge_channels_list *participants)
{
struct ast_stream_topology *joiner_topology = NULL;
struct ast_stream_topology *joiner_video = NULL;
struct ast_stream_topology *existing_video = NULL;
struct ast_bridge_channel *participant;
int res;
struct softmix_channel *sc;
joiner_video = ast_stream_topology_alloc();
if (!joiner_video) {
return;
}
sc = joiner->tech_pvt;
ast_channel_lock(joiner->chan);
res = append_source_streams(joiner_video, ast_channel_name(joiner->chan), ast_channel_get_stream_topology(joiner->chan));
sc->topology = ast_stream_topology_clone(ast_channel_get_stream_topology(joiner->chan));
ast_channel_unlock(joiner->chan);
if (res) {
goto cleanup;
}
existing_video = ast_stream_topology_alloc();
if (!existing_video) {
if (res || !sc->topology) {
goto cleanup;
}
@ -602,7 +599,7 @@ static void sfu_topologies_on_join(struct ast_bridge_channel *joiner, struct ast
continue;
}
ast_channel_lock(participant->chan);
res = append_source_streams(existing_video, ast_channel_name(participant->chan),
res = append_source_streams(sc->topology, ast_channel_name(participant->chan),
ast_channel_get_stream_topology(participant->chan));
ast_channel_unlock(participant->chan);
if (res) {
@ -610,41 +607,22 @@ static void sfu_topologies_on_join(struct ast_bridge_channel *joiner, struct ast
}
}
ast_channel_lock(joiner->chan);
joiner_topology = ast_stream_topology_clone(ast_channel_get_stream_topology(joiner->chan));
ast_channel_unlock(joiner->chan);
if (!joiner_topology) {
goto cleanup;
}
if (append_all_streams(joiner_topology, existing_video)) {
goto cleanup;
}
ast_channel_request_stream_topology_change(joiner->chan, joiner_topology, NULL);
ast_channel_request_stream_topology_change(joiner->chan, sc->topology, NULL);
AST_LIST_TRAVERSE(participants, participant, entry) {
struct ast_stream_topology *participant_topology;
if (participant == joiner) {
continue;
}
ast_channel_lock(participant->chan);
participant_topology = ast_stream_topology_clone(ast_channel_get_stream_topology(participant->chan));
ast_channel_unlock(participant->chan);
if (!participant_topology) {
goto cleanup;
}
if (append_all_streams(participant_topology, joiner_video)) {
ast_stream_topology_free(participant_topology);
sc = participant->tech_pvt;
if (append_all_streams(sc->topology, joiner_video)) {
goto cleanup;
}
ast_channel_request_stream_topology_change(participant->chan, participant_topology, NULL);
ast_stream_topology_free(participant_topology);
ast_channel_request_stream_topology_change(participant->chan, sc->topology, NULL);
}
cleanup:
ast_stream_topology_free(joiner_video);
ast_stream_topology_free(existing_video);
ast_stream_topology_free(joiner_topology);
}
/*! \brief Function called when a channel is joined into the bridge */
@ -718,65 +696,36 @@ static int softmix_bridge_join(struct ast_bridge *bridge, struct ast_bridge_chan
return 0;
}
static int remove_destination_streams(struct ast_stream_topology *dest,
const char *channel_name,
const struct ast_stream_topology *source)
static void remove_destination_streams(struct ast_stream_topology *topology,
const char *channel_name)
{
int i;
for (i = 0; i < ast_stream_topology_get_count(source); ++i) {
for (i = 0; i < ast_stream_topology_get_count(topology); ++i) {
struct ast_stream *stream;
struct ast_stream *stream_clone;
stream = ast_stream_topology_get_stream(source, i);
stream_clone = ast_stream_clone(stream, NULL);
if (!stream_clone) {
continue;
}
stream = ast_stream_topology_get_stream(topology, i);
if (is_video_dest(stream, channel_name, NULL)) {
ast_stream_set_state(stream_clone, AST_STREAM_STATE_REMOVED);
}
if (ast_stream_topology_append_stream(dest, stream_clone) < 0) {
ast_stream_free(stream_clone);
ast_stream_set_state(stream, AST_STREAM_STATE_REMOVED);
}
}
return 0;
}
static int sfu_topologies_on_leave(struct ast_bridge_channel *leaver, struct ast_bridge_channels_list *participants)
{
struct ast_stream_topology *leaver_topology;
struct ast_bridge_channel *participant;
leaver_topology = ast_stream_topology_alloc();
if (!leaver_topology) {
return -1;
}
struct softmix_channel *sc;
AST_LIST_TRAVERSE(participants, participant, entry) {
struct ast_stream_topology *participant_topology;
participant_topology = ast_stream_topology_alloc();
if (!participant_topology) {
continue;
}
ast_channel_lock(participant->chan);
remove_destination_streams(participant_topology, ast_channel_name(leaver->chan), ast_channel_get_stream_topology(participant->chan));
ast_channel_unlock(participant->chan);
ast_channel_request_stream_topology_change(participant->chan, participant_topology, NULL);
ast_stream_topology_free(participant_topology);
sc = participant->tech_pvt;
remove_destination_streams(sc->topology, ast_channel_name(leaver->chan));
ast_channel_request_stream_topology_change(participant->chan, sc->topology, NULL);
}
ast_channel_lock(leaver->chan);
remove_destination_streams(leaver_topology, "", ast_channel_get_stream_topology(leaver->chan));
ast_channel_unlock(leaver->chan);
ast_channel_request_stream_topology_change(leaver->chan, leaver_topology, NULL);
ast_stream_topology_free(leaver_topology);
sc = leaver->tech_pvt;
remove_destination_streams(sc->topology, "");
ast_channel_request_stream_topology_change(leaver->chan, sc->topology, NULL);
return 0;
}
@ -806,6 +755,8 @@ static void softmix_bridge_leave(struct ast_bridge *bridge, struct ast_bridge_ch
bridge_channel->tech_pvt = NULL;
ast_stream_topology_free(sc->topology);
/* Drop mutex lock */
ast_mutex_destroy(&sc->lock);
@ -1055,30 +1006,23 @@ static void sfu_topologies_on_source_change(struct ast_bridge_channel *source, s
AST_LIST_TRAVERSE(participants, participant, entry) {
struct ast_stream_topology *original_topology;
struct ast_stream_topology *participant_topology;
struct softmix_channel *sc;
if (participant == source) {
continue;
}
ast_channel_lock(participant->chan);
original_topology = ast_stream_topology_clone(ast_channel_get_stream_topology(participant->chan));
ast_channel_unlock(participant->chan);
if (!original_topology) {
goto cleanup;
}
sc = participant->tech_pvt;
participant_topology = ast_stream_topology_clone(original_topology);
if (!participant_topology) {
ast_stream_topology_free(original_topology);
original_topology = ast_stream_topology_clone(sc->topology);
if (!original_topology) {
goto cleanup;
}
/* We add all the source streams back in, if any removed streams are already present they will
* get used first followed by appending new ones.
*/
if (append_all_streams(participant_topology, source_video)) {
ast_stream_topology_free(participant_topology);
if (append_all_streams(sc->topology, source_video)) {
ast_stream_topology_free(original_topology);
goto cleanup;
}
@ -1086,14 +1030,12 @@ static void sfu_topologies_on_source_change(struct ast_bridge_channel *source, s
/* And the original existing streams get marked as removed. This causes the remote side to see
* a new stream for the source streams.
*/
if (remove_all_original_streams(participant_topology, source_video, original_topology)) {
ast_stream_topology_free(participant_topology);
if (remove_all_original_streams(sc->topology, source_video, original_topology)) {
ast_stream_topology_free(original_topology);
goto cleanup;
}
ast_channel_request_stream_topology_change(participant->chan, participant_topology, NULL);
ast_stream_topology_free(participant_topology);
ast_channel_request_stream_topology_change(participant->chan, sc->topology, NULL);
ast_stream_topology_free(original_topology);
}
@ -2144,7 +2086,6 @@ AST_TEST_DEFINE(sfu_remove_destination_streams)
{ "", 4, { 0, 1, 2, 3 }, },
};
struct ast_stream_topology *orig = NULL;
struct ast_stream_topology *result = NULL;
int i;
switch (cmd) {
@ -2168,20 +2109,11 @@ AST_TEST_DEFINE(sfu_remove_destination_streams)
for (i = 0; i < ARRAY_LEN(removal_results); ++i) {
int j;
result = ast_stream_topology_alloc();
if (!result) {
ast_test_status_update(test, "Unable to allocate result stream topology\n");
goto end;
}
if (remove_destination_streams(result, removal_results[i].channel_name, orig)) {
ast_test_status_update(test, "Failure while attempting to remove video streams\n");
goto end;
}
remove_destination_streams(orig, removal_results[i].channel_name);
if (ast_stream_topology_get_count(result) != removal_results[i].num_streams) {
if (ast_stream_topology_get_count(orig) != removal_results[i].num_streams) {
ast_test_status_update(test, "Resulting topology has %d streams, when %d are expected\n",
ast_stream_topology_get_count(result), removal_results[i].num_streams);
ast_stream_topology_get_count(orig), removal_results[i].num_streams);
goto end;
}
@ -2190,7 +2122,7 @@ AST_TEST_DEFINE(sfu_remove_destination_streams)
struct ast_stream *expected;
int orig_index;
actual = ast_stream_topology_get_stream(result, j);
actual = ast_stream_topology_get_stream(orig, j);
orig_index = removal_results[i].params_index[j];
expected = ast_stream_topology_get_stream(orig, orig_index);
@ -2221,7 +2153,6 @@ AST_TEST_DEFINE(sfu_remove_destination_streams)
end:
ast_stream_topology_free(orig);
ast_stream_topology_free(result);
return res;
}

2
bridges/bridge_softmix/include/bridge_softmix_internal.h
Unescape View File

@ -167,6 +167,8 @@ struct softmix_channel {
short our_buf[MAX_DATALEN];
/*! Data pertaining to talker mode for video conferencing */
struct video_follow_talker_data video_talker;
/*! The ideal stream topology for the channel */
struct ast_stream_topology *topology;
};
struct softmix_bridge_data {

Write Preview
Loading…
Cancel
Save