manawenuz/wz-phone
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: record mode decode-per-packet (same fix as live mode)

Browse Source 
The --record recv loop was using while-drain which exhausted the jitter
buffer and stopped decoding after the first burst. Now decodes once per
source packet, matching the live mode fix.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
Siavash Sameni
2026-03-27 18:05:10 +04:00
parent d5390db7af
commit a04b8271cc
1 changed files with 12 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
crates/wzp-client/src/cli.rs
View File

@@ -325,8 +325,10 @@ async fn run_file_mode(
result = recv_transport.recv_media() => { result = recv_transport.recv_media() => {
match result { match result {
Ok(Some(pkt)) => { Ok(Some(pkt)) => {
let is_repair = pkt.header.is_repair;
decoder.ingest(pkt); decoder.ingest(pkt);
while let Some(n) = decoder.decode_next(&mut pcm_buf) { if !is_repair {
if let Some(n) = decoder.decode_next(&mut pcm_buf) {
all_pcm.extend_from_slice(&pcm_buf[..n]); all_pcm.extend_from_slice(&pcm_buf[..n]);
frames_received += 1; frames_received += 1;
if frames_received % 250 == 0 { if frames_received % 250 == 0 {
@@ -338,6 +340,7 @@ async fn run_file_mode(
} }
} }
} }
}
Ok(None) => { Ok(None) => {
info!("connection closed by remote"); info!("connection closed by remote");
break; break;