elevator.h 7.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218
  1. #ifndef _LINUX_ELEVATOR_H
  2. #define _LINUX_ELEVATOR_H
  3. #include <linux/percpu.h>
  4. #ifdef CONFIG_BLOCK
  5. struct io_cq;
  6. typedef int (elevator_merge_fn) (struct request_queue *, struct request **,
  7. struct bio *);
  8. typedef void (elevator_merge_req_fn) (struct request_queue *, struct request *, struct request *);
  9. typedef void (elevator_merged_fn) (struct request_queue *, struct request *, int);
  10. typedef int (elevator_allow_merge_fn) (struct request_queue *, struct request *, struct bio *);
  11. typedef void (elevator_bio_merged_fn) (struct request_queue *,
  12. struct request *, struct bio *);
  13. typedef int (elevator_dispatch_fn) (struct request_queue *, int);
  14. typedef void (elevator_add_req_fn) (struct request_queue *, struct request *);
  15. typedef int (elevator_reinsert_req_fn) (struct request_queue *,
  16. struct request *);
  17. typedef bool (elevator_is_urgent_fn) (struct request_queue *);
  18. typedef struct request *(elevator_request_list_fn) (struct request_queue *, struct request *);
  19. typedef void (elevator_completed_req_fn) (struct request_queue *, struct request *);
  20. typedef int (elevator_may_queue_fn) (struct request_queue *, int);
  21. typedef void (elevator_init_icq_fn) (struct io_cq *);
  22. typedef void (elevator_exit_icq_fn) (struct io_cq *);
  23. typedef int (elevator_set_req_fn) (struct request_queue *, struct request *, gfp_t);
  24. typedef void (elevator_put_req_fn) (struct request *);
  25. typedef void (elevator_activate_req_fn) (struct request_queue *, struct request *);
  26. typedef void (elevator_deactivate_req_fn) (struct request_queue *, struct request *);
  27. typedef void *(elevator_init_fn) (struct request_queue *);
  28. typedef void (elevator_exit_fn) (struct elevator_queue *);
  29. typedef void (elevator_registered_fn) (struct request_queue *);
  30. struct elevator_ops
  31. {
  32. elevator_merge_fn *elevator_merge_fn;
  33. elevator_merged_fn *elevator_merged_fn;
  34. elevator_merge_req_fn *elevator_merge_req_fn;
  35. elevator_allow_merge_fn *elevator_allow_merge_fn;
  36. elevator_bio_merged_fn *elevator_bio_merged_fn;
  37. elevator_dispatch_fn *elevator_dispatch_fn;
  38. elevator_add_req_fn *elevator_add_req_fn;
  39. elevator_reinsert_req_fn *elevator_reinsert_req_fn;
  40. elevator_is_urgent_fn *elevator_is_urgent_fn;
  41. elevator_activate_req_fn *elevator_activate_req_fn;
  42. elevator_deactivate_req_fn *elevator_deactivate_req_fn;
  43. elevator_completed_req_fn *elevator_completed_req_fn;
  44. elevator_request_list_fn *elevator_former_req_fn;
  45. elevator_request_list_fn *elevator_latter_req_fn;
  46. elevator_init_icq_fn *elevator_init_icq_fn; /* see iocontext.h */
  47. elevator_exit_icq_fn *elevator_exit_icq_fn; /* ditto */
  48. elevator_set_req_fn *elevator_set_req_fn;
  49. elevator_put_req_fn *elevator_put_req_fn;
  50. elevator_may_queue_fn *elevator_may_queue_fn;
  51. elevator_init_fn *elevator_init_fn;
  52. elevator_exit_fn *elevator_exit_fn;
  53. elevator_registered_fn *elevator_registered_fn;
  54. };
  55. #define ELV_NAME_MAX (16)
  56. struct elv_fs_entry {
  57. struct attribute attr;
  58. ssize_t (*show)(struct elevator_queue *, char *);
  59. ssize_t (*store)(struct elevator_queue *, const char *, size_t);
  60. };
  61. /*
  62. * identifies an elevator type, such as AS or deadline
  63. */
  64. struct elevator_type
  65. {
  66. /* managed by elevator core */
  67. struct kmem_cache *icq_cache;
  68. /* fields provided by elevator implementation */
  69. struct elevator_ops ops;
  70. size_t icq_size; /* see iocontext.h */
  71. size_t icq_align; /* ditto */
  72. struct elv_fs_entry *elevator_attrs;
  73. char elevator_name[ELV_NAME_MAX];
  74. struct module *elevator_owner;
  75. /* managed by elevator core */
  76. char icq_cache_name[ELV_NAME_MAX + 5]; /* elvname + "_io_cq" */
  77. struct list_head list;
  78. };
  79. /*
  80. * each queue has an elevator_queue associated with it
  81. */
  82. struct elevator_queue
  83. {
  84. struct elevator_type *type;
  85. void *elevator_data;
  86. struct kobject kobj;
  87. struct mutex sysfs_lock;
  88. struct hlist_head *hash;
  89. unsigned int registered:1;
  90. };
  91. /*
  92. * block elevator interface
  93. */
  94. extern void elv_dispatch_sort(struct request_queue *, struct request *);
  95. extern void elv_dispatch_add_tail(struct request_queue *, struct request *);
  96. extern void elv_add_request(struct request_queue *, struct request *, int);
  97. extern void __elv_add_request(struct request_queue *, struct request *, int);
  98. extern int elv_merge(struct request_queue *, struct request **, struct bio *);
  99. extern void elv_merge_requests(struct request_queue *, struct request *,
  100. struct request *);
  101. extern void elv_merged_request(struct request_queue *, struct request *, int);
  102. extern void elv_bio_merged(struct request_queue *q, struct request *,
  103. struct bio *);
  104. extern void elv_requeue_request(struct request_queue *, struct request *);
  105. extern int elv_reinsert_request(struct request_queue *, struct request *);
  106. extern struct request *elv_former_request(struct request_queue *, struct request *);
  107. extern struct request *elv_latter_request(struct request_queue *, struct request *);
  108. extern int elv_register_queue(struct request_queue *q);
  109. extern void elv_unregister_queue(struct request_queue *q);
  110. extern int elv_may_queue(struct request_queue *, int);
  111. extern void elv_abort_queue(struct request_queue *);
  112. extern void elv_completed_request(struct request_queue *, struct request *);
  113. extern int elv_set_request(struct request_queue *, struct request *, gfp_t);
  114. extern void elv_put_request(struct request_queue *, struct request *);
  115. extern void elv_drain_elevator(struct request_queue *);
  116. /*
  117. * io scheduler registration
  118. */
  119. extern int elv_register(struct elevator_type *);
  120. extern void elv_unregister(struct elevator_type *);
  121. /*
  122. * io scheduler sysfs switching
  123. */
  124. extern ssize_t elv_iosched_show(struct request_queue *, char *);
  125. extern ssize_t elv_iosched_store(struct request_queue *, const char *, size_t);
  126. extern int elevator_init(struct request_queue *, char *);
  127. extern void elevator_exit(struct elevator_queue *);
  128. extern int elevator_change(struct request_queue *, const char *);
  129. extern bool elv_rq_merge_ok(struct request *, struct bio *);
  130. /*
  131. * Helper functions.
  132. */
  133. extern struct request *elv_rb_former_request(struct request_queue *, struct request *);
  134. extern struct request *elv_rb_latter_request(struct request_queue *, struct request *);
  135. /*
  136. * rb support functions.
  137. */
  138. extern void elv_rb_add(struct rb_root *, struct request *);
  139. extern void elv_rb_del(struct rb_root *, struct request *);
  140. extern struct request *elv_rb_find(struct rb_root *, sector_t);
  141. /*
  142. * Return values from elevator merger
  143. */
  144. #define ELEVATOR_NO_MERGE 0
  145. #define ELEVATOR_FRONT_MERGE 1
  146. #define ELEVATOR_BACK_MERGE 2
  147. /*
  148. * Insertion selection
  149. */
  150. #define ELEVATOR_INSERT_FRONT 1
  151. #define ELEVATOR_INSERT_BACK 2
  152. #define ELEVATOR_INSERT_SORT 3
  153. #define ELEVATOR_INSERT_REQUEUE 4
  154. #define ELEVATOR_INSERT_FLUSH 5
  155. #define ELEVATOR_INSERT_SORT_MERGE 6
  156. /*
  157. * return values from elevator_may_queue_fn
  158. */
  159. enum {
  160. ELV_MQUEUE_MAY,
  161. ELV_MQUEUE_NO,
  162. ELV_MQUEUE_MUST,
  163. };
  164. #define rq_end_sector(rq) (blk_rq_pos(rq) + blk_rq_sectors(rq))
  165. #define rb_entry_rq(node) rb_entry((node), struct request, rb_node)
  166. /*
  167. * Hack to reuse the csd.list list_head as the fifo time holder while
  168. * the request is in the io scheduler. Saves an unsigned long in rq.
  169. */
  170. #define rq_fifo_time(rq) ((unsigned long) (rq)->csd.list.next)
  171. #define rq_set_fifo_time(rq,exp) ((rq)->csd.list.next = (void *) (exp))
  172. #define rq_entry_fifo(ptr) list_entry((ptr), struct request, queuelist)
  173. #define rq_fifo_clear(rq) do { \
  174. list_del_init(&(rq)->queuelist); \
  175. INIT_LIST_HEAD(&(rq)->csd.list); \
  176. } while (0)
  177. #endif /* CONFIG_BLOCK */
  178. #endif