mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-04 13:30:12 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

spa: support: loop: add polling flag

Browse source 
Store whether or not the loop is currently polling, i.e.
calling `spa_system_pollfd_wait()`.
This commit is contained in:
Barnabás Pőcze 2022-02-19 11:44:04 +01:00 • committed by Wim Taymans
parent 4ed0365976
commit 2eb36c00c1
1 changed files with 3 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

3
spa/plugins/support/loop.c
View file

@ -90,6 +90,7 @@ struct impl {
uint8_t buffer_mem[DATAS_SIZE + MAX_ALIGN]; uint8_t buffer_mem[DATAS_SIZE + MAX_ALIGN];
unsigned int flushing:1; unsigned int flushing:1;
unsigned int polling:1;
}; };
struct source_impl { struct source_impl {
@ -350,11 +351,13 @@ static int loop_iterate(void *object, int timeout)
struct spa_poll_event ep[MAX_EP], *e; struct spa_poll_event ep[MAX_EP], *e;
int i, nfds; int i, nfds;
impl->polling = true;
spa_loop_control_hook_before(&impl->hooks_list); spa_loop_control_hook_before(&impl->hooks_list);
nfds = spa_system_pollfd_wait(impl->system, impl->poll_fd, ep, SPA_N_ELEMENTS(ep), timeout); nfds = spa_system_pollfd_wait(impl->system, impl->poll_fd, ep, SPA_N_ELEMENTS(ep), timeout);
spa_loop_control_hook_after(&impl->hooks_list); spa_loop_control_hook_after(&impl->hooks_list);
impl->polling = false;
/* first we set all the rmasks, then call the callbacks. The reason is that /* first we set all the rmasks, then call the callbacks. The reason is that
* some callback might also want to look at other sources it manages and * some callback might also want to look at other sources it manages and