sjg/trx-rs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[fix](trx-server): remove unused pass_start_ms variable in wxsat decoder

Browse Source 
The variable was assigned in six places but never read, producing
compiler warnings. The other `pass_start_ms` in `run_wxsat_image_task`
is unaffected and still used.

https://claude.ai/code/session_01SWe5x4CWy1q6BXtX4Gt3Qd
Signed-off-by: Claude <noreply@anthropic.com>
This commit is contained in:
Claude
2026-03-28 11:32:00 +00:00
committed by Stan Grams
parent 560b6ec912
commit 929f1d3fab
1 changed files with 0 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/trx-server/src/audio.rs
-6
View File
@@ -2467,12 +2467,10 @@ pub async fn run_wxsat_decoder(
let mut decoder = AptDecoder::new(sample_rate); let mut decoder = AptDecoder::new(sample_rate);
let mut last_reset_seq: u64 = 0; let mut last_reset_seq: u64 = 0;
let mut active = state_rx.borrow().wxsat_decode_enabled; let mut active = state_rx.borrow().wxsat_decode_enabled;
let mut pass_start_ms: i64 = 0;
// Instant of the last time new lines were decoded (for auto-finalise) // Instant of the last time new lines were decoded (for auto-finalise)
let mut last_line_at = tokio::time::Instant::now(); let mut last_line_at = tokio::time::Instant::now();
if active { if active {
pass_start_ms = current_timestamp_ms();
pcm_rx = pcm_rx.resubscribe(); pcm_rx = pcm_rx.resubscribe();
} }
@@ -2484,7 +2482,6 @@ pub async fn run_wxsat_decoder(
active = state.wxsat_decode_enabled; active = state.wxsat_decode_enabled;
if active { if active {
decoder.reset(); decoder.reset();
pass_start_ms = current_timestamp_ms();
last_line_at = tokio::time::Instant::now(); last_line_at = tokio::time::Instant::now();
pcm_rx = pcm_rx.resubscribe(); pcm_rx = pcm_rx.resubscribe();
} }
@@ -2537,7 +2534,6 @@ pub async fn run_wxsat_decoder(
if new_reset_seq != last_reset_seq { if new_reset_seq != last_reset_seq {
last_reset_seq = new_reset_seq; last_reset_seq = new_reset_seq;
decoder.reset(); decoder.reset();
pass_start_ms = current_timestamp_ms();
} }
if was_active && !active { if was_active && !active {
// User disabled — finalise whatever we have // User disabled — finalise whatever we have
@@ -2556,7 +2552,6 @@ pub async fn run_wxsat_decoder(
.await; .await;
} else if !was_active && active { } else if !was_active && active {
decoder.reset(); decoder.reset();
pass_start_ms = current_timestamp_ms();
last_line_at = tokio::time::Instant::now(); last_line_at = tokio::time::Instant::now();
pcm_rx = pcm_rx.resubscribe(); pcm_rx = pcm_rx.resubscribe();
} }
@@ -2585,7 +2580,6 @@ pub async fn run_wxsat_decoder(
) )
.await; .await;
// Remain active; ready for the next pass // Remain active; ready for the next pass
pass_start_ms = current_timestamp_ms();
last_line_at = tokio::time::Instant::now(); last_line_at = tokio::time::Instant::now();
} }
} }