grabbit/meteor_detect
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix： 树莓派gstreamer pipeline报错

Browse Source
This commit is contained in:
grabbit 2025-04-05 16:29:21 +08:00
parent 2cab6e8a7a
commit f2cecfbbd4
1 changed files with 31 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
src/camera/opencv.rs
View File

@ -63,7 +63,13 @@ impl OpenCVCamera {
// For Linux device files like /dev/video0
if let Some(num_str) = path_str.strip_prefix("/dev/video") {
if let Ok(device_index) = num_str.parse::<i32>() {
return Ok(videoio::VideoCapture::new(device_index, videoio::CAP_ANY)?);
// 在Linux下使用GStreamer pipeline
let pipeline = format!(
"v4l2src device={} ! videoconvert ! video/x-raw,format=BGR ! appsink",
path_str
);
info!("Using GStreamer pipeline: {}", pipeline);
return Ok(videoio::VideoCapture::from_file(&pipeline, videoio::CAP_GSTREAMER)?);
} else {
return Err(anyhow!("Invalid device number in path: {}", path_str));
}
@ -193,6 +199,30 @@ impl OpenCVCamera {
return Err(anyhow!("Camera is not open"));
}
#[cfg(target_os = "linux")]
{
// 在Linux下创建一个使用GStreamer的流
if self.device.starts_with("/dev/video") {
let pipeline = format!(
"v4l2src device={} ! videoconvert ! video/x-raw,width={},height={},format=BGR,framerate={}/1 ! appsink",
self.device, self.width, self.height, 30 // 使用固定的30fps，或者从设置获取
);
info!("Starting stream with GStreamer pipeline: {}", pipeline);
let stream_capture = videoio::VideoCapture::from_file(&pipeline, videoio::CAP_GSTREAMER)?;
if !stream_capture.is_opened()? {
return Err(anyhow!("Failed to open GStreamer camera stream"));
}
self.is_streaming = true;
info!("Started camera streaming with GStreamer");
return Ok(OpenCVCaptureStream {
capture: stream_capture,
});
}
}
// For non-Linux platforms or if GStreamer approach fails, use regular approach
// Create a separate VideoCapture for the stream to avoid concurrent access issues
let device = self.device.clone();
let mut stream_capture = Self::create_capture_from_path(&device)?;