unom/punktfunk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 16 Wiki Activity

style: rustfmt drift from the AMF/watchdog commits

Browse Source 
`cargo fmt --all --check` (a CI gate) failed on main: config.rs (the new
`zerocopy: val(...).map { !matches!(...) }` from 76bc7fe) and punktfunk1.rs
(the `reset_stalled_encoder` conditions from 167d590) were left unwrapped by
the pinned rustfmt. Pure reformat, no semantic change.

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
This commit is contained in:
Enrico Bühler
2026-07-06 12:59:40 +00:00
parent f47d417f37
commit eaaf176adf
2 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/punktfunk-host/src/config.rs
+4 -1
View File
@@ -89,7 +89,10 @@ impl HostConfig {
.and_then(|s| s.parse::<usize>().ok()) .and_then(|s| s.parse::<usize>().ok())
.unwrap_or(2), .unwrap_or(2),
zerocopy: val("PUNKTFUNK_ZEROCOPY").map(|s| { zerocopy: val("PUNKTFUNK_ZEROCOPY").map(|s| {
!matches!(s.trim().to_ascii_lowercase().as_str(), "0" | "false" | "off" | "no") !matches!(
s.trim().to_ascii_lowercase().as_str(),
"0" | "false" | "off" | "no"
)
}), }),
ten_bit: flag("PUNKTFUNK_10BIT"), ten_bit: flag("PUNKTFUNK_10BIT"),
four_four_four: flag("PUNKTFUNK_444"), four_four_four: flag("PUNKTFUNK_444"),
crates/punktfunk-host/src/punktfunk1.rs
+4 -2
View File
@@ -3586,7 +3586,8 @@ fn virtual_stream(ctx: SessionContext) -> Result<()> {
// (bounded) instead of killing an otherwise healthy session; a backend without an // (bounded) instead of killing an otherwise healthy session; a backend without an
// in-place rebuild keeps today's fail-fast behavior. // in-place rebuild keeps today's fail-fast behavior.
encoder_resets += 1; encoder_resets += 1;
if encoder_resets > MAX_ENCODER_RESETS || !reset_stalled_encoder(&mut enc, &mut inflight) if encoder_resets > MAX_ENCODER_RESETS
|| !reset_stalled_encoder(&mut enc, &mut inflight)
{ {
return Err(e).context("encoder submit"); return Err(e).context("encoder submit");
} }
@@ -3710,7 +3711,8 @@ fn virtual_stream(ctx: SessionContext) -> Result<()> {
), ),
}; };
encoder_resets += 1; encoder_resets += 1;
if encoder_resets > MAX_ENCODER_RESETS || !reset_stalled_encoder(&mut enc, &mut inflight) if encoder_resets > MAX_ENCODER_RESETS
|| !reset_stalled_encoder(&mut enc, &mut inflight)
{ {
return Err(poll_err.unwrap_or_else(|| anyhow!("{why}"))) return Err(poll_err.unwrap_or_else(|| anyhow!("{why}")))
.context("encoder stalled — in-place rebuild unavailable or exhausted"); .context("encoder stalled — in-place rebuild unavailable or exhausted");