dm: add target num_write_bios fn
authorAlasdair G Kergon <agk@redhat.com>
Fri, 1 Mar 2013 22:45:49 +0000 (22:45 +0000)
committerAlasdair G Kergon <agk@redhat.com>
Fri, 1 Mar 2013 22:45:49 +0000 (22:45 +0000)
Add a num_write_bios function to struct target.

If an instance of a target sets this, it will be queried before the
target's mapping function is called on a write bio, and the response
controls the number of copies of the write bio that the target will
receive.

This provides a convenient way for a target to send the same data to
more than one device.  The new cache target uses this in writethrough
mode, to send the data both to the cache and the backing device.

Signed-off-by: Alasdair G Kergon <agk@redhat.com>
drivers/md/dm.c
include/linux/device-mapper.h

index e417cf0a69ef4e5efe3cb77f67cba51afb5843a2..7e469260fe5eba5272ab56f74d9bd1c38fc2cfbf 100644 (file)
@@ -1152,15 +1152,23 @@ static void __clone_and_map_data_bio(struct clone_info *ci, struct dm_target *ti
 {
        struct bio *bio = ci->bio;
        struct dm_target_io *tio;
+       unsigned target_bio_nr;
+       unsigned num_target_bios = 1;
 
-       tio = alloc_tio(ci, ti, nr_iovecs, 0);
-
-       if (split_bvec)
-               clone_split_bio(tio, bio, sector, idx, offset, len);
-       else
-               clone_bio(tio, bio, sector, idx, bv_count, len);
+       /*
+        * Does the target want to receive duplicate copies of the bio?
+        */
+       if (bio_data_dir(bio) == WRITE && ti->num_write_bios)
+               num_target_bios = ti->num_write_bios(ti, bio);
 
-       __map_bio(tio);
+       for (target_bio_nr = 0; target_bio_nr < num_target_bios; target_bio_nr++) {
+               tio = alloc_tio(ci, ti, nr_iovecs, target_bio_nr);
+               if (split_bvec)
+                       clone_split_bio(tio, bio, sector, idx, offset, len);
+               else
+                       clone_bio(tio, bio, sector, idx, bv_count, len);
+               __map_bio(tio);
+       }
 }
 
 typedef unsigned (*get_num_bios_fn)(struct dm_target *ti);
index d5f984b0746611c80ba49dd3dfc9a67d5e5a1dd8..1e483fa7afb41b681ba802061d4ae5ab4ad4676a 100644 (file)
@@ -175,6 +175,14 @@ struct target_type {
 #define DM_TARGET_IMMUTABLE            0x00000004
 #define dm_target_is_immutable(type)   ((type)->features & DM_TARGET_IMMUTABLE)
 
+/*
+ * Some targets need to be sent the same WRITE bio severals times so
+ * that they can send copies of it to different devices.  This function
+ * examines any supplied bio and returns the number of copies of it the
+ * target requires.
+ */
+typedef unsigned (*dm_num_write_bios_fn) (struct dm_target *ti, struct bio *bio);
+
 struct dm_target {
        struct dm_table *table;
        struct target_type *type;
@@ -214,6 +222,13 @@ struct dm_target {
         */
        unsigned per_bio_data_size;
 
+       /*
+        * If defined, this function is called to find out how many
+        * duplicate bios should be sent to the target when writing
+        * data.
+        */
+       dm_num_write_bios_fn num_write_bios;
+
        /* target specific data */
        void *private;