video updates

This commit is contained in:
Brad Stein 2025-06-26 17:12:59 -05:00
parent da22370468
commit 0940004c70

View File

@ -7,6 +7,7 @@ use gst::prelude::*;
use lesavka_common::lesavka::VideoPacket; use lesavka_common::lesavka::VideoPacket;
use tokio_stream::wrappers::ReceiverStream; use tokio_stream::wrappers::ReceiverStream;
use tonic::Status; use tonic::Status;
use tracing::{debug, enabled, Level};
pub async fn spawn_camera( pub async fn spawn_camera(
dev: &str, dev: &str,
@ -64,6 +65,22 @@ pub async fn spawn_camera(
let map = buffer.map_readable().map_err(|_| gst::FlowError::Error)?; let map = buffer.map_readable().map_err(|_| gst::FlowError::Error)?;
if enabled!(Level::DEBUG) {
if let Some(slice) = map.as_slice().get(0..5) {
match slice[4] & 0b1_1111 {
// 0x07 = SPS, 0x05 = IDR (Annex-B “byte-stream”)
0x07 | 0x05 => {
debug!(
"🎞️ monitor {id}: got NAL {:02X}, {} bytes",
slice[4],
map.as_slice().len()
);
}
_ => {}
}
}
}
let pkt = VideoPacket { let pkt = VideoPacket {
id, id,
pts: pts_us, pts: pts_us,