asgardius/android_kernel_motorola_sm6225
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

V4L/DVB (6817): Cleanup kernel thread and provide overrun detection

Browse source 
The previous code were a little bit messy. Cleans it up.

Signed-off-by: Mauro Carvalho Chehab <mchehab@infradead.org>
This commit is contained in:
Mauro Carvalho Chehab 2007-12-13 16:15:41 -03:00
parent 55862ac9b2
commit 6594ad829a
1 changed files with 35 additions and 26 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

61
drivers/media/video/vivi.c
View file

@ -425,48 +425,57 @@ static void vivi_thread_tick(struct vivi_dmaqueue *dma_q)
spin_unlock(&dev->slock); spin_unlock(&dev->slock);
} }
#define frames_to_ms(frames) \
((frames * WAKE_NUMERATOR * 1000) / WAKE_DENOMINATOR)
static void vivi_sleep(struct vivi_dmaqueue *dma_q) static void vivi_sleep(struct vivi_dmaqueue *dma_q)
{ {
struct vivi_dev *dev = container_of(dma_q, struct vivi_dev, vidq); struct vivi_dev *dev = container_of(dma_q, struct vivi_dev, vidq);
int timeout; int timeout, running_time;
DECLARE_WAITQUEUE(wait, current); DECLARE_WAITQUEUE(wait, current);
dprintk(dev, 1, "%s dma_q=0x%08lx\n", __FUNCTION__, dprintk(dev, 1, "%s dma_q=0x%08lx\n", __FUNCTION__,
(unsigned long)dma_q); (unsigned long)dma_q);
add_wait_queue(&dma_q->wq, &wait); add_wait_queue(&dma_q->wq, &wait);
if (!kthread_should_stop()) { if (kthread_should_stop())
dma_q->frame++; goto stop_task;
/* Calculate time to wake up */ running_time = jiffies - dma_q->ini_jiffies;
timeout = dma_q->ini_jiffies+ dma_q->frame++;
msecs_to_jiffies((dma_q->frame*WAKE_NUMERATOR * 1000)
/ WAKE_DENOMINATOR) - jiffies;
if (timeout <= 0) { /* Calculate time to wake up */
int old = dma_q->frame; timeout = msecs_to_jiffies(frames_to_ms(dma_q->frame)) - running_time;
dma_q->frame = (jiffies_to_msecs(jiffies -
dma_q->ini_jiffies) *
WAKE_DENOMINATOR) /
(WAKE_NUMERATOR * 1000) + 1;
timeout = dma_q->ini_jiffies+ if (timeout > msecs_to_jiffies(frames_to_ms(2)) || timeout <= 0) {
msecs_to_jiffies((dma_q->frame * int old = dma_q->frame;
WAKE_NUMERATOR * 1000) int nframes;
/ WAKE_DENOMINATOR) - jiffies;
dprintk(dev, 1, "underrun, losed %d frames. " dma_q->frame = (jiffies_to_msecs(running_time) /
"Now, frame is %d. Waking on %d jiffies\n", frames_to_ms(1)) + 1;
dma_q->frame-old, dma_q->frame, timeout);
} else
dprintk(dev, 1, "will sleep for %i jiffies\n",
timeout);
vivi_thread_tick(dma_q); timeout = msecs_to_jiffies(frames_to_ms(dma_q->frame))
- running_time;
schedule_timeout_interruptible(timeout); if (unlikely (timeout <= 0))
} timeout = 1;
nframes = (dma_q->frame > old)?
dma_q->frame - old : old - dma_q->frame;
dprintk(dev, 1, "%ld: %s %d frames. "
"Current frame is %d. Will sleep for %d jiffies\n",
jiffies,
(dma_q->frame > old)? "Underrun, losed" : "Overrun of",
nframes, dma_q->frame, timeout);
} else
dprintk(dev, 1, "will sleep for %d jiffies\n", timeout);
vivi_thread_tick(dma_q);
schedule_timeout_interruptible(timeout);
stop_task:
remove_wait_queue(&dma_q->wq, &wait); remove_wait_queue(&dma_q->wq, &wait);
try_to_freeze(); try_to_freeze();
} }