ahill/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2026-01-26 14:13:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

bluez5: media-source: do buffering on connection start also with PLC

Browse Source 
Also when we are capable of PLC, it's better to buffer audio at start,
to get a buffer level close to the target initially.

Delay ISO overrun handling one cycle after buffering is complete, so
that any resamplers are filled at that point.
This commit is contained in:
Pauli Virtanen 2026-01-01 11:50:43 +02:00 committed by Wim Taymans
parent 1d7e89e069
commit b535534611
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
spa/plugins/bluez5/iso-io.c
View File

@ -682,7 +682,6 @@ void spa_bt_iso_io_set_source_buffer(struct spa_bt_iso_io *this, struct spa_bt_d
if (buffer) {
/* Take over buffer overrun handling */
buffer->no_overrun_drop = true;
buffer->buffering = false;
buffer->avg_period = ISO_BUFFERING_AVG_PERIOD;
buffer->rate_diff_max = ISO_BUFFERING_RATE_DIFF_MAX;
}

10
spa/plugins/bluez5/media-source.c
View File

@ -173,6 +173,7 @@ struct impl {
int seqnum;
uint32_t plc_packets;
bool initial_buffering;
uint32_t errqueue_count;
@ -555,6 +556,8 @@ static int produce_plc_data(struct impl *this)
if (!this->codec->produce_plc)
return -ENOTSUP;
if (this->initial_buffering)
return -EINVAL;
buf = spa_bt_decode_buffer_get_write(&port->buffer, &avail);
res = this->codec->produce_plc(this->codec_data, buf, avail);
@ -1059,6 +1062,8 @@ static int transport_start(struct impl *this)
spa_loop_locked(this->data_loop, do_start_sco_iso_io, 0, NULL, 0, this);
}
this->initial_buffering = true;
this->transport_started = true;
set_latency(this, true);
@ -1875,9 +1880,12 @@ static void process_buffering(struct impl *this)
spa_list_append(&port->ready, &buffer->link);
}
if (this->transport->iso_io && this->position)
if (this->transport->iso_io && this->position && !this->initial_buffering)
spa_bt_iso_io_check_rx_sync(this->transport->iso_io, this->position->clock.position);
if (!port->buffer.buffering)
this->initial_buffering = false;
if (this->update_delay_event) {
int32_t target = spa_bt_decode_buffer_get_target_latency(&port->buffer);
uint32_t decoder_delay = 0;