remove our paths from outbound queues

pull/873/head
Thomas Winget 5 years ago
parent ef1a5652ef
commit 23a9773e1e
No known key found for this signature in database
GPG Key ID: 58131A160789E630

@ -671,8 +671,7 @@ namespace llarp
#ifdef _WIN32 #ifdef _WIN32
struct llarp_fd_promise struct llarp_fd_promise
{ {
void void Set(std::pair< int, int >)
Set(std::pair< int, int >)
{ {
} }

@ -83,7 +83,8 @@ namespace llarp
{ {
if(itr->second->Expired(now)) if(itr->second->Expired(now))
{ {
router->outboundMessageHandler().QueueRemoveEmptyPath(itr->second->TXID()); router->outboundMessageHandler().QueueRemoveEmptyPath(
itr->second->TXID());
itr = m_Paths.erase(itr); itr = m_Paths.erase(itr);
} }
else else

@ -199,15 +199,15 @@ namespace llarp
} }
/// override me in subtype /// override me in subtype
virtual bool virtual bool HandleGotIntroMessage(
HandleGotIntroMessage(std::shared_ptr< const dht::GotIntroMessage >) std::shared_ptr< const dht::GotIntroMessage >)
{ {
return false; return false;
} }
/// override me in subtype /// override me in subtype
virtual bool virtual bool HandleGotRouterMessage(
HandleGotRouterMessage(std::shared_ptr< const dht::GotRouterMessage >) std::shared_ptr< const dht::GotRouterMessage >)
{ {
return false; return false;
} }

@ -65,7 +65,8 @@ namespace llarp
return m_CachedAddr.ToString(); return m_CachedAddr.ToString();
} }
bool ServiceInfo::CalculateAddress(std::array< byte_t, 32 >& data) const bool
ServiceInfo::CalculateAddress(std::array< byte_t, 32 >& data) const
{ {
std::array< byte_t, 256 > tmp; std::array< byte_t, 256 > tmp;
llarp_buffer_t buf(tmp); llarp_buffer_t buf(tmp);

@ -89,7 +89,8 @@ namespace llarp
} }
/// calculate our address /// calculate our address
bool CalculateAddress(std::array< byte_t, 32 >& data) const; bool
CalculateAddress(std::array< byte_t, 32 >& data) const;
bool bool
BDecode(llarp_buffer_t* buf) BDecode(llarp_buffer_t* buf)

Loading…
Cancel
Save