mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-12-27 02:30:35 +00:00
audio: Use new GType for GThread instead of just G_TYPE_POINTER
This commit is contained in:
parent
af3f75f3a9
commit
32139f9a3d
2 changed files with 12 additions and 5 deletions
|
@ -230,11 +230,12 @@ audioringbuffer_thread_func (GstAudioRingBuffer * buf)
|
||||||
if (writefunc == NULL)
|
if (writefunc == NULL)
|
||||||
goto no_function;
|
goto no_function;
|
||||||
|
|
||||||
g_value_init (&val, G_TYPE_POINTER);
|
|
||||||
g_value_set_pointer (&val, sink->thread);
|
|
||||||
message = gst_message_new_stream_status (GST_OBJECT_CAST (buf),
|
message = gst_message_new_stream_status (GST_OBJECT_CAST (buf),
|
||||||
GST_STREAM_STATUS_TYPE_ENTER, GST_ELEMENT_CAST (sink));
|
GST_STREAM_STATUS_TYPE_ENTER, GST_ELEMENT_CAST (sink));
|
||||||
|
g_value_init (&val, GST_TYPE_G_THREAD);
|
||||||
|
g_value_set_boxed (&val, sink->thread);
|
||||||
gst_message_set_stream_status_object (message, &val);
|
gst_message_set_stream_status_object (message, &val);
|
||||||
|
g_value_unset (&val);
|
||||||
GST_DEBUG_OBJECT (sink, "posting ENTER stream status");
|
GST_DEBUG_OBJECT (sink, "posting ENTER stream status");
|
||||||
gst_element_post_message (GST_ELEMENT_CAST (sink), message);
|
gst_element_post_message (GST_ELEMENT_CAST (sink), message);
|
||||||
|
|
||||||
|
@ -306,7 +307,10 @@ stop_running:
|
||||||
GST_DEBUG_OBJECT (sink, "stop running, exit thread");
|
GST_DEBUG_OBJECT (sink, "stop running, exit thread");
|
||||||
message = gst_message_new_stream_status (GST_OBJECT_CAST (buf),
|
message = gst_message_new_stream_status (GST_OBJECT_CAST (buf),
|
||||||
GST_STREAM_STATUS_TYPE_LEAVE, GST_ELEMENT_CAST (sink));
|
GST_STREAM_STATUS_TYPE_LEAVE, GST_ELEMENT_CAST (sink));
|
||||||
|
g_value_init (&val, GST_TYPE_G_THREAD);
|
||||||
|
g_value_set_boxed (&val, sink->thread);
|
||||||
gst_message_set_stream_status_object (message, &val);
|
gst_message_set_stream_status_object (message, &val);
|
||||||
|
g_value_unset (&val);
|
||||||
GST_DEBUG_OBJECT (sink, "posting LEAVE stream status");
|
GST_DEBUG_OBJECT (sink, "posting LEAVE stream status");
|
||||||
gst_element_post_message (GST_ELEMENT_CAST (sink), message);
|
gst_element_post_message (GST_ELEMENT_CAST (sink), message);
|
||||||
return;
|
return;
|
||||||
|
|
|
@ -216,12 +216,12 @@ audioringbuffer_thread_func (GstAudioRingBuffer * buf)
|
||||||
if ((readfunc = csrc->read) == NULL)
|
if ((readfunc = csrc->read) == NULL)
|
||||||
goto no_function;
|
goto no_function;
|
||||||
|
|
||||||
/* FIXME: maybe we should at least use a custom pointer type here? */
|
|
||||||
g_value_init (&val, G_TYPE_POINTER);
|
|
||||||
g_value_set_pointer (&val, src->thread);
|
|
||||||
message = gst_message_new_stream_status (GST_OBJECT_CAST (buf),
|
message = gst_message_new_stream_status (GST_OBJECT_CAST (buf),
|
||||||
GST_STREAM_STATUS_TYPE_ENTER, GST_ELEMENT_CAST (src));
|
GST_STREAM_STATUS_TYPE_ENTER, GST_ELEMENT_CAST (src));
|
||||||
|
g_value_init (&val, GST_TYPE_G_THREAD);
|
||||||
|
g_value_set_boxed (&val, src->thread);
|
||||||
gst_message_set_stream_status_object (message, &val);
|
gst_message_set_stream_status_object (message, &val);
|
||||||
|
g_value_unset (&val);
|
||||||
GST_DEBUG_OBJECT (src, "posting ENTER stream status");
|
GST_DEBUG_OBJECT (src, "posting ENTER stream status");
|
||||||
gst_element_post_message (GST_ELEMENT_CAST (src), message);
|
gst_element_post_message (GST_ELEMENT_CAST (src), message);
|
||||||
|
|
||||||
|
@ -291,7 +291,10 @@ stop_running:
|
||||||
GST_DEBUG ("stop running, exit thread");
|
GST_DEBUG ("stop running, exit thread");
|
||||||
message = gst_message_new_stream_status (GST_OBJECT_CAST (buf),
|
message = gst_message_new_stream_status (GST_OBJECT_CAST (buf),
|
||||||
GST_STREAM_STATUS_TYPE_LEAVE, GST_ELEMENT_CAST (src));
|
GST_STREAM_STATUS_TYPE_LEAVE, GST_ELEMENT_CAST (src));
|
||||||
|
g_value_init (&val, GST_TYPE_G_THREAD);
|
||||||
|
g_value_set_boxed (&val, src->thread);
|
||||||
gst_message_set_stream_status_object (message, &val);
|
gst_message_set_stream_status_object (message, &val);
|
||||||
|
g_value_unset (&val);
|
||||||
GST_DEBUG_OBJECT (src, "posting LEAVE stream status");
|
GST_DEBUG_OBJECT (src, "posting LEAVE stream status");
|
||||||
gst_element_post_message (GST_ELEMENT_CAST (src), message);
|
gst_element_post_message (GST_ELEMENT_CAST (src), message);
|
||||||
return;
|
return;
|
||||||
|
|
Loading…
Reference in a new issue