stick for 10 seconds longer in relay commit

pull/344/head
Jeff Becker 5 years ago
parent 6c5a015f4f
commit 77e238bf94
No known key found for this signature in database
GPG Key ID: F357B3B42F6F9B05

@ -203,10 +203,10 @@ namespace llarp
static_cast< LRCMFrameDecrypt* >(user)); static_cast< LRCMFrameDecrypt* >(user));
// persist sessions to upstream and downstream routers until the commit // persist sessions to upstream and downstream routers until the commit
// ends // ends
self->context->Router()->PersistSessionUntil(self->hop->info.downstream, self->context->Router()->PersistSessionUntil(
self->hop->ExpireTime()); self->hop->info.downstream, self->hop->ExpireTime() + 10000);
self->context->Router()->PersistSessionUntil(self->hop->info.upstream, self->context->Router()->PersistSessionUntil(
self->hop->ExpireTime()); self->hop->info.upstream, self->hop->ExpireTime() + 10000);
// put hop // put hop
self->context->PutTransitHop(self->hop); self->context->PutTransitHop(self->hop);
// forward to next hop // forward to next hop
@ -221,8 +221,8 @@ namespace llarp
std::unique_ptr< LRCMFrameDecrypt > self( std::unique_ptr< LRCMFrameDecrypt > self(
static_cast< LRCMFrameDecrypt* >(user)); static_cast< LRCMFrameDecrypt* >(user));
// persist session to downstream until path expiration // persist session to downstream until path expiration
self->context->Router()->PersistSessionUntil(self->hop->info.downstream, self->context->Router()->PersistSessionUntil(
self->hop->ExpireTime()); self->hop->info.downstream, self->hop->ExpireTime() + 10000);
// put hop // put hop
self->context->PutTransitHop(self->hop); self->context->PutTransitHop(self->hop);
// send path confirmation // send path confirmation
@ -281,7 +281,7 @@ namespace llarp
using namespace std::placeholders; using namespace std::placeholders;
if(self->record.work if(self->record.work
&& self->record.work->IsValid( && self->record.work->IsValid(
std::bind(&Crypto::shorthash, crypto, _1, _2), now)) std::bind(&Crypto::shorthash, crypto, _1, _2), now))
{ {
llarp::LogDebug("LRCM extended lifetime by ", llarp::LogDebug("LRCM extended lifetime by ",
self->record.work->extendedLifetime, " seconds for ", self->record.work->extendedLifetime, " seconds for ",

Loading…
Cancel
Save