{
        dmz_unlock_map(zmd);
        dmz_unlock_metadata(zmd);
+       set_bit(DMZ_RECLAIM_TERMINATE, &zone->flags);
        wait_on_bit_timeout(&zone->flags, DMZ_RECLAIM, TASK_UNINTERRUPTIBLE, HZ);
+       clear_bit(DMZ_RECLAIM_TERMINATE, &zone->flags);
        dmz_lock_metadata(zmd);
        dmz_lock_map(zmd);
 }
 
                if (dst_dev->flags & DMZ_BDEV_DYING)
                        return -EIO;
 
+               if (dmz_reclaim_should_terminate(src_zone))
+                       return -EINTR;
+
                /* Get a valid region from the source zone */
                ret = dmz_first_valid_block(zmd, src_zone, &block);
                if (ret <= 0)
                dmz_nr_rnd_zones(zmd));
 
        ret = dmz_do_reclaim(zrc);
-       if (ret) {
+       if (ret && ret != -EINTR) {
                DMDEBUG("(%s): Reclaim error %d",
                        dmz_metadata_label(zmd), ret);
                if (!dmz_check_dev(zmd))
        if (dmz_should_reclaim(zrc, p_unmap))
                mod_delayed_work(zrc->wq, &zrc->work, 0);
 }
-
 
        /* Zone internal state */
        DMZ_RECLAIM,
        DMZ_SEQ_WRITE_ERR,
+       DMZ_RECLAIM_TERMINATE,
 };
 
 /*
 #define dmz_is_readonly(z)     test_bit(DMZ_READ_ONLY, &(z)->flags)
 #define dmz_in_reclaim(z)      test_bit(DMZ_RECLAIM, &(z)->flags)
 #define dmz_seq_write_err(z)   test_bit(DMZ_SEQ_WRITE_ERR, &(z)->flags)
+#define dmz_reclaim_should_terminate(z) \
+                               test_bit(DMZ_RECLAIM_TERMINATE, &(z)->flags)
 
 #define dmz_is_meta(z)         test_bit(DMZ_META, &(z)->flags)
 #define dmz_is_buf(z)          test_bit(DMZ_BUF, &(z)->flags)