drbd_interval.c 5.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207
  1. #include <asm/bug.h>
  2. #include <linux/rbtree_augmented.h>
  3. #include "drbd_interval.h"
  4. /**
  5. * interval_end - return end of @node
  6. */
  7. static inline
  8. sector_t interval_end(struct rb_node *node)
  9. {
  10. struct drbd_interval *this = rb_entry(node, struct drbd_interval, rb);
  11. return this->end;
  12. }
  13. /**
  14. * compute_subtree_last - compute end of @node
  15. *
  16. * The end of an interval is the highest (start + (size >> 9)) value of this
  17. * node and of its children. Called for @node and its parents whenever the end
  18. * may have changed.
  19. */
  20. static inline sector_t
  21. compute_subtree_last(struct drbd_interval *node)
  22. {
  23. sector_t max = node->sector + (node->size >> 9);
  24. if (node->rb.rb_left) {
  25. sector_t left = interval_end(node->rb.rb_left);
  26. if (left > max)
  27. max = left;
  28. }
  29. if (node->rb.rb_right) {
  30. sector_t right = interval_end(node->rb.rb_right);
  31. if (right > max)
  32. max = right;
  33. }
  34. return max;
  35. }
  36. static void augment_propagate(struct rb_node *rb, struct rb_node *stop)
  37. {
  38. while (rb != stop) {
  39. struct drbd_interval *node = rb_entry(rb, struct drbd_interval, rb);
  40. sector_t subtree_last = compute_subtree_last(node);
  41. if (node->end == subtree_last)
  42. break;
  43. node->end = subtree_last;
  44. rb = rb_parent(&node->rb);
  45. }
  46. }
  47. static void augment_copy(struct rb_node *rb_old, struct rb_node *rb_new)
  48. {
  49. struct drbd_interval *old = rb_entry(rb_old, struct drbd_interval, rb);
  50. struct drbd_interval *new = rb_entry(rb_new, struct drbd_interval, rb);
  51. new->end = old->end;
  52. }
  53. static void augment_rotate(struct rb_node *rb_old, struct rb_node *rb_new)
  54. {
  55. struct drbd_interval *old = rb_entry(rb_old, struct drbd_interval, rb);
  56. struct drbd_interval *new = rb_entry(rb_new, struct drbd_interval, rb);
  57. new->end = old->end;
  58. old->end = compute_subtree_last(old);
  59. }
  60. static const struct rb_augment_callbacks augment_callbacks = {
  61. augment_propagate,
  62. augment_copy,
  63. augment_rotate,
  64. };
  65. /**
  66. * drbd_insert_interval - insert a new interval into a tree
  67. */
  68. bool
  69. drbd_insert_interval(struct rb_root *root, struct drbd_interval *this)
  70. {
  71. struct rb_node **new = &root->rb_node, *parent = NULL;
  72. BUG_ON(!IS_ALIGNED(this->size, 512));
  73. while (*new) {
  74. struct drbd_interval *here =
  75. rb_entry(*new, struct drbd_interval, rb);
  76. parent = *new;
  77. if (this->sector < here->sector)
  78. new = &(*new)->rb_left;
  79. else if (this->sector > here->sector)
  80. new = &(*new)->rb_right;
  81. else if (this < here)
  82. new = &(*new)->rb_left;
  83. else if (this > here)
  84. new = &(*new)->rb_right;
  85. else
  86. return false;
  87. }
  88. rb_link_node(&this->rb, parent, new);
  89. rb_insert_augmented(&this->rb, root, &augment_callbacks);
  90. return true;
  91. }
  92. /**
  93. * drbd_contains_interval - check if a tree contains a given interval
  94. * @sector: start sector of @interval
  95. * @interval: may not be a valid pointer
  96. *
  97. * Returns if the tree contains the node @interval with start sector @start.
  98. * Does not dereference @interval until @interval is known to be a valid object
  99. * in @tree. Returns %false if @interval is in the tree but with a different
  100. * sector number.
  101. */
  102. bool
  103. drbd_contains_interval(struct rb_root *root, sector_t sector,
  104. struct drbd_interval *interval)
  105. {
  106. struct rb_node *node = root->rb_node;
  107. while (node) {
  108. struct drbd_interval *here =
  109. rb_entry(node, struct drbd_interval, rb);
  110. if (sector < here->sector)
  111. node = node->rb_left;
  112. else if (sector > here->sector)
  113. node = node->rb_right;
  114. else if (interval < here)
  115. node = node->rb_left;
  116. else if (interval > here)
  117. node = node->rb_right;
  118. else
  119. return true;
  120. }
  121. return false;
  122. }
  123. /**
  124. * drbd_remove_interval - remove an interval from a tree
  125. */
  126. void
  127. drbd_remove_interval(struct rb_root *root, struct drbd_interval *this)
  128. {
  129. rb_erase_augmented(&this->rb, root, &augment_callbacks);
  130. }
  131. /**
  132. * drbd_find_overlap - search for an interval overlapping with [sector, sector + size)
  133. * @sector: start sector
  134. * @size: size, aligned to 512 bytes
  135. *
  136. * Returns an interval overlapping with [sector, sector + size), or NULL if
  137. * there is none. When there is more than one overlapping interval in the
  138. * tree, the interval with the lowest start sector is returned, and all other
  139. * overlapping intervals will be on the right side of the tree, reachable with
  140. * rb_next().
  141. */
  142. struct drbd_interval *
  143. drbd_find_overlap(struct rb_root *root, sector_t sector, unsigned int size)
  144. {
  145. struct rb_node *node = root->rb_node;
  146. struct drbd_interval *overlap = NULL;
  147. sector_t end = sector + (size >> 9);
  148. BUG_ON(!IS_ALIGNED(size, 512));
  149. while (node) {
  150. struct drbd_interval *here =
  151. rb_entry(node, struct drbd_interval, rb);
  152. if (node->rb_left &&
  153. sector < interval_end(node->rb_left)) {
  154. /* Overlap if any must be on left side */
  155. node = node->rb_left;
  156. } else if (here->sector < end &&
  157. sector < here->sector + (here->size >> 9)) {
  158. overlap = here;
  159. break;
  160. } else if (sector >= here->sector) {
  161. /* Overlap if any must be on right side */
  162. node = node->rb_right;
  163. } else
  164. break;
  165. }
  166. return overlap;
  167. }
  168. struct drbd_interval *
  169. drbd_next_overlap(struct drbd_interval *i, sector_t sector, unsigned int size)
  170. {
  171. sector_t end = sector + (size >> 9);
  172. struct rb_node *node;
  173. for (;;) {
  174. node = rb_next(&i->rb);
  175. if (!node)
  176. return NULL;
  177. i = rb_entry(node, struct drbd_interval, rb);
  178. if (i->sector >= end)
  179. return NULL;
  180. if (sector < i->sector + (i->size >> 9))
  181. return i;
  182. }
  183. }