diff options
Diffstat (limited to 'drivers/media/video/uvc/uvc_queue.c')
-rw-r--r-- | drivers/media/video/uvc/uvc_queue.c | 13 |
1 files changed, 9 insertions, 4 deletions
diff --git a/drivers/media/video/uvc/uvc_queue.c b/drivers/media/video/uvc/uvc_queue.c index 133c78d113ac..e9928a415086 100644 --- a/drivers/media/video/uvc/uvc_queue.c +++ b/drivers/media/video/uvc/uvc_queue.c | |||
@@ -78,12 +78,14 @@ | |||
78 | * | 78 | * |
79 | */ | 79 | */ |
80 | 80 | ||
81 | void uvc_queue_init(struct uvc_video_queue *queue, enum v4l2_buf_type type) | 81 | void uvc_queue_init(struct uvc_video_queue *queue, enum v4l2_buf_type type, |
82 | int drop_corrupted) | ||
82 | { | 83 | { |
83 | mutex_init(&queue->mutex); | 84 | mutex_init(&queue->mutex); |
84 | spin_lock_init(&queue->irqlock); | 85 | spin_lock_init(&queue->irqlock); |
85 | INIT_LIST_HEAD(&queue->mainqueue); | 86 | INIT_LIST_HEAD(&queue->mainqueue); |
86 | INIT_LIST_HEAD(&queue->irqqueue); | 87 | INIT_LIST_HEAD(&queue->irqqueue); |
88 | queue->flags = drop_corrupted ? UVC_QUEUE_DROP_CORRUPTED : 0; | ||
87 | queue->type = type; | 89 | queue->type = type; |
88 | } | 90 | } |
89 | 91 | ||
@@ -435,8 +437,10 @@ int uvc_queue_enable(struct uvc_video_queue *queue, int enable) | |||
435 | uvc_queue_cancel(queue, 0); | 437 | uvc_queue_cancel(queue, 0); |
436 | INIT_LIST_HEAD(&queue->mainqueue); | 438 | INIT_LIST_HEAD(&queue->mainqueue); |
437 | 439 | ||
438 | for (i = 0; i < queue->count; ++i) | 440 | for (i = 0; i < queue->count; ++i) { |
441 | queue->buffer[i].error = 0; | ||
439 | queue->buffer[i].state = UVC_BUF_STATE_IDLE; | 442 | queue->buffer[i].state = UVC_BUF_STATE_IDLE; |
443 | } | ||
440 | 444 | ||
441 | queue->flags &= ~UVC_QUEUE_STREAMING; | 445 | queue->flags &= ~UVC_QUEUE_STREAMING; |
442 | } | 446 | } |
@@ -488,8 +492,8 @@ struct uvc_buffer *uvc_queue_next_buffer(struct uvc_video_queue *queue, | |||
488 | struct uvc_buffer *nextbuf; | 492 | struct uvc_buffer *nextbuf; |
489 | unsigned long flags; | 493 | unsigned long flags; |
490 | 494 | ||
491 | if ((queue->flags & UVC_QUEUE_DROP_INCOMPLETE) && | 495 | if ((queue->flags & UVC_QUEUE_DROP_CORRUPTED) && buf->error) { |
492 | buf->buf.length != buf->buf.bytesused) { | 496 | buf->error = 0; |
493 | buf->state = UVC_BUF_STATE_QUEUED; | 497 | buf->state = UVC_BUF_STATE_QUEUED; |
494 | buf->buf.bytesused = 0; | 498 | buf->buf.bytesused = 0; |
495 | return buf; | 499 | return buf; |
@@ -497,6 +501,7 @@ struct uvc_buffer *uvc_queue_next_buffer(struct uvc_video_queue *queue, | |||
497 | 501 | ||
498 | spin_lock_irqsave(&queue->irqlock, flags); | 502 | spin_lock_irqsave(&queue->irqlock, flags); |
499 | list_del(&buf->queue); | 503 | list_del(&buf->queue); |
504 | buf->error = 0; | ||
500 | buf->state = UVC_BUF_STATE_DONE; | 505 | buf->state = UVC_BUF_STATE_DONE; |
501 | if (!list_empty(&queue->irqqueue)) | 506 | if (!list_empty(&queue->irqqueue)) |
502 | nextbuf = list_first_entry(&queue->irqqueue, struct uvc_buffer, | 507 | nextbuf = list_first_entry(&queue->irqqueue, struct uvc_buffer, |