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

stream: return error when no timing info yet

Browse source
This commit is contained in:
Wim Taymans 2018-08-13 14:28:25 +02:00
parent e6b7dd1d0f
commit 5a3883509b
1 changed files with 7 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/pipewire/stream.c
View file

@ -932,6 +932,8 @@ static void client_node_command(void *data, uint32_t seq, const struct spa_comma
impl->last_ticks = cu->body.ticks.value; impl->last_ticks = cu->body.ticks.value;
impl->last_rate = cu->body.rate.value; impl->last_rate = cu->body.rate.value;
impl->last_monotonic = cu->body.monotonic_time.value; impl->last_monotonic = cu->body.monotonic_time.value;
pw_log_debug("clock update %ld %d %ld", impl->last_ticks,
impl->last_rate, impl->last_monotonic);
} else { } else {
pw_log_warn("unhandled node command %d", SPA_COMMAND_TYPE(command)); pw_log_warn("unhandled node command %d", SPA_COMMAND_TYPE(command));
add_async_complete(stream, seq, -ENOTSUP); add_async_complete(stream, seq, -ENOTSUP);
@ -1374,6 +1376,9 @@ int pw_stream_get_time(struct pw_stream *stream, struct pw_time *time)
int64_t elapsed; int64_t elapsed;
struct timespec ts; struct timespec ts;
if (impl->last_rate == 0)
return -EAGAIN;
clock_gettime(CLOCK_MONOTONIC, &ts); clock_gettime(CLOCK_MONOTONIC, &ts);
time->now = SPA_TIMESPEC_TO_TIME(&ts); time->now = SPA_TIMESPEC_TO_TIME(&ts);
elapsed = (time->now - impl->last_monotonic) / 1000; elapsed = (time->now - impl->last_monotonic) / 1000;
@ -1387,7 +1392,8 @@ int pw_stream_get_time(struct pw_stream *stream, struct pw_time *time)
else else
time->queued = get_queue_size(&impl->queue); time->queued = get_queue_size(&impl->queue);
pw_log_trace("%ld %d/%d %ld", time->ticks, time->rate.num, time->rate.denom, time->queued); pw_log_trace("stream %p: %ld %d/%d %ld", stream,
time->ticks, time->rate.num, time->rate.denom, time->queued);
return 0; return 0;
} }