diff --git a/spa/plugins/audioconvert/audioadapter.c b/spa/plugins/audioconvert/audioadapter.c
index c9c509367..fbed63b38 100644
--- a/spa/plugins/audioconvert/audioadapter.c
+++ b/spa/plugins/audioconvert/audioadapter.c
@@ -32,6 +32,7 @@ static struct spa_log_topic log_topic = SPA_LOG_TOPIC(0, "spa.audioadapter");
 #define DEFAULT_ALIGN	16
 
 #define MAX_PORTS	(SPA_AUDIO_MAX_CHANNELS+1)
+#define MAX_RETRY	64
 
 /** \cond */
 
@@ -1360,7 +1361,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->convert);
 				if (status & SPA_STATUS_HAVE_DATA)
@@ -1588,7 +1589,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 585964e33..a3dfa8d02 100644
--- a/spa/plugins/videoconvert/videoadapter.c
+++ b/spa/plugins/videoconvert/videoadapter.c
@@ -31,6 +31,7 @@ static struct spa_log_topic log_topic = SPA_LOG_TOPIC(0, "spa.videoadapter");
 #define DEFAULT_ALIGN	16
 
 #define MAX_PORTS	1
+#define MAX_RETRY	64
 
 /** \cond */
 
@@ -1128,7 +1129,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(this->convert);
 				if (status & SPA_STATUS_HAVE_DATA)
@@ -1367,7 +1368,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;
 
 	spa_log_trace_fp(this->log, "%p: process convert:%p driver:%d",
 			this, this->convert, this->driver);