Commit c37b11bf authored by Andy Walls's avatar Andy Walls Committed by Mauro Carvalho Chehab

V4L/DVB (13427): cx18: Rename struct cx18_queue.buffers to struct cx18_queue.depth

Signed-off-by: default avatarAndy Walls <awalls@radix.net>
Signed-off-by: default avatarMauro Carvalho Chehab <mchehab@redhat.com>
parent f0076e60
...@@ -285,7 +285,7 @@ struct cx18_buffer { ...@@ -285,7 +285,7 @@ struct cx18_buffer {
struct cx18_queue { struct cx18_queue {
struct list_head list; struct list_head list;
atomic_t buffers; atomic_t depth;
u32 bytesused; u32 bytesused;
spinlock_t lock; spinlock_t lock;
}; };
......
...@@ -229,7 +229,7 @@ static struct cx18_buffer *cx18_get_buffer(struct cx18_stream *s, int non_block, ...@@ -229,7 +229,7 @@ static struct cx18_buffer *cx18_get_buffer(struct cx18_stream *s, int non_block,
prepare_to_wait(&s->waitq, &wait, TASK_INTERRUPTIBLE); prepare_to_wait(&s->waitq, &wait, TASK_INTERRUPTIBLE);
/* New buffers might have become available before we were added /* New buffers might have become available before we were added
to the waitqueue */ to the waitqueue */
if (!atomic_read(&s->q_full.buffers)) if (!atomic_read(&s->q_full.depth))
schedule(); schedule();
finish_wait(&s->waitq, &wait); finish_wait(&s->waitq, &wait);
if (signal_pending(current)) { if (signal_pending(current)) {
...@@ -543,7 +543,7 @@ unsigned int cx18_v4l2_enc_poll(struct file *filp, poll_table *wait) ...@@ -543,7 +543,7 @@ unsigned int cx18_v4l2_enc_poll(struct file *filp, poll_table *wait)
CX18_DEBUG_HI_FILE("Encoder poll\n"); CX18_DEBUG_HI_FILE("Encoder poll\n");
poll_wait(filp, &s->waitq, wait); poll_wait(filp, &s->waitq, wait);
if (atomic_read(&s->q_full.buffers)) if (atomic_read(&s->q_full.depth))
return POLLIN | POLLRDNORM; return POLLIN | POLLRDNORM;
if (eof) if (eof)
return POLLHUP; return POLLHUP;
......
...@@ -910,7 +910,7 @@ static int cx18_log_status(struct file *file, void *fh) ...@@ -910,7 +910,7 @@ static int cx18_log_status(struct file *file, void *fh)
continue; continue;
CX18_INFO("Stream %s: status 0x%04lx, %d%% of %d KiB (%d buffers) in use\n", CX18_INFO("Stream %s: status 0x%04lx, %d%% of %d KiB (%d buffers) in use\n",
s->name, s->s_flags, s->name, s->s_flags,
atomic_read(&s->q_full.buffers) * 100 / s->buffers, atomic_read(&s->q_full.depth) * 100 / s->buffers,
(s->buffers * s->buf_size) / 1024, s->buffers); (s->buffers * s->buf_size) / 1024, s->buffers);
} }
CX18_INFO("Read MPEG/VBI: %lld/%lld bytes\n", CX18_INFO("Read MPEG/VBI: %lld/%lld bytes\n",
......
...@@ -38,7 +38,7 @@ void cx18_buf_swap(struct cx18_buffer *buf) ...@@ -38,7 +38,7 @@ void cx18_buf_swap(struct cx18_buffer *buf)
void cx18_queue_init(struct cx18_queue *q) void cx18_queue_init(struct cx18_queue *q)
{ {
INIT_LIST_HEAD(&q->list); INIT_LIST_HEAD(&q->list);
atomic_set(&q->buffers, 0); atomic_set(&q->depth, 0);
q->bytesused = 0; q->bytesused = 0;
} }
...@@ -55,7 +55,7 @@ struct cx18_queue *_cx18_enqueue(struct cx18_stream *s, struct cx18_buffer *buf, ...@@ -55,7 +55,7 @@ struct cx18_queue *_cx18_enqueue(struct cx18_stream *s, struct cx18_buffer *buf,
/* q_busy is restricted to a max buffer count imposed by firmware */ /* q_busy is restricted to a max buffer count imposed by firmware */
if (q == &s->q_busy && if (q == &s->q_busy &&
atomic_read(&q->buffers) >= CX18_MAX_FW_MDLS_PER_STREAM) atomic_read(&q->depth) >= CX18_MAX_FW_MDLS_PER_STREAM)
q = &s->q_free; q = &s->q_free;
spin_lock(&q->lock); spin_lock(&q->lock);
...@@ -65,7 +65,7 @@ struct cx18_queue *_cx18_enqueue(struct cx18_stream *s, struct cx18_buffer *buf, ...@@ -65,7 +65,7 @@ struct cx18_queue *_cx18_enqueue(struct cx18_stream *s, struct cx18_buffer *buf,
else else
list_add_tail(&buf->list, &q->list); /* FIFO */ list_add_tail(&buf->list, &q->list); /* FIFO */
q->bytesused += buf->bytesused - buf->readpos; q->bytesused += buf->bytesused - buf->readpos;
atomic_inc(&q->buffers); atomic_inc(&q->depth);
spin_unlock(&q->lock); spin_unlock(&q->lock);
return q; return q;
...@@ -81,7 +81,7 @@ struct cx18_buffer *cx18_dequeue(struct cx18_stream *s, struct cx18_queue *q) ...@@ -81,7 +81,7 @@ struct cx18_buffer *cx18_dequeue(struct cx18_stream *s, struct cx18_queue *q)
list_del_init(&buf->list); list_del_init(&buf->list);
q->bytesused -= buf->bytesused - buf->readpos; q->bytesused -= buf->bytesused - buf->readpos;
buf->skipped = 0; buf->skipped = 0;
atomic_dec(&q->buffers); atomic_dec(&q->depth);
} }
spin_unlock(&q->lock); spin_unlock(&q->lock);
return buf; return buf;
...@@ -113,7 +113,7 @@ struct cx18_buffer *cx18_queue_get_buf(struct cx18_stream *s, u32 id, ...@@ -113,7 +113,7 @@ struct cx18_buffer *cx18_queue_get_buf(struct cx18_stream *s, u32 id,
*/ */
if (buf->id != id) { if (buf->id != id) {
buf->skipped++; buf->skipped++;
if (buf->skipped >= atomic_read(&s->q_busy.buffers)-1) { if (buf->skipped >= atomic_read(&s->q_busy.depth)-1) {
/* buffer must have fallen out of rotation */ /* buffer must have fallen out of rotation */
CX18_WARN("Skipped %s, buffer %d, %d " CX18_WARN("Skipped %s, buffer %d, %d "
"times - it must have dropped out of " "times - it must have dropped out of "
...@@ -121,7 +121,7 @@ struct cx18_buffer *cx18_queue_get_buf(struct cx18_stream *s, u32 id, ...@@ -121,7 +121,7 @@ struct cx18_buffer *cx18_queue_get_buf(struct cx18_stream *s, u32 id,
buf->skipped); buf->skipped);
/* Sweep it up to put it back into rotation */ /* Sweep it up to put it back into rotation */
list_move_tail(&buf->list, &sweep_up); list_move_tail(&buf->list, &sweep_up);
atomic_dec(&s->q_busy.buffers); atomic_dec(&s->q_busy.depth);
} }
continue; continue;
} }
...@@ -130,7 +130,7 @@ struct cx18_buffer *cx18_queue_get_buf(struct cx18_stream *s, u32 id, ...@@ -130,7 +130,7 @@ struct cx18_buffer *cx18_queue_get_buf(struct cx18_stream *s, u32 id,
* will have to put it back on a queue later. * will have to put it back on a queue later.
*/ */
list_del_init(&buf->list); list_del_init(&buf->list);
atomic_dec(&s->q_busy.buffers); atomic_dec(&s->q_busy.depth);
ret = buf; ret = buf;
break; break;
} }
...@@ -170,7 +170,7 @@ static void cx18_queue_flush(struct cx18_stream *s, struct cx18_queue *q) ...@@ -170,7 +170,7 @@ static void cx18_queue_flush(struct cx18_stream *s, struct cx18_queue *q)
buf = list_first_entry(&q->list, struct cx18_buffer, list); buf = list_first_entry(&q->list, struct cx18_buffer, list);
list_move_tail(&buf->list, &s->q_free.list); list_move_tail(&buf->list, &s->q_free.list);
buf->bytesused = buf->readpos = buf->b_flags = buf->skipped = 0; buf->bytesused = buf->readpos = buf->b_flags = buf->skipped = 0;
atomic_inc(&s->q_free.buffers); atomic_inc(&s->q_free.depth);
} }
cx18_queue_init(q); cx18_queue_init(q);
spin_unlock(&q->lock); spin_unlock(&q->lock);
......
...@@ -470,8 +470,8 @@ void _cx18_stream_load_fw_queue(struct cx18_stream *s) ...@@ -470,8 +470,8 @@ void _cx18_stream_load_fw_queue(struct cx18_stream *s)
struct cx18_queue *q; struct cx18_queue *q;
struct cx18_buffer *buf; struct cx18_buffer *buf;
if (atomic_read(&s->q_free.buffers) == 0 || if (atomic_read(&s->q_free.depth) == 0 ||
atomic_read(&s->q_busy.buffers) >= CX18_MAX_FW_MDLS_PER_STREAM) atomic_read(&s->q_busy.depth) >= CX18_MAX_FW_MDLS_PER_STREAM)
return; return;
/* Move from q_free to q_busy notifying the firmware, until the limit */ /* Move from q_free to q_busy notifying the firmware, until the limit */
...@@ -480,7 +480,7 @@ void _cx18_stream_load_fw_queue(struct cx18_stream *s) ...@@ -480,7 +480,7 @@ void _cx18_stream_load_fw_queue(struct cx18_stream *s)
if (buf == NULL) if (buf == NULL)
break; break;
q = _cx18_stream_put_buf_fw(s, buf); q = _cx18_stream_put_buf_fw(s, buf);
} while (atomic_read(&s->q_busy.buffers) < CX18_MAX_FW_MDLS_PER_STREAM } while (atomic_read(&s->q_busy.depth) < CX18_MAX_FW_MDLS_PER_STREAM
&& q == &s->q_busy); && q == &s->q_busy);
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment