DHTMessageTrackerEntryTest.cc 1.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152
  1. #include "DHTMessageTrackerEntry.h"
  2. #include "Exception.h"
  3. #include "Util.h"
  4. #include "MockDHTMessage.h"
  5. #include "DHTNode.h"
  6. #include "MetaEntry.h"
  7. #include "DHTMessageCallback.h"
  8. #include <cppunit/extensions/HelperMacros.h>
  9. class DHTMessageTrackerEntryTest:public CppUnit::TestFixture {
  10. CPPUNIT_TEST_SUITE(DHTMessageTrackerEntryTest);
  11. CPPUNIT_TEST(testMatch);
  12. CPPUNIT_TEST(testHandleTimeout);
  13. CPPUNIT_TEST_SUITE_END();
  14. public:
  15. void setUp() {}
  16. void tearDown() {}
  17. void testMatch();
  18. void testHandleTimeout();
  19. };
  20. CPPUNIT_TEST_SUITE_REGISTRATION(DHTMessageTrackerEntryTest);
  21. void DHTMessageTrackerEntryTest::testMatch()
  22. {
  23. DHTNodeHandle localNode = new DHTNode();
  24. try {
  25. MockDHTMessageHandle msg1 = new MockDHTMessage(localNode, new DHTNode());
  26. MockDHTMessageHandle msg2 = new MockDHTMessage(localNode, new DHTNode());
  27. DHTMessageTrackerEntry entry(msg1, 30);
  28. CPPUNIT_ASSERT(entry.match(msg1->getTransactionID(),
  29. msg1->getRemoteNode()->getIPAddress(),
  30. msg1->getRemoteNode()->getPort()));
  31. CPPUNIT_ASSERT(!entry.match(msg2->getTransactionID(),
  32. msg2->getRemoteNode()->getIPAddress(),
  33. msg2->getRemoteNode()->getPort()));
  34. } catch(Exception* e) {
  35. cerr << *e << endl;
  36. CPPUNIT_FAIL("exception thrown.");
  37. }
  38. }
  39. void DHTMessageTrackerEntryTest::testHandleTimeout()
  40. {
  41. }