mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2026-06-04 03:03:00 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

pulse: inline the message check

Browse source 
Inline the resize check and then call the resize function when
necessary.
This commit is contained in:
Wim Taymans 2026-05-26 14:48:47 +02:00
parent 7ce0b0f339
commit 753ed37ec5
1 changed files with 12 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -377,18 +377,12 @@ done:
return res; return res;
} }
static int ensure_size(struct message *m, uint32_t size) static int message_resize(struct message *m, uint32_t size)
{ {
uint64_t needed; uint64_t needed;
uint32_t alloc, diff; uint32_t alloc, diff;
void *data; void *data;
if (m->length > m->allocated)
return -ENOMEM;
if (size <= m->allocated - m->length)
return size;
needed = SPA_ROUND_UP_N(SPA_MAX((uint64_t)m->allocated + size, 4096u), 4096u); needed = SPA_ROUND_UP_N(SPA_MAX((uint64_t)m->allocated + size, 4096u), 4096u);
if (needed > UINT32_MAX) if (needed > UINT32_MAX)
return -ENOMEM; return -ENOMEM;
@ -408,6 +402,17 @@ static int ensure_size(struct message *m, uint32_t size)
return size; return size;
} }
static inline int ensure_size(struct message *m, uint32_t size)
{
if (m->length > m->allocated)
return -ENOMEM;
if (size <= m->allocated - m->length)
return size;
return message_resize(m, size);
}
static void write_8(struct message *m, uint8_t val) static void write_8(struct message *m, uint8_t val)
{ {
if (ensure_size(m, 1) > 0) if (ensure_size(m, 1) > 0)