DefaultBtProgressInfoFileTest.cc 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580
  1. #include "DefaultBtProgressInfoFile.h"
  2. #include <fstream>
  3. #include <cppunit/extensions/HelperMacros.h>
  4. #include "Option.h"
  5. #include "util.h"
  6. #include "Exception.h"
  7. #include "MockPieceStorage.h"
  8. #include "prefs.h"
  9. #include "DownloadContext.h"
  10. #include "Piece.h"
  11. #include "FileEntry.h"
  12. #include "array_fun.h"
  13. #ifdef ENABLE_BITTORRENT
  14. # include "MockPeerStorage.h"
  15. # include "BtRuntime.h"
  16. # include "bittorrent_helper.h"
  17. #endif // ENABLE_BITTORRENT
  18. namespace aria2 {
  19. class DefaultBtProgressInfoFileTest:public CppUnit::TestFixture {
  20. CPPUNIT_TEST_SUITE(DefaultBtProgressInfoFileTest);
  21. #ifdef ENABLE_BITTORRENT
  22. CPPUNIT_TEST(testSave);
  23. CPPUNIT_TEST(testLoad);
  24. #ifndef WORDS_BIGENDIAN
  25. CPPUNIT_TEST(testLoad_compat);
  26. #endif // !WORDS_BIGENDIAN
  27. #endif // ENABLE_BITTORRENT
  28. CPPUNIT_TEST(testSave_nonBt);
  29. CPPUNIT_TEST(testLoad_nonBt);
  30. #ifndef WORDS_BIGENDIAN
  31. CPPUNIT_TEST(testLoad_nonBt_compat);
  32. #endif // !WORDS_BIGENDIAN
  33. CPPUNIT_TEST(testLoad_nonBt_pieceLengthShorter);
  34. CPPUNIT_TEST(testUpdateFilename);
  35. CPPUNIT_TEST_SUITE_END();
  36. private:
  37. #ifdef ENABLE_BITTORRENT
  38. std::shared_ptr<DownloadContext> dctx_;
  39. std::shared_ptr<MockPeerStorage> peerStorage_;
  40. std::shared_ptr<BtRuntime> btRuntime_;
  41. #endif // ENABLE_BITTORRENT
  42. std::shared_ptr<MockPieceStorage> pieceStorage_;
  43. std::shared_ptr<Option> option_;
  44. std::shared_ptr<BitfieldMan> bitfield_;
  45. public:
  46. void initializeMembers(int32_t pieceLength, int64_t totalLength)
  47. {
  48. option_.reset(new Option());
  49. option_->put(PREF_DIR, A2_TEST_OUT_DIR);
  50. bitfield_.reset(new BitfieldMan(pieceLength, totalLength));
  51. pieceStorage_.reset(new MockPieceStorage());
  52. pieceStorage_->setBitfield(bitfield_.get());
  53. #ifdef ENABLE_BITTORRENT
  54. static unsigned char infoHash[] = {
  55. 0x11, 0x22, 0x33, 0x44, 0x55, 0x66, 0x77, 0x88, 0x99, 0xaa,
  56. 0xbb, 0xcc, 0xdd, 0xee, 0xff, 0x00, 0xff, 0xff, 0xff, 0xff,
  57. };
  58. dctx_.reset(new DownloadContext());
  59. {
  60. auto torrentAttrs = make_unique<TorrentAttribute>();
  61. torrentAttrs->infoHash.assign(std::begin(infoHash), std::end(infoHash));
  62. dctx_->setAttribute(CTX_ATTR_BT, std::move(torrentAttrs));
  63. }
  64. const std::shared_ptr<FileEntry> fileEntries[] = {
  65. std::shared_ptr<FileEntry>(new FileEntry("/path/to/file",totalLength,0))
  66. };
  67. dctx_->setFileEntries(std::begin(fileEntries), std::end(fileEntries));
  68. dctx_->setPieceLength(pieceLength);
  69. peerStorage_.reset(new MockPeerStorage());
  70. btRuntime_.reset(new BtRuntime());
  71. #endif // ENABLE_BITTORRENT
  72. }
  73. #ifdef ENABLE_BITTORRENT
  74. void testSave();
  75. void testLoad();
  76. #ifndef WORDS_BIGENDIAN
  77. void testLoad_compat();
  78. #endif // !WORDS_BIGENDIAN
  79. #endif // ENABLE_BITTORRENT
  80. void testSave_nonBt();
  81. void testLoad_nonBt();
  82. #ifndef WORDS_BIGENDIAN
  83. void testLoad_nonBt_compat();
  84. #endif // !WORDS_BIGENDIAN
  85. void testLoad_nonBt_pieceLengthShorter();
  86. void testUpdateFilename();
  87. };
  88. #undef BLOCK_LENGTH
  89. #define BLOCK_LENGTH 256
  90. CPPUNIT_TEST_SUITE_REGISTRATION(DefaultBtProgressInfoFileTest);
  91. #ifdef ENABLE_BITTORRENT
  92. // Because load.aria2 is made for little endian systems, exclude
  93. // testLoad_compat() for big endian systems.
  94. #ifndef WORDS_BIGENDIAN
  95. void DefaultBtProgressInfoFileTest::testLoad_compat()
  96. {
  97. initializeMembers(1024, 81920);
  98. dctx_->setBasePath(A2_TEST_DIR"/load");
  99. DefaultBtProgressInfoFile infoFile(dctx_, pieceStorage_, option_.get());
  100. infoFile.setBtRuntime(btRuntime_);
  101. infoFile.setPeerStorage(peerStorage_);
  102. CPPUNIT_ASSERT_EQUAL(std::string(A2_TEST_DIR"/load.aria2"),
  103. infoFile.getFilename());
  104. infoFile.load();
  105. // check the contents of objects
  106. // total length
  107. CPPUNIT_ASSERT_EQUAL((int64_t)81920, dctx_->getTotalLength());
  108. // upload length
  109. CPPUNIT_ASSERT_EQUAL((int64_t)1024, btRuntime_->getUploadLengthAtStartup());
  110. // bitfield
  111. CPPUNIT_ASSERT_EQUAL(std::string("fffffffffffffffffffe"),
  112. util::toHex(bitfield_->getBitfield(),
  113. bitfield_->getBitfieldLength()));
  114. // the number of in-flight pieces
  115. CPPUNIT_ASSERT_EQUAL((size_t)2,
  116. pieceStorage_->countInFlightPiece());
  117. // piece index 1
  118. std::vector<std::shared_ptr<Piece> > inFlightPieces;
  119. pieceStorage_->getInFlightPieces(inFlightPieces);
  120. std::shared_ptr<Piece> piece1 = inFlightPieces[0];
  121. CPPUNIT_ASSERT_EQUAL((size_t)1, piece1->getIndex());
  122. CPPUNIT_ASSERT_EQUAL(1024, piece1->getLength());
  123. CPPUNIT_ASSERT_EQUAL((size_t)1, piece1->getBitfieldLength());
  124. CPPUNIT_ASSERT_EQUAL(std::string("00"), util::toHex(piece1->getBitfield(),
  125. piece1->getBitfieldLength()));
  126. // piece index 2
  127. std::shared_ptr<Piece> piece2 = inFlightPieces[1];
  128. CPPUNIT_ASSERT_EQUAL((size_t)2, piece2->getIndex());
  129. CPPUNIT_ASSERT_EQUAL(512, piece2->getLength());
  130. }
  131. #endif // !WORDS_BIGENDIAN
  132. void DefaultBtProgressInfoFileTest::testLoad()
  133. {
  134. initializeMembers(1024, 81920);
  135. dctx_->setBasePath(A2_TEST_DIR"/load-v0001");
  136. DefaultBtProgressInfoFile infoFile(dctx_, pieceStorage_, option_.get());
  137. CPPUNIT_ASSERT_EQUAL(std::string(A2_TEST_DIR"/load-v0001.aria2"),
  138. infoFile.getFilename());
  139. infoFile.setBtRuntime(btRuntime_);
  140. infoFile.setPeerStorage(peerStorage_);
  141. infoFile.load();
  142. // check the contents of objects
  143. // total length
  144. CPPUNIT_ASSERT_EQUAL((int64_t)81920, dctx_->getTotalLength());
  145. // upload length
  146. CPPUNIT_ASSERT_EQUAL((int64_t)1024, btRuntime_->getUploadLengthAtStartup());
  147. // bitfield
  148. CPPUNIT_ASSERT_EQUAL(std::string("fffffffffffffffffffe"),
  149. util::toHex(bitfield_->getBitfield(),
  150. bitfield_->getBitfieldLength()));
  151. // the number of in-flight pieces
  152. CPPUNIT_ASSERT_EQUAL((size_t)2,
  153. pieceStorage_->countInFlightPiece());
  154. // piece index 1
  155. std::vector<std::shared_ptr<Piece> > inFlightPieces;
  156. pieceStorage_->getInFlightPieces(inFlightPieces);
  157. std::shared_ptr<Piece> piece1 = inFlightPieces[0];
  158. CPPUNIT_ASSERT_EQUAL((size_t)1, piece1->getIndex());
  159. CPPUNIT_ASSERT_EQUAL(1024, piece1->getLength());
  160. CPPUNIT_ASSERT_EQUAL((size_t)1, piece1->getBitfieldLength());
  161. CPPUNIT_ASSERT_EQUAL(std::string("00"), util::toHex(piece1->getBitfield(),
  162. piece1->getBitfieldLength()));
  163. // piece index 2
  164. std::shared_ptr<Piece> piece2 = inFlightPieces[1];
  165. CPPUNIT_ASSERT_EQUAL((size_t)2, piece2->getIndex());
  166. CPPUNIT_ASSERT_EQUAL(512, piece2->getLength());
  167. }
  168. void DefaultBtProgressInfoFileTest::testSave()
  169. {
  170. initializeMembers(1024, 81920);
  171. dctx_->setBasePath(A2_TEST_OUT_DIR"/save-temp");
  172. dctx_->getNetStat().updateUploadLength(768);
  173. btRuntime_->setUploadLengthAtStartup(256);
  174. bitfield_->setAllBit();
  175. bitfield_->unsetBit(79);
  176. pieceStorage_->setCompletedLength(80896);
  177. std::shared_ptr<Piece> p1(new Piece(1, 1024));
  178. std::shared_ptr<Piece> p2(new Piece(2, 512));
  179. std::vector<std::shared_ptr<Piece> > inFlightPieces;
  180. inFlightPieces.push_back(p1);
  181. inFlightPieces.push_back(p2);
  182. pieceStorage_->addInFlightPiece(inFlightPieces);
  183. DefaultBtProgressInfoFile infoFile(dctx_, pieceStorage_, option_.get());
  184. infoFile.setBtRuntime(btRuntime_);
  185. infoFile.setPeerStorage(peerStorage_);
  186. CPPUNIT_ASSERT_EQUAL(std::string(A2_TEST_OUT_DIR"/save-temp.aria2"),
  187. infoFile.getFilename());
  188. infoFile.save();
  189. // read and validate
  190. std::ifstream in(infoFile.getFilename().c_str(), std::ios::binary);
  191. //in.exceptions(ios::failbit);
  192. unsigned char version[2];
  193. in.read((char*)version, sizeof(version));
  194. CPPUNIT_ASSERT_EQUAL(std::string("0001"),
  195. util::toHex(version, sizeof(version)));
  196. unsigned char extension[4];
  197. in.read((char*)extension, sizeof(extension));
  198. CPPUNIT_ASSERT_EQUAL(std::string("00000001"),
  199. util::toHex(extension, sizeof(extension)));
  200. uint32_t infoHashLength;
  201. in.read(reinterpret_cast<char*>(&infoHashLength), sizeof(infoHashLength));
  202. infoHashLength = ntohl(infoHashLength);
  203. CPPUNIT_ASSERT_EQUAL((uint32_t)20, infoHashLength);
  204. unsigned char infoHashRead[20];
  205. in.read((char*)infoHashRead, sizeof(infoHashRead));
  206. CPPUNIT_ASSERT_EQUAL(std::string("112233445566778899aabbccddeeff00ffffffff"),
  207. util::toHex(infoHashRead, sizeof(infoHashRead)));
  208. uint32_t pieceLength;
  209. in.read((char*)&pieceLength, sizeof(pieceLength));
  210. pieceLength = ntohl(pieceLength);
  211. CPPUNIT_ASSERT_EQUAL((uint32_t)1024, pieceLength);
  212. uint64_t totalLength;
  213. in.read((char*)&totalLength, sizeof(totalLength));
  214. totalLength = ntoh64(totalLength);
  215. CPPUNIT_ASSERT_EQUAL((uint64_t)81920/* 80*1024 */, totalLength);
  216. uint64_t uploadLength;
  217. in.read((char*)&uploadLength, sizeof(uploadLength));
  218. uploadLength = ntoh64(uploadLength);
  219. CPPUNIT_ASSERT_EQUAL((uint64_t)1024, uploadLength);
  220. uint32_t bitfieldLength;
  221. in.read((char*)&bitfieldLength, sizeof(bitfieldLength));
  222. bitfieldLength = ntohl(bitfieldLength);
  223. CPPUNIT_ASSERT_EQUAL((uint32_t)10, bitfieldLength);
  224. unsigned char bitfieldRead[10];
  225. in.read((char*)bitfieldRead, sizeof(bitfieldRead));
  226. CPPUNIT_ASSERT_EQUAL(std::string("fffffffffffffffffffe"),
  227. util::toHex(bitfieldRead, sizeof(bitfieldRead)));
  228. uint32_t numInFlightPiece;
  229. in.read((char*)&numInFlightPiece, sizeof(numInFlightPiece));
  230. numInFlightPiece = ntohl(numInFlightPiece);
  231. CPPUNIT_ASSERT_EQUAL((uint32_t)2, numInFlightPiece);
  232. // piece index 1
  233. uint32_t index1;
  234. in.read((char*)&index1, sizeof(index1));
  235. index1 = ntohl(index1);
  236. CPPUNIT_ASSERT_EQUAL((uint32_t)1, index1);
  237. uint32_t pieceLength1;
  238. in.read((char*)&pieceLength1, sizeof(pieceLength1));
  239. pieceLength1 = ntohl(pieceLength1);
  240. CPPUNIT_ASSERT_EQUAL((uint32_t)1024, pieceLength1);
  241. uint32_t pieceBitfieldLength1;
  242. in.read((char*)&pieceBitfieldLength1, sizeof(pieceBitfieldLength1));
  243. pieceBitfieldLength1 = ntohl(pieceBitfieldLength1);
  244. CPPUNIT_ASSERT_EQUAL((uint32_t)1, pieceBitfieldLength1);
  245. unsigned char pieceBitfield1[1];
  246. in.read((char*)pieceBitfield1, sizeof(pieceBitfield1));
  247. CPPUNIT_ASSERT_EQUAL(std::string("00"),
  248. util::toHex(pieceBitfield1, sizeof(pieceBitfield1)));
  249. // piece index 2
  250. uint32_t index2;
  251. in.read((char*)&index2, sizeof(index2));
  252. index2 = ntohl(index2);
  253. CPPUNIT_ASSERT_EQUAL((uint32_t)2, index2);
  254. uint32_t pieceLength2;
  255. in.read((char*)&pieceLength2, sizeof(pieceLength2));
  256. pieceLength2 = ntohl(pieceLength2);
  257. CPPUNIT_ASSERT_EQUAL((uint32_t)512, pieceLength2);
  258. }
  259. #endif // ENABLE_BITTORRENT
  260. // Because load-nonBt.aria2 is made for little endian systems, exclude
  261. // testLoad_nonBt_compat() for big endian systems.
  262. #ifndef WORDS_BIGENDIAN
  263. void DefaultBtProgressInfoFileTest::testLoad_nonBt_compat()
  264. {
  265. initializeMembers(1024, 81920);
  266. std::shared_ptr<DownloadContext> dctx
  267. (new DownloadContext(1024, 81920, A2_TEST_DIR"/load-nonBt"));
  268. DefaultBtProgressInfoFile infoFile(dctx, pieceStorage_, option_.get());
  269. CPPUNIT_ASSERT_EQUAL(std::string(A2_TEST_DIR"/load-nonBt.aria2"),
  270. infoFile.getFilename());
  271. infoFile.load();
  272. // check the contents of objects
  273. // total length
  274. CPPUNIT_ASSERT_EQUAL((int64_t)81920, dctx->getTotalLength());
  275. // bitfield
  276. CPPUNIT_ASSERT_EQUAL(std::string("fffffffffffffffffffe"),
  277. util::toHex(bitfield_->getBitfield(),
  278. bitfield_->getBitfieldLength()));
  279. // the number of in-flight pieces
  280. CPPUNIT_ASSERT_EQUAL((size_t)2,
  281. pieceStorage_->countInFlightPiece());
  282. // piece index 1
  283. std::vector<std::shared_ptr<Piece> > inFlightPieces;
  284. pieceStorage_->getInFlightPieces(inFlightPieces);
  285. std::shared_ptr<Piece> piece1 = inFlightPieces[0];
  286. CPPUNIT_ASSERT_EQUAL((size_t)1, piece1->getIndex());
  287. CPPUNIT_ASSERT_EQUAL(1024, piece1->getLength());
  288. CPPUNIT_ASSERT_EQUAL((size_t)1, piece1->getBitfieldLength());
  289. CPPUNIT_ASSERT_EQUAL(std::string("00"), util::toHex(piece1->getBitfield(),
  290. piece1->getBitfieldLength()));
  291. // piece index 2
  292. std::shared_ptr<Piece> piece2 = inFlightPieces[1];
  293. CPPUNIT_ASSERT_EQUAL((size_t)2, piece2->getIndex());
  294. CPPUNIT_ASSERT_EQUAL(512, piece2->getLength());
  295. }
  296. #endif // !WORDS_BIGENDIAN
  297. void DefaultBtProgressInfoFileTest::testLoad_nonBt()
  298. {
  299. initializeMembers(1024, 81920);
  300. std::shared_ptr<DownloadContext> dctx
  301. (new DownloadContext(1024, 81920, A2_TEST_DIR"/load-nonBt-v0001"));
  302. DefaultBtProgressInfoFile infoFile(dctx, pieceStorage_, option_.get());
  303. CPPUNIT_ASSERT_EQUAL(std::string(A2_TEST_DIR"/load-nonBt-v0001.aria2"),
  304. infoFile.getFilename());
  305. infoFile.load();
  306. // check the contents of objects
  307. // total length
  308. CPPUNIT_ASSERT_EQUAL((int64_t)81920, dctx->getTotalLength());
  309. // bitfield
  310. CPPUNIT_ASSERT_EQUAL(std::string("fffffffffffffffffffe"),
  311. util::toHex(bitfield_->getBitfield(),
  312. bitfield_->getBitfieldLength()));
  313. // the number of in-flight pieces
  314. CPPUNIT_ASSERT_EQUAL((size_t)2,
  315. pieceStorage_->countInFlightPiece());
  316. // piece index 1
  317. std::vector<std::shared_ptr<Piece> > inFlightPieces;
  318. pieceStorage_->getInFlightPieces(inFlightPieces);
  319. std::shared_ptr<Piece> piece1 = inFlightPieces[0];
  320. CPPUNIT_ASSERT_EQUAL((size_t)1, piece1->getIndex());
  321. CPPUNIT_ASSERT_EQUAL(1024, piece1->getLength());
  322. CPPUNIT_ASSERT_EQUAL((size_t)1, piece1->getBitfieldLength());
  323. CPPUNIT_ASSERT_EQUAL(std::string("00"), util::toHex(piece1->getBitfield(),
  324. piece1->getBitfieldLength()));
  325. // piece index 2
  326. std::shared_ptr<Piece> piece2 = inFlightPieces[1];
  327. CPPUNIT_ASSERT_EQUAL((size_t)2, piece2->getIndex());
  328. CPPUNIT_ASSERT_EQUAL(512, piece2->getLength());
  329. }
  330. void DefaultBtProgressInfoFileTest::testLoad_nonBt_pieceLengthShorter()
  331. {
  332. initializeMembers(512, 81920);
  333. option_->put(PREF_ALLOW_PIECE_LENGTH_CHANGE, A2_V_TRUE);
  334. std::shared_ptr<DownloadContext> dctx
  335. (new DownloadContext(512, 81920, A2_TEST_DIR"/load-nonBt-v0001"));
  336. DefaultBtProgressInfoFile infoFile(dctx, pieceStorage_, option_.get());
  337. CPPUNIT_ASSERT_EQUAL(std::string(A2_TEST_DIR"/load-nonBt-v0001.aria2"),
  338. infoFile.getFilename());
  339. infoFile.load();
  340. // check the contents of objects
  341. // bitfield
  342. CPPUNIT_ASSERT_EQUAL(std::string("fffffffffffffffffffffffffffffffffffffffc"),
  343. util::toHex(bitfield_->getBitfield(),
  344. bitfield_->getBitfieldLength()));
  345. // the number of in-flight pieces
  346. CPPUNIT_ASSERT_EQUAL((size_t)0,
  347. pieceStorage_->countInFlightPiece());
  348. }
  349. void DefaultBtProgressInfoFileTest::testSave_nonBt()
  350. {
  351. initializeMembers(1024, 81920);
  352. std::shared_ptr<DownloadContext> dctx
  353. (new DownloadContext(1024, 81920, A2_TEST_OUT_DIR"/save-temp"));
  354. bitfield_->setAllBit();
  355. bitfield_->unsetBit(79);
  356. pieceStorage_->setCompletedLength(80896);
  357. std::shared_ptr<Piece> p1(new Piece(1, 1024));
  358. std::shared_ptr<Piece> p2(new Piece(2, 512));
  359. std::vector<std::shared_ptr<Piece> > inFlightPieces;
  360. inFlightPieces.push_back(p1);
  361. inFlightPieces.push_back(p2);
  362. pieceStorage_->addInFlightPiece(inFlightPieces);
  363. DefaultBtProgressInfoFile infoFile(dctx, pieceStorage_, option_.get());
  364. CPPUNIT_ASSERT_EQUAL(std::string(A2_TEST_OUT_DIR"/save-temp.aria2"),
  365. infoFile.getFilename());
  366. infoFile.save();
  367. // read and validate
  368. std::ifstream in(infoFile.getFilename().c_str(), std::ios::binary);
  369. //in.exceptions(ios::failbit);
  370. unsigned char version[2];
  371. in.read((char*)version, sizeof(version));
  372. CPPUNIT_ASSERT_EQUAL(std::string("0001"),
  373. util::toHex(version, sizeof(version)));
  374. unsigned char extension[4];
  375. in.read((char*)extension, sizeof(extension));
  376. CPPUNIT_ASSERT_EQUAL(std::string("00000000"),
  377. util::toHex(extension, sizeof(extension)));
  378. uint32_t infoHashLength;
  379. in.read(reinterpret_cast<char*>(&infoHashLength), sizeof(infoHashLength));
  380. infoHashLength = ntohl(infoHashLength);
  381. CPPUNIT_ASSERT_EQUAL((uint32_t)0, infoHashLength);
  382. uint32_t pieceLength;
  383. in.read((char*)&pieceLength, sizeof(pieceLength));
  384. pieceLength = ntohl(pieceLength);
  385. CPPUNIT_ASSERT_EQUAL((uint32_t)1024, pieceLength);
  386. uint64_t totalLength;
  387. in.read((char*)&totalLength, sizeof(totalLength));
  388. totalLength = ntoh64(totalLength);
  389. CPPUNIT_ASSERT_EQUAL((uint64_t)81920/* 80*1024 */, totalLength);
  390. uint64_t uploadLength;
  391. in.read((char*)&uploadLength, sizeof(uploadLength));
  392. uploadLength = ntoh64(uploadLength);
  393. CPPUNIT_ASSERT_EQUAL((uint64_t)0, uploadLength);
  394. uint32_t bitfieldLength;
  395. in.read((char*)&bitfieldLength, sizeof(bitfieldLength));
  396. bitfieldLength = ntohl(bitfieldLength);
  397. CPPUNIT_ASSERT_EQUAL((uint32_t)10, bitfieldLength);
  398. unsigned char bitfieldRead[10];
  399. in.read((char*)bitfieldRead, sizeof(bitfieldRead));
  400. CPPUNIT_ASSERT_EQUAL(std::string("fffffffffffffffffffe"),
  401. util::toHex(bitfieldRead, sizeof(bitfieldRead)));
  402. uint32_t numInFlightPiece;
  403. in.read((char*)&numInFlightPiece, sizeof(numInFlightPiece));
  404. numInFlightPiece = ntohl(numInFlightPiece);
  405. CPPUNIT_ASSERT_EQUAL((uint32_t)2, numInFlightPiece);
  406. // piece index 1
  407. uint32_t index1;
  408. in.read((char*)&index1, sizeof(index1));
  409. index1 = ntohl(index1);
  410. CPPUNIT_ASSERT_EQUAL((uint32_t)1, index1);
  411. uint32_t pieceLength1;
  412. in.read((char*)&pieceLength1, sizeof(pieceLength1));
  413. pieceLength1 = ntohl(pieceLength1);
  414. CPPUNIT_ASSERT_EQUAL((uint32_t)1024, pieceLength1);
  415. uint32_t pieceBitfieldLength1;
  416. in.read((char*)&pieceBitfieldLength1, sizeof(pieceBitfieldLength1));
  417. pieceBitfieldLength1 = ntohl(pieceBitfieldLength1);
  418. CPPUNIT_ASSERT_EQUAL((uint32_t)1, pieceBitfieldLength1);
  419. unsigned char pieceBitfield1[1];
  420. in.read((char*)pieceBitfield1, sizeof(pieceBitfield1));
  421. CPPUNIT_ASSERT_EQUAL(std::string("00"),
  422. util::toHex(pieceBitfield1, sizeof(pieceBitfield1)));
  423. // piece index 2
  424. uint32_t index2;
  425. in.read((char*)&index2, sizeof(index2));
  426. index2 = ntohl(index2);
  427. CPPUNIT_ASSERT_EQUAL((uint32_t)2, index2);
  428. uint32_t pieceLength2;
  429. in.read((char*)&pieceLength2, sizeof(pieceLength2));
  430. pieceLength2 = ntohl(pieceLength2);
  431. CPPUNIT_ASSERT_EQUAL((uint32_t)512, pieceLength2);
  432. }
  433. void DefaultBtProgressInfoFileTest::testUpdateFilename()
  434. {
  435. std::shared_ptr<DownloadContext> dctx
  436. (new DownloadContext(1024, 81920, A2_TEST_DIR"/file1"));
  437. DefaultBtProgressInfoFile infoFile(dctx, std::shared_ptr<MockPieceStorage>(), nullptr);
  438. #ifdef ENABLE_BITTORRENT
  439. infoFile.setBtRuntime(btRuntime_);
  440. infoFile.setPeerStorage(peerStorage_);
  441. #endif // ENABLE_BITTORRENT
  442. CPPUNIT_ASSERT_EQUAL(std::string(A2_TEST_DIR"/file1.aria2"),
  443. infoFile.getFilename());
  444. dctx->getFirstFileEntry()->setPath(A2_TEST_DIR"/file1.1");
  445. CPPUNIT_ASSERT_EQUAL(std::string(A2_TEST_DIR"/file1.aria2"),
  446. infoFile.getFilename());
  447. infoFile.updateFilename();
  448. CPPUNIT_ASSERT_EQUAL(std::string(A2_TEST_DIR"/file1.1.aria2"),
  449. infoFile.getFilename());
  450. }
  451. } // namespace aria2