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

module-rtp: Allow updating sess.name from params

Browse source 
We might want to add more such properties to be dynamically updated, but
just adding this one for now.
This commit is contained in:
Arun Raghavan 2024-06-28 12:04:05 -04:00
parent 59b9da9477
commit 02fea0ba8f
1 changed files with 16 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

28
src/modules/module-rtp-sink.c
View file

@ -333,6 +333,8 @@ static void stream_props_changed(struct impl *impl, uint32_t id, const struct sp
const char *key; const char *key;
struct spa_pod *pod; struct spa_pod *pod;
const char *value; const char *value;
struct spa_dict_item items[2];
unsigned int n_items = 0;
if (spa_pod_parse_object(param, SPA_TYPE_OBJECT_Props, NULL, SPA_PROP_params, if (spa_pod_parse_object(param, SPA_TYPE_OBJECT_Props, NULL, SPA_PROP_params,
SPA_POD_OPT_Pod(&params)) < 0) SPA_POD_OPT_Pod(&params)) < 0)
@ -341,7 +343,7 @@ static void stream_props_changed(struct impl *impl, uint32_t id, const struct sp
if (spa_pod_parser_push_struct(&prs, &f) < 0) if (spa_pod_parser_push_struct(&prs, &f) < 0)
return; return;
while (true) { while (n_items < SPA_N_ELEMENTS(items)) {
if (spa_pod_parser_get_string(&prs, &key) < 0) if (spa_pod_parser_get_string(&prs, &key) < 0)
break; break;
if (spa_pod_parser_get_pod(&prs, &pod) < 0) if (spa_pod_parser_get_pod(&prs, &pod) < 0)
@ -349,19 +351,21 @@ static void stream_props_changed(struct impl *impl, uint32_t id, const struct sp
if (spa_pod_get_string(pod, &value) < 0) if (spa_pod_get_string(pod, &value) < 0)
continue; continue;
pw_log_info("key '%s', value '%s'", key, value); pw_log_info("key '%s', value '%s'", key, value);
if (!spa_streq(key, "destination.ip")) if (spa_streq(key, "destination.ip")) {
continue; if (pw_net_parse_address(value, impl->dst_port, &impl->dst_addr,
if (pw_net_parse_address(value, impl->dst_port, &impl->dst_addr, &impl->dst_len) < 0) {
&impl->dst_len) < 0) { pw_log_error("invalid destination.ip: '%s'", value);
pw_log_error("invalid destination.ip: '%s'", value); break;
break; }
pw_properties_set(impl->stream_props, "rtp.destination.ip", value);
items[n_items++] = SPA_DICT_ITEM_INIT("rtp.destination.ip", value);
} else if (spa_streq(key, "sess.name")) {
pw_properties_set(impl->stream_props, "sess.name", value);
items[n_items++] = SPA_DICT_ITEM_INIT("sess.name", value);
} }
pw_properties_set(impl->stream_props, "rtp.destination.ip", value);
struct spa_dict_item item[1];
item[0] = SPA_DICT_ITEM_INIT("rtp.destination.ip", value);
rtp_stream_update_properties(impl->stream, &SPA_DICT_INIT(item, 1));
break;
} }
rtp_stream_update_properties(impl->stream, &SPA_DICT_INIT(items, n_items));
} }
} }
} }