BitfieldManTest.cc 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756
  1. #include "BitfieldMan.h"
  2. #include "FixedNumberRandomizer.h"
  3. #include <cstring>
  4. #include <cppunit/extensions/HelperMacros.h>
  5. namespace aria2 {
  6. class BitfieldManTest:public CppUnit::TestFixture {
  7. CPPUNIT_TEST_SUITE(BitfieldManTest);
  8. CPPUNIT_TEST(testGetBlockSize);
  9. CPPUNIT_TEST(testGetFirstMissingUnusedIndex);
  10. CPPUNIT_TEST(testGetFirstMissingIndex);
  11. CPPUNIT_TEST(testIsAllBitSet);
  12. CPPUNIT_TEST(testFilter);
  13. CPPUNIT_TEST(testGetMissingIndex);
  14. CPPUNIT_TEST(testGetSparceMissingUnusedIndex);
  15. CPPUNIT_TEST(testGetSparceMissingUnusedIndex_setBit);
  16. CPPUNIT_TEST(testIsBitSetOffsetRange);
  17. CPPUNIT_TEST(testGetMissingUnusedLength);
  18. CPPUNIT_TEST(testSetBitRange);
  19. CPPUNIT_TEST(testGetAllMissingIndexes);
  20. CPPUNIT_TEST(testGetAllMissingIndexes_noarg);
  21. CPPUNIT_TEST(testGetAllMissingUnusedIndexes);
  22. CPPUNIT_TEST(testGetMissingUnusedIndex);
  23. CPPUNIT_TEST(testGetMissingIndex_noarg);
  24. CPPUNIT_TEST(testGetMissingUnusedIndex_noarg);
  25. CPPUNIT_TEST(testCountFilteredBlock);
  26. CPPUNIT_TEST(testCountMissingBlock);
  27. CPPUNIT_TEST_SUITE_END();
  28. private:
  29. SharedHandle<Randomizer> fixedNumberRandomizer;
  30. public:
  31. BitfieldManTest() {
  32. FixedNumberRandomizer* randomizer = new FixedNumberRandomizer();
  33. randomizer->setFixedNumber(0);
  34. this->fixedNumberRandomizer.reset(randomizer);
  35. }
  36. void setUp() {
  37. }
  38. void testGetBlockSize();
  39. void testGetFirstMissingUnusedIndex();
  40. void testGetFirstMissingIndex();
  41. void testGetMissingIndex();
  42. void testGetMissingIndex_noarg();
  43. void testGetMissingUnusedIndex();
  44. void testGetMissingUnusedIndex_noarg();
  45. void testGetAllMissingIndexes();
  46. void testGetAllMissingIndexes_noarg();
  47. void testGetAllMissingUnusedIndexes();
  48. void testIsAllBitSet();
  49. void testFilter();
  50. void testGetSparceMissingUnusedIndex();
  51. void testGetSparceMissingUnusedIndex_setBit();
  52. void testIsBitSetOffsetRange();
  53. void testGetMissingUnusedLength();
  54. void testSetBitRange();
  55. void testCountFilteredBlock();
  56. void testCountMissingBlock();
  57. };
  58. CPPUNIT_TEST_SUITE_REGISTRATION( BitfieldManTest );
  59. void BitfieldManTest::testGetBlockSize() {
  60. BitfieldMan bt1(1024, 1024*10);
  61. CPPUNIT_ASSERT_EQUAL((size_t)1024, bt1.getBlockLength(9));
  62. BitfieldMan bt2(1024, 1024*10+1);
  63. CPPUNIT_ASSERT_EQUAL((size_t)1024, bt2.getBlockLength(9));
  64. CPPUNIT_ASSERT_EQUAL((size_t)1, bt2.getBlockLength(10));
  65. CPPUNIT_ASSERT_EQUAL((size_t)0, bt2.getBlockLength(11));
  66. }
  67. void BitfieldManTest::testGetFirstMissingUnusedIndex()
  68. {
  69. {
  70. BitfieldMan bt1(1024, 1024*10);
  71. {
  72. size_t index;
  73. CPPUNIT_ASSERT(bt1.getFirstMissingUnusedIndex(index));
  74. CPPUNIT_ASSERT_EQUAL((size_t)0, index);
  75. }
  76. bt1.setUseBit(0);
  77. {
  78. size_t index;
  79. CPPUNIT_ASSERT(bt1.getFirstMissingUnusedIndex(index));
  80. CPPUNIT_ASSERT_EQUAL((size_t)1, index);
  81. }
  82. bt1.unsetUseBit(0);
  83. bt1.setBit(0);
  84. {
  85. size_t index;
  86. CPPUNIT_ASSERT(bt1.getFirstMissingUnusedIndex(index));
  87. CPPUNIT_ASSERT_EQUAL((size_t)1, index);
  88. }
  89. bt1.setAllBit();
  90. {
  91. size_t index;
  92. CPPUNIT_ASSERT(!bt1.getFirstMissingUnusedIndex(index));
  93. }
  94. }
  95. {
  96. BitfieldMan bt1(1024, 1024*10);
  97. bt1.addFilter(1024, 1024*10);
  98. bt1.enableFilter();
  99. {
  100. size_t index;
  101. CPPUNIT_ASSERT(bt1.getFirstMissingUnusedIndex(index));
  102. CPPUNIT_ASSERT_EQUAL((size_t)1, index);
  103. }
  104. bt1.setUseBit(1);
  105. {
  106. size_t index;
  107. CPPUNIT_ASSERT(bt1.getFirstMissingUnusedIndex(index));
  108. CPPUNIT_ASSERT_EQUAL((size_t)2, index);
  109. }
  110. bt1.setBit(2);
  111. {
  112. size_t index;
  113. CPPUNIT_ASSERT(bt1.getFirstMissingUnusedIndex(index));
  114. CPPUNIT_ASSERT_EQUAL((size_t)3, index);
  115. }
  116. }
  117. }
  118. void BitfieldManTest::testGetFirstMissingIndex()
  119. {
  120. {
  121. BitfieldMan bt1(1024, 1024*10);
  122. {
  123. size_t index;
  124. CPPUNIT_ASSERT(bt1.getFirstMissingIndex(index));
  125. CPPUNIT_ASSERT_EQUAL((size_t)0, index);
  126. }
  127. bt1.setUseBit(0);
  128. {
  129. size_t index;
  130. CPPUNIT_ASSERT(bt1.getFirstMissingIndex(index));
  131. CPPUNIT_ASSERT_EQUAL((size_t)0, index);
  132. }
  133. bt1.unsetUseBit(0);
  134. bt1.setBit(0);
  135. {
  136. size_t index;
  137. CPPUNIT_ASSERT(bt1.getFirstMissingIndex(index));
  138. CPPUNIT_ASSERT_EQUAL((size_t)1, index);
  139. }
  140. bt1.setAllBit();
  141. {
  142. size_t index;
  143. CPPUNIT_ASSERT(!bt1.getFirstMissingIndex(index));
  144. }
  145. }
  146. {
  147. BitfieldMan bt1(1024, 1024*10);
  148. bt1.addFilter(1024, 1024*10);
  149. bt1.enableFilter();
  150. {
  151. size_t index;
  152. CPPUNIT_ASSERT(bt1.getFirstMissingIndex(index));
  153. CPPUNIT_ASSERT_EQUAL((size_t)1, index);
  154. }
  155. bt1.setUseBit(1);
  156. {
  157. size_t index;
  158. CPPUNIT_ASSERT(bt1.getFirstMissingIndex(index));
  159. CPPUNIT_ASSERT_EQUAL((size_t)1, index);
  160. }
  161. bt1.setBit(1);
  162. {
  163. size_t index;
  164. CPPUNIT_ASSERT(bt1.getFirstMissingIndex(index));
  165. CPPUNIT_ASSERT_EQUAL((size_t)2, index);
  166. }
  167. }
  168. }
  169. void BitfieldManTest::testGetMissingUnusedIndex_noarg()
  170. {
  171. {
  172. BitfieldMan bt1(1024, 1024*10);
  173. bt1.setRandomizer(fixedNumberRandomizer);
  174. {
  175. size_t index;
  176. CPPUNIT_ASSERT(bt1.getMissingUnusedIndex(index));
  177. CPPUNIT_ASSERT_EQUAL((size_t)0, index);
  178. }
  179. bt1.setUseBit(0);
  180. {
  181. size_t index;
  182. CPPUNIT_ASSERT(bt1.getMissingUnusedIndex(index));
  183. CPPUNIT_ASSERT_EQUAL((size_t)1, index);
  184. }
  185. bt1.unsetUseBit(0);
  186. bt1.setBit(0);
  187. {
  188. size_t index;
  189. CPPUNIT_ASSERT(bt1.getMissingUnusedIndex(index));
  190. CPPUNIT_ASSERT_EQUAL((size_t)1, index);
  191. }
  192. bt1.setAllBit();
  193. {
  194. size_t index;
  195. CPPUNIT_ASSERT(!bt1.getMissingUnusedIndex(index));
  196. }
  197. }
  198. {
  199. BitfieldMan bt1(1024, 1024*10);
  200. bt1.setRandomizer(fixedNumberRandomizer);
  201. bt1.addFilter(1024, 1024*10);
  202. bt1.enableFilter();
  203. {
  204. size_t index;
  205. CPPUNIT_ASSERT(bt1.getMissingUnusedIndex(index));
  206. CPPUNIT_ASSERT_EQUAL((size_t)1, index);
  207. }
  208. bt1.setUseBit(1);
  209. {
  210. size_t index;
  211. CPPUNIT_ASSERT(bt1.getMissingUnusedIndex(index));
  212. CPPUNIT_ASSERT_EQUAL((size_t)2, index);
  213. }
  214. bt1.setBit(2);
  215. {
  216. size_t index;
  217. CPPUNIT_ASSERT(bt1.getMissingUnusedIndex(index));
  218. CPPUNIT_ASSERT_EQUAL((size_t)3, index);
  219. }
  220. }
  221. }
  222. void BitfieldManTest::testGetMissingIndex_noarg()
  223. {
  224. {
  225. BitfieldMan bt1(1024, 1024*10);
  226. bt1.setRandomizer(fixedNumberRandomizer);
  227. {
  228. size_t index;
  229. CPPUNIT_ASSERT(bt1.getMissingIndex(index));
  230. CPPUNIT_ASSERT_EQUAL((size_t)0, index);
  231. }
  232. bt1.setUseBit(0);
  233. {
  234. size_t index;
  235. CPPUNIT_ASSERT(bt1.getMissingIndex(index));
  236. CPPUNIT_ASSERT_EQUAL((size_t)0, index);
  237. }
  238. bt1.unsetUseBit(0);
  239. bt1.setBit(0);
  240. {
  241. size_t index;
  242. CPPUNIT_ASSERT(bt1.getMissingIndex(index));
  243. CPPUNIT_ASSERT_EQUAL((size_t)1, index);
  244. }
  245. bt1.setAllBit();
  246. {
  247. size_t index;
  248. CPPUNIT_ASSERT(!bt1.getMissingIndex(index));
  249. }
  250. }
  251. {
  252. BitfieldMan bt1(1024, 1024*10);
  253. bt1.setRandomizer(fixedNumberRandomizer);
  254. bt1.addFilter(1024, 1024*10);
  255. bt1.enableFilter();
  256. {
  257. size_t index;
  258. CPPUNIT_ASSERT(bt1.getMissingIndex(index));
  259. CPPUNIT_ASSERT_EQUAL((size_t)1, index);
  260. }
  261. bt1.setUseBit(1);
  262. {
  263. size_t index;
  264. CPPUNIT_ASSERT(bt1.getMissingIndex(index));
  265. CPPUNIT_ASSERT_EQUAL((size_t)1, index);
  266. }
  267. bt1.setBit(1);
  268. {
  269. size_t index;
  270. CPPUNIT_ASSERT(bt1.getMissingIndex(index));
  271. CPPUNIT_ASSERT_EQUAL((size_t)2, index);
  272. }
  273. }
  274. }
  275. void BitfieldManTest::testIsAllBitSet() {
  276. BitfieldMan bt1(1024, 1024*10);
  277. CPPUNIT_ASSERT(!bt1.isAllBitSet());
  278. bt1.setBit(1);
  279. CPPUNIT_ASSERT(!bt1.isAllBitSet());
  280. for(size_t i = 0; i < 8; i++) {
  281. CPPUNIT_ASSERT(bt1.setBit(i));
  282. }
  283. CPPUNIT_ASSERT(!bt1.isAllBitSet());
  284. for(size_t i = 0; i < bt1.countBlock(); i++) {
  285. CPPUNIT_ASSERT(bt1.setBit(i));
  286. }
  287. CPPUNIT_ASSERT(bt1.isAllBitSet());
  288. BitfieldMan btzero(1024, 0);
  289. CPPUNIT_ASSERT(btzero.isAllBitSet());
  290. }
  291. void BitfieldManTest::testFilter() {
  292. BitfieldMan btman(2, 32);
  293. btman.setRandomizer(fixedNumberRandomizer);
  294. // test offset=4, length=12
  295. btman.addFilter(4, 12);
  296. btman.enableFilter();
  297. unsigned char peerBt[2];
  298. memset(peerBt, 0xff, sizeof(peerBt));
  299. size_t index;
  300. CPPUNIT_ASSERT(btman.getMissingUnusedIndex(index, peerBt, sizeof(peerBt)));
  301. btman.setUseBit(index);
  302. CPPUNIT_ASSERT_EQUAL((size_t)2, index);
  303. CPPUNIT_ASSERT(btman.getMissingUnusedIndex(index, peerBt, sizeof(peerBt)));
  304. btman.setUseBit(index);
  305. CPPUNIT_ASSERT_EQUAL((size_t)3, index);
  306. CPPUNIT_ASSERT(btman.getMissingUnusedIndex(index, peerBt, sizeof(peerBt)));
  307. btman.setUseBit(index);
  308. CPPUNIT_ASSERT_EQUAL((size_t)4, index);
  309. CPPUNIT_ASSERT(btman.getMissingUnusedIndex(index, peerBt, sizeof(peerBt)));
  310. btman.setUseBit(index);
  311. CPPUNIT_ASSERT_EQUAL((size_t)5, index);
  312. CPPUNIT_ASSERT(btman.getMissingUnusedIndex(index, peerBt, sizeof(peerBt)));
  313. btman.setUseBit(index);
  314. CPPUNIT_ASSERT_EQUAL((size_t)6, index);
  315. CPPUNIT_ASSERT(btman.getMissingUnusedIndex(index, peerBt, sizeof(peerBt)));
  316. btman.setUseBit(index);
  317. CPPUNIT_ASSERT_EQUAL((size_t)7, index);
  318. CPPUNIT_ASSERT(!btman.getMissingUnusedIndex(index, peerBt, sizeof(peerBt)));
  319. CPPUNIT_ASSERT_EQUAL((uint64_t)12ULL, btman.getFilteredTotalLength());
  320. // test offset=5, length=2
  321. btman.clearAllBit();
  322. btman.clearAllUseBit();
  323. btman.clearFilter();
  324. btman.addFilter(5, 2);
  325. btman.enableFilter();
  326. CPPUNIT_ASSERT(btman.getMissingUnusedIndex(index, peerBt, sizeof(peerBt)));
  327. btman.setUseBit(index);
  328. btman.setBit(index);
  329. CPPUNIT_ASSERT_EQUAL((size_t)2, index);
  330. CPPUNIT_ASSERT(btman.getMissingUnusedIndex(index, peerBt, sizeof(peerBt)));
  331. btman.setUseBit(index);
  332. btman.setBit(index);
  333. CPPUNIT_ASSERT_EQUAL((size_t)3, index);
  334. CPPUNIT_ASSERT(!btman.getMissingUnusedIndex(index, peerBt, sizeof(peerBt)));
  335. CPPUNIT_ASSERT_EQUAL((uint64_t)4ULL, btman.getFilteredTotalLength());
  336. CPPUNIT_ASSERT(btman.isFilteredAllBitSet());
  337. BitfieldMan btman2(2, 31);
  338. btman2.addFilter(0, 31);
  339. btman2.enableFilter();
  340. CPPUNIT_ASSERT_EQUAL((uint64_t)31ULL, btman2.getFilteredTotalLength());
  341. }
  342. void BitfieldManTest::testGetMissingIndex() {
  343. BitfieldMan bt1(1024, 1024*256);
  344. bt1.setRandomizer(fixedNumberRandomizer);
  345. unsigned char bitArray[] = {
  346. 0xff, 0xff, 0xff, 0xff,
  347. 0xff, 0xff, 0xff, 0xff,
  348. 0xff, 0xff, 0xff, 0xff,
  349. 0xff, 0xff, 0xff, 0xff,
  350. 0xff, 0xff, 0xff, 0xff,
  351. 0xff, 0xff, 0xff, 0xff,
  352. 0xff, 0xff, 0xff, 0xff,
  353. 0xff, 0xff, 0xff, 0xff,
  354. };
  355. size_t index;
  356. CPPUNIT_ASSERT(bt1.getMissingIndex(index, bitArray, 32));
  357. CPPUNIT_ASSERT_EQUAL((size_t)0, index);
  358. bt1.addFilter(1024, 1024*256);
  359. bt1.enableFilter();
  360. CPPUNIT_ASSERT(bt1.getMissingIndex(index, bitArray, 32));
  361. CPPUNIT_ASSERT_EQUAL((size_t)1, index);
  362. bt1.disableFilter();
  363. unsigned char bitArray2[] = {
  364. 0x0f, 0xff, 0xff, 0xff,
  365. 0xff, 0xff, 0xff, 0xff,
  366. 0xff, 0xff, 0xff, 0xff,
  367. 0xff, 0xff, 0xff, 0xff,
  368. 0xff, 0xff, 0xff, 0xff,
  369. 0xff, 0xff, 0xff, 0xff,
  370. 0xff, 0xff, 0xff, 0xff,
  371. 0xff, 0xff, 0xff, 0xff,
  372. };
  373. CPPUNIT_ASSERT(bt1.getMissingIndex(index, bitArray2, 32));
  374. CPPUNIT_ASSERT_EQUAL((size_t)4, index);
  375. unsigned char bitArray3[] = {
  376. 0x00, 0xff, 0xff, 0xff,
  377. 0xff, 0xff, 0xff, 0xff,
  378. 0xff, 0xff, 0xff, 0xff,
  379. 0xff, 0xff, 0xff, 0xff,
  380. 0xff, 0xff, 0xff, 0xff,
  381. 0xff, 0xff, 0xff, 0xff,
  382. 0xff, 0xff, 0xff, 0xff,
  383. 0xff, 0xff, 0xff, 0xff,
  384. };
  385. CPPUNIT_ASSERT(bt1.getMissingIndex(index, bitArray3, 32));
  386. CPPUNIT_ASSERT_EQUAL((size_t)8, index);
  387. unsigned char bitArray4[] = {
  388. 0x00, 0x00, 0x00, 0x00,
  389. 0x00, 0x00, 0x00, 0x00,
  390. 0x00, 0x00, 0x00, 0x00,
  391. 0x00, 0x00, 0x00, 0x00,
  392. 0x00, 0x00, 0x00, 0x00,
  393. 0x00, 0x00, 0x00, 0x00,
  394. 0x00, 0x00, 0x00, 0x00,
  395. 0x00, 0x00, 0x00, 0x00,
  396. };
  397. CPPUNIT_ASSERT(!bt1.getMissingIndex(index, bitArray4, 32));
  398. }
  399. void BitfieldManTest::testGetSparceMissingUnusedIndex() {
  400. BitfieldMan bitfield(1024*1024, 10*1024*1024);
  401. size_t index;
  402. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  403. CPPUNIT_ASSERT_EQUAL((size_t)0, index);
  404. bitfield.setUseBit(0);
  405. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  406. CPPUNIT_ASSERT_EQUAL((size_t)5, index);
  407. bitfield.setUseBit(5);
  408. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  409. CPPUNIT_ASSERT_EQUAL((size_t)3, index);
  410. bitfield.setUseBit(3);
  411. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  412. CPPUNIT_ASSERT_EQUAL((size_t)8, index);
  413. bitfield.setUseBit(8);
  414. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  415. CPPUNIT_ASSERT_EQUAL((size_t)2, index);
  416. bitfield.setUseBit(2);
  417. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  418. CPPUNIT_ASSERT_EQUAL((size_t)7, index);
  419. bitfield.setUseBit(7);
  420. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  421. CPPUNIT_ASSERT_EQUAL((size_t)1, index);
  422. bitfield.setUseBit(1);
  423. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  424. CPPUNIT_ASSERT_EQUAL((size_t)4, index);
  425. bitfield.setUseBit(4);
  426. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  427. CPPUNIT_ASSERT_EQUAL((size_t)6, index);
  428. bitfield.setUseBit(6);
  429. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  430. CPPUNIT_ASSERT_EQUAL((size_t)9, index);
  431. bitfield.setUseBit(9);
  432. CPPUNIT_ASSERT(!bitfield.getSparseMissingUnusedIndex(index));
  433. }
  434. void BitfieldManTest::testGetSparceMissingUnusedIndex_setBit() {
  435. BitfieldMan bitfield(1024*1024, 10*1024*1024);
  436. size_t index;
  437. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  438. CPPUNIT_ASSERT_EQUAL((size_t)0, index);
  439. bitfield.setBit(0);
  440. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  441. CPPUNIT_ASSERT_EQUAL((size_t)1, index);
  442. bitfield.setBit(1);
  443. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  444. CPPUNIT_ASSERT_EQUAL((size_t)2, index);
  445. bitfield.setBit(2);
  446. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  447. CPPUNIT_ASSERT_EQUAL((size_t)3, index);
  448. bitfield.setBit(3);
  449. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  450. CPPUNIT_ASSERT_EQUAL((size_t)4, index);
  451. bitfield.setBit(4);
  452. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  453. CPPUNIT_ASSERT_EQUAL((size_t)5, index);
  454. bitfield.setBit(5);
  455. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  456. CPPUNIT_ASSERT_EQUAL((size_t)6, index);
  457. bitfield.setBit(6);
  458. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  459. CPPUNIT_ASSERT_EQUAL((size_t)7, index);
  460. bitfield.setBit(7);
  461. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  462. CPPUNIT_ASSERT_EQUAL((size_t)8, index);
  463. bitfield.setBit(8);
  464. CPPUNIT_ASSERT(bitfield.getSparseMissingUnusedIndex(index));
  465. CPPUNIT_ASSERT_EQUAL((size_t)9, index);
  466. bitfield.setBit(9);
  467. CPPUNIT_ASSERT(!bitfield.getSparseMissingUnusedIndex(index));
  468. }
  469. void BitfieldManTest::testIsBitSetOffsetRange()
  470. {
  471. int64_t totalLength = 4ULL*1024*1024*1024;
  472. int32_t pieceLength = 4*1024*1024;
  473. BitfieldMan bitfield(pieceLength, totalLength);
  474. bitfield.setAllBit();
  475. CPPUNIT_ASSERT(!bitfield.isBitSetOffsetRange(0, 0));
  476. CPPUNIT_ASSERT(!bitfield.isBitSetOffsetRange(totalLength, 100));
  477. CPPUNIT_ASSERT(!bitfield.isBitSetOffsetRange(totalLength+1, 100));
  478. CPPUNIT_ASSERT(bitfield.isBitSetOffsetRange(0, totalLength));
  479. CPPUNIT_ASSERT(bitfield.isBitSetOffsetRange(0, totalLength+1));
  480. bitfield.clearAllBit();
  481. bitfield.setBit(100);
  482. bitfield.setBit(101);
  483. CPPUNIT_ASSERT(bitfield.isBitSetOffsetRange(pieceLength*100, pieceLength*2));
  484. CPPUNIT_ASSERT(!bitfield.isBitSetOffsetRange(pieceLength*100-10, pieceLength*2));
  485. CPPUNIT_ASSERT(!bitfield.isBitSetOffsetRange(pieceLength*100, pieceLength*2+1));
  486. bitfield.clearAllBit();
  487. bitfield.setBit(100);
  488. bitfield.setBit(102);
  489. CPPUNIT_ASSERT(!bitfield.isBitSetOffsetRange(pieceLength*100, pieceLength*3));
  490. }
  491. void BitfieldManTest::testGetMissingUnusedLength()
  492. {
  493. uint64_t totalLength = 1024*10+10;
  494. size_t blockLength = 1024;
  495. BitfieldMan bf(blockLength, totalLength);
  496. // from index 0 and all blocks are unused and not acquired.
  497. CPPUNIT_ASSERT_EQUAL(totalLength, bf.getMissingUnusedLength(0));
  498. // from index 10 and all blocks are unused and not acquired.
  499. CPPUNIT_ASSERT_EQUAL((uint64_t)10ULL, bf.getMissingUnusedLength(10));
  500. // from index -1
  501. CPPUNIT_ASSERT_EQUAL((uint64_t)0ULL, bf.getMissingUnusedLength(-1));
  502. // from index 11
  503. CPPUNIT_ASSERT_EQUAL((uint64_t)0ULL, bf.getMissingUnusedLength(11));
  504. // from index 12
  505. CPPUNIT_ASSERT_EQUAL((uint64_t)0ULL, bf.getMissingUnusedLength(12));
  506. // from index 0 and 5th block is used.
  507. bf.setUseBit(5);
  508. CPPUNIT_ASSERT_EQUAL((uint64_t)5ULL*blockLength, bf.getMissingUnusedLength(0));
  509. // from index 0 and 4th block is acquired.
  510. bf.setBit(4);
  511. CPPUNIT_ASSERT_EQUAL((uint64_t)4ULL*blockLength, bf.getMissingUnusedLength(0));
  512. // from index 1
  513. CPPUNIT_ASSERT_EQUAL((uint64_t)3ULL*blockLength, bf.getMissingUnusedLength(1));
  514. }
  515. void BitfieldManTest::testSetBitRange()
  516. {
  517. size_t blockLength = 1024*1024;
  518. uint64_t totalLength = 10*blockLength;
  519. BitfieldMan bf(blockLength, totalLength);
  520. bf.setBitRange(0, 4);
  521. for(size_t i = 0; i < 5; ++i) {
  522. CPPUNIT_ASSERT(bf.isBitSet(i));
  523. }
  524. for(size_t i = 5; i < 10; ++i) {
  525. CPPUNIT_ASSERT(!bf.isBitSet(i));
  526. }
  527. CPPUNIT_ASSERT_EQUAL((uint64_t)5ULL*blockLength, bf.getCompletedLength());
  528. }
  529. void BitfieldManTest::testGetAllMissingIndexes_noarg()
  530. {
  531. size_t blockLength = 16*1024;
  532. uint64_t totalLength = 1024*1024;
  533. BitfieldMan bf(blockLength, totalLength);
  534. {
  535. std::deque<size_t> indexes;
  536. CPPUNIT_ASSERT(bf.getAllMissingIndexes(indexes));
  537. CPPUNIT_ASSERT_EQUAL((size_t)64, indexes.size());
  538. }
  539. for(size_t i = 0; i < 63; ++i) {
  540. bf.setBit(i);
  541. }
  542. {
  543. std::deque<size_t> indexes;
  544. CPPUNIT_ASSERT(bf.getAllMissingIndexes(indexes));
  545. CPPUNIT_ASSERT_EQUAL((size_t)1, indexes.size());
  546. CPPUNIT_ASSERT_EQUAL((size_t)63, indexes.front());
  547. }
  548. }
  549. void BitfieldManTest::testGetAllMissingIndexes()
  550. {
  551. size_t blockLength = 16*1024;
  552. uint64_t totalLength = 1024*1024;
  553. BitfieldMan bf(blockLength, totalLength);
  554. BitfieldMan peerBf(blockLength, totalLength);
  555. peerBf.setAllBit();
  556. {
  557. std::deque<size_t> indexes;
  558. CPPUNIT_ASSERT(bf.getAllMissingIndexes(indexes,
  559. peerBf.getBitfield(),
  560. peerBf.getBitfieldLength()));
  561. CPPUNIT_ASSERT_EQUAL((size_t)64, indexes.size());
  562. }
  563. for(size_t i = 0; i < 62; ++i) {
  564. bf.setBit(i);
  565. }
  566. peerBf.unsetBit(62);
  567. {
  568. std::deque<size_t> indexes;
  569. CPPUNIT_ASSERT(bf.getAllMissingIndexes(indexes,
  570. peerBf.getBitfield(),
  571. peerBf.getBitfieldLength()));
  572. CPPUNIT_ASSERT_EQUAL((size_t)1, indexes.size());
  573. CPPUNIT_ASSERT_EQUAL((size_t)63, indexes.front());
  574. }
  575. }
  576. void BitfieldManTest::testGetAllMissingUnusedIndexes()
  577. {
  578. size_t blockLength = 16*1024;
  579. uint64_t totalLength = 1024*1024;
  580. BitfieldMan bf(blockLength, totalLength);
  581. BitfieldMan peerBf(blockLength, totalLength);
  582. peerBf.setAllBit();
  583. {
  584. std::deque<size_t> indexes;
  585. CPPUNIT_ASSERT(bf.getAllMissingUnusedIndexes(indexes,
  586. peerBf.getBitfield(),
  587. peerBf.getBitfieldLength()));
  588. CPPUNIT_ASSERT_EQUAL((size_t)64, indexes.size());
  589. }
  590. for(size_t i = 0; i < 61; ++i) {
  591. bf.setBit(i);
  592. }
  593. bf.setUseBit(61);
  594. peerBf.unsetBit(62);
  595. {
  596. std::deque<size_t> indexes;
  597. CPPUNIT_ASSERT(bf.getAllMissingUnusedIndexes(indexes,
  598. peerBf.getBitfield(),
  599. peerBf.getBitfieldLength()));
  600. CPPUNIT_ASSERT_EQUAL((size_t)1, indexes.size());
  601. CPPUNIT_ASSERT_EQUAL((size_t)63, indexes.front());
  602. }
  603. }
  604. void BitfieldManTest::testGetMissingUnusedIndex()
  605. {
  606. BitfieldMan bt1(1024, 1024*256);
  607. bt1.setRandomizer(fixedNumberRandomizer);
  608. size_t index;
  609. {
  610. unsigned char bitArray[] = {
  611. 0xff, 0xff, 0xff, 0xff,
  612. 0xff, 0xff, 0xff, 0xff,
  613. 0xff, 0xff, 0xff, 0xff,
  614. 0xff, 0xff, 0xff, 0xff,
  615. 0xff, 0xff, 0xff, 0xff,
  616. 0xff, 0xff, 0xff, 0xff,
  617. 0xff, 0xff, 0xff, 0xff,
  618. 0xff, 0xff, 0xff, 0xff,
  619. };
  620. CPPUNIT_ASSERT(bt1.getMissingUnusedIndex(index, bitArray, 32));
  621. CPPUNIT_ASSERT_EQUAL((size_t)0, index);
  622. bt1.addFilter(1024, 1024*256);
  623. bt1.enableFilter();
  624. CPPUNIT_ASSERT(bt1.getMissingUnusedIndex(index, bitArray, 32));
  625. CPPUNIT_ASSERT_EQUAL((size_t)1, index);
  626. bt1.setUseBit(1);
  627. CPPUNIT_ASSERT(bt1.getMissingUnusedIndex(index, bitArray, 32));
  628. CPPUNIT_ASSERT_EQUAL((size_t)2, index);
  629. bt1.disableFilter();
  630. bt1.setBit(0);
  631. CPPUNIT_ASSERT(bt1.getMissingUnusedIndex(index, bitArray, 32));
  632. CPPUNIT_ASSERT_EQUAL((size_t)2, index);
  633. bt1.setAllBit();
  634. CPPUNIT_ASSERT(!bt1.getMissingUnusedIndex(index, bitArray, 32));
  635. bt1.clearAllBit();
  636. bt1.setAllUseBit();
  637. CPPUNIT_ASSERT(!bt1.getMissingUnusedIndex(index, bitArray, 32));
  638. }
  639. {
  640. unsigned char bitArray4[] = {
  641. 0x00, 0x00, 0x00, 0x00,
  642. 0x00, 0x00, 0x00, 0x00,
  643. 0x00, 0x00, 0x00, 0x00,
  644. 0x00, 0x00, 0x00, 0x00,
  645. 0x00, 0x00, 0x00, 0x00,
  646. 0x00, 0x00, 0x00, 0x00,
  647. 0x00, 0x00, 0x00, 0x00,
  648. 0x00, 0x00, 0x00, 0x00,
  649. };
  650. CPPUNIT_ASSERT(!bt1.getMissingUnusedIndex(index, bitArray4, 32));
  651. }
  652. }
  653. void BitfieldManTest::testCountFilteredBlock()
  654. {
  655. BitfieldMan bt(1024, 1024*256);
  656. CPPUNIT_ASSERT_EQUAL((size_t)256, bt.countBlock());
  657. CPPUNIT_ASSERT_EQUAL((size_t)0, bt.countFilteredBlock());
  658. bt.addFilter(1024, 1024*256);
  659. bt.enableFilter();
  660. CPPUNIT_ASSERT_EQUAL((size_t)256, bt.countBlock());
  661. CPPUNIT_ASSERT_EQUAL((size_t)255, bt.countFilteredBlock());
  662. bt.disableFilter();
  663. CPPUNIT_ASSERT_EQUAL((size_t)256, bt.countBlock());
  664. CPPUNIT_ASSERT_EQUAL((size_t)0, bt.countFilteredBlock());
  665. }
  666. void BitfieldManTest::testCountMissingBlock()
  667. {
  668. BitfieldMan bt(1024, 1024*10);
  669. CPPUNIT_ASSERT_EQUAL((size_t)10, bt.countMissingBlock());
  670. bt.setBit(1);
  671. CPPUNIT_ASSERT_EQUAL((size_t)9, bt.countMissingBlock());
  672. bt.setAllBit();
  673. CPPUNIT_ASSERT_EQUAL((size_t)0, bt.countMissingBlock());
  674. }
  675. } // namespace aria2