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: Make max SAP sessions configurable

Browse source 
Keep the current limit, but allow for more if someone wants to track
more.
This commit is contained in:
Arun Raghavan 2024-07-16 08:45:50 -04:00
parent 291fd9704f
commit a3c68ef9cf
1 changed files with 8 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

13
src/modules/module-rtp-sap.c
View file

@ -61,6 +61,7 @@
* - `net.ttl = <int>`: TTL to use, default 1 * - `net.ttl = <int>`: TTL to use, default 1
* - `net.loop = <bool>`: loopback multicast, default false * - `net.loop = <bool>`: loopback multicast, default false
* - `stream.rules` = <rules>: match rules, use create-stream and announce-stream actions * - `stream.rules` = <rules>: match rules, use create-stream and announce-stream actions
* - `sap.max-sessions = <int>`: maximum number of concurrent send/receive sessions to track
* - `sap.preamble-extra = [strings]`: extra attributes to add to the atomic SDP preamble * - `sap.preamble-extra = [strings]`: extra attributes to add to the atomic SDP preamble
* - `sap.end-extra = [strings]`: extra attributes to add to the end of the SDP message * - `sap.end-extra = [strings]`: extra attributes to add to the end of the SDP message
* *
@ -134,7 +135,7 @@
PW_LOG_TOPIC_STATIC(mod_topic, "mod." NAME); PW_LOG_TOPIC_STATIC(mod_topic, "mod." NAME);
#define PW_LOG_TOPIC_DEFAULT mod_topic #define PW_LOG_TOPIC_DEFAULT mod_topic
#define MAX_SESSIONS 64 #define DEFAULT_MAX_SESSIONS 64
#define DEFAULT_ANNOUNCE_RULES \ #define DEFAULT_ANNOUNCE_RULES \
"[ { matches = [ { sess.sap.announce = true } ] actions = { announce-stream = { } } } ]" "[ { matches = [ { sess.sap.announce = true } ] actions = { announce-stream = { } } } ]"
@ -272,6 +273,7 @@ struct impl {
struct spa_source *sap_source; struct spa_source *sap_source;
uint32_t cleanup_interval; uint32_t cleanup_interval;
uint32_t max_sessions;
uint32_t n_sessions; uint32_t n_sessions;
struct spa_list sessions; struct spa_list sessions;
@ -842,8 +844,8 @@ static struct session *session_new_announce(struct impl *impl, struct node *node
if (node->session) if (node->session)
session_free(node->session); session_free(node->session);
if (impl->n_sessions >= MAX_SESSIONS) { if (impl->n_sessions >= impl->max_sessions) {
pw_log_warn("too many sessions (%u >= %u)", impl->n_sessions, MAX_SESSIONS); pw_log_warn("too many sessions (%u >= %u)", impl->n_sessions, impl->max_sessions);
errno = EMFILE; errno = EMFILE;
return NULL; return NULL;
} }
@ -1103,8 +1105,8 @@ static struct session *session_new(struct impl *impl, struct sdp_info *info)
const char *str; const char *str;
char dst_addr[64], tmp[64]; char dst_addr[64], tmp[64];
if (impl->n_sessions >= MAX_SESSIONS) { if (impl->n_sessions >= impl->max_sessions) {
pw_log_warn("too many sessions (%u >= %u)", impl->n_sessions, MAX_SESSIONS); pw_log_warn("too many sessions (%u >= %u)", impl->n_sessions, impl->max_sessions);
errno = EMFILE; errno = EMFILE;
return NULL; return NULL;
} }
@ -1784,6 +1786,7 @@ int pipewire__module_init(struct pw_impl_module *module, const char *args)
impl->ttl = pw_properties_get_uint32(props, "net.ttl", DEFAULT_TTL); impl->ttl = pw_properties_get_uint32(props, "net.ttl", DEFAULT_TTL);
impl->mcast_loop = pw_properties_get_bool(props, "net.loop", DEFAULT_LOOP); impl->mcast_loop = pw_properties_get_bool(props, "net.loop", DEFAULT_LOOP);
impl->max_sessions = pw_properties_get_uint32(props, "sap.max-sessions", DEFAULT_MAX_SESSIONS);
impl->extra_attrs_preamble = NULL; impl->extra_attrs_preamble = NULL;
impl->extra_attrs_end = NULL; impl->extra_attrs_end = NULL;