mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-10-31 22:25:38 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

pulse-server: set record attributes more like PulseAudio

Browse source 
PulseAudio assigns half of the fragsize to the source latency.
PulseAudio sends in chunks up to a fixed limit.

Checked against #2418
This commit is contained in:
Wim Taymans 2022-09-05 18:13:12 +02:00
parent ad06db91ee
commit 1a915c2ced
1 changed files with 8 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -87,6 +87,9 @@
#define DEFAULT_POSITION "[ FL FR ]"
#define MAX_FORMATS 32
/* The max amount of data we send in one block when capturing. In PulseAudio this
* size is derived from the mempool PA_MEMPOOL_SLOT_SIZE */
#define MAX_FRAGSIZE (64*1024)
#define TEMPORARY_MOVE_TIMEOUT (SPA_NSEC_PER_SEC)
@ -670,13 +673,9 @@ static uint32_t fix_record_buffer_attr(struct stream *s, struct buffer_attr *att
attr->tlength = attr->minreq = attr->prebuf = 0;
if (s->early_requests) {
latency = attr->fragsize;
} else if (s->adjust_latency) {
latency = attr->fragsize;
} else {
latency = attr->fragsize;
}
/* pulseaudio configures half the fragsize as latency in the source. */
latency = attr->fragsize / 2;
/* make sure can queue at least to fragsize without overruns */
if (attr->maxlength < attr->fragsize * 4)
attr->maxlength = attr->fragsize * 4;
@ -1335,7 +1334,8 @@ do_process_done(struct spa_loop *loop,
pw_log_trace("avail:%d index:%u", avail, index);
while ((uint32_t)avail >= stream->attr.fragsize) {
towrite = SPA_MIN((uint32_t)avail, stream->attr.fragsize);
towrite = SPA_MIN(avail, MAX_FRAGSIZE);
towrite = SPA_ROUND_DOWN(towrite, stream->frame_size);
msg = message_alloc(impl, stream->channel, towrite);
if (msg == NULL)