|
@@ -4385,10 +4385,11 @@ static int got_BarrierAck(struct drbd_conf *mdev, struct p_header80 *h)
|
|
|
|
|
|
if (mdev->state.conn == C_AHEAD &&
|
|
|
atomic_read(&mdev->ap_in_flight) == 0 &&
|
|
|
+ atomic_read(&mdev->rs_pending_cnt) == 0 &&
|
|
|
list_empty(&mdev->start_resync_work.list)) {
|
|
|
struct drbd_work *w = &mdev->start_resync_work;
|
|
|
w->cb = w_start_resync;
|
|
|
- drbd_queue_work_front(&mdev->data.work, w);
|
|
|
+ drbd_queue_work(&mdev->data.work, w);
|
|
|
}
|
|
|
|
|
|
return true;
|