mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-02 09:01:50 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

stream: do fast calls for the process function

Browse source 
We checked it while registering.
This commit is contained in:
Wim Taymans 2023-05-24 18:01:41 +02:00
parent 004d3d900a
commit 8303082024
2 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/pipewire/filter.c
View file

@ -966,9 +966,9 @@ do_call_process(struct spa_loop *loop,
static void call_process(struct filter *impl) static void call_process(struct filter *impl)
{ {
pw_log_trace("%p: call process", impl); pw_log_trace_fp("%p: call process", impl);
if (SPA_FLAG_IS_SET(impl->flags, PW_FILTER_FLAG_RT_PROCESS)) { if (SPA_FLAG_IS_SET(impl->flags, PW_FILTER_FLAG_RT_PROCESS)) {
spa_callbacks_call(&impl->rt_callbacks, struct pw_filter_events, spa_callbacks_call_fast(&impl->rt_callbacks, struct pw_filter_events,
process, 0, impl->rt.position); process, 0, impl->rt.position);
} }
else { else {
@ -1934,7 +1934,7 @@ struct pw_buffer *pw_filter_dequeue_buffer(void *port_data)
if (SPA_UNLIKELY((b = pop_queue(p, &p->dequeued)) == NULL)) { if (SPA_UNLIKELY((b = pop_queue(p, &p->dequeued)) == NULL)) {
res = -errno; res = -errno;
pw_log_debug("%p: no more buffers: %m", impl); pw_log_trace_fp("%p: no more buffers: %m", impl);
errno = -res; errno = -res;
return NULL; return NULL;
} }

2
src/pipewire/stream.c
View file

@ -427,7 +427,7 @@ static inline void call_process(struct stream *impl)
if (impl->direction == SPA_DIRECTION_OUTPUT && update_requested(impl) <= 0) if (impl->direction == SPA_DIRECTION_OUTPUT && update_requested(impl) <= 0)
return; return;
if (impl->process_rt) if (impl->process_rt)
spa_callbacks_call(&impl->rt_callbacks, struct pw_stream_events, process, 0); spa_callbacks_call_fast(&impl->rt_callbacks, struct pw_stream_events, process, 0);
else else
pw_loop_invoke(impl->main_loop, pw_loop_invoke(impl->main_loop,
do_call_process, 1, NULL, 0, false, impl); do_call_process, 1, NULL, 0, false, impl);