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

module-protocol-simple: limit to 10 connections

Browse source 
Like in pulseaudio.
This commit is contained in:
Wim Taymans 2021-06-17 18:37:04 +02:00
parent 38c721993f
commit 3944687a14
1 changed files with 18 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

25
src/modules/module-protocol-simple.c
View file

@ -60,6 +60,8 @@
#define DEFAULT_POSITION "[ FL FR ]" #define DEFAULT_POSITION "[ FL FR ]"
#define DEFAULT_LATENCY "1024/48000" #define DEFAULT_LATENCY "1024/48000"
#define MAX_CLIENTS 10
#define MODULE_USAGE "[ capture=<bool> ] " \ #define MODULE_USAGE "[ capture=<bool> ] " \
"[ playback=<bool> ] " \ "[ playback=<bool> ] " \
"[ capture.node=<source-target> ] " \ "[ capture.node=<source-target> ] " \
@ -129,6 +131,7 @@ struct server {
struct spa_source *source; struct spa_source *source;
struct spa_list client_list; struct spa_list client_list;
uint32_t n_clients;
}; };
static void client_disconnect(struct client *client) static void client_disconnect(struct client *client)
@ -153,6 +156,7 @@ static void client_free(struct client *client)
client_disconnect(client); client_disconnect(client);
spa_list_remove(&client->link); spa_list_remove(&client->link);
client->server->n_clients--;
if (client->capture) if (client->capture)
pw_stream_destroy(client->capture); pw_stream_destroy(client->capture);
@ -465,6 +469,12 @@ on_connect(void *data, int fd, uint32_t mask)
if (client_fd < 0) if (client_fd < 0)
goto error; goto error;
if (server->n_clients >= MAX_CLIENTS) {
close(client_fd);
errno = ECONNREFUSED;
goto error;
}
client = calloc(1, sizeof(struct client)); client = calloc(1, sizeof(struct client));
if (client == NULL) if (client == NULL)
goto error; goto error;
@ -472,10 +482,18 @@ on_connect(void *data, int fd, uint32_t mask)
client->impl = impl; client->impl = impl;
client->server = server; client->server = server;
spa_list_append(&server->client_list, &client->link); spa_list_append(&server->client_list, &client->link);
server->n_clients++;
if (inet_ntop(addr.sa_family, addr.sa_data, client->name, sizeof(client->name)) == NULL) if (inet_ntop(addr.sa_family, addr.sa_data, client->name, sizeof(client->name)) == NULL)
snprintf(client->name, sizeof(client->name), "client %d", client_fd); snprintf(client->name, sizeof(client->name), "client %d", client_fd);
client->source = pw_loop_add_io(impl->loop,
client_fd,
SPA_IO_ERR | SPA_IO_HUP,
true, on_client_data, client);
if (client->source == NULL)
goto error;
pw_log_info(NAME" %p: client:%p [%s] connected", impl, client, client->name); pw_log_info(NAME" %p: client:%p [%s] connected", impl, client, client->name);
props = pw_properties_new( props = pw_properties_new(
@ -504,13 +522,6 @@ on_connect(void *data, int fd, uint32_t mask)
pw_properties_set(props, PW_KEY_CLIENT_ACCESS, "restricted"); pw_properties_set(props, PW_KEY_CLIENT_ACCESS, "restricted");
} }
client->source = pw_loop_add_io(impl->loop,
client_fd,
SPA_IO_ERR | SPA_IO_HUP,
true, on_client_data, client);
if (client->source == NULL)
goto error;
client->core = pw_context_connect(impl->context, props, 0); client->core = pw_context_connect(impl->context, props, 0);
props = NULL; props = NULL;
if (client->core == NULL) if (client->core == NULL)