drbd: Ensure that an epoch contains only requests of one kind

The assert in drbd_req.c:755 forces us to have only requests of
one kind in an epoch. The two kinds we distinguish here are:
local-only or mirrored.

Signed-off-by: Philipp Reisner <philipp.reisner@linbit.com>
Signed-off-by: Lars Ellenberg <lars.ellenberg@linbit.com>

1 files changed, 4 insertions, 25 deletions

diff --git a/drivers/block/drbd/drbd_req.c b/drivers/block/drbd/drbd_req.c
index 6f9d1bfcca58..336937a14d3f 100644
--- a/drivers/block/drbd/drbd_req.c
+++ b/drivers/block/drbd/drbd_req.c
@@ -762,27 +762,6 @@ static int drbd_may_do_local_read(struct drbd_conf *mdev, sector_t sector, int s
         return 0 == drbd_bm_count_bits(mdev, sbnr, ebnr);
 }
 
-static bool drbd_should_do_remote(struct drbd_conf *mdev)
-{
-        union drbd_state s = mdev->state;
-
-        return s.pdsk == D_UP_TO_DATE ||
-                (s.pdsk >= D_INCONSISTENT &&
-                 s.conn >= C_WF_BITMAP_T &&
-                 s.conn < C_AHEAD);
-        /* Before proto 96 that was >= CONNECTED instead of >= C_WF_BITMAP_T.
-           That is equivalent since before 96 IO was frozen in the C_WF_BITMAP*
-           states. */
-}
-static bool drbd_should_send_oos(struct drbd_conf *mdev)
-{
-        union drbd_state s = mdev->state;
-
-        return s.conn == C_AHEAD || s.conn == C_WF_BITMAP_S;
-        /* pdsk = D_INCONSISTENT as a consequence. Protocol 96 check not necessary
-           since we enter state C_AHEAD only if proto >= 96 */
-}
-
 static int drbd_make_request_common(struct drbd_conf *mdev, struct bio *bio, unsigned long start_time)
 {
         const int rw = bio_rw(bio);
@@ -854,8 +833,8 @@ static int drbd_make_request_common(struct drbd_conf *mdev, struct bio *bio, uns
                 drbd_al_begin_io(mdev, sector);
         }
 
-        remote = remote && drbd_should_do_remote(mdev);
-        send_oos = rw == WRITE && drbd_should_send_oos(mdev);
+        remote = remote && drbd_should_do_remote(mdev->state);
+        send_oos = rw == WRITE && drbd_should_send_oos(mdev->state);
         D_ASSERT(!(remote && send_oos));
 
         if (!(local || remote) && !is_susp(mdev->state)) {
@@ -896,8 +875,8 @@ allocate_barrier:
         }
 
         if (remote || send_oos) {
-                remote = drbd_should_do_remote(mdev);
-                send_oos = rw == WRITE && drbd_should_send_oos(mdev);
+                remote = drbd_should_do_remote(mdev->state);
+                send_oos = rw == WRITE && drbd_should_send_oos(mdev->state);
                 D_ASSERT(!(remote && send_oos));
 
                 if (!(remote || send_oos))