|
|
|
@ -1160,18 +1160,18 @@ namespace llarp
|
|
|
|
|
}
|
|
|
|
|
m_PendingTraffic[remote].emplace_back(data, t);
|
|
|
|
|
// no converstation
|
|
|
|
|
return EnsurePathToService(
|
|
|
|
|
remote,
|
|
|
|
|
[&](Address r, OutboundContext* c) {
|
|
|
|
|
if(c)
|
|
|
|
|
{
|
|
|
|
|
c->UpdateIntroSet(true);
|
|
|
|
|
for(auto& pending : m_PendingTraffic[r])
|
|
|
|
|
c->AsyncEncryptAndSendTo(pending.Buffer(), pending.protocol);
|
|
|
|
|
}
|
|
|
|
|
m_PendingTraffic.erase(r);
|
|
|
|
|
},
|
|
|
|
|
5000, true);
|
|
|
|
|
return EnsurePathToService(remote,
|
|
|
|
|
[&](Address r, OutboundContext* c) {
|
|
|
|
|
if(c)
|
|
|
|
|
{
|
|
|
|
|
c->UpdateIntroSet(true);
|
|
|
|
|
for(auto& pending : m_PendingTraffic[r])
|
|
|
|
|
c->AsyncEncryptAndSendTo(
|
|
|
|
|
pending.Buffer(), pending.protocol);
|
|
|
|
|
}
|
|
|
|
|
m_PendingTraffic.erase(r);
|
|
|
|
|
},
|
|
|
|
|
5000, true);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
void
|
|
|
|
|