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

loop: improve update_timer

Browse source 
Handle NULL time as now when specifying an interval.
This commit is contained in:
Wim Taymans 2017-03-30 09:18:26 +02:00
parent 61885b00b6
commit 73ec9e2d24
2 changed files with 8 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

7
pinos/client/loop.c
View file

@ -505,8 +505,13 @@ loop_update_timer (SpaSource *source,
int flags = 0; int flags = 0;
spa_zero (its); spa_zero (its);
if (value) if (value) {
its.it_value = *value; its.it_value = *value;
}
else if (interval) {
its.it_value = *interval;
absolute = true;
}
if (interval) if (interval)
its.it_interval = *interval; its.it_interval = *interval;
if (absolute) if (absolute)

6
pinos/client/stream.c
View file

@ -542,7 +542,7 @@ static void
handle_socket (PinosStream *stream, int rtfd) handle_socket (PinosStream *stream, int rtfd)
{ {
PinosStreamImpl *impl = SPA_CONTAINER_OF (stream, PinosStreamImpl, this); PinosStreamImpl *impl = SPA_CONTAINER_OF (stream, PinosStreamImpl, this);
struct timespec interval, start; struct timespec interval;
impl->rtfd = rtfd; impl->rtfd = rtfd;
impl->rtsocket_source = pinos_loop_add_io (stream->context->loop, impl->rtsocket_source = pinos_loop_add_io (stream->context->loop,
@ -555,13 +555,11 @@ handle_socket (PinosStream *stream, int rtfd)
impl->timeout_source = pinos_loop_add_timer (stream->context->loop, impl->timeout_source = pinos_loop_add_timer (stream->context->loop,
on_timeout, on_timeout,
stream); stream);
start.tv_sec = 0;
start.tv_nsec = 100000000;
interval.tv_sec = 0; interval.tv_sec = 0;
interval.tv_nsec = 100000000; interval.tv_nsec = 100000000;
pinos_loop_update_timer (stream->context->loop, pinos_loop_update_timer (stream->context->loop,
impl->timeout_source, impl->timeout_source,
&start, NULL,
&interval, &interval,
false); false);
return; return;