drbd_interval.c 4.5 KB

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