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

modules: add source ip and port in stream props

Browse source
This commit is contained in:
Wim Taymans 2023-12-11 10:04:14 +01:00
parent f31d87cfee
commit fbaf4db6b0
1 changed files with 17 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -194,6 +194,19 @@ short_packet:
return; return;
} }
static int get_ip(const struct sockaddr_storage *sa, char *ip, size_t len)
{
if (sa->ss_family == AF_INET) {
struct sockaddr_in *in = (struct sockaddr_in*)sa;
inet_ntop(sa->ss_family, &in->sin_addr, ip, len);
} else if (sa->ss_family == AF_INET6) {
struct sockaddr_in6 *in = (struct sockaddr_in6*)sa;
inet_ntop(sa->ss_family, &in->sin6_addr, ip, len);
} else
return -EIO;
return 0;
}
static int parse_address(const char *address, uint16_t port, static int parse_address(const char *address, uint16_t port,
struct sockaddr_storage *addr, socklen_t *len) struct sockaddr_storage *addr, socklen_t *len)
{ {
@ -447,6 +460,7 @@ int pipewire__module_init(struct pw_impl_module *module, const char *args)
struct timespec value, interval; struct timespec value, interval;
struct pw_properties *props, *stream_props; struct pw_properties *props, *stream_props;
int64_t ts_offset; int64_t ts_offset;
char addr[128];
int res = 0; int res = 0;
PW_LOG_TOPIC_INIT(mod_topic); PW_LOG_TOPIC_INIT(mod_topic);
@ -521,6 +535,9 @@ int pipewire__module_init(struct pw_impl_module *module, const char *args)
pw_log_error("invalid source.ip %s: %s", str, spa_strerror(res)); pw_log_error("invalid source.ip %s: %s", str, spa_strerror(res));
goto out; goto out;
} }
get_ip(&impl->src_addr, addr, sizeof(addr));
pw_properties_set(stream_props, "rtp.source.ip", addr);
pw_properties_setf(stream_props, "rtp.source.port", "%u", impl->src_port);
ts_offset = pw_properties_get_int64(props, "sess.ts-offset", DEFAULT_TS_OFFSET); ts_offset = pw_properties_get_int64(props, "sess.ts-offset", DEFAULT_TS_OFFSET);
if (ts_offset == -1) if (ts_offset == -1)