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

bluez5: media-sink: Skip samples to align audio data for ASHA

Browse source 
For ASHA, we want the media sinks to send packets where the ASHA packet
sequence number corresponds to time position of audio in that packet.
This commit is contained in:
Arun Raghavan 2025-04-22 11:56:11 +05:30 • committed by Wim Taymans
parent efb4a1df25
commit c5b5476aa4
1 changed files with 13 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

13
spa/plugins/bluez5/media-sink.c
View file

@ -117,6 +117,8 @@ struct spa_bt_asha {
uint64_t ref_t0; uint64_t ref_t0;
uint64_t ref_timer; uint64_t ref_timer;
uint64_t skip_frames;
uint64_t prev_time; uint64_t prev_time;
uint64_t next_time; uint64_t next_time;
@ -366,9 +368,12 @@ static int set_asha_timer(struct impl *this, bool snap)
if (snap) { if (snap) {
/* If requested, snap our wakeup time to a 20ms interval */ /* If requested, snap our wakeup time to a 20ms interval */
offset = (now_ns - this->asha->ref_timer) % ASHA_CONN_INTERVAL; offset = (now_ns - this->asha->ref_timer) % ASHA_CONN_INTERVAL;
this->asha->skip_frames = offset * this->port.current_format.info.raw.rate / SPA_NSEC_PER_SEC;
spa_log_debug(this->log, "will skip %"PRIu64 " frames", this->asha->skip_frames);
} else { } else {
/* Else, remember when we started this timer so the other side can use it */ /* Else, remember when we started this timer so the other side can use it */
this->asha->ref_timer = now_ns; this->asha->ref_timer = now_ns;
this->asha->skip_frames = 0;
} }
this->asha->prev_time = this->asha->next_time = now_ns + offset; this->asha->prev_time = this->asha->next_time = now_ns + offset;
@ -886,6 +891,14 @@ again:
avail = d[0].chunk->size - port->ready_offset; avail = d[0].chunk->size - port->ready_offset;
avail /= port->frame_size; avail /= port->frame_size;
if (is_asha && this->asha->skip_frames) {
/* Skip initial frames if needed */
uint64_t skip = SPA_MIN(this->asha->skip_frames, avail);
spa_log_trace(this->log, "skipping %"PRIu64 " frames", skip);
avail -= skip;
this->asha->skip_frames -= skip;
}
offs = index % d[0].maxsize; offs = index % d[0].maxsize;
n_frames = avail; n_frames = avail;
n_bytes = n_frames * port->frame_size; n_bytes = n_frames * port->frame_size;