Archives/lokinet
2
0
Fork 0
mirror of https://github.com/oxen-io/lokinet.git synced 2024-11-19 09:25:28 +00:00
Code Issues Projects Releases Wiki Activity

always put messages in inbound processing queue

Browse Source
This commit is contained in:
Jeff Becker 2018-07-03 10:04:13 -04:00
parent b994bf5f5b
commit f134b8c4d1
No known key found for this signature in database
GPG Key ID: F357B3B42F6F9B05
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
llarp/iwp_link.cpp
View File

@ -1793,9 +1793,10 @@ namespace iwp
if(id == nextMsgID)
{
session *impl = static_cast< session * >(parent->impl);
success = router->HandleRecvLinkMessage(parent, buf);
if(id == 0)
{
success = router->HandleRecvLinkMessage(parent, buf);
if(impl->CheckRCValid())
{
if(!impl->IsEstablished())
@ -1803,6 +1804,7 @@ namespace iwp
impl->send_LIM();
impl->session_established();
}
++nextMsgID;
}
else
{
@ -1812,7 +1814,11 @@ namespace iwp
success = false;
}
}
++nextMsgID;
else
{
recvqueue.Put(new InboundMessage(id, msg));
success = process_inbound_queue();
}
}
else
{