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

pulse-server: add some debugging

Browse source
This commit is contained in:
Wim Taymans 2022-07-13 10:42:00 +02:00
parent 52281b9a7e
commit 855d17ac1b
1 changed files with 7 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/modules/module-protocol-pulse/pulse-server.c
View file

@ -1332,6 +1332,7 @@ do_process_done(struct spa_loop *loop,
stream->read_index += skip; stream->read_index += skip;
avail = stream->attr.fragsize; avail = stream->attr.fragsize;
} }
pw_log_trace("avail:%d index:%u", avail, index);
while ((uint32_t)avail >= stream->attr.fragsize) { while ((uint32_t)avail >= stream->attr.fragsize) {
towrite = SPA_MIN((uint32_t)avail, stream->attr.fragsize); towrite = SPA_MIN((uint32_t)avail, stream->attr.fragsize);
@ -2124,7 +2125,7 @@ static int do_get_playback_latency(struct client *client, uint32_t command, uint
if (stream == NULL || stream->type != STREAM_TYPE_PLAYBACK) if (stream == NULL || stream->type != STREAM_TYPE_PLAYBACK)
return -ENOENT; return -ENOENT;
pw_log_debug("read:%"PRIx64" write:%"PRIx64" queued:%"PRIi64" delay:%"PRIi64 pw_log_debug("read:0x%"PRIx64" write:0x%"PRIx64" queued:%"PRIi64" delay:%"PRIi64
" playing:%"PRIu64, " playing:%"PRIu64,
stream->read_index, stream->write_index, stream->read_index, stream->write_index,
stream->write_index - stream->read_index, stream->delay, stream->write_index - stream->read_index, stream->delay,
@ -2173,6 +2174,11 @@ static int do_get_record_latency(struct client *client, uint32_t command, uint32
if (stream == NULL || stream->type != STREAM_TYPE_RECORD) if (stream == NULL || stream->type != STREAM_TYPE_RECORD)
return -ENOENT; return -ENOENT;
pw_log_debug("read:0x%"PRIx64" write:0x%"PRIx64" queued:%"PRIi64" delay:%"PRIi64,
stream->read_index, stream->write_index,
stream->write_index - stream->read_index, stream->delay);
gettimeofday(&now, NULL); gettimeofday(&now, NULL);
reply = reply_new(client, tag); reply = reply_new(client, tag);
message_put(reply, message_put(reply,