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

pulse-server: don't add large blocks to cache

Browse source 
See #1840
This commit is contained in:
Wim Taymans 2021-11-23 17:44:01 +01:00
parent 418c6fbe96
commit 9feecb36d0
1 changed files with 5 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

7
src/modules/module-protocol-pulse/message.c
View file

@ -39,6 +39,7 @@
#include "message.h" #include "message.h"
#include "volume.h" #include "volume.h"
#define MAX_SIZE (256*1024)
#define MAX_ALLOCATED (16*1024 *1024) #define MAX_ALLOCATED (16*1024 *1024)
#define VOLUME_MUTED ((uint32_t) 0U) #define VOLUME_MUTED ((uint32_t) 0U)
@ -861,17 +862,17 @@ void message_free(struct impl *impl, struct message *msg, bool dequeue, bool des
if (dequeue) if (dequeue)
spa_list_remove(&msg->link); spa_list_remove(&msg->link);
if (msg->stat->allocated > MAX_ALLOCATED) if (msg->stat->allocated > MAX_ALLOCATED || msg->allocated > MAX_SIZE)
destroy = true; destroy = true;
if (destroy) { if (destroy) {
pw_log_trace("destroy message %p", msg); pw_log_trace("destroy message %p size:%d", msg, msg->allocated);
msg->stat->n_allocated--; msg->stat->n_allocated--;
msg->stat->allocated -= msg->allocated; msg->stat->allocated -= msg->allocated;
free(msg->data); free(msg->data);
free(msg); free(msg);
} else { } else {
pw_log_trace("recycle message %p", msg); pw_log_trace("recycle message %p size:%d", msg, msg->allocated);
spa_list_append(&impl->free_messages, &msg->link); spa_list_append(&impl->free_messages, &msg->link);
} }
} }