file_test.go 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688
  1. package burndown
  2. import (
  3. "testing"
  4. "github.com/stretchr/testify/assert"
  5. "gopkg.in/src-d/hercules.v4/internal/rbtree"
  6. "fmt"
  7. )
  8. func updateStatusFile(status map[int]int64, _, previousTime, delta int) {
  9. status[previousTime] += int64(delta)
  10. }
  11. func fixtureFile() (*File, map[int]int64) {
  12. status := map[int]int64{}
  13. file := NewFile(0, 100, func(a, b, c int) {
  14. updateStatusFile(status, a, b, c)
  15. })
  16. return file, status
  17. }
  18. func TestInitializeFile(t *testing.T) {
  19. file, status := fixtureFile()
  20. dump := file.Dump()
  21. // Output:
  22. // 0 0
  23. // 100 -1
  24. assert.Equal(t, "0 0\n100 -1\n", dump)
  25. assert.Equal(t, int64(100), status[0])
  26. }
  27. func testPanicFile(t *testing.T, method func(*File), msg string) {
  28. defer func() {
  29. r := recover()
  30. assert.NotNil(t, r, "not panic()-ed")
  31. assert.IsType(t, "", r)
  32. assert.Contains(t, r.(string), msg)
  33. }()
  34. file, _ := fixtureFile()
  35. method(file)
  36. }
  37. func TestBullshitFile(t *testing.T) {
  38. testPanicFile(t, func(file *File) { file.Update(1, -10, 10, 0) }, "insert")
  39. testPanicFile(t, func(file *File) { file.Update(1, 110, 10, 0) }, "insert")
  40. testPanicFile(t, func(file *File) { file.Update(1, -10, 0, 10) }, "delete")
  41. testPanicFile(t, func(file *File) { file.Update(1, 100, 0, 10) }, "delete")
  42. testPanicFile(t, func(file *File) { file.Update(1, 0, -10, 0) }, "Length")
  43. testPanicFile(t, func(file *File) { file.Update(1, 0, 0, -10) }, "Length")
  44. testPanicFile(t, func(file *File) { file.Update(1, 0, -10, -10) }, "Length")
  45. testPanicFile(t, func(file *File) { file.Update(-1, 0, 10, 10) }, "time")
  46. file, status := fixtureFile()
  47. file.Update(1, 10, 0, 0)
  48. assert.Equal(t, int64(100), status[0])
  49. assert.Equal(t, int64(0), status[1])
  50. }
  51. func TestCloneFile(t *testing.T) {
  52. file, status := fixtureFile()
  53. // 0 0 | 100 -1 [0]: 100
  54. file.Update(1, 20, 30, 0)
  55. // 0 0 | 20 1 | 50 0 | 130 -1 [0]: 100, [1]: 30
  56. file.Update(2, 20, 0, 5)
  57. // 0 0 | 20 1 | 45 0 | 125 -1 [0]: 100, [1]: 25
  58. file.Update(3, 20, 0, 5)
  59. // 0 0 | 20 1 | 40 0 | 120 -1 [0]: 100, [1]: 20
  60. file.Update(4, 20, 10, 0)
  61. // 0 0 | 20 4 | 30 1 | 50 0 | 130 -1 [0]: 100, [1]: 20, [4]: 10
  62. clone := file.Clone(false)
  63. clone.Update(5, 45, 0, 10)
  64. // 0 0 | 20 4 | 30 1 | 45 0 | 120 -1 [0]: 95, [1]: 15, [4]: 10
  65. clone.Update(6, 45, 5, 0)
  66. // 0 0 | 20 4 | 30 1 | 45 6 | 50 0 | 125 -1 [0]: 95, [1]: 15, [4]: 10, [6]: 5
  67. assert.Equal(t, int64(95), status[0])
  68. assert.Equal(t, int64(15), status[1])
  69. assert.Equal(t, int64(0), status[2])
  70. assert.Equal(t, int64(0), status[3])
  71. assert.Equal(t, int64(10), status[4])
  72. assert.Equal(t, int64(0), status[5])
  73. assert.Equal(t, int64(5), status[6])
  74. dump := file.Dump()
  75. // Output:
  76. // 0 0
  77. // 20 4
  78. // 30 1
  79. // 50 0
  80. // 130 -1
  81. assert.Equal(t, "0 0\n20 4\n30 1\n50 0\n130 -1\n", dump)
  82. dump = clone.Dump()
  83. // Output:
  84. // 0 0
  85. // 20 4
  86. // 30 1
  87. // 45 6
  88. // 50 0
  89. // 125 -1
  90. assert.Equal(t, "0 0\n20 4\n30 1\n45 6\n50 0\n125 -1\n", dump)
  91. }
  92. func TestCloneFileClearStatus(t *testing.T) {
  93. file, status := fixtureFile()
  94. // 0 0 | 100 -1 [0]: 100
  95. file.Update(1, 20, 30, 0)
  96. // 0 0 | 20 1 | 50 0 | 130 -1 [0]: 100, [1]: 30
  97. file.Update(2, 20, 0, 5)
  98. // 0 0 | 20 1 | 45 0 | 125 -1 [0]: 100, [1]: 25
  99. file.Update(3, 20, 0, 5)
  100. // 0 0 | 20 1 | 40 0 | 120 -1 [0]: 100, [1]: 20
  101. file.Update(4, 20, 10, 0)
  102. // 0 0 | 20 4 | 30 1 | 50 0 | 130 -1 [0]: 100, [1]: 20, [4]: 10
  103. newStatus := map[int]int64{}
  104. clone := file.Clone(true, func(a, b, c int) {
  105. updateStatusFile(newStatus, a, b, c)
  106. })
  107. clone.Update(5, 45, 0, 10)
  108. // 0 0 | 20 4 | 30 1 | 45 0 | 120 -1 [0]: -5, [1]: -5
  109. clone.Update(6, 45, 5, 0)
  110. // 0 0 | 20 4 | 30 1 | 45 6 | 50 0 | 125 -1 [0]: -5, [1]: -5, [6]: 5
  111. assert.Equal(t, int64(100), status[0])
  112. assert.Equal(t, int64(20), status[1])
  113. assert.Equal(t, int64(0), status[2])
  114. assert.Equal(t, int64(0), status[3])
  115. assert.Equal(t, int64(10), status[4])
  116. assert.Equal(t, int64(-5), newStatus[0])
  117. assert.Equal(t, int64(-5), newStatus[1])
  118. assert.Equal(t, int64(0), newStatus[2])
  119. assert.Equal(t, int64(0), newStatus[3])
  120. assert.Equal(t, int64(0), newStatus[4])
  121. assert.Equal(t, int64(0), newStatus[5])
  122. assert.Equal(t, int64(5), newStatus[6])
  123. dump := file.Dump()
  124. // Output:
  125. // 0 0
  126. // 20 4
  127. // 30 1
  128. // 50 0
  129. // 130 -1
  130. assert.Equal(t, "0 0\n20 4\n30 1\n50 0\n130 -1\n", dump)
  131. dump = clone.Dump()
  132. // Output:
  133. // 0 0
  134. // 20 4
  135. // 30 1
  136. // 45 6
  137. // 50 0
  138. // 125 -1
  139. assert.Equal(t, "0 0\n20 4\n30 1\n45 6\n50 0\n125 -1\n", dump)
  140. }
  141. func TestLenFile(t *testing.T) {
  142. file, _ := fixtureFile()
  143. assert.Equal(t, 100, file.Len())
  144. }
  145. func TestInsertFile(t *testing.T) {
  146. file, status := fixtureFile()
  147. file.Update(1, 10, 10, 0)
  148. dump := file.Dump()
  149. // Output:
  150. // 0 0
  151. // 10 1
  152. // 20 0
  153. // 110 -1
  154. assert.Equal(t, "0 0\n10 1\n20 0\n110 -1\n", dump)
  155. assert.Equal(t, int64(100), status[0])
  156. assert.Equal(t, int64(10), status[1])
  157. }
  158. func TestZeroInitializeFile(t *testing.T) {
  159. status := map[int]int64{}
  160. file := NewFile(0, 0, func(a, b, c int) {
  161. updateStatusFile(status, a, b, c)
  162. })
  163. assert.Contains(t, status, 0)
  164. dump := file.Dump()
  165. // Output:
  166. // 0 -1
  167. assert.Equal(t, "0 -1\n", dump)
  168. file.Update(1, 0, 10, 0)
  169. dump = file.Dump()
  170. // Output:
  171. // 0 1
  172. // 10 -1
  173. assert.Equal(t, "0 1\n10 -1\n", dump)
  174. assert.Equal(t, int64(10), status[1])
  175. }
  176. func TestDeleteFile(t *testing.T) {
  177. file, status := fixtureFile()
  178. file.Update(1, 10, 0, 10)
  179. dump := file.Dump()
  180. // Output:
  181. // 0 0
  182. // 90 -1
  183. assert.Equal(t, "0 0\n90 -1\n", dump)
  184. assert.Equal(t, int64(90), status[0])
  185. assert.Equal(t, int64(0), status[1])
  186. }
  187. func TestFusedFile(t *testing.T) {
  188. file, status := fixtureFile()
  189. file.Update(1, 10, 6, 7)
  190. dump := file.Dump()
  191. // Output:
  192. // 0 0
  193. // 10 1
  194. // 16 0
  195. // 99 -1
  196. assert.Equal(t, "0 0\n10 1\n16 0\n99 -1\n", dump)
  197. assert.Equal(t, int64(93), status[0])
  198. assert.Equal(t, int64(6), status[1])
  199. }
  200. func TestInsertSameTimeFile(t *testing.T) {
  201. file, status := fixtureFile()
  202. file.Update(0, 5, 10, 0)
  203. dump := file.Dump()
  204. // Output:
  205. // 0 0
  206. // 110 -1
  207. assert.Equal(t, "0 0\n110 -1\n", dump)
  208. assert.Equal(t, int64(110), status[0])
  209. }
  210. func TestInsertSameStartFile(t *testing.T) {
  211. file, status := fixtureFile()
  212. file.Update(1, 10, 10, 0)
  213. file.Update(2, 10, 10, 0)
  214. dump := file.Dump()
  215. // Output:
  216. // 0 0
  217. // 10 2
  218. // 20 1
  219. // 30 0
  220. // 120 -1
  221. assert.Equal(t, "0 0\n10 2\n20 1\n30 0\n120 -1\n", dump)
  222. assert.Equal(t, int64(100), status[0])
  223. assert.Equal(t, int64(10), status[1])
  224. assert.Equal(t, int64(10), status[2])
  225. }
  226. func TestInsertEndFile(t *testing.T) {
  227. file, status := fixtureFile()
  228. file.Update(1, 100, 10, 0)
  229. dump := file.Dump()
  230. // Output:
  231. // 0 0
  232. // 100 1
  233. // 110 -1
  234. assert.Equal(t, "0 0\n100 1\n110 -1\n", dump)
  235. assert.Equal(t, int64(100), status[0])
  236. assert.Equal(t, int64(10), status[1])
  237. }
  238. func TestDeleteSameStart0File(t *testing.T) {
  239. file, status := fixtureFile()
  240. file.Update(1, 0, 0, 10)
  241. dump := file.Dump()
  242. // Output:
  243. // 0 0
  244. // 90 -1
  245. assert.Equal(t, "0 0\n90 -1\n", dump)
  246. assert.Equal(t, int64(90), status[0])
  247. assert.Equal(t, int64(0), status[1])
  248. }
  249. func TestDeleteSameStartMiddleFile(t *testing.T) {
  250. file, status := fixtureFile()
  251. file.Update(1, 10, 10, 0)
  252. file.Update(2, 10, 0, 5)
  253. dump := file.Dump()
  254. // Output:
  255. // 0 0
  256. // 10 1
  257. // 15 0
  258. // 105 -1
  259. assert.Equal(t, "0 0\n10 1\n15 0\n105 -1\n", dump)
  260. assert.Equal(t, int64(100), status[0])
  261. assert.Equal(t, int64(5), status[1])
  262. }
  263. func TestDeleteIntersectionFile(t *testing.T) {
  264. file, status := fixtureFile()
  265. file.Update(1, 10, 10, 0)
  266. file.Update(2, 15, 0, 10)
  267. dump := file.Dump()
  268. // Output:
  269. // 0 0
  270. // 10 1
  271. // 15 0
  272. // 100 -1
  273. assert.Equal(t, "0 0\n10 1\n15 0\n100 -1\n", dump)
  274. assert.Equal(t, int64(95), status[0])
  275. assert.Equal(t, int64(5), status[1])
  276. }
  277. func TestDeleteAllFile(t *testing.T) {
  278. file, status := fixtureFile()
  279. file.Update(1, 0, 0, 100)
  280. // Output:
  281. // 0 -1
  282. dump := file.Dump()
  283. assert.Equal(t, "0 -1\n", dump)
  284. assert.Equal(t, int64(0), status[0])
  285. assert.Equal(t, int64(0), status[1])
  286. }
  287. func TestFusedIntersectionFile(t *testing.T) {
  288. file, status := fixtureFile()
  289. file.Update(1, 10, 10, 0)
  290. file.Update(2, 15, 3, 10)
  291. dump := file.Dump()
  292. // Output:
  293. // 0 0
  294. // 10 1
  295. // 15 2
  296. // 18 0
  297. // 103 -1
  298. assert.Equal(t, "0 0\n10 1\n15 2\n18 0\n103 -1\n", dump)
  299. assert.Equal(t, int64(95), status[0])
  300. assert.Equal(t, int64(5), status[1])
  301. assert.Equal(t, int64(3), status[2])
  302. }
  303. func TestTortureFile(t *testing.T) {
  304. file, status := fixtureFile()
  305. // 0 0 | 100 -1 [0]: 100
  306. file.Update(1, 20, 30, 0)
  307. // 0 0 | 20 1 | 50 0 | 130 -1 [0]: 100, [1]: 30
  308. file.Update(2, 20, 0, 5)
  309. // 0 0 | 20 1 | 45 0 | 125 -1 [0]: 100, [1]: 25
  310. file.Update(3, 20, 0, 5)
  311. // 0 0 | 20 1 | 40 0 | 120 -1 [0]: 100, [1]: 20
  312. file.Update(4, 20, 10, 0)
  313. // 0 0 | 20 4 | 30 1 | 50 0 | 130 -1 [0]: 100, [1]: 20, [4]: 10
  314. file.Update(5, 45, 0, 10)
  315. // 0 0 | 20 4 | 30 1 | 45 0 | 120 -1 [0]: 95, [1]: 15, [4]: 10
  316. file.Update(6, 45, 5, 0)
  317. // 0 0 | 20 4 | 30 1 | 45 6 | 50 0 | 125 -1 [0]: 95, [1]: 15, [4]: 10, [6]: 5
  318. file.Update(7, 10, 0, 50)
  319. // 0 0 | 75 -1 [0]: 75
  320. file.Update(8, 0, 10, 10)
  321. // 0 8 | 10 0 | 75 -1 [0]: 65, [8]: 10
  322. dump := file.Dump()
  323. assert.Equal(t, "0 8\n10 0\n75 -1\n", dump)
  324. assert.Equal(t, int64(65), status[0])
  325. assert.Equal(t, int64(0), status[1])
  326. assert.Equal(t, int64(0), status[2])
  327. assert.Equal(t, int64(0), status[3])
  328. assert.Equal(t, int64(0), status[4])
  329. assert.Equal(t, int64(0), status[5])
  330. assert.Equal(t, int64(0), status[6])
  331. assert.Equal(t, int64(0), status[7])
  332. assert.Equal(t, int64(10), status[8])
  333. }
  334. func TestInsertDeleteSameTimeFile(t *testing.T) {
  335. file, status := fixtureFile()
  336. file.Update(0, 10, 10, 20)
  337. dump := file.Dump()
  338. assert.Equal(t, "0 0\n90 -1\n", dump)
  339. assert.Equal(t, int64(90), status[0])
  340. file.Update(0, 10, 20, 10)
  341. dump = file.Dump()
  342. assert.Equal(t, "0 0\n100 -1\n", dump)
  343. assert.Equal(t, int64(100), status[0])
  344. }
  345. func TestBug1File(t *testing.T) {
  346. file, status := fixtureFile()
  347. file.Update(316, 1, 86, 0)
  348. file.Update(316, 87, 0, 99)
  349. file.Update(251, 0, 1, 0)
  350. file.Update(251, 1, 0, 1)
  351. dump := file.Dump()
  352. assert.Equal(t, "0 251\n1 316\n87 -1\n", dump)
  353. assert.Equal(t, int64(1), status[251])
  354. assert.Equal(t, int64(86), status[316])
  355. file.Update(316, 0, 0, 1)
  356. file.Update(316, 0, 1, 0)
  357. dump = file.Dump()
  358. assert.Equal(t, "0 316\n87 -1\n", dump)
  359. assert.Equal(t, int64(0), status[251])
  360. assert.Equal(t, int64(87), status[316])
  361. }
  362. func TestBug2File(t *testing.T) {
  363. file, status := fixtureFile()
  364. file.Update(316, 1, 86, 0)
  365. file.Update(316, 87, 0, 99)
  366. file.Update(251, 0, 1, 0)
  367. file.Update(251, 1, 0, 1)
  368. dump := file.Dump()
  369. assert.Equal(t, "0 251\n1 316\n87 -1\n", dump)
  370. file.Update(316, 0, 1, 1)
  371. dump = file.Dump()
  372. assert.Equal(t, "0 316\n87 -1\n", dump)
  373. assert.Equal(t, int64(0), status[251])
  374. assert.Equal(t, int64(87), status[316])
  375. }
  376. func TestJoinFile(t *testing.T) {
  377. file, status := fixtureFile()
  378. file.Update(1, 10, 10, 0)
  379. file.Update(1, 30, 10, 0)
  380. file.Update(1, 20, 10, 10)
  381. dump := file.Dump()
  382. assert.Equal(t, "0 0\n10 1\n40 0\n120 -1\n", dump)
  383. assert.Equal(t, int64(90), status[0])
  384. assert.Equal(t, int64(30), status[1])
  385. }
  386. func TestBug3File(t *testing.T) {
  387. file, status := fixtureFile()
  388. file.Update(0, 1, 0, 99)
  389. file.Update(0, 0, 1, 1)
  390. dump := file.Dump()
  391. assert.Equal(t, "0 0\n1 -1\n", dump)
  392. assert.Equal(t, int64(1), status[0])
  393. }
  394. func TestBug4File(t *testing.T) {
  395. status := map[int]int64{}
  396. file := NewFile(0, 10, func(a, b, c int) {
  397. updateStatusFile(status, a, b, c)
  398. })
  399. // 0 0 | 10 -1
  400. file.Update(125, 0, 20, 9)
  401. // 0 125 | 20 0 | 21 -1
  402. file.Update(125, 0, 20, 20)
  403. // 0 125 | 20 0 | 21 -1
  404. file.Update(166, 12, 1, 1)
  405. // 0 125 | 12 166 | 13 125 | 20 0 | 21 -1
  406. file.Update(214, 2, 1, 1)
  407. // 0 125 | 2 214 | 3 125 | 12 166 | 13 125 | 20 0 | 21 -1
  408. file.Update(214, 4, 9, 0)
  409. // 0 125 | 2 214 | 3 125 | 4 214 | 13 125 | 21 166 | 22 125 | 29 0 | 30 -1
  410. file.Update(214, 27, 1, 1)
  411. // 0 125 | 2 214 | 3 125 | 4 214 | 13 125 | 21 166 | 22 125 | 27 214 | 28 125 | 29 0 | 30 -1
  412. file.Update(215, 3, 1, 1)
  413. // 0 125 | 2 214 | 3 215 | 4 214 | 13 125 | 21 166 | 22 125 | 27 214 | 28 125 | 29 0 | 30 -1
  414. file.Update(215, 13, 1, 1)
  415. // 0 125 | 2 214 | 3 215 | 4 214 | 13 215 | 14 125 | 21 166 | 22 125 | 27 214 | 28 125 | 29 0 | 30 -1
  416. file.Update(215, 17, 1, 1)
  417. // 0 125 | 2 214 | 3 215 | 4 214 | 13 215 | 14 125 | 17 215 | 18 125 | 21 166 | 22 125 | 27 214 | 28 125 | 29 0 | 30 -1
  418. file.Update(215, 19, 5, 0)
  419. // 0 125 | 2 214 | 3 215 | 4 214 | 13 215 | 14 125 | 17 215 | 18 125 | 19 215 | 24 125 | 26 166 | 27 125 | 32 214 | 33 125 | 34 0 | 35 -1
  420. file.Update(215, 25, 0, 1)
  421. // 0 125 | 2 214 | 3 215 | 4 214 | 13 215 | 14 125 | 17 215 | 18 125 | 19 215 | 24 125 | 25 166 | 26 125 | 31 214 | 32 125 | 33 0 | 34 -1
  422. file.Update(215, 31, 6, 1)
  423. // 0 125 | 2 214 | 3 215 | 4 214 | 13 215 | 14 125 | 17 215 | 18 125 | 19 215 | 24 125 | 25 166 | 26 125 | 31 215 | 37 125 | 38 0 | 39 -1
  424. file.Update(215, 27, 15, 0)
  425. // 0 125 | 2 214 | 3 215 | 4 214 | 13 215 | 14 125 | 17 215 | 18 125 | 19 215 | 24 125 | 25 166 | 26 125 | 27 215 | 42 125 | 46 215 | 52 125 | 53 0 | 54 -1
  426. file.Update(215, 2, 25, 4)
  427. // 0 125 | 2 215 | 27 214 | 34 215 | 35 125 | 38 215 | 39 125 | 40 215 | 45 125 | 46 166 | 47 125 | 48 215 | 63 125 | 67 215 | 73 125 | 74 0 | 75 -1
  428. file.Update(215, 28, 1, 1)
  429. // 0 125 | 2 215 | 27 214 | 28 215 | 29 214 | 34 215 | 35 125 | 38 215 | 39 125 | 40 215 | 45 125 | 46 166 | 47 125 | 48 215 | 63 125 | 67 215 | 73 125 | 74 0 | 75 -1
  430. file.Update(215, 30, 7, 2)
  431. // 0 125 | 2 215 | 27 214 | 28 215 | 29 214 | 30 215 | 37 214 | 39 215 | 40 125 | 43 215 | 44 125 | 45 215 | 50 125 | 51 166 | 52 125 | 53 215 | 68 125 | 72 215 | 78 125 | 79 0 | 80 -1
  432. file.Update(215, 38, 1, 0)
  433. // 0 125 | 2 215 | 27 214 | 28 215 | 29 214 | 30 215 | 37 214 | 38 215 | 39 214 | 40 215 | 41 125 | 44 215 | 45 125 | 46 215 | 51 125 | 52 166 | 53 125 | 54 215 | 69 125 | 73 215 | 79 125 | 80 0 | 81 -1
  434. file.Update(215, 40, 4, 2)
  435. // 0 125 | 2 215 | 27 214 | 28 215 | 29 214 | 30 215 | 37 214 | 38 215 | 39 214 | 40 215 | 44 125 | 46 215 | 47 125 | 48 215 | 53 125 | 54 166 | 55 125 | 56 215 | 71 125 | 75 215 | 81 125 | 82 0 | 83 -1
  436. file.Update(215, 46, 1, 0)
  437. // 0 125 | 2 215 | 27 214 | 28 215 | 29 214 | 30 215 | 37 214 | 38 215 | 39 214 | 40 215 | 44 125 | 46 215 | 48 125 | 49 215 | 54 125 | 55 166 | 56 125 | 57 215 | 72 125 | 76 215 | 82 125 | 83 0 | 84 -1
  438. file.Update(215, 49, 1, 0)
  439. // 0 125 | 2 215 | 27 214 | 28 215 | 29 214 | 30 215 | 37 214 | 38 215 | 39 214 | 40 215 | 44 125 | 46 215 | 48 125 | 49 215 | 55 125 | 56 166 | 57 125 | 58 215 | 73 125 | 77 215 | 83 125 | 84 0 | 85 -1
  440. file.Update(215, 52, 2, 6)
  441. // 0 125 | 2 215 | 27 214 | 28 215 | 29 214 | 30 215 | 37 214 | 38 215 | 39 214 | 40 215 | 44 125 | 46 215 | 48 125 | 49 215 | 69 125 | 73 215 | 79 125 | 80 0 | 81 -1
  442. dump := file.Dump()
  443. assert.Equal(t, "0 125\n2 215\n27 214\n28 215\n29 214\n30 215\n37 214\n38 215\n39 214\n40 215\n44 125\n46 215\n48 125\n49 215\n69 125\n73 215\n79 125\n80 0\n81 -1\n", dump)
  444. file.Update(214, 38, 1, 1)
  445. // 0 125 | 2 215 | 27 214 | 28 215 | 29 214 | 30 215 | 37 214 | 40 215 | 44 125 | 46 215 | 48 125 | 49 215 | 69 125 | 73 215 | 79 125 | 80 0 | 81 -1
  446. dump = file.Dump()
  447. assert.Equal(t, "0 125\n2 215\n27 214\n28 215\n29 214\n30 215\n37 214\n40 215\n44 125\n46 215\n48 125\n49 215\n69 125\n73 215\n79 125\n80 0\n81 -1\n", dump)
  448. file.Update(300, 28, 1, 1)
  449. // 0 125 | 2 215 | 27 214 | 28 300 | 29 214 | 30 215 | 37 214 | 40 215 | 44 125 | 46 215 | 48 125 | 49 215 | 69 125 | 73 215 | 79 125 | 80 0 | 81 -1
  450. dump = file.Dump()
  451. assert.Equal(t, "0 125\n2 215\n27 214\n28 300\n29 214\n30 215\n37 214\n40 215\n44 125\n46 215\n48 125\n49 215\n69 125\n73 215\n79 125\n80 0\n81 -1\n", dump)
  452. }
  453. func TestBug5File(t *testing.T) {
  454. status := map[int]int64{}
  455. keys := []int{0, 2, 4, 7, 10}
  456. vals := []int{24, 28, 24, 28, -1}
  457. file := NewFileFromTree(keys, vals, func(a, b, c int) {
  458. updateStatusFile(status, a, b, c)
  459. })
  460. file.Update(28, 0, 1, 3)
  461. dump := file.Dump()
  462. assert.Equal(t, "0 28\n2 24\n5 28\n8 -1\n", dump)
  463. keys = []int{0, 1, 16, 18}
  464. vals = []int{305, 0, 157, -1}
  465. file = NewFileFromTree(keys, vals, func(a, b, c int) {
  466. updateStatusFile(status, a, b, c)
  467. })
  468. file.Update(310, 0, 0, 2)
  469. dump = file.Dump()
  470. assert.Equal(t, "0 0\n14 157\n16 -1\n", dump)
  471. }
  472. func TestNewFileFromTreeInvalidSize(t *testing.T) {
  473. keys := [...]int{1, 2, 3}
  474. vals := [...]int{4, 5}
  475. assert.Panics(t, func() { NewFileFromTree(keys[:], vals[:]) })
  476. }
  477. func TestUpdatePanic(t *testing.T) {
  478. keys := [...]int{0}
  479. vals := [...]int{-1}
  480. file := NewFileFromTree(keys[:], vals[:])
  481. file.tree.DeleteWithKey(0)
  482. file.tree.Insert(rbtree.Item{Key: -1, Value: -1})
  483. var paniced interface{}
  484. func() {
  485. defer func() {
  486. paniced = recover()
  487. }()
  488. file.Update(1, 0, 1, 0)
  489. }()
  490. assert.Contains(t, paniced, "invalid tree state")
  491. }
  492. func TestFileValidate(t *testing.T) {
  493. keys := [...]int{0}
  494. vals := [...]int{-1}
  495. file := NewFileFromTree(keys[:], vals[:])
  496. file.tree.DeleteWithKey(0)
  497. file.tree.Insert(rbtree.Item{Key: -1, Value: -1})
  498. assert.Panics(t, func() { file.Validate() })
  499. file.tree.DeleteWithKey(-1)
  500. file.tree.Insert(rbtree.Item{Key: 0, Value: -1})
  501. file.Validate()
  502. file.tree.DeleteWithKey(0)
  503. file.tree.Insert(rbtree.Item{Key: 0, Value: 0})
  504. assert.Panics(t, func() { file.Validate() })
  505. file.tree.DeleteWithKey(0)
  506. file.tree.Insert(rbtree.Item{Key: 0, Value: 1})
  507. file.tree.Insert(rbtree.Item{Key: 1, Value: 1})
  508. file.tree.Insert(rbtree.Item{Key: 2, Value: -1})
  509. file.Validate()
  510. file.tree.FindGE(2).Item().Key = 1
  511. assert.Panics(t, func() { file.Validate() })
  512. }
  513. func TestFileFlatten(t *testing.T) {
  514. file, _ := fixtureFile()
  515. // 0 0 | 100 -1 [0]: 100
  516. file.Update(1, 20, 30, 0)
  517. // 0 0 | 20 1 | 50 0 | 130 -1 [0]: 100, [1]: 30
  518. file.Update(2, 20, 0, 5)
  519. // 0 0 | 20 1 | 45 0 | 125 -1 [0]: 100, [1]: 25
  520. file.Update(3, 20, 0, 5)
  521. // 0 0 | 20 1 | 40 0 | 120 -1 [0]: 100, [1]: 20
  522. file.Update(4, 20, 10, 0)
  523. // 0 0 | 20 4 | 30 1 | 50 0 | 130 -1 [0]: 100, [1]: 20, [4]: 10
  524. lines := file.flatten()
  525. for i := 0; i < 20; i++ {
  526. assert.Equal(t, 0, lines[i], fmt.Sprintf("line %d", i))
  527. }
  528. for i := 20; i < 30; i++ {
  529. assert.Equal(t, 4, lines[i], fmt.Sprintf("line %d", i))
  530. }
  531. for i := 30; i < 50; i++ {
  532. assert.Equal(t, 1, lines[i], fmt.Sprintf("line %d", i))
  533. }
  534. for i := 50; i < 130; i++ {
  535. assert.Equal(t, 0, lines[i], fmt.Sprintf("line %d", i))
  536. }
  537. assert.Len(t, lines, 130)
  538. }
  539. func TestFileMergeMark(t *testing.T) {
  540. file, status := fixtureFile()
  541. // 0 0 | 100 -1 [0]: 100
  542. file.Update(1, 20, 30, 0)
  543. // 0 0 | 20 1 | 50 0 | 130 -1 [0]: 100, [1]: 30
  544. file.Update(2, 20, 0, 5)
  545. // 0 0 | 20 1 | 45 0 | 125 -1 [0]: 100, [1]: 25
  546. file.Update(3, 20, 0, 5)
  547. // 0 0 | 20 1 | 40 0 | 120 -1 [0]: 100, [1]: 20
  548. file.Update(4, 20, 10, 0)
  549. // 0 0 | 20 4 | 30 1 | 50 0 | 130 -1 [0]: 100, [1]: 20, [4]: 10
  550. file.Update(TreeMergeMark, 60, 20, 20)
  551. // 0 0 | 20 4 | 30 1 | 50 0 | 60 M | 80 0 | 130 -1
  552. // [0]: 100, [1]: 20, [4]: 10
  553. dump := file.Dump()
  554. assert.Equal(t, "0 0\n20 4\n30 1\n50 0\n60 16383\n80 0\n130 -1\n", dump)
  555. assert.Contains(t, status, 0)
  556. assert.Equal(t, int64(100), status[0])
  557. assert.Equal(t, int64(20), status[1])
  558. assert.Equal(t, int64(0), status[2])
  559. assert.Equal(t, int64(0), status[3])
  560. assert.Equal(t, int64(10), status[4])
  561. assert.NotContains(t, status, TreeMergeMark)
  562. }
  563. func TestFileMerge(t *testing.T) {
  564. file1, status := fixtureFile()
  565. // 0 0 | 100 -1 [0]: 100
  566. file1.Update(1, 20, 30, 0)
  567. // 0 0 | 20 1 | 50 0 | 130 -1 [0]: 100, [1]: 30
  568. file1.Update(2, 20, 0, 5)
  569. // 0 0 | 20 1 | 45 0 | 125 -1 [0]: 100, [1]: 25
  570. file1.Update(3, 20, 0, 5)
  571. // 0 0 | 20 1 | 40 0 | 120 -1 [0]: 100, [1]: 20
  572. file1.Update(4, 20, 10, 0)
  573. // 0 0 | 20 4 | 30 1 | 50 0 | 130 -1 [0]: 100, [1]: 20, [4]: 10
  574. file2 := file1.Clone(false)
  575. file1.Update(TreeMergeMark, 60, 30, 30)
  576. // 0 0 | 20 4 | 30 1 | 50 0 | 60 M | 90 0 | 130 -1
  577. // [0]: 70, [1]: 20, [4]: 10
  578. file2.Update(5, 60, 20, 20)
  579. // 0 0 | 20 4 | 30 1 | 50 0 | 60 5 | 80 0 | 130 -1
  580. // [0]: 80, [1]: 20, [4]: 10, [5]: 20
  581. file2.Update(TreeMergeMark, 80, 10, 10)
  582. // 0 0 | 20 4 | 30 1 | 50 0 | 60 5 | 80 M | 90 0 | 130 -1
  583. // [0]: 70, [1]: 20, [4]: 10, [5]: 20
  584. file2.Update(6, 0, 10, 10)
  585. // 0 6 | 10 0 | 20 4 | 30 1 | 50 0 | 60 5 | 80 M | 90 0 | 130 -1
  586. // [0]: 60, [1]: 20, [4]: 10, [5]: 20, [6]: 10
  587. file1.Merge(7, file2)
  588. // 0 0 | 20 4 | 30 1 | 50 0 | 60 5 | 80 7 | 90 0 | 130 -1
  589. // [0]: 70, [1]: 20, [4]: 10, [5]: 20, [6]: 0, [7]: 10
  590. dump := file1.Dump()
  591. assert.Equal(t, "0 0\n20 4\n30 1\n50 0\n60 5\n80 7\n90 0\n130 -1\n", dump)
  592. assert.Equal(t, int64(70), status[0])
  593. assert.Equal(t, int64(20), status[1])
  594. assert.Equal(t, int64(0), status[2])
  595. assert.Equal(t, int64(0), status[3])
  596. assert.Equal(t, int64(10), status[4])
  597. assert.Equal(t, int64(20), status[5])
  598. assert.Equal(t, int64(10), status[6])
  599. assert.Equal(t, int64(10), status[7])
  600. }
  601. func TestFileMergeNoop(t *testing.T) {
  602. file1, _ := fixtureFile()
  603. // 0 0 | 100 -1 [0]: 100
  604. assert.Panics(t, func() { file1.Merge(3, nil) })
  605. }
  606. func TestFileMergeNil(t *testing.T) {
  607. file, _ := fixtureFile()
  608. assert.Panics(t, func() {
  609. file.Merge(1, nil)
  610. })
  611. }
  612. func TestBug6File(t *testing.T) {
  613. status := map[int]int64{}
  614. keys := []int{0, 113, 153, 154}
  615. vals := []int{7, 10, 7, -1}
  616. file := NewFileFromTree(keys, vals, func(a, b, c int) {
  617. updateStatusFile(status, a, b, c)
  618. })
  619. // 0 7 | 113 10 | 153 7 | 154 -1
  620. file.Update(10, 99, 1, 1)
  621. // 0 7 | 99 10 | 100 7 | 113 10 | 153 7 | 154 -1
  622. file.Update(10, 104, 1, 1)
  623. // 0 7 | 99 10 | 100 7 | 104 10 | 105 7 | 113 10 | 153 7 | 154 -1
  624. file.Update(10, 106, 1, 1)
  625. // 0 7 | 99 10 | 100 7 | 104 10 | 105 7 | 106 10 | 107 7 | 113 10 | 153 7 | 154 -1
  626. file.Update(10, 108, 1, 1)
  627. // 0 7 | 99 10 | 100 7 | 104 10 | 105 7 | 106 10 | 107 7 | 108 10 | 109 7 | 113 10 | 153 7 | 154 -1
  628. file.Update(10, 115, 2, 0)
  629. // 0 7 | 99 10 | 100 7 | 104 10 | 105 7 | 106 10 | 107 7 | 108 10 | 109 7 | 113 10 | 155 7 | 156 -1
  630. file.Update(10, 125, 4, 2)
  631. // 0 7 | 99 10 | 100 7 | 104 10 | 105 7 | 106 10 | 107 7 | 108 10 | 109 7 | 113 10 | 157 7 | 158 -1
  632. dump := file.Dump()
  633. assert.Equal(t, "0 7\n99 10\n100 7\n104 10\n105 7\n106 10\n107 7\n108 10\n109 7\n113 10\n157 7\n158 -1\n", dump)
  634. file = NewFileFromTree(keys, vals, func(a, b, c int) {
  635. updateStatusFile(status, a, b, c)
  636. })
  637. // 0 7 | 113 10 | 153 7 | 154 -1
  638. file.Update(10, 112, 1, 1)
  639. // 0 7 | 112 10 | 153 7 | 154 -1
  640. dump = file.Dump()
  641. assert.Equal(t, "0 7\n112 10\n153 7\n154 -1\n", dump)
  642. }