aniani/icecast-server
1
0
Fork 0
mirror of https://gitlab.xiph.org/xiph/icecast-server.git synced 2024-12-04 14:46:30 -05:00
Code

Update: Use a condition not a sleep in event queue thread

Browse Source
This commit is contained in:
Philipp Schafft 2022-03-21 12:47:15 +00:00
parent b675f36729
commit e9ed0527ed
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/event.c
View File

@ -32,6 +32,7 @@ static mutex_t event_lock;
static event_t *event_queue = NULL; static event_t *event_queue = NULL;
static bool event_running = false; static bool event_running = false;
static thread_type *event_thread = NULL; static thread_type *event_thread = NULL;
static cond_t cond;
/* work with event_t* */ /* work with event_t* */
static void event_addref(event_t *event) { static void event_addref(event_t *event) {
@ -90,6 +91,8 @@ static void event_push(event_t **event, event_t *next) {
} }
*event = next; *event = next;
thread_cond_broadcast(&cond);
} }
static void event_push_reglist(event_t *event, event_registration_t *reglist) { static void event_push_reglist(event_t *event, event_registration_t *reglist) {
@ -186,7 +189,7 @@ static void *event_run_thread (void *arg) {
/* sleep if nothing todo and then try again */ /* sleep if nothing todo and then try again */
if (!event) { if (!event) {
thread_sleep(150000); thread_cond_wait(&cond);
continue; continue;
} }
@ -202,6 +205,7 @@ static void *event_run_thread (void *arg) {
void event_initialise(void) { void event_initialise(void) {
/* create mutex */ /* create mutex */
thread_mutex_create(&event_lock); thread_mutex_create(&event_lock);
thread_cond_create(&cond);
/* initialise everything */ /* initialise everything */
thread_mutex_lock(&event_lock); thread_mutex_lock(&event_lock);
@ -224,6 +228,7 @@ void event_shutdown(void) {
thread_mutex_unlock(&event_lock); thread_mutex_unlock(&event_lock);
/* join thread as soon as it stopped */ /* join thread as soon as it stopped */
thread_cond_broadcast(&cond);
thread_join(event_thread); thread_join(event_thread);
/* shutdown everything */ /* shutdown everything */
@ -235,6 +240,7 @@ void event_shutdown(void) {
event_release(event_queue_to_free); event_release(event_queue_to_free);
thread_cond_destroy(&cond);
/* destry mutex */ /* destry mutex */
thread_mutex_destroy(&event_lock); thread_mutex_destroy(&event_lock);
} }