Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 17478
b: refs/heads/master
c: 11b751a
h: refs/heads/master
v: v3
  • Loading branch information
Ingo Molnar authored and Ingo Molnar committed Jan 9, 2006
1 parent 40443d5 commit 67827eb
Show file tree
Hide file tree
Showing 3 changed files with 15 additions and 18 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: f36d4024caa3790606e43228a574157c45b73b22
refs/heads/master: 11b751ae8c8ca3fa24c85bd5a3e51dd9f95cda17
27 changes: 12 additions & 15 deletions trunk/drivers/block/loop.c
Original file line number Diff line number Diff line change
Expand Up @@ -527,12 +527,12 @@ static int loop_make_request(request_queue_t *q, struct bio *old_bio)
lo->lo_pending++;
loop_add_bio(lo, old_bio);
spin_unlock_irq(&lo->lo_lock);
up(&lo->lo_bh_mutex);
complete(&lo->lo_bh_done);
return 0;

out:
if (lo->lo_pending == 0)
up(&lo->lo_bh_mutex);
complete(&lo->lo_bh_done);
spin_unlock_irq(&lo->lo_lock);
bio_io_error(old_bio, old_bio->bi_size);
return 0;
Expand Down Expand Up @@ -593,23 +593,20 @@ static int loop_thread(void *data)
lo->lo_pending = 1;

/*
* up sem, we are running
* complete it, we are running
*/
up(&lo->lo_sem);
complete(&lo->lo_done);

for (;;) {
int pending;

/*
* interruptible just to not contribute to load avg
*/
if (down_interruptible(&lo->lo_bh_mutex))
if (wait_for_completion_interruptible(&lo->lo_bh_done))
continue;

spin_lock_irq(&lo->lo_lock);

/*
* could be upped because of tear-down, not pending work
* could be completed because of tear-down, not pending work
*/
if (unlikely(!lo->lo_pending)) {
spin_unlock_irq(&lo->lo_lock);
Expand All @@ -632,7 +629,7 @@ static int loop_thread(void *data)
break;
}

up(&lo->lo_sem);
complete(&lo->lo_done);
return 0;
}

Expand Down Expand Up @@ -843,7 +840,7 @@ static int loop_set_fd(struct loop_device *lo, struct file *lo_file,
set_blocksize(bdev, lo_blocksize);

kernel_thread(loop_thread, lo, CLONE_KERNEL);
down(&lo->lo_sem);
wait_for_completion(&lo->lo_done);
return 0;

out_putf:
Expand Down Expand Up @@ -909,10 +906,10 @@ static int loop_clr_fd(struct loop_device *lo, struct block_device *bdev)
lo->lo_state = Lo_rundown;
lo->lo_pending--;
if (!lo->lo_pending)
up(&lo->lo_bh_mutex);
complete(&lo->lo_bh_done);
spin_unlock_irq(&lo->lo_lock);

down(&lo->lo_sem);
wait_for_completion(&lo->lo_done);

lo->lo_backing_file = NULL;

Expand Down Expand Up @@ -1289,8 +1286,8 @@ static int __init loop_init(void)
if (!lo->lo_queue)
goto out_mem4;
init_MUTEX(&lo->lo_ctl_mutex);
init_MUTEX_LOCKED(&lo->lo_sem);
init_MUTEX_LOCKED(&lo->lo_bh_mutex);
init_completion(&lo->lo_done);
init_completion(&lo->lo_bh_done);
lo->lo_number = i;
spin_lock_init(&lo->lo_lock);
disk->major = LOOP_MAJOR;
Expand Down
4 changes: 2 additions & 2 deletions trunk/include/linux/loop.h
Original file line number Diff line number Diff line change
Expand Up @@ -58,9 +58,9 @@ struct loop_device {
struct bio *lo_bio;
struct bio *lo_biotail;
int lo_state;
struct semaphore lo_sem;
struct completion lo_done;
struct completion lo_bh_done;
struct semaphore lo_ctl_mutex;
struct semaphore lo_bh_mutex;
int lo_pending;

request_queue_t *lo_queue;
Expand Down

0 comments on commit 67827eb

Please sign in to comment.