device-mapper.h 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607
  1. /*
  2. * Copyright (C) 2001 Sistina Software (UK) Limited.
  3. * Copyright (C) 2004-2008 Red Hat, Inc. All rights reserved.
  4. *
  5. * This file is released under the LGPL.
  6. */
  7. #ifndef _LINUX_DEVICE_MAPPER_H
  8. #define _LINUX_DEVICE_MAPPER_H
  9. #include <linux/bio.h>
  10. #include <linux/blkdev.h>
  11. #include <linux/math64.h>
  12. #include <linux/ratelimit.h>
  13. struct dm_dev;
  14. struct dm_target;
  15. struct dm_table;
  16. struct mapped_device;
  17. struct bio_vec;
  18. typedef enum { STATUSTYPE_INFO, STATUSTYPE_TABLE } status_type_t;
  19. union map_info {
  20. void *ptr;
  21. };
  22. /*
  23. * In the constructor the target parameter will already have the
  24. * table, type, begin and len fields filled in.
  25. */
  26. typedef int (*dm_ctr_fn) (struct dm_target *target,
  27. unsigned int argc, char **argv);
  28. /*
  29. * The destructor doesn't need to free the dm_target, just
  30. * anything hidden ti->private.
  31. */
  32. typedef void (*dm_dtr_fn) (struct dm_target *ti);
  33. /*
  34. * The map function must return:
  35. * < 0: error
  36. * = 0: The target will handle the io by resubmitting it later
  37. * = 1: simple remap complete
  38. * = 2: The target wants to push back the io
  39. */
  40. typedef int (*dm_map_fn) (struct dm_target *ti, struct bio *bio);
  41. typedef int (*dm_map_request_fn) (struct dm_target *ti, struct request *clone,
  42. union map_info *map_context);
  43. /*
  44. * Returns:
  45. * < 0 : error (currently ignored)
  46. * 0 : ended successfully
  47. * 1 : for some reason the io has still not completed (eg,
  48. * multipath target might want to requeue a failed io).
  49. * 2 : The target wants to push back the io
  50. */
  51. typedef int (*dm_endio_fn) (struct dm_target *ti,
  52. struct bio *bio, int error);
  53. typedef int (*dm_request_endio_fn) (struct dm_target *ti,
  54. struct request *clone, int error,
  55. union map_info *map_context);
  56. typedef void (*dm_presuspend_fn) (struct dm_target *ti);
  57. typedef void (*dm_postsuspend_fn) (struct dm_target *ti);
  58. typedef int (*dm_preresume_fn) (struct dm_target *ti);
  59. typedef void (*dm_resume_fn) (struct dm_target *ti);
  60. typedef void (*dm_status_fn) (struct dm_target *ti, status_type_t status_type,
  61. unsigned status_flags, char *result, unsigned maxlen);
  62. typedef int (*dm_message_fn) (struct dm_target *ti, unsigned argc, char **argv);
  63. typedef int (*dm_ioctl_fn) (struct dm_target *ti, unsigned int cmd,
  64. unsigned long arg);
  65. typedef int (*dm_merge_fn) (struct dm_target *ti, struct bvec_merge_data *bvm,
  66. struct bio_vec *biovec, int max_size);
  67. /*
  68. * These iteration functions are typically used to check (and combine)
  69. * properties of underlying devices.
  70. * E.g. Does at least one underlying device support flush?
  71. * Does any underlying device not support WRITE_SAME?
  72. *
  73. * The callout function is called once for each contiguous section of
  74. * an underlying device. State can be maintained in *data.
  75. * Return non-zero to stop iterating through any further devices.
  76. */
  77. typedef int (*iterate_devices_callout_fn) (struct dm_target *ti,
  78. struct dm_dev *dev,
  79. sector_t start, sector_t len,
  80. void *data);
  81. /*
  82. * This function must iterate through each section of device used by the
  83. * target until it encounters a non-zero return code, which it then returns.
  84. * Returns zero if no callout returned non-zero.
  85. */
  86. typedef int (*dm_iterate_devices_fn) (struct dm_target *ti,
  87. iterate_devices_callout_fn fn,
  88. void *data);
  89. typedef void (*dm_io_hints_fn) (struct dm_target *ti,
  90. struct queue_limits *limits);
  91. /*
  92. * Returns:
  93. * 0: The target can handle the next I/O immediately.
  94. * 1: The target can't handle the next I/O immediately.
  95. */
  96. typedef int (*dm_busy_fn) (struct dm_target *ti);
  97. void dm_error(const char *message);
  98. struct dm_dev {
  99. struct block_device *bdev;
  100. fmode_t mode;
  101. char name[16];
  102. };
  103. /*
  104. * Constructors should call these functions to ensure destination devices
  105. * are opened/closed correctly.
  106. */
  107. int dm_get_device(struct dm_target *ti, const char *path, fmode_t mode,
  108. struct dm_dev **result);
  109. void dm_put_device(struct dm_target *ti, struct dm_dev *d);
  110. /*
  111. * Information about a target type
  112. */
  113. struct target_type {
  114. uint64_t features;
  115. const char *name;
  116. struct module *module;
  117. unsigned version[3];
  118. dm_ctr_fn ctr;
  119. dm_dtr_fn dtr;
  120. dm_map_fn map;
  121. dm_map_request_fn map_rq;
  122. dm_endio_fn end_io;
  123. dm_request_endio_fn rq_end_io;
  124. dm_presuspend_fn presuspend;
  125. dm_postsuspend_fn postsuspend;
  126. dm_preresume_fn preresume;
  127. dm_resume_fn resume;
  128. dm_status_fn status;
  129. dm_message_fn message;
  130. dm_ioctl_fn ioctl;
  131. dm_merge_fn merge;
  132. dm_busy_fn busy;
  133. dm_iterate_devices_fn iterate_devices;
  134. dm_io_hints_fn io_hints;
  135. /* For internal device-mapper use. */
  136. struct list_head list;
  137. };
  138. /*
  139. * Target features
  140. */
  141. /*
  142. * Any table that contains an instance of this target must have only one.
  143. */
  144. #define DM_TARGET_SINGLETON 0x00000001
  145. #define dm_target_needs_singleton(type) ((type)->features & DM_TARGET_SINGLETON)
  146. /*
  147. * Indicates that a target does not support read-only devices.
  148. */
  149. #define DM_TARGET_ALWAYS_WRITEABLE 0x00000002
  150. #define dm_target_always_writeable(type) \
  151. ((type)->features & DM_TARGET_ALWAYS_WRITEABLE)
  152. /*
  153. * Any device that contains a table with an instance of this target may never
  154. * have tables containing any different target type.
  155. */
  156. #define DM_TARGET_IMMUTABLE 0x00000004
  157. #define dm_target_is_immutable(type) ((type)->features & DM_TARGET_IMMUTABLE)
  158. /*
  159. * Some targets need to be sent the same WRITE bio severals times so
  160. * that they can send copies of it to different devices. This function
  161. * examines any supplied bio and returns the number of copies of it the
  162. * target requires.
  163. */
  164. typedef unsigned (*dm_num_write_bios_fn) (struct dm_target *ti, struct bio *bio);
  165. struct dm_target {
  166. struct dm_table *table;
  167. struct target_type *type;
  168. /* target limits */
  169. sector_t begin;
  170. sector_t len;
  171. /* If non-zero, maximum size of I/O submitted to a target. */
  172. uint32_t max_io_len;
  173. /*
  174. * A number of zero-length barrier bios that will be submitted
  175. * to the target for the purpose of flushing cache.
  176. *
  177. * The bio number can be accessed with dm_bio_get_target_bio_nr.
  178. * It is a responsibility of the target driver to remap these bios
  179. * to the real underlying devices.
  180. */
  181. unsigned num_flush_bios;
  182. /*
  183. * The number of discard bios that will be submitted to the target.
  184. * The bio number can be accessed with dm_bio_get_target_bio_nr.
  185. */
  186. unsigned num_discard_bios;
  187. /*
  188. * The number of WRITE SAME bios that will be submitted to the target.
  189. * The bio number can be accessed with dm_bio_get_target_bio_nr.
  190. */
  191. unsigned num_write_same_bios;
  192. /*
  193. * The minimum number of extra bytes allocated in each bio for the
  194. * target to use. dm_per_bio_data returns the data location.
  195. */
  196. unsigned per_bio_data_size;
  197. /*
  198. * If defined, this function is called to find out how many
  199. * duplicate bios should be sent to the target when writing
  200. * data.
  201. */
  202. dm_num_write_bios_fn num_write_bios;
  203. /* target specific data */
  204. void *private;
  205. /* Used to provide an error string from the ctr */
  206. char *error;
  207. /*
  208. * Set if this target needs to receive flushes regardless of
  209. * whether or not its underlying devices have support.
  210. */
  211. bool flush_supported:1;
  212. /*
  213. * Set if this target needs to receive discards regardless of
  214. * whether or not its underlying devices have support.
  215. */
  216. bool discards_supported:1;
  217. /*
  218. * Set if the target required discard bios to be split
  219. * on max_io_len boundary.
  220. */
  221. bool split_discard_bios:1;
  222. /*
  223. * Set if this target does not return zeroes on discarded blocks.
  224. */
  225. bool discard_zeroes_data_unsupported:1;
  226. };
  227. /* Each target can link one of these into the table */
  228. struct dm_target_callbacks {
  229. struct list_head list;
  230. int (*congested_fn) (struct dm_target_callbacks *, int);
  231. };
  232. /*
  233. * For bio-based dm.
  234. * One of these is allocated for each bio.
  235. * This structure shouldn't be touched directly by target drivers.
  236. * It is here so that we can inline dm_per_bio_data and
  237. * dm_bio_from_per_bio_data
  238. */
  239. struct dm_target_io {
  240. struct dm_io *io;
  241. struct dm_target *ti;
  242. unsigned target_bio_nr;
  243. unsigned *len_ptr;
  244. struct bio clone;
  245. };
  246. static inline void *dm_per_bio_data(struct bio *bio, size_t data_size)
  247. {
  248. return (char *)bio - offsetof(struct dm_target_io, clone) - data_size;
  249. }
  250. static inline struct bio *dm_bio_from_per_bio_data(void *data, size_t data_size)
  251. {
  252. return (struct bio *)((char *)data + data_size + offsetof(struct dm_target_io, clone));
  253. }
  254. static inline unsigned dm_bio_get_target_bio_nr(const struct bio *bio)
  255. {
  256. return container_of(bio, struct dm_target_io, clone)->target_bio_nr;
  257. }
  258. int dm_register_target(struct target_type *t);
  259. void dm_unregister_target(struct target_type *t);
  260. /*
  261. * Target argument parsing.
  262. */
  263. struct dm_arg_set {
  264. unsigned argc;
  265. char **argv;
  266. };
  267. /*
  268. * The minimum and maximum value of a numeric argument, together with
  269. * the error message to use if the number is found to be outside that range.
  270. */
  271. struct dm_arg {
  272. unsigned min;
  273. unsigned max;
  274. char *error;
  275. };
  276. /*
  277. * Validate the next argument, either returning it as *value or, if invalid,
  278. * returning -EINVAL and setting *error.
  279. */
  280. int dm_read_arg(struct dm_arg *arg, struct dm_arg_set *arg_set,
  281. unsigned *value, char **error);
  282. /*
  283. * Process the next argument as the start of a group containing between
  284. * arg->min and arg->max further arguments. Either return the size as
  285. * *num_args or, if invalid, return -EINVAL and set *error.
  286. */
  287. int dm_read_arg_group(struct dm_arg *arg, struct dm_arg_set *arg_set,
  288. unsigned *num_args, char **error);
  289. /*
  290. * Return the current argument and shift to the next.
  291. */
  292. const char *dm_shift_arg(struct dm_arg_set *as);
  293. /*
  294. * Move through num_args arguments.
  295. */
  296. void dm_consume_args(struct dm_arg_set *as, unsigned num_args);
  297. /*-----------------------------------------------------------------
  298. * Functions for creating and manipulating mapped devices.
  299. * Drop the reference with dm_put when you finish with the object.
  300. *---------------------------------------------------------------*/
  301. /*
  302. * DM_ANY_MINOR chooses the next available minor number.
  303. */
  304. #define DM_ANY_MINOR (-1)
  305. int dm_create(int minor, struct mapped_device **md);
  306. /*
  307. * Reference counting for md.
  308. */
  309. struct mapped_device *dm_get_md(dev_t dev);
  310. void dm_get(struct mapped_device *md);
  311. int dm_hold(struct mapped_device *md);
  312. void dm_put(struct mapped_device *md);
  313. /*
  314. * An arbitrary pointer may be stored alongside a mapped device.
  315. */
  316. void dm_set_mdptr(struct mapped_device *md, void *ptr);
  317. void *dm_get_mdptr(struct mapped_device *md);
  318. /*
  319. * A device can still be used while suspended, but I/O is deferred.
  320. */
  321. int dm_suspend(struct mapped_device *md, unsigned suspend_flags);
  322. int dm_resume(struct mapped_device *md);
  323. /*
  324. * Event functions.
  325. */
  326. uint32_t dm_get_event_nr(struct mapped_device *md);
  327. int dm_wait_event(struct mapped_device *md, int event_nr);
  328. uint32_t dm_next_uevent_seq(struct mapped_device *md);
  329. void dm_uevent_add(struct mapped_device *md, struct list_head *elist);
  330. /*
  331. * Info functions.
  332. */
  333. const char *dm_device_name(struct mapped_device *md);
  334. int dm_copy_name_and_uuid(struct mapped_device *md, char *name, char *uuid);
  335. struct gendisk *dm_disk(struct mapped_device *md);
  336. int dm_suspended(struct dm_target *ti);
  337. int dm_noflush_suspending(struct dm_target *ti);
  338. void dm_accept_partial_bio(struct bio *bio, unsigned n_sectors);
  339. union map_info *dm_get_rq_mapinfo(struct request *rq);
  340. struct queue_limits *dm_get_queue_limits(struct mapped_device *md);
  341. /*
  342. * Geometry functions.
  343. */
  344. int dm_get_geometry(struct mapped_device *md, struct hd_geometry *geo);
  345. int dm_set_geometry(struct mapped_device *md, struct hd_geometry *geo);
  346. /*-----------------------------------------------------------------
  347. * Functions for manipulating device-mapper tables.
  348. *---------------------------------------------------------------*/
  349. /*
  350. * First create an empty table.
  351. */
  352. int dm_table_create(struct dm_table **result, fmode_t mode,
  353. unsigned num_targets, struct mapped_device *md);
  354. /*
  355. * Then call this once for each target.
  356. */
  357. int dm_table_add_target(struct dm_table *t, const char *type,
  358. sector_t start, sector_t len, char *params);
  359. /*
  360. * Target_ctr should call this if it needs to add any callbacks.
  361. */
  362. void dm_table_add_target_callbacks(struct dm_table *t, struct dm_target_callbacks *cb);
  363. /*
  364. * Finally call this to make the table ready for use.
  365. */
  366. int dm_table_complete(struct dm_table *t);
  367. /*
  368. * Target may require that it is never sent I/O larger than len.
  369. */
  370. int __must_check dm_set_target_max_io_len(struct dm_target *ti, sector_t len);
  371. /*
  372. * Table reference counting.
  373. */
  374. struct dm_table *dm_get_live_table(struct mapped_device *md, int *srcu_idx);
  375. void dm_put_live_table(struct mapped_device *md, int srcu_idx);
  376. void dm_sync_table(struct mapped_device *md);
  377. /*
  378. * Queries
  379. */
  380. sector_t dm_table_get_size(struct dm_table *t);
  381. unsigned int dm_table_get_num_targets(struct dm_table *t);
  382. fmode_t dm_table_get_mode(struct dm_table *t);
  383. struct mapped_device *dm_table_get_md(struct dm_table *t);
  384. /*
  385. * Trigger an event.
  386. */
  387. void dm_table_event(struct dm_table *t);
  388. /*
  389. * Run the queue for request-based targets.
  390. */
  391. void dm_table_run_md_queue_async(struct dm_table *t);
  392. /*
  393. * The device must be suspended before calling this method.
  394. * Returns the previous table, which the caller must destroy.
  395. */
  396. struct dm_table *dm_swap_table(struct mapped_device *md,
  397. struct dm_table *t);
  398. /*
  399. * A wrapper around vmalloc.
  400. */
  401. void *dm_vcalloc(unsigned long nmemb, unsigned long elem_size);
  402. /*-----------------------------------------------------------------
  403. * Macros.
  404. *---------------------------------------------------------------*/
  405. #define DM_NAME "device-mapper"
  406. #ifdef CONFIG_PRINTK
  407. extern struct ratelimit_state dm_ratelimit_state;
  408. #define dm_ratelimit() __ratelimit(&dm_ratelimit_state)
  409. #else
  410. #define dm_ratelimit() 0
  411. #endif
  412. #define DMCRIT(f, arg...) \
  413. printk(KERN_CRIT DM_NAME ": " DM_MSG_PREFIX ": " f "\n", ## arg)
  414. #define DMERR(f, arg...) \
  415. printk(KERN_ERR DM_NAME ": " DM_MSG_PREFIX ": " f "\n", ## arg)
  416. #define DMERR_LIMIT(f, arg...) \
  417. do { \
  418. if (dm_ratelimit()) \
  419. printk(KERN_ERR DM_NAME ": " DM_MSG_PREFIX ": " \
  420. f "\n", ## arg); \
  421. } while (0)
  422. #define DMWARN(f, arg...) \
  423. printk(KERN_WARNING DM_NAME ": " DM_MSG_PREFIX ": " f "\n", ## arg)
  424. #define DMWARN_LIMIT(f, arg...) \
  425. do { \
  426. if (dm_ratelimit()) \
  427. printk(KERN_WARNING DM_NAME ": " DM_MSG_PREFIX ": " \
  428. f "\n", ## arg); \
  429. } while (0)
  430. #define DMINFO(f, arg...) \
  431. printk(KERN_INFO DM_NAME ": " DM_MSG_PREFIX ": " f "\n", ## arg)
  432. #define DMINFO_LIMIT(f, arg...) \
  433. do { \
  434. if (dm_ratelimit()) \
  435. printk(KERN_INFO DM_NAME ": " DM_MSG_PREFIX ": " f \
  436. "\n", ## arg); \
  437. } while (0)
  438. #ifdef CONFIG_DM_DEBUG
  439. # define DMDEBUG(f, arg...) \
  440. printk(KERN_DEBUG DM_NAME ": " DM_MSG_PREFIX " DEBUG: " f "\n", ## arg)
  441. # define DMDEBUG_LIMIT(f, arg...) \
  442. do { \
  443. if (dm_ratelimit()) \
  444. printk(KERN_DEBUG DM_NAME ": " DM_MSG_PREFIX ": " f \
  445. "\n", ## arg); \
  446. } while (0)
  447. #else
  448. # define DMDEBUG(f, arg...) do {} while (0)
  449. # define DMDEBUG_LIMIT(f, arg...) do {} while (0)
  450. #endif
  451. #define DMEMIT(x...) sz += ((sz >= maxlen) ? \
  452. 0 : scnprintf(result + sz, maxlen - sz, x))
  453. #define SECTOR_SHIFT 9
  454. /*
  455. * Definitions of return values from target end_io function.
  456. */
  457. #define DM_ENDIO_INCOMPLETE 1
  458. #define DM_ENDIO_REQUEUE 2
  459. /*
  460. * Definitions of return values from target map function.
  461. */
  462. #define DM_MAPIO_SUBMITTED 0
  463. #define DM_MAPIO_REMAPPED 1
  464. #define DM_MAPIO_REQUEUE DM_ENDIO_REQUEUE
  465. #define dm_sector_div64(x, y)( \
  466. { \
  467. u64 _res; \
  468. (x) = div64_u64_rem(x, y, &_res); \
  469. _res; \
  470. } \
  471. )
  472. /*
  473. * Ceiling(n / sz)
  474. */
  475. #define dm_div_up(n, sz) (((n) + (sz) - 1) / (sz))
  476. #define dm_sector_div_up(n, sz) ( \
  477. { \
  478. sector_t _r = ((n) + (sz) - 1); \
  479. sector_div(_r, (sz)); \
  480. _r; \
  481. } \
  482. )
  483. /*
  484. * ceiling(n / size) * size
  485. */
  486. #define dm_round_up(n, sz) (dm_div_up((n), (sz)) * (sz))
  487. #define dm_array_too_big(fixed, obj, num) \
  488. ((num) > (UINT_MAX - (fixed)) / (obj))
  489. /*
  490. * Sector offset taken relative to the start of the target instead of
  491. * relative to the start of the device.
  492. */
  493. #define dm_target_offset(ti, sector) ((sector) - (ti)->begin)
  494. static inline sector_t to_sector(unsigned long n)
  495. {
  496. return (n >> SECTOR_SHIFT);
  497. }
  498. static inline unsigned long to_bytes(sector_t n)
  499. {
  500. return (n << SECTOR_SHIFT);
  501. }
  502. /*-----------------------------------------------------------------
  503. * Helper for block layer and dm core operations
  504. *---------------------------------------------------------------*/
  505. void dm_dispatch_request(struct request *rq);
  506. void dm_requeue_unmapped_request(struct request *rq);
  507. void dm_kill_unmapped_request(struct request *rq, int error);
  508. int dm_underlying_device_busy(struct request_queue *q);
  509. #endif /* _LINUX_DEVICE_MAPPER_H */