From 8000a55654d88fc5edaeed4faa7c65387484f32d Mon Sep 17 00:00:00 2001 From: Dmitry Sharshakov Date: Thu, 3 Nov 2022 10:39:07 +0300 Subject: [PATCH] module-rtp-source: make incoming RTP messages more elaborate --- src/modules/module-rtp-source.c | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/modules/module-rtp-source.c b/src/modules/module-rtp-source.c index 29cd2bd19..aeca32fd4 100644 --- a/src/modules/module-rtp-source.c +++ b/src/modules/module-rtp-source.c @@ -344,7 +344,6 @@ on_rtp_io(void *data, int fd, uint32_t mask) uint16_t seq; int32_t filled; - pw_log_trace("got rtp"); if ((len = recv(fd, buffer, sizeof(buffer), 0)) < 0) goto receive_error; @@ -380,6 +379,7 @@ on_rtp_io(void *data, int fd, uint32_t mask) expected_index = timestamp * sess->info.stride; if (!sess->have_sync) { + pw_log_trace("got rtp, no sync"); sess->ring.readindex = sess->ring.writeindex = index = expected_index; filled = 0; @@ -391,6 +391,7 @@ on_rtp_io(void *data, int fd, uint32_t mask) spa_dll_set_bw(&sess->dll, SPA_DLL_BW_MIN, 128, sess->info.info.rate); } else if (expected_index != index) { + pw_log_trace("got rtp, wrong timestamp"); pw_log_debug("unexpected timestamp (%u != %u)", index / sess->info.stride, expected_index / sess->info.stride); @@ -399,9 +400,11 @@ on_rtp_io(void *data, int fd, uint32_t mask) } if (filled + len > BUFFER_SIZE) { + pw_log_trace("got rtp, overrun"); pw_log_warn("capture overrun %u %zd", filled, len); sess->have_sync = false; } else { + pw_log_trace("got rtp, buffering"); spa_ringbuffer_write_data(&sess->ring, sess->buffer, BUFFER_SIZE,