diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2010-08-07 14:15:21 +0000 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2010-08-07 14:15:21 +0000 |
| commit | 26d66923767581d63fdfc303525cddebf9125bde (patch) | |
| tree | 97eb6054d697b53c7296adfaeaa43fb8013de3f2 /test/DHTGetPeersMessageTest.cc | |
| parent | be7012272dbd029a7843df43466f4cd83e6fb9e3 (diff) | |
2010-08-07 Tatsuhiro Tsujikawa <t-tujikawa@users.sourceforge.net>
Added IPv6 DHT. Added --dht-entry-porint6, --dht-file-path6,
--dht-listen-addr6 and --enable-dht6 option. IPv6 DHT is disabled
by default. To use IPv6 DHT, you need to use --enable-dht6 and
specify a global unicast address to --dht-listen-addr6. IPv6 DHT
is highly experimental.
* src/BtSetup.cc
* src/DHTAutoSaveCommand.cc
* src/DHTAutoSaveCommand.h
* src/DHTConnectionImpl.cc
* src/DHTConnectionImpl.h
* src/DHTEntryPointNameResolveCommand.cc
* src/DHTFindNodeReplyMessage.cc
* src/DHTFindNodeReplyMessage.h
* src/DHTGetPeersMessage.cc
* src/DHTGetPeersReplyMessage.cc
* src/DHTGetPeersReplyMessage.h
* src/DHTMessageFactory.h
* src/DHTMessageFactoryImpl.cc
* src/DHTMessageFactoryImpl.h
* src/DHTMessageTracker.cc
* src/DHTRegistry.cc
* src/DHTRegistry.h
* src/DHTRoutingTableDeserializer.cc
* src/DHTRoutingTableDeserializer.h
* src/DHTRoutingTableSerializer.cc
* src/DHTRoutingTableSerializer.h
* src/DHTSetup.cc
* src/DHTSetup.h
* src/FtpConnection.cc
* src/LpdMessageReceiver.cc
* src/OptionHandlerFactory.cc
* src/OptionHandlerImpl.h
* src/PeerInteractionCommand.cc
* src/RequestGroup.cc
* src/SocketCore.cc
* src/SocketCore.h
* src/bittorrent_helper.cc
* src/bittorrent_helper.h
* src/prefs.cc
* src/prefs.h
* src/usage_text.h
* test/DHTConnectionImplTest.cc
* test/DHTFindNodeReplyMessageTest.cc
* test/DHTGetPeersMessageTest.cc
* test/DHTGetPeersReplyMessageTest.cc
* test/DHTMessageFactoryImplTest.cc
* test/DHTRoutingTableDeserializerTest.cc
* test/DHTRoutingTableSerializerTest.cc
* test/LpdMessageDispatcherTest.cc
* test/MockDHTMessageFactory.h
Diffstat (limited to 'test/DHTGetPeersMessageTest.cc')
| -rw-r--r-- | test/DHTGetPeersMessageTest.cc | 28 |
1 files changed, 7 insertions, 21 deletions
diff --git a/test/DHTGetPeersMessageTest.cc b/test/DHTGetPeersMessageTest.cc index 9a817cbf..11a280c1 100644 --- a/test/DHTGetPeersMessageTest.cc +++ b/test/DHTGetPeersMessageTest.cc @@ -32,23 +32,10 @@ public: class MockDHTMessageFactory2:public MockDHTMessageFactory { public: virtual SharedHandle<DHTResponseMessage> - createGetPeersReplyMessage(const SharedHandle<DHTNode>& remoteNode, - const std::vector<SharedHandle<Peer> >& peers, - const std::string& token, - const std::string& transactionID) - { - SharedHandle<MockDHTResponseMessage> m - (new MockDHTResponseMessage - (localNode_, remoteNode, "get_peers", transactionID)); - m->peers_ = peers; - m->token_ = token; - return m; - } - - virtual SharedHandle<DHTResponseMessage> createGetPeersReplyMessage (const SharedHandle<DHTNode>& remoteNode, const std::vector<SharedHandle<DHTNode> >& closestKNodes, + const std::vector<SharedHandle<Peer> >& peers, const std::string& token, const std::string& transactionID) { @@ -56,10 +43,10 @@ public: (new MockDHTResponseMessage (localNode_, remoteNode, "get_peers", transactionID)); m->nodes_ = closestKNodes; + m->peers_ = peers; m->token_ = token; return m; } - }; }; @@ -115,14 +102,13 @@ void DHTGetPeersMessageTest::testDoReceivedAction() MockDHTMessageDispatcher dispatcher; MockDHTMessageFactory2 factory; factory.setLocalNode(localNode); + DHTRoutingTable routingTable(localNode); DHTGetPeersMessage msg(localNode, remoteNode, infoHash, transactionID); - msg.setTokenTracker(WeakHandle<DHTTokenTracker> - (&tokenTracker)); - msg.setMessageDispatcher(WeakHandle<DHTMessageDispatcher> - (&dispatcher)); - msg.setMessageFactory(WeakHandle<DHTMessageFactory> - (&factory)); + msg.setRoutingTable(WeakHandle<DHTRoutingTable>(&routingTable)); + msg.setTokenTracker(WeakHandle<DHTTokenTracker>(&tokenTracker)); + msg.setMessageDispatcher(WeakHandle<DHTMessageDispatcher>(&dispatcher)); + msg.setMessageFactory(WeakHandle<DHTMessageFactory>(&factory)); { // localhost has peer contact information for that infohash. DHTPeerAnnounceStorage peerAnnounceStorage; |