Mirrors/bark
2
0
Fork 0
mirror of https://github.com/haileys/bark synced 2025-03-16 22:57:00 +00:00
Code Issues Projects Releases Packages Wiki Activity

receiver signals lost packets to decoder

Browse source
This commit is contained in:
Hailey Somerville 2023-12-27 16:31:15 +11:00
parent 90fb076fff
commit 4aa5850055
1 changed files with 15 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
bark/src/receive.rs
View file

@ -171,21 +171,23 @@ impl Receiver {
return SampleDuration::ONE_PACKET;
};
let Some(packet) = stream.queue.pop_front() else {
// no packets yet
buffer[0..SAMPLES_PER_PACKET].fill(0f32);
return SampleDuration::ONE_PACKET;
};
// get next packet from queue, or None if missing (packet loss)
let packet = stream.queue.pop_front();
let header_pts = Timestamp::from_micros_lossy(packet.header().pts);
// calculate stream timing from packet timing info if present
let header_pts = packet.as_ref()
.map(|packet| packet.header().pts)
.map(Timestamp::from_micros_lossy);
let timing = stream.adjust_pts(header_pts)
.map(|stream_pts| Timing {
real: pts,
play: stream_pts,
});
let stream_pts = header_pts
.and_then(|header_pts| stream.adjust_pts(header_pts));
// adjust resampler rate based on packet timing info
let timing = stream_pts.map(|stream_pts| Timing {
real: pts,
play: stream_pts,
});
// adjust resampler rate based on stream timing info
if let Some(timing) = timing {
let rate = stream.rate_adjust.sample_rate(timing);
@ -203,7 +205,7 @@ impl Receiver {
// decode packet
let mut decode_buffer: SampleBuffer = array::from_fn(|_| 0.0);
if let Some(decoder) = stream.decoder.as_mut() {
match decoder.decode(Some(&packet), &mut decode_buffer) {
match decoder.decode(packet.as_ref(), &mut decode_buffer) {
Ok(()) => {}
Err(e) => {
log::warn!("error in decoder, skipping packet: {e}");