Lines Matching refs:queue

46 	struct uvc_video_queue *queue = vb2_get_drv_priv(vq);  in uvc_queue_setup()  local
47 struct uvc_video *video = container_of(queue, struct uvc_video, queue); in uvc_queue_setup()
63 struct uvc_video_queue *queue = vb2_get_drv_priv(vb->vb2_queue); in uvc_buffer_prepare() local
64 struct uvc_video *video = container_of(queue, struct uvc_video, queue); in uvc_buffer_prepare()
74 if (unlikely(queue->flags & UVC_QUEUE_DISCONNECTED)) in uvc_buffer_prepare()
78 if (queue->use_sg) { in uvc_buffer_prepare()
100 struct uvc_video_queue *queue = vb2_get_drv_priv(vb->vb2_queue); in uvc_buffer_queue() local
105 spin_lock_irqsave(&queue->irqlock, flags); in uvc_buffer_queue()
107 if (likely(!(queue->flags & UVC_QUEUE_DISCONNECTED))) { in uvc_buffer_queue()
108 list_add_tail(&buf->queue, &queue->irqqueue); in uvc_buffer_queue()
118 spin_unlock_irqrestore(&queue->irqlock, flags); in uvc_buffer_queue()
127 int uvcg_queue_init(struct uvc_video_queue *queue, struct device *dev, enum v4l2_buf_type type, in uvcg_queue_init() argument
130 struct uvc_video *video = container_of(queue, struct uvc_video, queue); in uvcg_queue_init()
134 queue->queue.type = type; in uvcg_queue_init()
135 queue->queue.io_modes = VB2_MMAP | VB2_USERPTR | VB2_DMABUF; in uvcg_queue_init()
136 queue->queue.drv_priv = queue; in uvcg_queue_init()
137 queue->queue.buf_struct_size = sizeof(struct uvc_buffer); in uvcg_queue_init()
138 queue->queue.ops = &uvc_queue_qops; in uvcg_queue_init()
139 queue->queue.lock = lock; in uvcg_queue_init()
141 queue->queue.mem_ops = &vb2_dma_sg_memops; in uvcg_queue_init()
142 queue->use_sg = 1; in uvcg_queue_init()
144 queue->queue.mem_ops = &vb2_vmalloc_memops; in uvcg_queue_init()
147 queue->queue.timestamp_flags = V4L2_BUF_FLAG_TIMESTAMP_COPY in uvcg_queue_init()
149 queue->queue.dev = dev; in uvcg_queue_init()
151 ret = vb2_queue_init(&queue->queue); in uvcg_queue_init()
155 spin_lock_init(&queue->irqlock); in uvcg_queue_init()
156 INIT_LIST_HEAD(&queue->irqqueue); in uvcg_queue_init()
157 queue->flags = 0; in uvcg_queue_init()
165 void uvcg_free_buffers(struct uvc_video_queue *queue) in uvcg_free_buffers() argument
167 vb2_queue_release(&queue->queue); in uvcg_free_buffers()
173 int uvcg_alloc_buffers(struct uvc_video_queue *queue, in uvcg_alloc_buffers() argument
178 ret = vb2_reqbufs(&queue->queue, rb); in uvcg_alloc_buffers()
183 int uvcg_query_buffer(struct uvc_video_queue *queue, struct v4l2_buffer *buf) in uvcg_query_buffer() argument
185 return vb2_querybuf(&queue->queue, buf); in uvcg_query_buffer()
188 int uvcg_queue_buffer(struct uvc_video_queue *queue, struct v4l2_buffer *buf) in uvcg_queue_buffer() argument
190 return vb2_qbuf(&queue->queue, NULL, buf); in uvcg_queue_buffer()
197 int uvcg_dequeue_buffer(struct uvc_video_queue *queue, struct v4l2_buffer *buf, in uvcg_dequeue_buffer() argument
200 return vb2_dqbuf(&queue->queue, buf, nonblocking); in uvcg_dequeue_buffer()
209 __poll_t uvcg_queue_poll(struct uvc_video_queue *queue, struct file *file, in uvcg_queue_poll() argument
212 return vb2_poll(&queue->queue, file, wait); in uvcg_queue_poll()
215 int uvcg_queue_mmap(struct uvc_video_queue *queue, struct vm_area_struct *vma) in uvcg_queue_mmap() argument
217 return vb2_mmap(&queue->queue, vma); in uvcg_queue_mmap()
226 unsigned long uvcg_queue_get_unmapped_area(struct uvc_video_queue *queue, in uvcg_queue_get_unmapped_area() argument
229 return vb2_get_unmapped_area(&queue->queue, 0, 0, pgoff, 0); in uvcg_queue_get_unmapped_area()
245 void uvcg_queue_cancel(struct uvc_video_queue *queue, int disconnect) in uvcg_queue_cancel() argument
250 spin_lock_irqsave(&queue->irqlock, flags); in uvcg_queue_cancel()
251 while (!list_empty(&queue->irqqueue)) { in uvcg_queue_cancel()
252 buf = list_first_entry(&queue->irqqueue, struct uvc_buffer, in uvcg_queue_cancel()
253 queue); in uvcg_queue_cancel()
254 list_del(&buf->queue); in uvcg_queue_cancel()
258 queue->buf_used = 0; in uvcg_queue_cancel()
268 queue->flags |= UVC_QUEUE_DISCONNECTED; in uvcg_queue_cancel()
269 spin_unlock_irqrestore(&queue->irqlock, flags); in uvcg_queue_cancel()
289 int uvcg_queue_enable(struct uvc_video_queue *queue, int enable) in uvcg_queue_enable() argument
295 ret = vb2_streamon(&queue->queue, queue->queue.type); in uvcg_queue_enable()
299 queue->sequence = 0; in uvcg_queue_enable()
300 queue->buf_used = 0; in uvcg_queue_enable()
301 queue->flags &= ~UVC_QUEUE_DROP_INCOMPLETE; in uvcg_queue_enable()
303 ret = vb2_streamoff(&queue->queue, queue->queue.type); in uvcg_queue_enable()
307 spin_lock_irqsave(&queue->irqlock, flags); in uvcg_queue_enable()
308 INIT_LIST_HEAD(&queue->irqqueue); in uvcg_queue_enable()
316 queue->flags &= ~UVC_QUEUE_DISCONNECTED; in uvcg_queue_enable()
317 spin_unlock_irqrestore(&queue->irqlock, flags); in uvcg_queue_enable()
324 void uvcg_complete_buffer(struct uvc_video_queue *queue, in uvcg_complete_buffer() argument
327 if (queue->flags & UVC_QUEUE_DROP_INCOMPLETE) { in uvcg_complete_buffer()
328 queue->flags &= ~UVC_QUEUE_DROP_INCOMPLETE; in uvcg_complete_buffer()
336 buf->buf.sequence = queue->sequence++; in uvcg_complete_buffer()
343 struct uvc_buffer *uvcg_queue_head(struct uvc_video_queue *queue) in uvcg_queue_head() argument
347 if (!list_empty(&queue->irqqueue)) in uvcg_queue_head()
348 buf = list_first_entry(&queue->irqqueue, struct uvc_buffer, in uvcg_queue_head()
349 queue); in uvcg_queue_head()