aniani/icecast-server
1
0
Fork 0
mirror of https://gitlab.xiph.org/xiph/icecast-server.git synced 2025-02-02 15:07:36 -05:00
Code

Feature: Trim the queue to 32 entries max

Browse Source
This commit is contained in:
Philipp Schafft 2024-01-25 11:11:00 +00:00
parent 165a56c819
commit 7f59a845a8
1 changed files with 28 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/event_stream.c
View File

@ -256,6 +256,32 @@ static void event_stream_send_to_client(client_t *client)
} }
} }
static void event_stream_cleanup_queue(void)
{
thread_mutex_lock(&event_stream_event_mutex);
{
static const size_t to_keep = 32;
event_stream_event_t *cur;
size_t count = 0;
cur = event_queue;
while (cur) {
count++;
cur = cur->next;
}
if (count > to_keep) {
for (size_t to_remove = count - to_keep; to_remove; to_remove--) {
cur = event_queue;
event_queue = cur->next;
cur->removed = 1;
cur->next = NULL;
}
}
}
thread_mutex_unlock(&event_stream_event_mutex);
}
static void *event_stream_thread_function(void *arg) static void *event_stream_thread_function(void *arg)
{ {
bool running = true; bool running = true;
@ -265,6 +291,8 @@ static void *event_stream_thread_function(void *arg)
do { do {
thread_cond_timedwait(&event_stream_cond, 1000); thread_cond_timedwait(&event_stream_cond, 1000);
event_stream_cleanup_queue();
{ {
avl_tree_wlock(client_tree); avl_tree_wlock(client_tree);
avl_node *next; avl_node *next;