FaSTTUBe/GST-Tensordecoder-ov_ep
61
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

gstsourcebufferlist: Added locking

Browse Source 
Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/8512>
This commit is contained in:
Jordan Yelloz 2025-02-18 13:08:37 -07:00 committed by GStreamer Marge Bot
parent 8041073465
commit b1c279f0d8
1 changed files with 30 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
subprojects/gst-plugins-bad/gst-libs/gst/mse/gstsourcebufferlist.c
View File

@ -98,6 +98,12 @@ typedef struct
static GParamSpec *properties[N_PROPS]; static GParamSpec *properties[N_PROPS];
static guint signals[N_SIGNALS] = { 0 }; static guint signals[N_SIGNALS] = { 0 };
static guint
get_length_unlocked (GstSourceBufferList * self)
{
return self->buffers->len;
}
static gboolean static gboolean
is_frozen (GstSourceBufferList * self) is_frozen (GstSourceBufferList * self)
{ {
@ -306,9 +312,14 @@ GstSourceBuffer *
gst_source_buffer_list_index (GstSourceBufferList * self, guint index) gst_source_buffer_list_index (GstSourceBufferList * self, guint index)
{ {
g_return_val_if_fail (GST_IS_SOURCE_BUFFER_LIST (self), NULL); g_return_val_if_fail (GST_IS_SOURCE_BUFFER_LIST (self), NULL);
if (index >= gst_source_buffer_list_get_length (self))
return NULL; GST_OBJECT_LOCK (self);
return gst_object_ref (g_ptr_array_index (self->buffers, index)); guint length = get_length_unlocked (self);
GstSourceBuffer *buf = index >= length ? NULL : gst_object_ref
(g_ptr_array_index (self->buffers, index));
GST_OBJECT_UNLOCK (self);
return buf;
} }
/** /**
@ -324,7 +335,12 @@ guint
gst_source_buffer_list_get_length (GstSourceBufferList * self) gst_source_buffer_list_get_length (GstSourceBufferList * self)
{ {
g_return_val_if_fail (GST_IS_SOURCE_BUFFER_LIST (self), 0); g_return_val_if_fail (GST_IS_SOURCE_BUFFER_LIST (self), 0);
return self->buffers->len;
GST_OBJECT_LOCK (self);
guint length = get_length_unlocked (self);
GST_OBJECT_UNLOCK (self);
return length;
} }
gboolean gboolean
@ -333,7 +349,12 @@ gst_source_buffer_list_contains (GstSourceBufferList * self,
{ {
g_return_val_if_fail (GST_IS_SOURCE_BUFFER_LIST (self), FALSE); g_return_val_if_fail (GST_IS_SOURCE_BUFFER_LIST (self), FALSE);
g_return_val_if_fail (GST_IS_SOURCE_BUFFER (buf), FALSE); g_return_val_if_fail (GST_IS_SOURCE_BUFFER (buf), FALSE);
return g_ptr_array_find (self->buffers, buf, NULL);
GST_OBJECT_LOCK (self);
gboolean found = g_ptr_array_find (self->buffers, buf, NULL);
GST_OBJECT_UNLOCK (self);
return found;
} }
void void
@ -341,7 +362,11 @@ gst_source_buffer_list_append (GstSourceBufferList * self,
GstSourceBuffer * buf) GstSourceBuffer * buf)
{ {
g_return_if_fail (GST_IS_SOURCE_BUFFER_LIST (self)); g_return_if_fail (GST_IS_SOURCE_BUFFER_LIST (self));
GST_OBJECT_LOCK (self);
g_ptr_array_add (self->buffers, gst_object_ref (buf)); g_ptr_array_add (self->buffers, gst_object_ref (buf));
GST_OBJECT_UNLOCK (self);
call_source_buffer_added (self); call_source_buffer_added (self);
} }