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

pulse-server: fix some allocation errors

Browse source
This commit is contained in:
Wim Taymans 2020-10-21 12:02:42 +02:00
parent d6391070c4
commit ee3298137b
1 changed files with 30 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

27
src/modules/module-protocol-pulse/pulse-server.c
View file

@ -525,6 +525,7 @@ static void stream_flush(struct stream *stream)
static void stream_free(struct stream *stream) static void stream_free(struct stream *stream)
{ {
struct client *client = stream->client; struct client *client = stream->client;
if (stream->channel != SPA_ID_INVALID)
pw_map_remove(&client->streams, stream->channel); pw_map_remove(&client->streams, stream->channel);
stream_flush(stream); stream_flush(stream);
if (stream->stream) { if (stream->stream) {
@ -1121,6 +1122,10 @@ static int do_create_playback_stream(struct client *client, uint32_t command, ui
const char *str; const char *str;
props = pw_properties_new(NULL, NULL); props = pw_properties_new(NULL, NULL);
if (props == NULL) {
res = -errno;
goto error;
}
if (client->version < 13) { if (client->version < 13) {
if ((res = message_get(m, if ((res = message_get(m,
@ -1239,6 +1244,10 @@ static int do_create_playback_stream(struct client *client, uint32_t command, ui
stream->corked = corked; stream->corked = corked;
stream->adjust_latency = adjust_latency; stream->adjust_latency = adjust_latency;
stream->channel = pw_map_insert_new(&client->streams, stream); stream->channel = pw_map_insert_new(&client->streams, stream);
if (stream->channel == SPA_ID_INVALID) {
res = -errno;
goto error;
}
stream->buffer = calloc(1, MAXLENGTH); stream->buffer = calloc(1, MAXLENGTH);
if (stream->buffer == NULL) { if (stream->buffer == NULL) {
@ -1354,6 +1363,10 @@ static int do_create_record_stream(struct client *client, uint32_t command, uint
struct spa_pod_builder b = SPA_POD_BUILDER_INIT(buffer, sizeof(buffer)); struct spa_pod_builder b = SPA_POD_BUILDER_INIT(buffer, sizeof(buffer));
props = pw_properties_new(NULL, NULL); props = pw_properties_new(NULL, NULL);
if (props == NULL) {
res = -errno;
goto error;
}
if (client->version < 13) { if (client->version < 13) {
if ((res = message_get(m, if ((res = message_get(m,
@ -1464,6 +1477,10 @@ static int do_create_record_stream(struct client *client, uint32_t command, uint
stream->corked = corked; stream->corked = corked;
stream->adjust_latency = adjust_latency; stream->adjust_latency = adjust_latency;
stream->channel = pw_map_insert_new(&client->streams, stream); stream->channel = pw_map_insert_new(&client->streams, stream);
if (stream->channel == SPA_ID_INVALID) {
res = -errno;
goto error;
}
stream->buffer = calloc(1, MAXLENGTH); stream->buffer = calloc(1, MAXLENGTH);
if (stream->buffer == NULL) { if (stream->buffer == NULL) {
@ -1791,6 +1808,10 @@ static int do_update_proplist(struct client *client, uint32_t command, uint32_t
int res; int res;
props = pw_properties_new(NULL, NULL); props = pw_properties_new(NULL, NULL);
if (props == NULL) {
res = -errno;
goto exit;
}
if (command != COMMAND_UPDATE_CLIENT_PROPLIST) { if (command != COMMAND_UPDATE_CLIENT_PROPLIST) {
if ((res = message_get(m, if ((res = message_get(m,
@ -1821,6 +1842,7 @@ static int do_update_proplist(struct client *client, uint32_t command, uint32_t
} }
res = reply_simple_ack(client, tag); res = reply_simple_ack(client, tag);
exit: exit:
if (props)
pw_properties_free(props); pw_properties_free(props);
return res; return res;
} }
@ -1836,6 +1858,10 @@ static int do_remove_proplist(struct client *client, uint32_t command, uint32_t
int res; int res;
props = pw_properties_new(NULL, NULL); props = pw_properties_new(NULL, NULL);
if (props == NULL) {
res = -errno;
goto exit;
}
if (command != COMMAND_REMOVE_CLIENT_PROPLIST) { if (command != COMMAND_REMOVE_CLIENT_PROPLIST) {
if ((res = message_get(m, if ((res = message_get(m,
@ -1880,6 +1906,7 @@ static int do_remove_proplist(struct client *client, uint32_t command, uint32_t
} }
res = reply_simple_ack(client, tag); res = reply_simple_ack(client, tag);
exit: exit:
if (props)
pw_properties_free(props); pw_properties_free(props);
return res; return res;
} }