sequence_test.go 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748
  1. package bitseq
  2. import (
  3. "testing"
  4. _ "github.com/docker/libnetwork/testutils"
  5. )
  6. func TestSequenceGetAvailableBit(t *testing.T) {
  7. input := []struct {
  8. head *sequence
  9. from uint64
  10. bytePos uint64
  11. bitPos uint64
  12. }{
  13. {&sequence{block: 0x0, count: 0}, 0, invalidPos, invalidPos},
  14. {&sequence{block: 0x0, count: 1}, 0, 0, 0},
  15. {&sequence{block: 0x0, count: 100}, 0, 0, 0},
  16. {&sequence{block: 0x80000000, count: 0}, 0, invalidPos, invalidPos},
  17. {&sequence{block: 0x80000000, count: 1}, 0, 0, 1},
  18. {&sequence{block: 0x80000000, count: 100}, 0, 0, 1},
  19. {&sequence{block: 0xFF000000, count: 0}, 0, invalidPos, invalidPos},
  20. {&sequence{block: 0xFF000000, count: 1}, 0, 1, 0},
  21. {&sequence{block: 0xFF000000, count: 100}, 0, 1, 0},
  22. {&sequence{block: 0xFF800000, count: 0}, 0, invalidPos, invalidPos},
  23. {&sequence{block: 0xFF800000, count: 1}, 0, 1, 1},
  24. {&sequence{block: 0xFF800000, count: 100}, 0, 1, 1},
  25. {&sequence{block: 0xFFC0FF00, count: 0}, 0, invalidPos, invalidPos},
  26. {&sequence{block: 0xFFC0FF00, count: 1}, 0, 1, 2},
  27. {&sequence{block: 0xFFC0FF00, count: 100}, 0, 1, 2},
  28. {&sequence{block: 0xFFE0FF00, count: 0}, 0, invalidPos, invalidPos},
  29. {&sequence{block: 0xFFE0FF00, count: 1}, 0, 1, 3},
  30. {&sequence{block: 0xFFE0FF00, count: 100}, 0, 1, 3},
  31. {&sequence{block: 0xFFFEFF00, count: 0}, 0, invalidPos, invalidPos},
  32. {&sequence{block: 0xFFFEFF00, count: 1}, 0, 1, 7},
  33. {&sequence{block: 0xFFFEFF00, count: 100}, 0, 1, 7},
  34. {&sequence{block: 0xFFFFC0FF, count: 0}, 0, invalidPos, invalidPos},
  35. {&sequence{block: 0xFFFFC0FF, count: 1}, 0, 2, 2},
  36. {&sequence{block: 0xFFFFC0FF, count: 100}, 0, 2, 2},
  37. {&sequence{block: 0xFFFFFF00, count: 0}, 0, invalidPos, invalidPos},
  38. {&sequence{block: 0xFFFFFF00, count: 1}, 0, 3, 0},
  39. {&sequence{block: 0xFFFFFF00, count: 100}, 0, 3, 0},
  40. {&sequence{block: 0xFFFFFFFE, count: 0}, 0, invalidPos, invalidPos},
  41. {&sequence{block: 0xFFFFFFFE, count: 1}, 0, 3, 7},
  42. {&sequence{block: 0xFFFFFFFE, count: 100}, 0, 3, 7},
  43. {&sequence{block: 0xFFFFFFFF, count: 0}, 0, invalidPos, invalidPos},
  44. {&sequence{block: 0xFFFFFFFF, count: 1}, 0, invalidPos, invalidPos},
  45. {&sequence{block: 0xFFFFFFFF, count: 100}, 0, invalidPos, invalidPos},
  46. // now test with offset
  47. {&sequence{block: 0x0, count: 0}, 0, invalidPos, invalidPos},
  48. {&sequence{block: 0x0, count: 0}, 31, invalidPos, invalidPos},
  49. {&sequence{block: 0x0, count: 0}, 32, invalidPos, invalidPos},
  50. {&sequence{block: 0x0, count: 1}, 0, 0, 0},
  51. {&sequence{block: 0x0, count: 1}, 1, 0, 1},
  52. {&sequence{block: 0x0, count: 1}, 31, 3, 7},
  53. {&sequence{block: 0xF0FF0000, count: 1}, 0, 0, 4},
  54. {&sequence{block: 0xF0FF0000, count: 1}, 8, 2, 0},
  55. {&sequence{block: 0xFFFFFFFF, count: 1}, 0, invalidPos, invalidPos},
  56. {&sequence{block: 0xFFFFFFFF, count: 1}, 16, invalidPos, invalidPos},
  57. {&sequence{block: 0xFFFFFFFF, count: 1}, 31, invalidPos, invalidPos},
  58. {&sequence{block: 0xFFFFFFFE, count: 1}, 0, 3, 7},
  59. {&sequence{block: 0xFFFFFFFF, count: 2}, 0, invalidPos, invalidPos},
  60. {&sequence{block: 0xFFFFFFFF, count: 2}, 32, invalidPos, invalidPos},
  61. }
  62. for n, i := range input {
  63. b, bb, err := i.head.getAvailableBit(i.from)
  64. if b != i.bytePos || bb != i.bitPos {
  65. t.Fatalf("Error in sequence.getAvailableBit(%d) (%d).\nExp: (%d, %d)\nGot: (%d, %d), err: %v", i.from, n, i.bytePos, i.bitPos, b, bb, err)
  66. }
  67. }
  68. }
  69. func TestSequenceEqual(t *testing.T) {
  70. input := []struct {
  71. first *sequence
  72. second *sequence
  73. areEqual bool
  74. }{
  75. {&sequence{block: 0x0, count: 8, next: nil}, &sequence{block: 0x0, count: 8}, true},
  76. {&sequence{block: 0x0, count: 0, next: nil}, &sequence{block: 0x0, count: 0}, true},
  77. {&sequence{block: 0x0, count: 2, next: nil}, &sequence{block: 0x0, count: 1, next: &sequence{block: 0x0, count: 1}}, false},
  78. {&sequence{block: 0x0, count: 2, next: &sequence{block: 0x1, count: 1}}, &sequence{block: 0x0, count: 2}, false},
  79. {&sequence{block: 0x12345678, count: 8, next: nil}, &sequence{block: 0x12345678, count: 8}, true},
  80. {&sequence{block: 0x12345678, count: 8, next: nil}, &sequence{block: 0x12345678, count: 9}, false},
  81. {&sequence{block: 0x12345678, count: 1, next: &sequence{block: 0XFFFFFFFF, count: 1}}, &sequence{block: 0x12345678, count: 1}, false},
  82. {&sequence{block: 0x12345678, count: 1}, &sequence{block: 0x12345678, count: 1, next: &sequence{block: 0XFFFFFFFF, count: 1}}, false},
  83. }
  84. for n, i := range input {
  85. if i.areEqual != i.first.equal(i.second) {
  86. t.Fatalf("Error in sequence.equal() (%d).\nExp: %t\nGot: %t,", n, i.areEqual, !i.areEqual)
  87. }
  88. }
  89. }
  90. func TestSequenceCopy(t *testing.T) {
  91. s := getTestSequence()
  92. n := s.getCopy()
  93. if !s.equal(n) {
  94. t.Fatalf("copy of s failed")
  95. }
  96. if n == s {
  97. t.Fatalf("not true copy of s")
  98. }
  99. }
  100. func TestGetFirstAvailable(t *testing.T) {
  101. input := []struct {
  102. mask *sequence
  103. bytePos uint64
  104. bitPos uint64
  105. }{
  106. {&sequence{block: 0xffffffff, count: 2048}, invalidPos, invalidPos},
  107. {&sequence{block: 0x0, count: 8}, 0, 0},
  108. {&sequence{block: 0x80000000, count: 8}, 0, 1},
  109. {&sequence{block: 0xC0000000, count: 8}, 0, 2},
  110. {&sequence{block: 0xE0000000, count: 8}, 0, 3},
  111. {&sequence{block: 0xF0000000, count: 8}, 0, 4},
  112. {&sequence{block: 0xF8000000, count: 8}, 0, 5},
  113. {&sequence{block: 0xFC000000, count: 8}, 0, 6},
  114. {&sequence{block: 0xFE000000, count: 8}, 0, 7},
  115. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0x00000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 4, 0},
  116. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0x80000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 4, 1},
  117. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xC0000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 4, 2},
  118. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xE0000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 4, 3},
  119. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xF0000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 4, 4},
  120. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xF8000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 4, 5},
  121. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFC000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 4, 6},
  122. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFE000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 4, 7},
  123. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFF000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 5, 0},
  124. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFF800000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 5, 1},
  125. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFC00000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 5, 2},
  126. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFE00000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 5, 3},
  127. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFF00000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 5, 4},
  128. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFF80000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 5, 5},
  129. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFFC0000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 5, 6},
  130. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFFE0000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 5, 7},
  131. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xfffffffe, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 7, 7},
  132. {&sequence{block: 0xffffffff, count: 2, next: &sequence{block: 0x0, count: 6}}, 8, 0},
  133. }
  134. for n, i := range input {
  135. bytePos, bitPos, _ := getFirstAvailable(i.mask, 0)
  136. if bytePos != i.bytePos || bitPos != i.bitPos {
  137. t.Fatalf("Error in (%d) getFirstAvailable(). Expected (%d, %d). Got (%d, %d)", n, i.bytePos, i.bitPos, bytePos, bitPos)
  138. }
  139. }
  140. }
  141. func TestFindSequence(t *testing.T) {
  142. input := []struct {
  143. head *sequence
  144. bytePos uint64
  145. precBlocks uint64
  146. inBlockBytePos uint64
  147. }{
  148. {&sequence{block: 0xffffffff, count: 0}, 0, 0, invalidPos},
  149. {&sequence{block: 0xffffffff, count: 0}, 31, 0, invalidPos},
  150. {&sequence{block: 0xffffffff, count: 0}, 100, 0, invalidPos},
  151. {&sequence{block: 0x0, count: 1}, 0, 0, 0},
  152. {&sequence{block: 0x0, count: 1}, 1, 0, 1},
  153. {&sequence{block: 0x0, count: 1}, 31, 0, invalidPos},
  154. {&sequence{block: 0x0, count: 1}, 60, 0, invalidPos},
  155. {&sequence{block: 0xffffffff, count: 10}, 0, 0, 0},
  156. {&sequence{block: 0xffffffff, count: 10}, 3, 0, 3},
  157. {&sequence{block: 0xffffffff, count: 10}, 4, 1, 0},
  158. {&sequence{block: 0xffffffff, count: 10}, 7, 1, 3},
  159. {&sequence{block: 0xffffffff, count: 10}, 8, 2, 0},
  160. {&sequence{block: 0xffffffff, count: 10}, 39, 9, 3},
  161. {&sequence{block: 0xffffffff, count: 10, next: &sequence{block: 0xcc000000, count: 10}}, 79, 9, 3},
  162. {&sequence{block: 0xffffffff, count: 10, next: &sequence{block: 0xcc000000, count: 10}}, 80, 0, invalidPos},
  163. }
  164. for n, i := range input {
  165. _, _, precBlocks, inBlockBytePos := findSequence(i.head, i.bytePos)
  166. if precBlocks != i.precBlocks || inBlockBytePos != i.inBlockBytePos {
  167. t.Fatalf("Error in (%d) findSequence(). Expected (%d, %d). Got (%d, %d)", n, i.precBlocks, i.inBlockBytePos, precBlocks, inBlockBytePos)
  168. }
  169. }
  170. }
  171. func TestCheckIfAvailable(t *testing.T) {
  172. input := []struct {
  173. head *sequence
  174. ordinal uint64
  175. bytePos uint64
  176. bitPos uint64
  177. }{
  178. {&sequence{block: 0xffffffff, count: 0}, 0, invalidPos, invalidPos},
  179. {&sequence{block: 0xffffffff, count: 0}, 31, invalidPos, invalidPos},
  180. {&sequence{block: 0xffffffff, count: 0}, 100, invalidPos, invalidPos},
  181. {&sequence{block: 0x0, count: 1}, 0, 0, 0},
  182. {&sequence{block: 0x0, count: 1}, 1, 0, 1},
  183. {&sequence{block: 0x0, count: 1}, 31, 3, 7},
  184. {&sequence{block: 0x0, count: 1}, 60, invalidPos, invalidPos},
  185. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0x800000ff, count: 1}}, 31, invalidPos, invalidPos},
  186. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0x800000ff, count: 1}}, 32, invalidPos, invalidPos},
  187. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0x800000ff, count: 1}}, 33, 4, 1},
  188. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xC00000ff, count: 1}}, 33, invalidPos, invalidPos},
  189. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xC00000ff, count: 1}}, 34, 4, 2},
  190. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xC00000ff, count: 1, next: &sequence{block: 0x0, count: 1}}}, 55, 6, 7},
  191. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xC00000ff, count: 1, next: &sequence{block: 0x0, count: 1}}}, 56, invalidPos, invalidPos},
  192. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xC00000ff, count: 1, next: &sequence{block: 0x0, count: 1}}}, 63, invalidPos, invalidPos},
  193. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xC00000ff, count: 1, next: &sequence{block: 0x0, count: 1}}}, 64, 8, 0},
  194. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xC00000ff, count: 1, next: &sequence{block: 0x0, count: 1}}}, 95, 11, 7},
  195. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xC00000ff, count: 1, next: &sequence{block: 0x0, count: 1}}}, 96, invalidPos, invalidPos},
  196. }
  197. for n, i := range input {
  198. bytePos, bitPos, err := checkIfAvailable(i.head, i.ordinal)
  199. if bytePos != i.bytePos || bitPos != i.bitPos {
  200. t.Fatalf("Error in (%d) checkIfAvailable(ord:%d). Expected (%d, %d). Got (%d, %d). err: %v", n, i.ordinal, i.bytePos, i.bitPos, bytePos, bitPos, err)
  201. }
  202. }
  203. }
  204. func TestMergeSequences(t *testing.T) {
  205. input := []struct {
  206. original *sequence
  207. merged *sequence
  208. }{
  209. {&sequence{block: 0xFE000000, count: 8, next: &sequence{block: 0xFE000000, count: 2}}, &sequence{block: 0xFE000000, count: 10}},
  210. {&sequence{block: 0xFFFFFFFF, count: 8, next: &sequence{block: 0xFFFFFFFF, count: 1}}, &sequence{block: 0xFFFFFFFF, count: 9}},
  211. {&sequence{block: 0xFFFFFFFF, count: 1, next: &sequence{block: 0xFFFFFFFF, count: 8}}, &sequence{block: 0xFFFFFFFF, count: 9}},
  212. {&sequence{block: 0xFFFFFFF0, count: 8, next: &sequence{block: 0xFFFFFFF0, count: 1}}, &sequence{block: 0xFFFFFFF0, count: 9}},
  213. {&sequence{block: 0xFFFFFFF0, count: 1, next: &sequence{block: 0xFFFFFFF0, count: 8}}, &sequence{block: 0xFFFFFFF0, count: 9}},
  214. {&sequence{block: 0xFE, count: 8, next: &sequence{block: 0xFE, count: 1, next: &sequence{block: 0xFE, count: 5}}}, &sequence{block: 0xFE, count: 14}},
  215. {&sequence{block: 0xFE, count: 8, next: &sequence{block: 0xFE, count: 1, next: &sequence{block: 0xFE, count: 5, next: &sequence{block: 0xFF, count: 1}}}},
  216. &sequence{block: 0xFE, count: 14, next: &sequence{block: 0xFF, count: 1}}},
  217. // No merge
  218. {&sequence{block: 0xFE, count: 8, next: &sequence{block: 0xF8, count: 1, next: &sequence{block: 0xFE, count: 5}}},
  219. &sequence{block: 0xFE, count: 8, next: &sequence{block: 0xF8, count: 1, next: &sequence{block: 0xFE, count: 5}}}},
  220. // No merge from head: // Merge function tries to merge from passed head. If it can't merge with next, it does not reattempt with next as head
  221. {&sequence{block: 0xFE, count: 8, next: &sequence{block: 0xFF, count: 1, next: &sequence{block: 0xFF, count: 5}}},
  222. &sequence{block: 0xFE, count: 8, next: &sequence{block: 0xFF, count: 6}}},
  223. }
  224. for n, i := range input {
  225. mergeSequences(i.original)
  226. for !i.merged.equal(i.original) {
  227. t.Fatalf("Error in (%d) mergeSequences().\nExp: %s\nGot: %s,", n, i.merged.toString(), i.original.toString())
  228. }
  229. }
  230. }
  231. func TestPushReservation(t *testing.T) {
  232. input := []struct {
  233. mask *sequence
  234. bytePos uint64
  235. bitPos uint64
  236. newMask *sequence
  237. }{
  238. // Create first sequence and fill in 8 addresses starting from address 0
  239. {&sequence{block: 0x0, count: 8, next: nil}, 0, 0, &sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 7, next: nil}}},
  240. {&sequence{block: 0x80000000, count: 8}, 0, 1, &sequence{block: 0xC0000000, count: 1, next: &sequence{block: 0x80000000, count: 7, next: nil}}},
  241. {&sequence{block: 0xC0000000, count: 8}, 0, 2, &sequence{block: 0xE0000000, count: 1, next: &sequence{block: 0xC0000000, count: 7, next: nil}}},
  242. {&sequence{block: 0xE0000000, count: 8}, 0, 3, &sequence{block: 0xF0000000, count: 1, next: &sequence{block: 0xE0000000, count: 7, next: nil}}},
  243. {&sequence{block: 0xF0000000, count: 8}, 0, 4, &sequence{block: 0xF8000000, count: 1, next: &sequence{block: 0xF0000000, count: 7, next: nil}}},
  244. {&sequence{block: 0xF8000000, count: 8}, 0, 5, &sequence{block: 0xFC000000, count: 1, next: &sequence{block: 0xF8000000, count: 7, next: nil}}},
  245. {&sequence{block: 0xFC000000, count: 8}, 0, 6, &sequence{block: 0xFE000000, count: 1, next: &sequence{block: 0xFC000000, count: 7, next: nil}}},
  246. {&sequence{block: 0xFE000000, count: 8}, 0, 7, &sequence{block: 0xFF000000, count: 1, next: &sequence{block: 0xFE000000, count: 7, next: nil}}},
  247. {&sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 7}}, 0, 1, &sequence{block: 0xC0000000, count: 1, next: &sequence{block: 0x0, count: 7, next: nil}}},
  248. // Create second sequence and fill in 8 addresses starting from address 32
  249. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0x00000000, count: 1, next: &sequence{block: 0xffffffff, count: 6, next: nil}}}, 4, 0,
  250. &sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0x80000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}},
  251. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0x80000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 4, 1,
  252. &sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xC0000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}},
  253. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xC0000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 4, 2,
  254. &sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xE0000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}},
  255. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xE0000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 4, 3,
  256. &sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xF0000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}},
  257. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xF0000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 4, 4,
  258. &sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xF8000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}},
  259. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xF8000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 4, 5,
  260. &sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFC000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}},
  261. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFC000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 4, 6,
  262. &sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFE000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}},
  263. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFE000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 4, 7,
  264. &sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFF000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}},
  265. // fill in 8 addresses starting from address 40
  266. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFF000000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 5, 0,
  267. &sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFF800000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}},
  268. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFF800000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 5, 1,
  269. &sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFC00000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}},
  270. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFC00000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 5, 2,
  271. &sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFE00000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}},
  272. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFE00000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 5, 3,
  273. &sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFF00000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}},
  274. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFF00000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 5, 4,
  275. &sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFF80000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}},
  276. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFF80000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 5, 5,
  277. &sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFFC0000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}},
  278. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFFC0000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 5, 6,
  279. &sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFFE0000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}},
  280. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFFE0000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}, 5, 7,
  281. &sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xFFFF0000, count: 1, next: &sequence{block: 0xffffffff, count: 6}}}},
  282. // Insert new sequence
  283. {&sequence{block: 0xffffffff, count: 2, next: &sequence{block: 0x0, count: 6}}, 8, 0,
  284. &sequence{block: 0xffffffff, count: 2, next: &sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 5}}}},
  285. {&sequence{block: 0xffffffff, count: 2, next: &sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 5}}}, 8, 1,
  286. &sequence{block: 0xffffffff, count: 2, next: &sequence{block: 0xC0000000, count: 1, next: &sequence{block: 0x0, count: 5}}}},
  287. // Merge affected with next
  288. {&sequence{block: 0xffffffff, count: 7, next: &sequence{block: 0xfffffffe, count: 2, next: &sequence{block: 0xffffffff, count: 1}}}, 31, 7,
  289. &sequence{block: 0xffffffff, count: 8, next: &sequence{block: 0xfffffffe, count: 1, next: &sequence{block: 0xffffffff, count: 1}}}},
  290. {&sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xfffffffc, count: 1, next: &sequence{block: 0xfffffffe, count: 6}}}, 7, 6,
  291. &sequence{block: 0xffffffff, count: 1, next: &sequence{block: 0xfffffffe, count: 7}}},
  292. // Merge affected with next and next.next
  293. {&sequence{block: 0xffffffff, count: 7, next: &sequence{block: 0xfffffffe, count: 1, next: &sequence{block: 0xffffffff, count: 1}}}, 31, 7,
  294. &sequence{block: 0xffffffff, count: 9}},
  295. {&sequence{block: 0xffffffff, count: 7, next: &sequence{block: 0xfffffffe, count: 1}}, 31, 7,
  296. &sequence{block: 0xffffffff, count: 8}},
  297. // Merge affected with previous and next
  298. {&sequence{block: 0xffffffff, count: 7, next: &sequence{block: 0xfffffffe, count: 1, next: &sequence{block: 0xffffffff, count: 1}}}, 31, 7,
  299. &sequence{block: 0xffffffff, count: 9}},
  300. // Redundant push: No change
  301. {&sequence{block: 0xffff0000, count: 1}, 0, 0, &sequence{block: 0xffff0000, count: 1}},
  302. {&sequence{block: 0xffff0000, count: 7}, 25, 7, &sequence{block: 0xffff0000, count: 7}},
  303. {&sequence{block: 0xffffffff, count: 7, next: &sequence{block: 0xfffffffe, count: 1, next: &sequence{block: 0xffffffff, count: 1}}}, 7, 7,
  304. &sequence{block: 0xffffffff, count: 7, next: &sequence{block: 0xfffffffe, count: 1, next: &sequence{block: 0xffffffff, count: 1}}}},
  305. // Set last bit
  306. {&sequence{block: 0x0, count: 8}, 31, 7, &sequence{block: 0x0, count: 7, next: &sequence{block: 0x1, count: 1}}},
  307. // Set bit in a middle sequence in the first block, first bit
  308. {&sequence{block: 0x40000000, count: 1, next: &sequence{block: 0x0, count: 6, next: &sequence{block: 0x1, count: 1}}}, 4, 0,
  309. &sequence{block: 0x40000000, count: 1, next: &sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 5,
  310. next: &sequence{block: 0x1, count: 1}}}}},
  311. // Set bit in a middle sequence in the first block, first bit (merge involved)
  312. {&sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 6, next: &sequence{block: 0x1, count: 1}}}, 4, 0,
  313. &sequence{block: 0x80000000, count: 2, next: &sequence{block: 0x0, count: 5, next: &sequence{block: 0x1, count: 1}}}},
  314. // Set bit in a middle sequence in the first block, last bit
  315. {&sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 6, next: &sequence{block: 0x1, count: 1}}}, 4, 31,
  316. &sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x1, count: 1, next: &sequence{block: 0x0, count: 5,
  317. next: &sequence{block: 0x1, count: 1}}}}},
  318. // Set bit in a middle sequence in the first block, middle bit
  319. {&sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 6, next: &sequence{block: 0x1, count: 1}}}, 4, 16,
  320. &sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x8000, count: 1, next: &sequence{block: 0x0, count: 5,
  321. next: &sequence{block: 0x1, count: 1}}}}},
  322. // Set bit in a middle sequence in a middle block, first bit
  323. {&sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 6, next: &sequence{block: 0x1, count: 1}}}, 16, 0,
  324. &sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 3, next: &sequence{block: 0x80000000, count: 1,
  325. next: &sequence{block: 0x0, count: 2, next: &sequence{block: 0x1, count: 1}}}}}},
  326. // Set bit in a middle sequence in a middle block, last bit
  327. {&sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 6, next: &sequence{block: 0x1, count: 1}}}, 16, 31,
  328. &sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 3, next: &sequence{block: 0x1, count: 1,
  329. next: &sequence{block: 0x0, count: 2, next: &sequence{block: 0x1, count: 1}}}}}},
  330. // Set bit in a middle sequence in a middle block, middle bit
  331. {&sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 6, next: &sequence{block: 0x1, count: 1}}}, 16, 15,
  332. &sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 3, next: &sequence{block: 0x10000, count: 1,
  333. next: &sequence{block: 0x0, count: 2, next: &sequence{block: 0x1, count: 1}}}}}},
  334. // Set bit in a middle sequence in the last block, first bit
  335. {&sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 6, next: &sequence{block: 0x1, count: 1}}}, 24, 0,
  336. &sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 5, next: &sequence{block: 0x80000000, count: 1,
  337. next: &sequence{block: 0x1, count: 1}}}}},
  338. // Set bit in a middle sequence in the last block, last bit
  339. {&sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 6, next: &sequence{block: 0x4, count: 1}}}, 24, 31,
  340. &sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 5, next: &sequence{block: 0x1, count: 1,
  341. next: &sequence{block: 0x4, count: 1}}}}},
  342. // Set bit in a middle sequence in the last block, last bit (merge involved)
  343. {&sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 6, next: &sequence{block: 0x1, count: 1}}}, 24, 31,
  344. &sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 5, next: &sequence{block: 0x1, count: 2}}}},
  345. // Set bit in a middle sequence in the last block, middle bit
  346. {&sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 6, next: &sequence{block: 0x1, count: 1}}}, 24, 16,
  347. &sequence{block: 0x80000000, count: 1, next: &sequence{block: 0x0, count: 5, next: &sequence{block: 0x8000, count: 1,
  348. next: &sequence{block: 0x1, count: 1}}}}},
  349. }
  350. for n, i := range input {
  351. mask := pushReservation(i.bytePos, i.bitPos, i.mask, false)
  352. if !mask.equal(i.newMask) {
  353. t.Fatalf("Error in (%d) pushReservation():\n%s + (%d,%d):\nExp: %s\nGot: %s,",
  354. n, i.mask.toString(), i.bytePos, i.bitPos, i.newMask.toString(), mask.toString())
  355. }
  356. }
  357. }
  358. func TestSerializeDeserialize(t *testing.T) {
  359. s := getTestSequence()
  360. data, err := s.toByteArray()
  361. if err != nil {
  362. t.Fatal(err)
  363. }
  364. r := &sequence{}
  365. err = r.fromByteArray(data)
  366. if err != nil {
  367. t.Fatal(err)
  368. }
  369. if !s.equal(r) {
  370. t.Fatalf("Sequences are different: \n%v\n%v", s, r)
  371. }
  372. }
  373. func getTestSequence() *sequence {
  374. // Returns a custom sequence of 1024 * 32 bits
  375. return &sequence{
  376. block: 0XFFFFFFFF,
  377. count: 100,
  378. next: &sequence{
  379. block: 0xFFFFFFFE,
  380. count: 1,
  381. next: &sequence{
  382. block: 0xFF000000,
  383. count: 10,
  384. next: &sequence{
  385. block: 0XFFFFFFFF,
  386. count: 50,
  387. next: &sequence{
  388. block: 0XFFFFFFFC,
  389. count: 1,
  390. next: &sequence{
  391. block: 0xFF800000,
  392. count: 1,
  393. next: &sequence{
  394. block: 0XFFFFFFFF,
  395. count: 87,
  396. next: &sequence{
  397. block: 0x0,
  398. count: 150,
  399. next: &sequence{
  400. block: 0XFFFFFFFF,
  401. count: 200,
  402. next: &sequence{
  403. block: 0x0000FFFF,
  404. count: 1,
  405. next: &sequence{
  406. block: 0x0,
  407. count: 399,
  408. next: &sequence{
  409. block: 0XFFFFFFFF,
  410. count: 23,
  411. next: &sequence{
  412. block: 0x1,
  413. count: 1,
  414. },
  415. },
  416. },
  417. },
  418. },
  419. },
  420. },
  421. },
  422. },
  423. },
  424. },
  425. },
  426. }
  427. }
  428. func TestSet(t *testing.T) {
  429. hnd, err := NewHandle("", nil, "", 1024*32)
  430. if err != nil {
  431. t.Fatal(err)
  432. }
  433. hnd.head = getTestSequence()
  434. firstAv := uint64(32*100 + 31)
  435. last := uint64(1024*32 - 1)
  436. if hnd.IsSet(100000) {
  437. t.Fatal("IsSet() returned wrong result")
  438. }
  439. if !hnd.IsSet(0) {
  440. t.Fatal("IsSet() returned wrong result")
  441. }
  442. if hnd.IsSet(firstAv) {
  443. t.Fatal("IsSet() returned wrong result")
  444. }
  445. if !hnd.IsSet(last) {
  446. t.Fatal("IsSet() returned wrong result")
  447. }
  448. if err := hnd.Set(0); err == nil {
  449. t.Fatalf("Expected failure, but succeeded")
  450. }
  451. os, err := hnd.SetAny()
  452. if err != nil {
  453. t.Fatalf("Unexpected failure: %v", err)
  454. }
  455. if os != firstAv {
  456. t.Fatalf("SetAny returned unexpected ordinal. Expected %d. Got %d.", firstAv, os)
  457. }
  458. if !hnd.IsSet(firstAv) {
  459. t.Fatal("IsSet() returned wrong result")
  460. }
  461. if err := hnd.Unset(firstAv); err != nil {
  462. t.Fatalf("Unexpected failure: %v", err)
  463. }
  464. if hnd.IsSet(firstAv) {
  465. t.Fatal("IsSet() returned wrong result")
  466. }
  467. if err := hnd.Set(firstAv); err != nil {
  468. t.Fatalf("Unexpected failure: %v", err)
  469. }
  470. if err := hnd.Set(last); err == nil {
  471. t.Fatalf("Expected failure, but succeeded")
  472. }
  473. }
  474. func TestSetUnset(t *testing.T) {
  475. numBits := uint64(64 * 1024)
  476. hnd, err := NewHandle("", nil, "", numBits)
  477. if err != nil {
  478. t.Fatal(err)
  479. }
  480. // set and unset all one by one
  481. for hnd.Unselected() > 0 {
  482. if _, err := hnd.SetAny(); err != nil {
  483. t.Fatal(err)
  484. }
  485. }
  486. i := uint64(0)
  487. for hnd.Unselected() < numBits {
  488. if err := hnd.Unset(i); err != nil {
  489. t.Fatal(err)
  490. }
  491. i++
  492. }
  493. }
  494. func TestSetInRange(t *testing.T) {
  495. numBits := uint64(1024 * blockLen)
  496. hnd, err := NewHandle("", nil, "", numBits)
  497. if err != nil {
  498. t.Fatal(err)
  499. }
  500. hnd.head = getTestSequence()
  501. firstAv := uint64(100*blockLen + blockLen - 1)
  502. if o, err := hnd.SetAnyInRange(4, 3); err == nil {
  503. t.Fatalf("Expected failure. Got success with ordinal:%d", o)
  504. }
  505. if o, err := hnd.SetAnyInRange(5, 5); err == nil {
  506. t.Fatalf("Expected failure. Got success with ordinal:%d", o)
  507. }
  508. if o, err := hnd.SetAnyInRange(0, numBits); err == nil {
  509. t.Fatalf("Expected failure. Got success with ordinal:%d", o)
  510. }
  511. o, err := hnd.SetAnyInRange(100*uint64(blockLen), 101*uint64(blockLen))
  512. if err != nil {
  513. t.Fatalf("Unexpected failure: (%d, %v)", o, err)
  514. }
  515. if o != firstAv {
  516. t.Fatalf("Unexpected ordinal: %d", o)
  517. }
  518. if o, err := hnd.SetAnyInRange(0, uint64(blockLen)); err == nil {
  519. t.Fatalf("Expected failure. Got success with ordinal:%d", o)
  520. }
  521. if o, err := hnd.SetAnyInRange(0, firstAv-1); err == nil {
  522. t.Fatalf("Expected failure. Got success with ordinal:%d", o)
  523. }
  524. if o, err := hnd.SetAnyInRange(111*uint64(blockLen), 161*uint64(blockLen)); err == nil {
  525. t.Fatalf("Expected failure. Got success with ordinal:%d", o)
  526. }
  527. o, err = hnd.SetAnyInRange(161*uint64(blockLen), 162*uint64(blockLen))
  528. if err != nil {
  529. t.Fatal(err)
  530. }
  531. if o != 161*uint64(blockLen)+30 {
  532. t.Fatalf("Unexpected ordinal: %d", o)
  533. }
  534. o, err = hnd.SetAnyInRange(161*uint64(blockLen), 162*uint64(blockLen))
  535. if err != nil {
  536. t.Fatal(err)
  537. }
  538. if o != 161*uint64(blockLen)+31 {
  539. t.Fatalf("Unexpected ordinal: %d", o)
  540. }
  541. o, err = hnd.SetAnyInRange(161*uint64(blockLen), 162*uint64(blockLen))
  542. if err == nil {
  543. t.Fatalf("Expected failure. Got success with ordinal:%d", o)
  544. }
  545. if _, err := hnd.SetAnyInRange(0, numBits-1); err != nil {
  546. t.Fatalf("Unexpected failure: %v", err)
  547. }
  548. // create a non multiple of 32 mask
  549. hnd, err = NewHandle("", nil, "", 30)
  550. if err != nil {
  551. t.Fatal(err)
  552. }
  553. // set all bit in the first range
  554. for hnd.Unselected() > 22 {
  555. if o, err := hnd.SetAnyInRange(0, 7); err != nil {
  556. t.Fatalf("Unexpected failure: (%d, %v)", o, err)
  557. }
  558. }
  559. // try one more set, which should fail
  560. o, err = hnd.SetAnyInRange(0, 7)
  561. if err == nil {
  562. t.Fatalf("Expected failure. Got success with ordinal:%d", o)
  563. }
  564. if err != errNoBitAvailable {
  565. t.Fatalf("Unexpected error: %v", err)
  566. }
  567. // set all bit in a second range
  568. for hnd.Unselected() > 14 {
  569. if o, err := hnd.SetAnyInRange(8, 15); err != nil {
  570. t.Fatalf("Unexpected failure: (%d, %v)", o, err)
  571. }
  572. }
  573. // try one more set, which should fail
  574. o, err = hnd.SetAnyInRange(0, 15)
  575. if err == nil {
  576. t.Fatalf("Expected failure. Got success with ordinal:%d", o)
  577. }
  578. if err != errNoBitAvailable {
  579. t.Fatalf("Unexpected error: %v", err)
  580. }
  581. // set all bit in a range which includes the last bit
  582. for hnd.Unselected() > 12 {
  583. if o, err := hnd.SetAnyInRange(28, 29); err != nil {
  584. t.Fatalf("Unexpected failure: (%d, %v)", o, err)
  585. }
  586. }
  587. o, err = hnd.SetAnyInRange(28, 29)
  588. if err == nil {
  589. t.Fatalf("Expected failure. Got success with ordinal:%d", o)
  590. }
  591. if err != errNoBitAvailable {
  592. t.Fatalf("Unexpected error: %v", err)
  593. }
  594. }
  595. // This one tests an allocation pattern which unveiled an issue in pushReservation
  596. // Specifically a failure in detecting when we are in the (B) case (the bit to set
  597. // belongs to the last block of the current sequence). Because of a bug, code
  598. // was assuming the bit belonged to a block in the middle of the current sequence.
  599. // Which in turn caused an incorrect allocation when requesting a bit which is not
  600. // in the first or last sequence block.
  601. func TestSetAnyInRange(t *testing.T) {
  602. numBits := uint64(8 * blockLen)
  603. hnd, err := NewHandle("", nil, "", numBits)
  604. if err != nil {
  605. t.Fatal(err)
  606. }
  607. if err := hnd.Set(0); err != nil {
  608. t.Fatal(err)
  609. }
  610. if err := hnd.Set(255); err != nil {
  611. t.Fatal(err)
  612. }
  613. o, err := hnd.SetAnyInRange(128, 255)
  614. if err != nil {
  615. t.Fatal(err)
  616. }
  617. if o != 128 {
  618. t.Fatalf("Unexpected ordinal: %d", o)
  619. }
  620. o, err = hnd.SetAnyInRange(128, 255)
  621. if err != nil {
  622. t.Fatal(err)
  623. }
  624. if o != 129 {
  625. t.Fatalf("Unexpected ordinal: %d", o)
  626. }
  627. o, err = hnd.SetAnyInRange(246, 255)
  628. if err != nil {
  629. t.Fatal(err)
  630. }
  631. if o != 246 {
  632. t.Fatalf("Unexpected ordinal: %d", o)
  633. }
  634. o, err = hnd.SetAnyInRange(246, 255)
  635. if err != nil {
  636. t.Fatal(err)
  637. }
  638. if o != 247 {
  639. t.Fatalf("Unexpected ordinal: %d", o)
  640. }
  641. }