mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-10-31 22:25:38 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

stream: mark functions with RT safe

Browse source 
Add some docs about the process function being a realtime thread and
mark the functions you can call in realtime threads.

Fixes #4521
This commit is contained in:
Wim Taymans 2025-01-22 13:03:49 +01:00
parent d0b3c00d29
commit 122170ad62
1 changed files with 16 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

25
src/pipewire/stream.h
View file

@ -147,6 +147,11 @@ extern "C" {
* *
* The process event is emitted when a new buffer should be queued. * The process event is emitted when a new buffer should be queued.
* *
* When the PW_STREAM_FLAG_RT_PROCESS flag was given, this function will be
* called from a realtime thread and it is not safe to call non-reatime
* functions such as doing file operations, blocking operations or any of
* the PipeWire functions that are not explicitly marked as being RT safe.
*
* \ref pw_stream_dequeue_buffer() gives an empty buffer that can be filled. * \ref pw_stream_dequeue_buffer() gives an empty buffer that can be filled.
* *
* The buffer is owned by the stream and stays alive until the * The buffer is owned by the stream and stays alive until the
@ -574,11 +579,11 @@ const struct pw_stream_control *pw_stream_get_control(struct pw_stream *stream,
/** Set control values */ /** Set control values */
int pw_stream_set_control(struct pw_stream *stream, uint32_t id, uint32_t n_values, float *values, ...); int pw_stream_set_control(struct pw_stream *stream, uint32_t id, uint32_t n_values, float *values, ...);
/** Query the time on the stream */ /** Query the time on the stream, RT safe */
int pw_stream_get_time_n(struct pw_stream *stream, struct pw_time *time, size_t size); int pw_stream_get_time_n(struct pw_stream *stream, struct pw_time *time, size_t size);
/** Get the current time in nanoseconds. This value can be compared with /** Get the current time in nanoseconds. This value can be compared with
* the \ref pw_time.now value. Since 1.1.0 */ * the \ref pw_time.now value. RT safe. Since 1.1.0 */
uint64_t pw_stream_get_nsec(struct pw_stream *stream); uint64_t pw_stream_get_nsec(struct pw_stream *stream);
/** Get the data loop that is doing the processing of this stream. This loop /** Get the data loop that is doing the processing of this stream. This loop
@ -586,19 +591,19 @@ uint64_t pw_stream_get_nsec(struct pw_stream *stream);
struct pw_loop *pw_stream_get_data_loop(struct pw_stream *stream); struct pw_loop *pw_stream_get_data_loop(struct pw_stream *stream);
/** Query the time on the stream, deprecated since 0.3.50, /** Query the time on the stream, deprecated since 0.3.50,
* use pw_stream_get_time_n() to get the fields added since 0.3.50. */ * use pw_stream_get_time_n() to get the fields added since 0.3.50. RT safe. */
SPA_DEPRECATED SPA_DEPRECATED
int pw_stream_get_time(struct pw_stream *stream, struct pw_time *time); int pw_stream_get_time(struct pw_stream *stream, struct pw_time *time);
/** Get a buffer that can be filled for playback streams or consumed /** Get a buffer that can be filled for playback streams or consumed
* for capture streams. */ * for capture streams. RT safe. */
struct pw_buffer *pw_stream_dequeue_buffer(struct pw_stream *stream); struct pw_buffer *pw_stream_dequeue_buffer(struct pw_stream *stream);
/** Submit a buffer for playback or recycle a buffer for capture. */ /** Submit a buffer for playback or recycle a buffer for capture. RT safe. */
int pw_stream_queue_buffer(struct pw_stream *stream, struct pw_buffer *buffer); int pw_stream_queue_buffer(struct pw_stream *stream, struct pw_buffer *buffer);
/** Return a buffer to the queue without using it. This makes the buffer /** Return a buffer to the queue without using it. This makes the buffer
* immediately available to dequeue again. */ * immediately available to dequeue again. RT safe. */
int pw_stream_return_buffer(struct pw_stream *stream, struct pw_buffer *buffer); int pw_stream_return_buffer(struct pw_stream *stream, struct pw_buffer *buffer);
/** Activate or deactivate the stream */ /** Activate or deactivate the stream */
@ -609,7 +614,7 @@ int pw_stream_set_active(struct pw_stream *stream, bool active);
* after the drain by setting it active again with * after the drain by setting it active again with
* \ref pw_stream_set_active(). A flush without a drain is mostly useful afer * \ref pw_stream_set_active(). A flush without a drain is mostly useful afer
* a state change to PAUSED, to flush any remaining data from the queues and * a state change to PAUSED, to flush any remaining data from the queues and
* the converters. */ * the converters. RT safe. */
int pw_stream_flush(struct pw_stream *stream, bool drain); int pw_stream_flush(struct pw_stream *stream, bool drain);
/** Check if the stream is driving. The stream needs to have the /** Check if the stream is driving. The stream needs to have the
@ -659,10 +664,12 @@ bool pw_stream_is_lazy(struct pw_stream *stream);
* driver. If the graph is not lazy scheduling and the stream is not a * driver. If the graph is not lazy scheduling and the stream is not a
* driver, this method will have no effect. * driver, this method will have no effect.
* *
* RT safe.
*
* Since 0.3.34 */ * Since 0.3.34 */
int pw_stream_trigger_process(struct pw_stream *stream); int pw_stream_trigger_process(struct pw_stream *stream);
/** Emit an event from this stream. /** Emit an event from this stream. RT safe.
* Since 1.2.6 */ * Since 1.2.6 */
int pw_stream_emit_event(struct pw_stream *stream, const struct spa_event *event); int pw_stream_emit_event(struct pw_stream *stream, const struct spa_event *event);
@ -670,7 +677,7 @@ int pw_stream_emit_event(struct pw_stream *stream, const struct spa_event *event
* When the stream is using an adaptive resampler, adjust the resampler rate. * When the stream is using an adaptive resampler, adjust the resampler rate.
* When there is no resampler, -ENOTSUP is returned. Activating the adaptive * When there is no resampler, -ENOTSUP is returned. Activating the adaptive
* resampler will add a small amount of delay to the samples, you can deactivate * resampler will add a small amount of delay to the samples, you can deactivate
* it again by setting a value <= 0.0. * it again by setting a value <= 0.0. RT safe.
* Since 1.4.0 */ * Since 1.4.0 */
int pw_stream_set_rate(struct pw_stream *stream, double rate); int pw_stream_set_rate(struct pw_stream *stream, double rate);