diff --git a/src/pipewire/filter.c b/src/pipewire/filter.c index 7bd8d698a..4b574c3a5 100644 --- a/src/pipewire/filter.c +++ b/src/pipewire/filter.c @@ -951,16 +951,6 @@ static int impl_port_reuse_buffer(void *object, uint32_t port_id, uint32_t buffe return 0; } -static inline void update_target(struct filter *impl) -{ - struct spa_io_position *p = impl->rt.position; - if (SPA_LIKELY(p != NULL)) { - p->clock.rate = p->clock.target_rate; - p->clock.position += p->clock.duration; - p->clock.duration = p->clock.target_duration; - } -} - static inline void copy_position(struct filter *impl) { struct spa_io_position *p = impl->rt.position; @@ -1964,10 +1954,7 @@ do_trigger_process(struct spa_loop *loop, bool async, uint32_t seq, const void *data, size_t size, void *user_data) { struct filter *impl = user_data; - int res; - - update_target(impl); - res = impl_node_process(impl); + int res = impl_node_process(impl); return spa_node_call_ready(&impl->callbacks, res); } diff --git a/src/pipewire/stream.c b/src/pipewire/stream.c index 76de36597..df5916ffd 100644 --- a/src/pipewire/stream.c +++ b/src/pipewire/stream.c @@ -572,16 +572,6 @@ static int impl_set_param(void *object, uint32_t id, uint32_t flags, const struc return 0; } -static inline void update_target(struct stream *impl) -{ - struct spa_io_position *p = impl->rt.position; - if (SPA_LIKELY(p != NULL)) { - p->clock.rate = p->clock.target_rate; - p->clock.position += p->clock.duration; - p->clock.duration = p->clock.target_duration; - } -} - static inline void copy_position(struct stream *impl, int64_t queued) { struct spa_io_position *p = impl->rt.position; @@ -2273,9 +2263,7 @@ do_trigger_deprecated(struct spa_loop *loop, bool async, uint32_t seq, const void *data, size_t size, void *user_data) { struct stream *impl = user_data; - int res; - update_target(impl); - res = impl->node_methods.process(impl); + int res = impl->node_methods.process(impl); return spa_node_call_ready(&impl->callbacks, res); } @@ -2426,8 +2414,6 @@ int pw_stream_trigger_process(struct pw_stream *stream) if (!impl->driving && !impl->trigger) { res = trigger_request_process(impl); } else { - update_target(impl); - if (!impl->process_rt) call_process(impl);