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

module-rtp-source: make incoming RTP messages more elaborate

Browse source
This commit is contained in:
Dmitry Sharshakov 2022-11-03 10:39:07 +03:00 • committed by Wim Taymans
parent f59b652142
commit 8000a55654
1 changed files with 4 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

5
src/modules/module-rtp-source.c
View file

@ -344,7 +344,6 @@ on_rtp_io(void *data, int fd, uint32_t mask)
uint16_t seq; uint16_t seq;
int32_t filled; int32_t filled;
pw_log_trace("got rtp");
if ((len = recv(fd, buffer, sizeof(buffer), 0)) < 0) if ((len = recv(fd, buffer, sizeof(buffer), 0)) < 0)
goto receive_error; goto receive_error;
@ -380,6 +379,7 @@ on_rtp_io(void *data, int fd, uint32_t mask)
expected_index = timestamp * sess->info.stride; expected_index = timestamp * sess->info.stride;
if (!sess->have_sync) { if (!sess->have_sync) {
pw_log_trace("got rtp, no sync");
sess->ring.readindex = sess->ring.writeindex = sess->ring.readindex = sess->ring.writeindex =
index = expected_index; index = expected_index;
filled = 0; 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); spa_dll_set_bw(&sess->dll, SPA_DLL_BW_MIN, 128, sess->info.info.rate);
} else if (expected_index != index) { } else if (expected_index != index) {
pw_log_trace("got rtp, wrong timestamp");
pw_log_debug("unexpected timestamp (%u != %u)", pw_log_debug("unexpected timestamp (%u != %u)",
index / sess->info.stride, index / sess->info.stride,
expected_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) { if (filled + len > BUFFER_SIZE) {
pw_log_trace("got rtp, overrun");
pw_log_warn("capture overrun %u %zd", filled, len); pw_log_warn("capture overrun %u %zd", filled, len);
sess->have_sync = false; sess->have_sync = false;
} else { } else {
pw_log_trace("got rtp, buffering");
spa_ringbuffer_write_data(&sess->ring, spa_ringbuffer_write_data(&sess->ring,
sess->buffer, sess->buffer,
BUFFER_SIZE, BUFFER_SIZE,