device-mapper.h 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516
  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/ratelimit.h>
  12. struct dm_dev;
  13. struct dm_target;
  14. struct dm_table;
  15. struct mapped_device;
  16. struct bio_vec;
  17. typedef enum { STATUSTYPE_INFO, STATUSTYPE_TABLE } status_type_t;
  18. union map_info {
  19. void *ptr;
  20. unsigned long long ll;
  21. unsigned target_request_nr;
  22. };
  23. /*
  24. * In the constructor the target parameter will already have the
  25. * table, type, begin and len fields filled in.
  26. */
  27. typedef int (*dm_ctr_fn) (struct dm_target *target,
  28. unsigned int argc, char **argv);
  29. /*
  30. * The destructor doesn't need to free the dm_target, just
  31. * anything hidden ti->private.
  32. */
  33. typedef void (*dm_dtr_fn) (struct dm_target *ti);
  34. /*
  35. * The map function must return:
  36. * < 0: error
  37. * = 0: The target will handle the io by resubmitting it later
  38. * = 1: simple remap complete
  39. * = 2: The target wants to push back the io
  40. */
  41. typedef int (*dm_map_fn) (struct dm_target *ti, struct bio *bio,
  42. union map_info *map_context);
  43. typedef int (*dm_map_request_fn) (struct dm_target *ti, struct request *clone,
  44. union map_info *map_context);
  45. /*
  46. * Returns:
  47. * < 0 : error (currently ignored)
  48. * 0 : ended successfully
  49. * 1 : for some reason the io has still not completed (eg,
  50. * multipath target might want to requeue a failed io).
  51. * 2 : The target wants to push back the io
  52. */
  53. typedef int (*dm_endio_fn) (struct dm_target *ti,
  54. struct bio *bio, int error,
  55. union map_info *map_context);
  56. typedef int (*dm_request_endio_fn) (struct dm_target *ti,
  57. struct request *clone, int error,
  58. union map_info *map_context);
  59. typedef void (*dm_flush_fn) (struct dm_target *ti);
  60. typedef void (*dm_presuspend_fn) (struct dm_target *ti);
  61. typedef void (*dm_postsuspend_fn) (struct dm_target *ti);
  62. typedef int (*dm_preresume_fn) (struct dm_target *ti);
  63. typedef void (*dm_resume_fn) (struct dm_target *ti);
  64. typedef void (*dm_status_fn) (struct dm_target *ti, status_type_t status_type,
  65. char *result, unsigned int maxlen);
  66. typedef int (*dm_message_fn) (struct dm_target *ti, unsigned argc, char **argv);
  67. typedef int (*dm_ioctl_fn) (struct dm_target *ti, unsigned int cmd,
  68. unsigned long arg);
  69. typedef int (*dm_merge_fn) (struct dm_target *ti, struct bvec_merge_data *bvm,
  70. struct bio_vec *biovec, int max_size);
  71. typedef int (*iterate_devices_callout_fn) (struct dm_target *ti,
  72. struct dm_dev *dev,
  73. sector_t start, sector_t len,
  74. void *data);
  75. typedef int (*dm_iterate_devices_fn) (struct dm_target *ti,
  76. iterate_devices_callout_fn fn,
  77. void *data);
  78. typedef void (*dm_io_hints_fn) (struct dm_target *ti,
  79. struct queue_limits *limits);
  80. /*
  81. * Returns:
  82. * 0: The target can handle the next I/O immediately.
  83. * 1: The target can't handle the next I/O immediately.
  84. */
  85. typedef int (*dm_busy_fn) (struct dm_target *ti);
  86. void dm_error(const char *message);
  87. /*
  88. * Combine device limits.
  89. */
  90. int dm_set_device_limits(struct dm_target *ti, struct dm_dev *dev,
  91. sector_t start, sector_t len, void *data);
  92. struct dm_dev {
  93. struct block_device *bdev;
  94. fmode_t mode;
  95. char name[16];
  96. };
  97. /*
  98. * Constructors should call these functions to ensure destination devices
  99. * are opened/closed correctly.
  100. */
  101. int dm_get_device(struct dm_target *ti, const char *path, fmode_t mode,
  102. struct dm_dev **result);
  103. void dm_put_device(struct dm_target *ti, struct dm_dev *d);
  104. /*
  105. * Information about a target type
  106. */
  107. struct target_type {
  108. uint64_t features;
  109. const char *name;
  110. struct module *module;
  111. unsigned version[3];
  112. dm_ctr_fn ctr;
  113. dm_dtr_fn dtr;
  114. dm_map_fn map;
  115. dm_map_request_fn map_rq;
  116. dm_endio_fn end_io;
  117. dm_request_endio_fn rq_end_io;
  118. dm_flush_fn flush;
  119. dm_presuspend_fn presuspend;
  120. dm_postsuspend_fn postsuspend;
  121. dm_preresume_fn preresume;
  122. dm_resume_fn resume;
  123. dm_status_fn status;
  124. dm_message_fn message;
  125. dm_ioctl_fn ioctl;
  126. dm_merge_fn merge;
  127. dm_busy_fn busy;
  128. dm_iterate_devices_fn iterate_devices;
  129. dm_io_hints_fn io_hints;
  130. /* For internal device-mapper use. */
  131. struct list_head list;
  132. };
  133. /*
  134. * Target features
  135. */
  136. /*
  137. * Any table that contains an instance of this target must have only one.
  138. */
  139. #define DM_TARGET_SINGLETON 0x00000001
  140. #define dm_target_needs_singleton(type) ((type)->features & DM_TARGET_SINGLETON)
  141. /*
  142. * Indicates that a target does not support read-only devices.
  143. */
  144. #define DM_TARGET_ALWAYS_WRITEABLE 0x00000002
  145. #define dm_target_always_writeable(type) \
  146. ((type)->features & DM_TARGET_ALWAYS_WRITEABLE)
  147. /*
  148. * Any device that contains a table with an instance of this target may never
  149. * have tables containing any different target type.
  150. */
  151. #define DM_TARGET_IMMUTABLE 0x00000004
  152. #define dm_target_is_immutable(type) ((type)->features & DM_TARGET_IMMUTABLE)
  153. struct dm_target {
  154. struct dm_table *table;
  155. struct target_type *type;
  156. /* target limits */
  157. sector_t begin;
  158. sector_t len;
  159. /* Always a power of 2 */
  160. sector_t split_io;
  161. /*
  162. * A number of zero-length barrier requests that will be submitted
  163. * to the target for the purpose of flushing cache.
  164. *
  165. * The request number will be placed in union map_info->target_request_nr.
  166. * It is a responsibility of the target driver to remap these requests
  167. * to the real underlying devices.
  168. */
  169. unsigned num_flush_requests;
  170. /*
  171. * The number of discard requests that will be submitted to the
  172. * target. map_info->request_nr is used just like num_flush_requests.
  173. */
  174. unsigned num_discard_requests;
  175. /* target specific data */
  176. void *private;
  177. /* Used to provide an error string from the ctr */
  178. char *error;
  179. /*
  180. * Set if this target needs to receive discards regardless of
  181. * whether or not its underlying devices have support.
  182. */
  183. unsigned discards_supported:1;
  184. /*
  185. * Set if this target does not return zeroes on discarded blocks.
  186. */
  187. unsigned discard_zeroes_data_unsupported:1;
  188. };
  189. /* Each target can link one of these into the table */
  190. struct dm_target_callbacks {
  191. struct list_head list;
  192. int (*congested_fn) (struct dm_target_callbacks *, int);
  193. };
  194. int dm_register_target(struct target_type *t);
  195. void dm_unregister_target(struct target_type *t);
  196. /*
  197. * Target argument parsing.
  198. */
  199. struct dm_arg_set {
  200. unsigned argc;
  201. char **argv;
  202. };
  203. /*
  204. * The minimum and maximum value of a numeric argument, together with
  205. * the error message to use if the number is found to be outside that range.
  206. */
  207. struct dm_arg {
  208. unsigned min;
  209. unsigned max;
  210. char *error;
  211. };
  212. /*
  213. * Validate the next argument, either returning it as *value or, if invalid,
  214. * returning -EINVAL and setting *error.
  215. */
  216. int dm_read_arg(struct dm_arg *arg, struct dm_arg_set *arg_set,
  217. unsigned *value, char **error);
  218. /*
  219. * Process the next argument as the start of a group containing between
  220. * arg->min and arg->max further arguments. Either return the size as
  221. * *num_args or, if invalid, return -EINVAL and set *error.
  222. */
  223. int dm_read_arg_group(struct dm_arg *arg, struct dm_arg_set *arg_set,
  224. unsigned *num_args, char **error);
  225. /*
  226. * Return the current argument and shift to the next.
  227. */
  228. const char *dm_shift_arg(struct dm_arg_set *as);
  229. /*
  230. * Move through num_args arguments.
  231. */
  232. void dm_consume_args(struct dm_arg_set *as, unsigned num_args);
  233. /*-----------------------------------------------------------------
  234. * Functions for creating and manipulating mapped devices.
  235. * Drop the reference with dm_put when you finish with the object.
  236. *---------------------------------------------------------------*/
  237. /*
  238. * DM_ANY_MINOR chooses the next available minor number.
  239. */
  240. #define DM_ANY_MINOR (-1)
  241. int dm_create(int minor, struct mapped_device **md);
  242. /*
  243. * Reference counting for md.
  244. */
  245. struct mapped_device *dm_get_md(dev_t dev);
  246. void dm_get(struct mapped_device *md);
  247. void dm_put(struct mapped_device *md);
  248. /*
  249. * An arbitrary pointer may be stored alongside a mapped device.
  250. */
  251. void dm_set_mdptr(struct mapped_device *md, void *ptr);
  252. void *dm_get_mdptr(struct mapped_device *md);
  253. /*
  254. * A device can still be used while suspended, but I/O is deferred.
  255. */
  256. int dm_suspend(struct mapped_device *md, unsigned suspend_flags);
  257. int dm_resume(struct mapped_device *md);
  258. /*
  259. * Event functions.
  260. */
  261. uint32_t dm_get_event_nr(struct mapped_device *md);
  262. int dm_wait_event(struct mapped_device *md, int event_nr);
  263. uint32_t dm_next_uevent_seq(struct mapped_device *md);
  264. void dm_uevent_add(struct mapped_device *md, struct list_head *elist);
  265. /*
  266. * Info functions.
  267. */
  268. const char *dm_device_name(struct mapped_device *md);
  269. int dm_copy_name_and_uuid(struct mapped_device *md, char *name, char *uuid);
  270. struct gendisk *dm_disk(struct mapped_device *md);
  271. int dm_suspended(struct dm_target *ti);
  272. int dm_noflush_suspending(struct dm_target *ti);
  273. union map_info *dm_get_mapinfo(struct bio *bio);
  274. union map_info *dm_get_rq_mapinfo(struct request *rq);
  275. /*
  276. * Geometry functions.
  277. */
  278. int dm_get_geometry(struct mapped_device *md, struct hd_geometry *geo);
  279. int dm_set_geometry(struct mapped_device *md, struct hd_geometry *geo);
  280. /*-----------------------------------------------------------------
  281. * Functions for manipulating device-mapper tables.
  282. *---------------------------------------------------------------*/
  283. /*
  284. * First create an empty table.
  285. */
  286. int dm_table_create(struct dm_table **result, fmode_t mode,
  287. unsigned num_targets, struct mapped_device *md);
  288. /*
  289. * Then call this once for each target.
  290. */
  291. int dm_table_add_target(struct dm_table *t, const char *type,
  292. sector_t start, sector_t len, char *params);
  293. /*
  294. * Target_ctr should call this if it needs to add any callbacks.
  295. */
  296. void dm_table_add_target_callbacks(struct dm_table *t, struct dm_target_callbacks *cb);
  297. /*
  298. * Finally call this to make the table ready for use.
  299. */
  300. int dm_table_complete(struct dm_table *t);
  301. /*
  302. * Table reference counting.
  303. */
  304. struct dm_table *dm_get_live_table(struct mapped_device *md);
  305. void dm_table_get(struct dm_table *t);
  306. void dm_table_put(struct dm_table *t);
  307. /*
  308. * Queries
  309. */
  310. sector_t dm_table_get_size(struct dm_table *t);
  311. unsigned int dm_table_get_num_targets(struct dm_table *t);
  312. fmode_t dm_table_get_mode(struct dm_table *t);
  313. struct mapped_device *dm_table_get_md(struct dm_table *t);
  314. /*
  315. * Trigger an event.
  316. */
  317. void dm_table_event(struct dm_table *t);
  318. /*
  319. * The device must be suspended before calling this method.
  320. * Returns the previous table, which the caller must destroy.
  321. */
  322. struct dm_table *dm_swap_table(struct mapped_device *md,
  323. struct dm_table *t);
  324. /*
  325. * A wrapper around vmalloc.
  326. */
  327. void *dm_vcalloc(unsigned long nmemb, unsigned long elem_size);
  328. /*-----------------------------------------------------------------
  329. * Macros.
  330. *---------------------------------------------------------------*/
  331. #define DM_NAME "device-mapper"
  332. #ifdef CONFIG_PRINTK
  333. extern struct ratelimit_state dm_ratelimit_state;
  334. #define dm_ratelimit() __ratelimit(&dm_ratelimit_state)
  335. #else
  336. #define dm_ratelimit() 0
  337. #endif
  338. #define DMCRIT(f, arg...) \
  339. printk(KERN_CRIT DM_NAME ": " DM_MSG_PREFIX ": " f "\n", ## arg)
  340. #define DMERR(f, arg...) \
  341. printk(KERN_ERR DM_NAME ": " DM_MSG_PREFIX ": " f "\n", ## arg)
  342. #define DMERR_LIMIT(f, arg...) \
  343. do { \
  344. if (dm_ratelimit()) \
  345. printk(KERN_ERR DM_NAME ": " DM_MSG_PREFIX ": " \
  346. f "\n", ## arg); \
  347. } while (0)
  348. #define DMWARN(f, arg...) \
  349. printk(KERN_WARNING DM_NAME ": " DM_MSG_PREFIX ": " f "\n", ## arg)
  350. #define DMWARN_LIMIT(f, arg...) \
  351. do { \
  352. if (dm_ratelimit()) \
  353. printk(KERN_WARNING DM_NAME ": " DM_MSG_PREFIX ": " \
  354. f "\n", ## arg); \
  355. } while (0)
  356. #define DMINFO(f, arg...) \
  357. printk(KERN_INFO DM_NAME ": " DM_MSG_PREFIX ": " f "\n", ## arg)
  358. #define DMINFO_LIMIT(f, arg...) \
  359. do { \
  360. if (dm_ratelimit()) \
  361. printk(KERN_INFO DM_NAME ": " DM_MSG_PREFIX ": " f \
  362. "\n", ## arg); \
  363. } while (0)
  364. #ifdef CONFIG_DM_DEBUG
  365. # define DMDEBUG(f, arg...) \
  366. printk(KERN_DEBUG DM_NAME ": " DM_MSG_PREFIX " DEBUG: " f "\n", ## arg)
  367. # define DMDEBUG_LIMIT(f, arg...) \
  368. do { \
  369. if (dm_ratelimit()) \
  370. printk(KERN_DEBUG DM_NAME ": " DM_MSG_PREFIX ": " f \
  371. "\n", ## arg); \
  372. } while (0)
  373. #else
  374. # define DMDEBUG(f, arg...) do {} while (0)
  375. # define DMDEBUG_LIMIT(f, arg...) do {} while (0)
  376. #endif
  377. #define DMEMIT(x...) sz += ((sz >= maxlen) ? \
  378. 0 : scnprintf(result + sz, maxlen - sz, x))
  379. #define SECTOR_SHIFT 9
  380. /*
  381. * Definitions of return values from target end_io function.
  382. */
  383. #define DM_ENDIO_INCOMPLETE 1
  384. #define DM_ENDIO_REQUEUE 2
  385. /*
  386. * Definitions of return values from target map function.
  387. */
  388. #define DM_MAPIO_SUBMITTED 0
  389. #define DM_MAPIO_REMAPPED 1
  390. #define DM_MAPIO_REQUEUE DM_ENDIO_REQUEUE
  391. /*
  392. * Ceiling(n / sz)
  393. */
  394. #define dm_div_up(n, sz) (((n) + (sz) - 1) / (sz))
  395. #define dm_sector_div_up(n, sz) ( \
  396. { \
  397. sector_t _r = ((n) + (sz) - 1); \
  398. sector_div(_r, (sz)); \
  399. _r; \
  400. } \
  401. )
  402. /*
  403. * ceiling(n / size) * size
  404. */
  405. #define dm_round_up(n, sz) (dm_div_up((n), (sz)) * (sz))
  406. #define dm_array_too_big(fixed, obj, num) \
  407. ((num) > (UINT_MAX - (fixed)) / (obj))
  408. /*
  409. * Sector offset taken relative to the start of the target instead of
  410. * relative to the start of the device.
  411. */
  412. #define dm_target_offset(ti, sector) ((sector) - (ti)->begin)
  413. static inline sector_t to_sector(unsigned long n)
  414. {
  415. return (n >> SECTOR_SHIFT);
  416. }
  417. static inline unsigned long to_bytes(sector_t n)
  418. {
  419. return (n << SECTOR_SHIFT);
  420. }
  421. /*-----------------------------------------------------------------
  422. * Helper for block layer and dm core operations
  423. *---------------------------------------------------------------*/
  424. void dm_dispatch_request(struct request *rq);
  425. void dm_requeue_unmapped_request(struct request *rq);
  426. void dm_kill_unmapped_request(struct request *rq, int error);
  427. int dm_underlying_device_busy(struct request_queue *q);
  428. void dm_end_request(struct request *clone, int error);
  429. #endif /* _LINUX_DEVICE_MAPPER_H */