diff --git a/src/pipewire/data-loop.c b/src/pipewire/data-loop.c index 92c1bdf55..3cee8a2e7 100644 --- a/src/pipewire/data-loop.c +++ b/src/pipewire/data-loop.c @@ -280,7 +280,7 @@ int pw_data_loop_stop(struct pw_data_loop *loop) pthread_cancel(loop->thread); } else { pw_log_debug("%p signal", loop); - pw_loop_locked(loop->loop, do_stop, 1, NULL, 0, loop); + pw_loop_invoke(loop->loop, do_stop, 1, NULL, 0, false, loop); } pw_log_debug("%p join", loop); if ((utils = loop->thread_utils) == NULL) diff --git a/src/pipewire/main-loop.c b/src/pipewire/main-loop.c index 41ac5bf28..6e73a13cb 100644 --- a/src/pipewire/main-loop.c +++ b/src/pipewire/main-loop.c @@ -107,7 +107,7 @@ SPA_EXPORT int pw_main_loop_quit(struct pw_main_loop *loop) { pw_log_debug("%p: quit", loop); - return pw_loop_locked(loop->loop, do_stop, 1, NULL, 0, loop); + return pw_loop_invoke(loop->loop, do_stop, 1, NULL, 0, false, loop); } /** Start a main loop