From 8cd3fc6922a24276684e7ee266ba2b66470db2be Mon Sep 17 00:00:00 2001 From: Wim Taymans Date: Mon, 7 Oct 2024 09:28:39 +0200 Subject: [PATCH] adapter: increase max-retry to 64 When the follower doesn't produce enough data for this many attempts, bail and cause an xrun to avoid an infinite loop. The limit of 8 cause real-life problems and should be larger. It should probably depend on the expected size per cycle (node.latency) and the current quantum but we don't always have this information. See #4334 --- spa/plugins/audioconvert/audioadapter.c | 5 +++-- spa/plugins/videoconvert/videoadapter.c | 5 +++-- 2 files changed, 6 insertions(+), 4 deletions(-) diff --git a/spa/plugins/audioconvert/audioadapter.c b/spa/plugins/audioconvert/audioadapter.c index e353e477c..c80c54a99 100644 --- a/spa/plugins/audioconvert/audioadapter.c +++ b/spa/plugins/audioconvert/audioadapter.c @@ -34,6 +34,7 @@ SPA_LOG_TOPIC_DEFINE_STATIC(log_topic, "spa.audioadapter"); #define DEFAULT_ALIGN 16 #define MAX_PORTS (SPA_AUDIO_MAX_CHANNELS+1) +#define MAX_RETRY 64 /** \cond */ @@ -1427,7 +1428,7 @@ static int follower_ready(void *data, int status) this->driver = true; if (this->direction == SPA_DIRECTION_OUTPUT) { - int retry = 8; + int retry = MAX_RETRY; while (retry--) { status = spa_node_process_fast(this->target); if (status & SPA_STATUS_HAVE_DATA) @@ -1656,7 +1657,7 @@ impl_node_port_reuse_buffer(void *object, uint32_t port_id, uint32_t buffer_id) static int impl_node_process(void *object) { struct impl *this = object; - int status = 0, fstatus, retry = 8; + int status = 0, fstatus, retry = MAX_RETRY; if (!this->ready) { if (!this->warned) diff --git a/spa/plugins/videoconvert/videoadapter.c b/spa/plugins/videoconvert/videoadapter.c index c9ee33bb8..65aee736b 100644 --- a/spa/plugins/videoconvert/videoadapter.c +++ b/spa/plugins/videoconvert/videoadapter.c @@ -34,6 +34,7 @@ SPA_LOG_TOPIC_DEFINE_STATIC(log_topic, "spa.videoadapter"); #define DEFAULT_ALIGN 16 #define MAX_PORTS (1+1) +#define MAX_RETRY 64 /** \cond */ @@ -1419,7 +1420,7 @@ static int follower_ready(void *data, int status) this->driver = true; if (this->direction == SPA_DIRECTION_OUTPUT) { - int retry = 8; + int retry = MAX_RETRY; while (retry--) { status = spa_node_process_fast(this->target); if (status & SPA_STATUS_HAVE_DATA) @@ -1708,7 +1709,7 @@ impl_node_port_reuse_buffer(void *object, uint32_t port_id, uint32_t buffer_id) static int impl_node_process(void *object) { struct impl *this = object; - int status = 0, fstatus, retry = 8; + int status = 0, fstatus, retry = MAX_RETRY; if (!this->ready) { if (!this->warned)