Lines Matching defs:queue
38 if (video->queue.buf_used == 0 && ts.tv_sec) {
62 if (buf->bytesused - video->queue.buf_used <= len - pos)
72 struct uvc_video_queue *queue = &video->queue;
77 mem = buf->mem + queue->buf_used;
78 nbytes = min((unsigned int)len, buf->bytesused - queue->buf_used);
81 queue->buf_used += nbytes;
113 if (buf->bytesused == video->queue.buf_used) {
114 video->queue.buf_used = 0;
116 list_del(&buf->queue);
124 video->queue.flags & UVC_QUEUE_DROP_INCOMPLETE ||
125 buf->bytesused == video->queue.buf_used)
133 unsigned int pending = buf->bytesused - video->queue.buf_used;
183 video->queue.buf_used += req->length - header_len;
185 if (buf->bytesused == video->queue.buf_used || !buf->sg ||
186 video->queue.flags & UVC_QUEUE_DROP_INCOMPLETE) {
187 video->queue.buf_used = 0;
190 list_del(&buf->queue);
216 if (buf->bytesused == video->queue.buf_used ||
217 video->queue.flags & UVC_QUEUE_DROP_INCOMPLETE) {
218 video->queue.buf_used = 0;
220 list_del(&buf->queue);
236 uvcg_err(&video->uvc->func, "Failed to queue request (%d).\n",
255 struct uvc_video_queue *queue = &video->queue;
265 queue->flags |= UVC_QUEUE_DROP_INCOMPLETE;
270 uvcg_queue_cancel(queue, 1);
277 uvcg_queue_cancel(queue, 0);
281 uvcg_complete_buffer(&video->queue, ureq->last_buf);
384 struct uvc_video_queue *queue = &video->queue;
410 * request, protected by the video queue irqlock.
412 spin_lock_irqsave(&queue->irqlock, flags);
413 buf = uvcg_queue_head(queue);
418 } else if (!(queue->flags & UVC_QUEUE_DISCONNECTED) && !is_bulk) {
420 * No video buffer available; the queue is still connected and
428 * Either the queue has been disconnected or no video buffer
432 spin_unlock_irqrestore(&queue->irqlock, flags);
441 * - When no more requests are available in the free queue, as
443 * request queue.
450 * - Four times over the length of the requests queue (as
465 spin_unlock_irqrestore(&queue->irqlock, flags);
468 uvcg_queue_cancel(queue, 0);
502 uvcg_queue_cancel(&video->queue, 0);
509 uvcg_queue_enable(&video->queue, 0);
513 if ((ret = uvcg_queue_enable(&video->queue, 1)) < 0)
523 video->encode = video->queue.use_sg ?
542 /* Allocate a work queue for asynchronous video pump handler. */
554 /* Initialize the video buffers queue. */
555 uvcg_queue_init(&video->queue, uvc->v4l2_dev.dev->parent,