Lines Matching full:queue
29 * Video buffers queue management.
35 * the videobuf2 queue operations by serializing calls to videobuf2 and a
36 * spinlock to protect the IRQ queue that holds the buffers to be processed by
41 uvc_queue_to_stream(struct uvc_video_queue *queue) in uvc_queue_to_stream() argument
43 return container_of(queue, struct uvc_streaming, queue); in uvc_queue_to_stream()
54 * This function must be called with the queue spinlock held.
56 static void uvc_queue_return_buffers(struct uvc_video_queue *queue, in uvc_queue_return_buffers() argument
63 while (!list_empty(&queue->irqqueue)) { in uvc_queue_return_buffers()
64 struct uvc_buffer *buf = list_first_entry(&queue->irqqueue, in uvc_queue_return_buffers()
66 queue); in uvc_queue_return_buffers()
67 list_del(&buf->queue); in uvc_queue_return_buffers()
74 * videobuf2 queue operations
81 struct uvc_video_queue *queue = vb2_get_drv_priv(vq); in uvc_queue_setup() local
91 stream = uvc_queue_to_stream(queue); in uvc_queue_setup()
112 struct uvc_video_queue *queue = vb2_get_drv_priv(vb->vb2_queue); in uvc_buffer_prepare() local
121 if (unlikely(queue->flags & UVC_QUEUE_DISCONNECTED)) in uvc_buffer_prepare()
139 struct uvc_video_queue *queue = vb2_get_drv_priv(vb->vb2_queue); in uvc_buffer_queue() local
143 spin_lock_irqsave(&queue->irqlock, flags); in uvc_buffer_queue()
144 if (likely(!(queue->flags & UVC_QUEUE_DISCONNECTED))) { in uvc_buffer_queue()
145 list_add_tail(&buf->queue, &queue->irqqueue); in uvc_buffer_queue()
154 spin_unlock_irqrestore(&queue->irqlock, flags); in uvc_buffer_queue()
160 struct uvc_video_queue *queue = vb2_get_drv_priv(vb->vb2_queue); in uvc_buffer_finish() local
161 struct uvc_streaming *stream = uvc_queue_to_stream(queue); in uvc_buffer_finish()
170 struct uvc_video_queue *queue = vb2_get_drv_priv(vq); in uvc_start_streaming() local
171 struct uvc_streaming *stream = uvc_queue_to_stream(queue); in uvc_start_streaming()
175 queue->buf_used = 0; in uvc_start_streaming()
181 spin_lock_irqsave(&queue->irqlock, flags); in uvc_start_streaming()
182 uvc_queue_return_buffers(queue, UVC_BUF_STATE_QUEUED); in uvc_start_streaming()
183 spin_unlock_irqrestore(&queue->irqlock, flags); in uvc_start_streaming()
190 struct uvc_video_queue *queue = vb2_get_drv_priv(vq); in uvc_stop_streaming() local
194 uvc_video_enable(uvc_queue_to_stream(queue), 0); in uvc_stop_streaming()
196 spin_lock_irqsave(&queue->irqlock, flags); in uvc_stop_streaming()
197 uvc_queue_return_buffers(queue, UVC_BUF_STATE_ERROR); in uvc_stop_streaming()
198 spin_unlock_irqrestore(&queue->irqlock, flags); in uvc_stop_streaming()
221 int uvc_queue_init(struct uvc_video_queue *queue, enum v4l2_buf_type type, in uvc_queue_init() argument
226 queue->queue.type = type; in uvc_queue_init()
227 queue->queue.io_modes = VB2_MMAP | VB2_USERPTR; in uvc_queue_init()
228 queue->queue.drv_priv = queue; in uvc_queue_init()
229 queue->queue.buf_struct_size = sizeof(struct uvc_buffer); in uvc_queue_init()
230 queue->queue.mem_ops = &vb2_vmalloc_memops; in uvc_queue_init()
231 queue->queue.timestamp_flags = V4L2_BUF_FLAG_TIMESTAMP_MONOTONIC in uvc_queue_init()
233 queue->queue.lock = &queue->mutex; in uvc_queue_init()
237 queue->queue.ops = &uvc_meta_queue_qops; in uvc_queue_init()
240 queue->queue.io_modes |= VB2_DMABUF; in uvc_queue_init()
241 queue->queue.ops = &uvc_queue_qops; in uvc_queue_init()
245 ret = vb2_queue_init(&queue->queue); in uvc_queue_init()
249 mutex_init(&queue->mutex); in uvc_queue_init()
250 spin_lock_init(&queue->irqlock); in uvc_queue_init()
251 INIT_LIST_HEAD(&queue->irqqueue); in uvc_queue_init()
252 queue->flags = drop_corrupted ? UVC_QUEUE_DROP_CORRUPTED : 0; in uvc_queue_init()
257 void uvc_queue_release(struct uvc_video_queue *queue) in uvc_queue_release() argument
259 mutex_lock(&queue->mutex); in uvc_queue_release()
260 vb2_queue_release(&queue->queue); in uvc_queue_release()
261 mutex_unlock(&queue->mutex); in uvc_queue_release()
265 * V4L2 queue operations
268 int uvc_request_buffers(struct uvc_video_queue *queue, in uvc_request_buffers() argument
273 mutex_lock(&queue->mutex); in uvc_request_buffers()
274 ret = vb2_reqbufs(&queue->queue, rb); in uvc_request_buffers()
275 mutex_unlock(&queue->mutex); in uvc_request_buffers()
280 int uvc_query_buffer(struct uvc_video_queue *queue, struct v4l2_buffer *buf) in uvc_query_buffer() argument
284 mutex_lock(&queue->mutex); in uvc_query_buffer()
285 ret = vb2_querybuf(&queue->queue, buf); in uvc_query_buffer()
286 mutex_unlock(&queue->mutex); in uvc_query_buffer()
291 int uvc_create_buffers(struct uvc_video_queue *queue, in uvc_create_buffers() argument
296 mutex_lock(&queue->mutex); in uvc_create_buffers()
297 ret = vb2_create_bufs(&queue->queue, cb); in uvc_create_buffers()
298 mutex_unlock(&queue->mutex); in uvc_create_buffers()
303 int uvc_queue_buffer(struct uvc_video_queue *queue, struct v4l2_buffer *buf) in uvc_queue_buffer() argument
307 mutex_lock(&queue->mutex); in uvc_queue_buffer()
308 ret = vb2_qbuf(&queue->queue, buf); in uvc_queue_buffer()
309 mutex_unlock(&queue->mutex); in uvc_queue_buffer()
314 int uvc_export_buffer(struct uvc_video_queue *queue, in uvc_export_buffer() argument
319 mutex_lock(&queue->mutex); in uvc_export_buffer()
320 ret = vb2_expbuf(&queue->queue, exp); in uvc_export_buffer()
321 mutex_unlock(&queue->mutex); in uvc_export_buffer()
326 int uvc_dequeue_buffer(struct uvc_video_queue *queue, struct v4l2_buffer *buf, in uvc_dequeue_buffer() argument
331 mutex_lock(&queue->mutex); in uvc_dequeue_buffer()
332 ret = vb2_dqbuf(&queue->queue, buf, nonblocking); in uvc_dequeue_buffer()
333 mutex_unlock(&queue->mutex); in uvc_dequeue_buffer()
338 int uvc_queue_streamon(struct uvc_video_queue *queue, enum v4l2_buf_type type) in uvc_queue_streamon() argument
342 mutex_lock(&queue->mutex); in uvc_queue_streamon()
343 ret = vb2_streamon(&queue->queue, type); in uvc_queue_streamon()
344 mutex_unlock(&queue->mutex); in uvc_queue_streamon()
349 int uvc_queue_streamoff(struct uvc_video_queue *queue, enum v4l2_buf_type type) in uvc_queue_streamoff() argument
353 mutex_lock(&queue->mutex); in uvc_queue_streamoff()
354 ret = vb2_streamoff(&queue->queue, type); in uvc_queue_streamoff()
355 mutex_unlock(&queue->mutex); in uvc_queue_streamoff()
360 int uvc_queue_mmap(struct uvc_video_queue *queue, struct vm_area_struct *vma) in uvc_queue_mmap() argument
362 return vb2_mmap(&queue->queue, vma); in uvc_queue_mmap()
366 unsigned long uvc_queue_get_unmapped_area(struct uvc_video_queue *queue, in uvc_queue_get_unmapped_area() argument
369 return vb2_get_unmapped_area(&queue->queue, 0, 0, pgoff, 0); in uvc_queue_get_unmapped_area()
373 __poll_t uvc_queue_poll(struct uvc_video_queue *queue, struct file *file, in uvc_queue_poll() argument
378 mutex_lock(&queue->mutex); in uvc_queue_poll()
379 ret = vb2_poll(&queue->queue, file, wait); in uvc_queue_poll()
380 mutex_unlock(&queue->mutex); in uvc_queue_poll()
392 int uvc_queue_allocated(struct uvc_video_queue *queue) in uvc_queue_allocated() argument
396 mutex_lock(&queue->mutex); in uvc_queue_allocated()
397 allocated = vb2_is_busy(&queue->queue); in uvc_queue_allocated()
398 mutex_unlock(&queue->mutex); in uvc_queue_allocated()
404 * Cancel the video buffers queue.
406 * Cancelling the queue marks all buffers on the irq queue as erroneous,
407 * wakes them up and removes them from the queue.
415 void uvc_queue_cancel(struct uvc_video_queue *queue, int disconnect) in uvc_queue_cancel() argument
419 spin_lock_irqsave(&queue->irqlock, flags); in uvc_queue_cancel()
420 uvc_queue_return_buffers(queue, UVC_BUF_STATE_ERROR); in uvc_queue_cancel()
425 * state outside the queue code. in uvc_queue_cancel()
428 queue->flags |= UVC_QUEUE_DISCONNECTED; in uvc_queue_cancel()
429 spin_unlock_irqrestore(&queue->irqlock, flags); in uvc_queue_cancel()
432 struct uvc_buffer *uvc_queue_next_buffer(struct uvc_video_queue *queue, in uvc_queue_next_buffer() argument
438 if ((queue->flags & UVC_QUEUE_DROP_CORRUPTED) && buf->error) { in uvc_queue_next_buffer()
446 spin_lock_irqsave(&queue->irqlock, flags); in uvc_queue_next_buffer()
447 list_del(&buf->queue); in uvc_queue_next_buffer()
448 if (!list_empty(&queue->irqqueue)) in uvc_queue_next_buffer()
449 nextbuf = list_first_entry(&queue->irqqueue, struct uvc_buffer, in uvc_queue_next_buffer()
450 queue); in uvc_queue_next_buffer()
453 spin_unlock_irqrestore(&queue->irqlock, flags); in uvc_queue_next_buffer()