Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 37266
b: refs/heads/master
c: 438bd52
h: refs/heads/master
v: v3
  • Loading branch information
Stefan Richter authored and Ben Collins committed Jul 3, 2006
1 parent 3905e49 commit 82958c4
Show file tree
Hide file tree
Showing 3 changed files with 20 additions and 19 deletions.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: d8831d5554c2f295a6746e9d3b4cbd8bb13a540f
refs/heads/master: 438bd525e5240a48233cd3290f7fe66ff0167e20
6 changes: 3 additions & 3 deletions trunk/drivers/ieee1394/dv1394-private.h
Original file line number Diff line number Diff line change
Expand Up @@ -460,17 +460,17 @@ struct video_card {
int dma_running;

/*
3) the sleeping semaphore 'sem' - this is used from process context only,
3) the sleeping mutex 'mtx' - this is used from process context only,
to serialize various operations on the video_card. Even though only one
open() is allowed, we still need to prevent multiple threads of execution
from entering calls like read, write, ioctl, etc.
I honestly can't think of a good reason to use dv1394 from several threads
at once, but we need to serialize anyway to prevent oopses =).
NOTE: if you need both spinlock and sem, take sem first to avoid deadlock!
NOTE: if you need both spinlock and mtx, take mtx first to avoid deadlock!
*/
struct semaphore sem;
struct mutex mtx;

/* people waiting for buffer space, please form a line here... */
wait_queue_head_t waitq;
Expand Down
31 changes: 16 additions & 15 deletions trunk/drivers/ieee1394/dv1394.c
Original file line number Diff line number Diff line change
Expand Up @@ -95,6 +95,7 @@
#include <linux/fs.h>
#include <linux/poll.h>
#include <linux/smp_lock.h>
#include <linux/mutex.h>
#include <linux/bitops.h>
#include <asm/byteorder.h>
#include <asm/atomic.h>
Expand Down Expand Up @@ -247,7 +248,7 @@ static void frame_delete(struct frame *f)
Frame_prepare() must be called OUTSIDE the video->spinlock.
However, frame_prepare() must still be serialized, so
it should be called WITH the video->sem taken.
it should be called WITH the video->mtx taken.
*/

static void frame_prepare(struct video_card *video, unsigned int this_frame)
Expand Down Expand Up @@ -1271,7 +1272,7 @@ static int dv1394_mmap(struct file *file, struct vm_area_struct *vma)
int retval = -EINVAL;

/* serialize mmap */
down(&video->sem);
mutex_lock(&video->mtx);

if ( ! video_card_initialized(video) ) {
retval = do_dv1394_init_default(video);
Expand All @@ -1281,7 +1282,7 @@ static int dv1394_mmap(struct file *file, struct vm_area_struct *vma)

retval = dma_region_mmap(&video->dv_buf, file, vma);
out:
up(&video->sem);
mutex_unlock(&video->mtx);
return retval;
}

Expand Down Expand Up @@ -1337,17 +1338,17 @@ static ssize_t dv1394_write(struct file *file, const char __user *buffer, size_t

/* serialize this to prevent multi-threaded mayhem */
if (file->f_flags & O_NONBLOCK) {
if (down_trylock(&video->sem))
if (!mutex_trylock(&video->mtx))
return -EAGAIN;
} else {
if (down_interruptible(&video->sem))
if (mutex_lock_interruptible(&video->mtx))
return -ERESTARTSYS;
}

if ( !video_card_initialized(video) ) {
ret = do_dv1394_init_default(video);
if (ret) {
up(&video->sem);
mutex_unlock(&video->mtx);
return ret;
}
}
Expand Down Expand Up @@ -1418,7 +1419,7 @@ static ssize_t dv1394_write(struct file *file, const char __user *buffer, size_t

remove_wait_queue(&video->waitq, &wait);
set_current_state(TASK_RUNNING);
up(&video->sem);
mutex_unlock(&video->mtx);
return ret;
}

Expand All @@ -1434,17 +1435,17 @@ static ssize_t dv1394_read(struct file *file, char __user *buffer, size_t count

/* serialize this to prevent multi-threaded mayhem */
if (file->f_flags & O_NONBLOCK) {
if (down_trylock(&video->sem))
if (!mutex_trylock(&video->mtx))
return -EAGAIN;
} else {
if (down_interruptible(&video->sem))
if (mutex_lock_interruptible(&video->mtx))
return -ERESTARTSYS;
}

if ( !video_card_initialized(video) ) {
ret = do_dv1394_init_default(video);
if (ret) {
up(&video->sem);
mutex_unlock(&video->mtx);
return ret;
}
video->continuity_counter = -1;
Expand Down Expand Up @@ -1526,7 +1527,7 @@ static ssize_t dv1394_read(struct file *file, char __user *buffer, size_t count

remove_wait_queue(&video->waitq, &wait);
set_current_state(TASK_RUNNING);
up(&video->sem);
mutex_unlock(&video->mtx);
return ret;
}

Expand All @@ -1547,12 +1548,12 @@ static long dv1394_ioctl(struct file *file, unsigned int cmd, unsigned long arg)

/* serialize this to prevent multi-threaded mayhem */
if (file->f_flags & O_NONBLOCK) {
if (down_trylock(&video->sem)) {
if (!mutex_trylock(&video->mtx)) {
unlock_kernel();
return -EAGAIN;
}
} else {
if (down_interruptible(&video->sem)) {
if (mutex_lock_interruptible(&video->mtx)) {
unlock_kernel();
return -ERESTARTSYS;
}
Expand Down Expand Up @@ -1778,7 +1779,7 @@ static long dv1394_ioctl(struct file *file, unsigned int cmd, unsigned long arg)
}

out:
up(&video->sem);
mutex_unlock(&video->mtx);
unlock_kernel();
return ret;
}
Expand Down Expand Up @@ -2253,7 +2254,7 @@ static int dv1394_init(struct ti_ohci *ohci, enum pal_or_ntsc format, enum modes
clear_bit(0, &video->open);
spin_lock_init(&video->spinlock);
video->dma_running = 0;
init_MUTEX(&video->sem);
mutex_init(&video->mtx);
init_waitqueue_head(&video->waitq);
video->fasync = NULL;

Expand Down

0 comments on commit 82958c4

Please sign in to comment.