Skip to content

Commit

Permalink
Merge pull request #11 from keremcadirci/AudioBridge_Stop-All-Annc
Browse files Browse the repository at this point in the history
meetecho#3403 stop_all_files, refactor
  • Loading branch information
keremcadirci authored Nov 5, 2024
2 parents 192e485 + bb753c5 commit 6752dae
Showing 1 changed file with 8 additions and 18 deletions.
26 changes: 8 additions & 18 deletions src/plugins/janus_audiobridge.c
Original file line number Diff line number Diff line change
Expand Up @@ -5881,12 +5881,12 @@ static json_t *janus_audiobridge_process_synchronous_request(janus_audiobridge_s
}

/* Get list of started announcements and send a stop announcement notification */
GList *items_to_remove = NULL;
GHashTableIter iterAnnc;
gpointer valueAnnc;
g_hash_table_iter_init(&iterAnnc, audiobridge->anncs);
while(g_hash_table_iter_next(&iterAnnc, NULL, &valueAnnc)) {
janus_audiobridge_participant *p = valueAnnc;
GHashTableIter iter;
gpointer value;
json_t *list_annc_removed = json_array();
g_hash_table_iter_init(&iter, audiobridge->anncs);
while(g_hash_table_iter_next(&iter, NULL, &value)) {
janus_audiobridge_participant *p = value;
gboolean started = (p && p->annc && p->annc->started);
if(p)
janus_refcount_increase(&p->ref);
Expand All @@ -5908,23 +5908,13 @@ static json_t *janus_audiobridge_process_synchronous_request(janus_audiobridge_s
json_object_set_new(info, "file_id", json_string(p->annc->id));
gateway->notify_event(&janus_audiobridge_plugin, NULL, info);
}
items_to_remove = g_list_prepend(items_to_remove, p->annc->id);
json_array_append_new(list_annc_removed, json_string(p->annc->id));
}
g_hash_table_iter_remove(&iter);
if(p)
janus_refcount_decrease(&p->ref);
}

/* Get rid of the announcements */
json_t *list_annc_removed = json_array();
GList *l =NULL;
for(l = items_to_remove; l!= NULL; l = l->next) {
json_t *file_id = json_string(l->data);
if(g_hash_table_remove(audiobridge->anncs, l->data)) {
json_array_append_new(list_annc_removed, file_id);
}
}
g_list_free(items_to_remove);

janus_mutex_unlock(&audiobridge->mutex);
janus_mutex_unlock(&rooms_mutex);

Expand Down

0 comments on commit 6752dae

Please sign in to comment.