13 use v4l2r::device::queue::direction;
14 use v4l2r::device::queue::direction::Capture;
15 use v4l2r::device::queue::direction::Output;
16 use v4l2r::device::queue::dqbuf::DqBuffer;
17 use v4l2r::device::queue::qbuf::QBuffer;
18 use v4l2r::device::queue::BuffersAllocated;
19 use v4l2r::device::queue::CaptureQueueable;
20 use v4l2r::device::queue::CreateQueueError;
21 use v4l2r::device::queue::GetFreeBufferError;
22 use v4l2r::device::queue::GetFreeCaptureBuffer;
23 use v4l2r::device::queue::GetFreeOutputBuffer;
24 use v4l2r::device::queue::Queue;
25 use v4l2r::device::queue::QueueInit;
26 use v4l2r::device::queue::RequestBuffersError;
58 enum V4l2OutputQueueHandle<T: v4l2r::device::queue::direction::Direction> {
59     Init(Queue<T, QueueInit>),
60     Streaming(Rc<Queue<T, BuffersAllocated<Vec<MmapHandle>>>>),
66 enum V4l2CaptureQueueHandle<T: v4l2r::device::queue::direction::Direction, V: VideoFrame> {
67     Init(Queue<T, QueueInit>),
68     Streaming(Rc<Queue<T, BuffersAllocated<V4l2VideoFrame<V>>>>),
75     #[error("unable to create queue.")]
77     #[error("failed to get format for queue.")]
79     #[error("failed to set format for queue.")]
91     #[error("failed to queue buffer.")]
97     #[error("failed to get queue handle.")]
101     #[error("failed to reset OUTPUT queue.")]
103     #[error("failed to reset CAPTURE queue.")]
113 impl<B: BufferHandles> From<v4l2r::device::queue::qbuf::QueueError<B>> for QueueError {
114     fn from(_err: v4l2r::device::queue::qbuf::QueueError<B>) -> Self {  in from()
170     queue: V4l2OutputQueue,  field
175         Rc<Queue<Output, BuffersAllocated<Vec<MmapHandle>>>>,
182         queue: V4l2OutputQueue,  in new()
187             Rc<Queue<Output, BuffersAllocated<Vec<MmapHandle>>>>,  in new()
190         Self { queue, handle, length: 0 }  in new()
208         let handle = &*self.queue.handle.borrow();  in submit()
214                     .queue(&[self.length])?;  in submit()
230         let handle = Queue::get_output_mplane_queue(device)  in new()
232         log::debug!("output queue created");  in new()
246                 let queue_handle = Queue::get_output_mplane_queue(device.clone())  in reset()
352         let handle = Queue::get_capture_mplane_queue(device.clone())  in new()
354         log::debug!("capture queue created");  in new()
368                 let queue_handle = Queue::get_capture_mplane_queue(device.clone())  in reset()