style(host): rustfmt sweep for the console-sweep push
b8da32e8 landed with two call sites and a log line rustfmt rewraps;
CI's cargo fmt --all --check gate was failing on every run since.
No code change.
Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
This commit is contained in:
@@ -252,7 +252,13 @@ pub fn serve(
|
|||||||
);
|
);
|
||||||
tokio::try_join!(
|
tokio::try_join!(
|
||||||
nvhttp::run(state.clone()),
|
nvhttp::run(state.clone()),
|
||||||
crate::mgmt::run(state.clone(), mgmt, Some(np.clone()), stats.clone(), gamestream),
|
crate::mgmt::run(
|
||||||
|
state.clone(),
|
||||||
|
mgmt,
|
||||||
|
Some(np.clone()),
|
||||||
|
stats.clone(),
|
||||||
|
gamestream
|
||||||
|
),
|
||||||
crate::punktfunk1::serve(native_opts, native.mgmt_port, np, stats.clone()),
|
crate::punktfunk1::serve(native_opts, native.mgmt_port, np, stats.clone()),
|
||||||
)?;
|
)?;
|
||||||
} else {
|
} else {
|
||||||
@@ -263,7 +269,13 @@ pub fn serve(
|
|||||||
(GameStream OFF — pass --gamestream for stock-Moonlight compat)"
|
(GameStream OFF — pass --gamestream for stock-Moonlight compat)"
|
||||||
);
|
);
|
||||||
tokio::try_join!(
|
tokio::try_join!(
|
||||||
crate::mgmt::run(state.clone(), mgmt, Some(np.clone()), stats.clone(), gamestream),
|
crate::mgmt::run(
|
||||||
|
state.clone(),
|
||||||
|
mgmt,
|
||||||
|
Some(np.clone()),
|
||||||
|
stats.clone(),
|
||||||
|
gamestream
|
||||||
|
),
|
||||||
crate::punktfunk1::serve(native_opts, native.mgmt_port, np, stats.clone()),
|
crate::punktfunk1::serve(native_opts, native.mgmt_port, np, stats.clone()),
|
||||||
)?;
|
)?;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1530,11 +1530,13 @@ async fn get_local_summary(State(st): State<Arc<MgmtState>>) -> Json<LocalSummar
|
|||||||
fps: l.fps,
|
fps: l.fps,
|
||||||
})
|
})
|
||||||
.or_else(|| {
|
.or_else(|| {
|
||||||
crate::session_status::snapshot().first().map(|s| SessionInfo {
|
crate::session_status::snapshot()
|
||||||
width: s.width,
|
.first()
|
||||||
height: s.height,
|
.map(|s| SessionInfo {
|
||||||
fps: s.fps,
|
width: s.width,
|
||||||
})
|
height: s.height,
|
||||||
|
fps: s.fps,
|
||||||
|
})
|
||||||
});
|
});
|
||||||
let (native_paired_clients, pending_approvals) = st
|
let (native_paired_clients, pending_approvals) = st
|
||||||
.native
|
.native
|
||||||
@@ -2004,7 +2006,11 @@ async fn stop_session(State(st): State<Arc<MgmtState>>) -> StatusCode {
|
|||||||
// session registry), so signal every live native session to tear down too.
|
// session registry), so signal every live native session to tear down too.
|
||||||
let native = crate::session_status::count();
|
let native = crate::session_status::count();
|
||||||
crate::session_status::stop_all();
|
crate::session_status::stop_all();
|
||||||
tracing::info!(was_streaming, native_sessions = native, "management API: session stopped");
|
tracing::info!(
|
||||||
|
was_streaming,
|
||||||
|
native_sessions = native,
|
||||||
|
"management API: session stopped"
|
||||||
|
);
|
||||||
StatusCode::NO_CONTENT
|
StatusCode::NO_CONTENT
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user