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: add some properties

Browse source
This commit is contained in:
Wim Taymans 2022-10-04 23:27:44 +02:00
parent f20959d62f
commit 6065c699bf
1 changed files with 9 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -236,7 +236,7 @@ on_rtp_io(void *data, int fd, uint32_t mask)
uint32_t index; uint32_t index;
int32_t filled; int32_t filled;
pw_log_info("got rtp"); pw_log_debug("got rtp");
if ((len = recv(fd, buffer, sizeof(buffer), 0)) < 0) { if ((len = recv(fd, buffer, sizeof(buffer), 0)) < 0) {
pw_log_warn("recv error: %m"); pw_log_warn("recv error: %m");
return; return;
@ -355,6 +355,11 @@ static int session_new(struct impl *impl, struct sdp_info *sdp)
return -errno; return -errno;
pw_properties_setf(props, PW_KEY_NODE_RATE, "1/%d", sdp->info.rate); pw_properties_setf(props, PW_KEY_NODE_RATE, "1/%d", sdp->info.rate);
pw_properties_set(props, "rtp.origin", sdp->origin);
pw_properties_set(props, "rtp.session", sdp->session);
pw_properties_setf(props, "rtp.payload", "%u", sdp->payload);
pw_log_info("new session %s %s", sdp->origin, sdp->session);
session->playback = pw_stream_new(impl->core, session->playback = pw_stream_new(impl->core,
"rtp-source playback", props); "rtp-source playback", props);
@ -382,6 +387,7 @@ static int session_new(struct impl *impl, struct sdp_info *sdp)
if ((fd = make_multicast_socket((const struct sockaddr *)&sdp->sa, sdp->salen)) < 0) if ((fd = make_multicast_socket((const struct sockaddr *)&sdp->sa, sdp->salen)) < 0)
return fd; return fd;
pw_log_info("starting RTP listener");
session->source = pw_loop_add_io(impl->loop, fd, session->source = pw_loop_add_io(impl->loop, fd,
SPA_IO_IN, true, on_rtp_io, session); SPA_IO_IN, true, on_rtp_io, session);
if (session->source == NULL) if (session->source == NULL)
@ -529,7 +535,7 @@ static int parse_sdp(struct impl *impl, char *sdp, struct sdp_info *info)
goto too_short; goto too_short;
s[l] = 0; s[l] = 0;
pw_log_info("%d: %s", count, s); pw_log_debug("%d: %s", count, s);
if (count++ == 0 && strcmp(s, "v=0") != 0) if (count++ == 0 && strcmp(s, "v=0") != 0)
goto invalid_version; goto invalid_version;
@ -592,7 +598,7 @@ static int parse_sap(struct impl *impl, void *data, size_t len)
else else
return -EINVAL; return -EINVAL;
pw_log_info("got sap: %s", mime); pw_log_debug("got sap: %s %s", mime, sdp);
spa_zero(info); spa_zero(info);
if ((res = parse_sdp(impl, sdp, &info)) < 0) if ((res = parse_sdp(impl, sdp, &info)) < 0)