BtHaveNoneMessageTest.cc 2.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788
  1. #include "BtHaveNoneMessage.h"
  2. #include <cstring>
  3. #include <cppunit/extensions/HelperMacros.h>
  4. #include "bittorrent_helper.h"
  5. #include "Peer.h"
  6. namespace aria2 {
  7. class BtHaveNoneMessageTest:public CppUnit::TestFixture {
  8. CPPUNIT_TEST_SUITE(BtHaveNoneMessageTest);
  9. CPPUNIT_TEST(testCreate);
  10. CPPUNIT_TEST(testCreateMessage);
  11. CPPUNIT_TEST(testDoReceivedAction);
  12. CPPUNIT_TEST(testToString);
  13. CPPUNIT_TEST_SUITE_END();
  14. private:
  15. public:
  16. void setUp() {
  17. }
  18. void testCreate();
  19. void testCreateMessage();
  20. void testDoReceivedAction();
  21. void testToString();
  22. };
  23. CPPUNIT_TEST_SUITE_REGISTRATION(BtHaveNoneMessageTest);
  24. void BtHaveNoneMessageTest::testCreate() {
  25. unsigned char msg[5];
  26. bittorrent::createPeerMessageString(msg, sizeof(msg), 1, 15);
  27. SharedHandle<BtHaveNoneMessage> pm = BtHaveNoneMessage::create(&msg[4], 1);
  28. CPPUNIT_ASSERT_EQUAL((uint8_t)15, pm->getId());
  29. // case: payload size is wrong
  30. try {
  31. unsigned char msg[6];
  32. bittorrent::createPeerMessageString(msg, sizeof(msg), 2, 15);
  33. BtHaveNoneMessage::create(&msg[4], 2);
  34. CPPUNIT_FAIL("exception must be thrown.");
  35. } catch(...) {
  36. }
  37. // case: id is wrong
  38. try {
  39. unsigned char msg[5];
  40. bittorrent::createPeerMessageString(msg, sizeof(msg), 1, 16);
  41. BtHaveNoneMessage::create(&msg[4], 1);
  42. CPPUNIT_FAIL("exception must be thrown.");
  43. } catch(...) {
  44. }
  45. }
  46. void BtHaveNoneMessageTest::testCreateMessage() {
  47. BtHaveNoneMessage msg;
  48. unsigned char data[5];
  49. bittorrent::createPeerMessageString(data, sizeof(data), 1, 15);
  50. unsigned char* rawmsg = msg.createMessage();
  51. CPPUNIT_ASSERT(memcmp(rawmsg, data, 5) == 0);
  52. delete [] rawmsg;
  53. }
  54. void BtHaveNoneMessageTest::testDoReceivedAction() {
  55. BtHaveNoneMessage msg;
  56. SharedHandle<Peer> peer(new Peer("host", 6969));
  57. peer->allocateSessionResource(1024, 1024*1024);
  58. peer->setFastExtensionEnabled(true);
  59. msg.setPeer(peer);
  60. msg.doReceivedAction();
  61. peer->setFastExtensionEnabled(false);
  62. try {
  63. msg.doReceivedAction();
  64. CPPUNIT_FAIL("an exception must be thrown.");
  65. } catch(...) {}
  66. }
  67. void BtHaveNoneMessageTest::testToString() {
  68. BtHaveNoneMessage msg;
  69. CPPUNIT_ASSERT_EQUAL(std::string("have none"), msg.toString());
  70. }
  71. } // namespace aria2