From fdb1b2d5628d285534650432081d2b912d4e84d9 Mon Sep 17 00:00:00 2001 From: Maxim Devaev Date: Sun, 10 Jul 2022 23:32:00 +0300 Subject: [PATCH] using 0 timeout in audio.c --- janus/src/audio.c | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/janus/src/audio.c b/janus/src/audio.c index 6b007ba..472defc 100644 --- a/janus/src/audio.c +++ b/janus/src/audio.c @@ -193,7 +193,7 @@ static void *_pcm_thread(void *v_audio) { _pcm_buffer_s *out; A_CALLOC(out, 1); memcpy(out->data, in, audio->pcm_size); - assert(!queue_put(audio->pcm_queue, out, 0.1)); + assert(!queue_put(audio->pcm_queue, out, 0)); } else { JLOG_ERROR("audio", "PCM queue is full"); } @@ -238,9 +238,7 @@ static void *_encoder_thread(void *v_audio) { // https://datatracker.ietf.org/doc/html/rfc7587#section-4.2 audio->pts += HZ_TO_FRAMES(ENCODER_INPUT_HZ); - if (queue_get_free(audio->enc_queue)) { - assert(!queue_put(audio->enc_queue, out, 0.1)); - } else { + if (queue_put(audio->enc_queue, out, 0) != 0) { JLOG_ERROR("audio", "OPUS encoder queue is full"); free(out); }