Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 242831
b: refs/heads/master
c: 8869d68
h: refs/heads/master
i:
  242829: ad0ba70
  242827: 67093c4
  242823: b22432c
  242815: f54d050
v: v3
  • Loading branch information
Philipp Reisner committed Mar 10, 2011
1 parent 51cc4ef commit 45b6f24
Show file tree
Hide file tree
Showing 2 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: 127b317844e7cc0458743b604998bece95eab030
refs/heads/master: 8869d683b7491467fd39fcbe79756fce3e6f35e7
31 changes: 14 additions & 17 deletions trunk/drivers/block/drbd/drbd_int.h
Original file line number Diff line number Diff line change
Expand Up @@ -2309,15 +2309,21 @@ static inline int __inc_ap_bio_cond(struct drbd_conf *mdev)
return 1;
}

/* I'd like to use wait_event_lock_irq,
* but I'm not sure when it got introduced,
* and not sure when it has 3 or 4 arguments */
static inline void inc_ap_bio(struct drbd_conf *mdev, int count)
static inline int _inc_ap_bio_cond(struct drbd_conf *mdev, int count)
{
/* compare with after_state_ch,
* os.conn != C_WF_BITMAP_S && ns.conn == C_WF_BITMAP_S */
DEFINE_WAIT(wait);
int rv = 0;

spin_lock_irq(&mdev->req_lock);
rv = __inc_ap_bio_cond(mdev);
if (rv)
atomic_add(count, &mdev->ap_bio_cnt);
spin_unlock_irq(&mdev->req_lock);

return rv;
}

static inline void inc_ap_bio(struct drbd_conf *mdev, int count)
{
/* we wait here
* as long as the device is suspended
* until the bitmap is no longer on the fly during connection
Expand All @@ -2326,16 +2332,7 @@ static inline void inc_ap_bio(struct drbd_conf *mdev, int count)
* to avoid races with the reconnect code,
* we need to atomic_inc within the spinlock. */

spin_lock_irq(&mdev->req_lock);
while (!__inc_ap_bio_cond(mdev)) {
prepare_to_wait(&mdev->misc_wait, &wait, TASK_UNINTERRUPTIBLE);
spin_unlock_irq(&mdev->req_lock);
schedule();
finish_wait(&mdev->misc_wait, &wait);
spin_lock_irq(&mdev->req_lock);
}
atomic_add(count, &mdev->ap_bio_cnt);
spin_unlock_irq(&mdev->req_lock);
wait_event(mdev->misc_wait, _inc_ap_bio_cond(mdev, count));
}

static inline void dec_ap_bio(struct drbd_conf *mdev)
Expand Down

0 comments on commit 45b6f24

Please sign in to comment.