mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-12 13:30:15 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

gst: pool add support for DONT_WAIT flag

Browse source
This commit is contained in:
Wim Taymans 2020-08-06 12:52:16 +02:00
parent 4b56574ce0
commit 0347a753c9
1 changed files with 9 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

9
src/gst/gstpipewirepool.c
View file

@ -180,6 +180,9 @@ acquire_buffer (GstBufferPool * pool, GstBuffer ** buffer,
if ((b = pw_stream_dequeue_buffer(p->stream))) if ((b = pw_stream_dequeue_buffer(p->stream)))
break; break;
if (params && (params->flags & GST_BUFFER_POOL_ACQUIRE_FLAG_DONTWAIT))
goto no_more_buffers;
GST_WARNING ("queue empty"); GST_WARNING ("queue empty");
g_cond_wait (&p->cond, GST_OBJECT_GET_LOCK (pool)); g_cond_wait (&p->cond, GST_OBJECT_GET_LOCK (pool));
} }
@ -197,6 +200,12 @@ flushing:
GST_OBJECT_UNLOCK (pool); GST_OBJECT_UNLOCK (pool);
return GST_FLOW_FLUSHING; return GST_FLOW_FLUSHING;
} }
no_more_buffers:
{
GST_LOG_OBJECT (pool, "no more buffers");
GST_OBJECT_UNLOCK (pool);
return GST_FLOW_EOS;
}
} }
static void static void