github
/
aria2
mirror of https://github.com/aria2/aria2
1
0
Fork 0
Code Issues Releases Wiki Activity

2008-02-11 Tatsuhiro Tsujikawa <tujikawa at rednoah dot com> 

Added handling of dynamic cast failure.
	* src/DHTNodeLookupTask.cc
	* src/DHTPeerLookupTask.cc
pull/1/head
Tatsuhiro Tsujikawa 2008-02-11 05:54:08 +00:00
parent 9c277148b9
commit 34e6a1dc9a
3 changed files with 19 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ChangeLog
View File

@ -1,3 +1,9 @@
2008-02-11 Tatsuhiro Tsujikawa <tujikawa at rednoah dot com>
Added handling of dynamic cast failure.
* src/DHTNodeLookupTask.cc
* src/DHTPeerLookupTask.cc
2008-02-11 Tatsuhiro Tsujikawa <tujikawa at rednoah dot com> 2008-02-11 Tatsuhiro Tsujikawa <tujikawa at rednoah dot com>
Added the ability to stop aria2 itself when given time has passed Added the ability to stop aria2 itself when given time has passed

4
src/DHTNodeLookupTask.cc
View File

@ -50,8 +50,12 @@ std::deque<SharedHandle<DHTNode> >
DHTNodeLookupTask::getNodesFromMessage(const SharedHandle<DHTMessage>& message) DHTNodeLookupTask::getNodesFromMessage(const SharedHandle<DHTMessage>& message)
{ {
SharedHandle<DHTFindNodeReplyMessage> m = message; SharedHandle<DHTFindNodeReplyMessage> m = message;
if(m.isNull()) {
return std::deque<SharedHandle<DHTNode> >();
} else {
return m->getClosestKNodes(); return m->getClosestKNodes();
} }
}
SharedHandle<DHTMessage> SharedHandle<DHTMessage>
DHTNodeLookupTask::createMessage(const SharedHandle<DHTNode>& remoteNode) DHTNodeLookupTask::createMessage(const SharedHandle<DHTNode>& remoteNode)

8
src/DHTPeerLookupTask.cc
View File

@ -59,13 +59,19 @@ DHTPeerLookupTask::DHTPeerLookupTask(const SharedHandle<BtContext>& btContext):
std::deque<SharedHandle<DHTNode> > DHTPeerLookupTask::getNodesFromMessage(const SharedHandle<DHTMessage>& message) std::deque<SharedHandle<DHTNode> > DHTPeerLookupTask::getNodesFromMessage(const SharedHandle<DHTMessage>& message)
{ {
SharedHandle<DHTGetPeersReplyMessage> m = message; SharedHandle<DHTGetPeersReplyMessage> m = message;
if(m.isNull()) {
return std::deque<SharedHandle<DHTNode> >();
} else {
return m->getClosestKNodes(); return m->getClosestKNodes();
} }
}
void DHTPeerLookupTask::onReceivedInternal(const SharedHandle<DHTMessage>& message) void DHTPeerLookupTask::onReceivedInternal(const SharedHandle<DHTMessage>& message)
{ {
SharedHandle<DHTGetPeersReplyMessage> m = message; SharedHandle<DHTGetPeersReplyMessage> m = message;
if(m.isNull()) {
return;
}
SharedHandle<DHTNode> remoteNode = m->getRemoteNode(); SharedHandle<DHTNode> remoteNode = m->getRemoteNode();
_tokenStorage[Util::toHex(remoteNode->getID(), DHT_ID_LENGTH)] = m->getToken(); _tokenStorage[Util::toHex(remoteNode->getID(), DHT_ID_LENGTH)] = m->getToken();