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

node-driver: make the timerfd non-blocking

Browse source 
Relates to #1377
This commit is contained in:
George Kiagiadakis 2021-07-01 11:50:40 +03:00
parent c633004bf3
commit 5aa9c95390
1 changed files with 6 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

8
spa/plugins/support/node-driver.c
View file

@ -119,8 +119,11 @@ static void on_timeout(struct spa_source *source)
spa_log_trace(this->log, "timeout"); spa_log_trace(this->log, "timeout");
if (spa_system_timerfd_read(this->data_system, if (spa_system_timerfd_read(this->data_system,
this->timer_source.fd, &expirations) < 0) this->timer_source.fd, &expirations) < 0) {
if (errno == EAGAIN)
return;
perror("read timerfd"); perror("read timerfd");
}
nsec = this->next_time; nsec = this->next_time;
@ -349,7 +352,8 @@ impl_init(const struct spa_handle_factory *factory,
this->timer_source.func = on_timeout; this->timer_source.func = on_timeout;
this->timer_source.data = this; this->timer_source.data = this;
this->timer_source.fd = spa_system_timerfd_create(this->data_system, CLOCK_MONOTONIC, SPA_FD_CLOEXEC); this->timer_source.fd = spa_system_timerfd_create(this->data_system, CLOCK_MONOTONIC,
SPA_FD_CLOEXEC | SPA_FD_NONBLOCK);
this->timer_source.mask = SPA_IO_IN; this->timer_source.mask = SPA_IO_IN;
this->timer_source.rmask = 0; this->timer_source.rmask = 0;
this->timerspec.it_value.tv_sec = 0; this->timerspec.it_value.tv_sec = 0;