oxen-io/lokinet
1
1
Fork 0
mirror of https://github.com/oxen-io/lokinet synced 2023-12-14 06:53:00 +01:00
Code Issues Projects Releases Wiki Activity

fix timer a bit more

Browse source
This commit is contained in:
Jeff Becker 2018-06-04 07:49:37 -04:00
parent 98130d0dcd
commit eae8a81e35
No known key found for this signature in database
GPG key ID: F357B3B42F6F9B05
1 changed files with 11 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
llarp/timer.cpp
View file

@ -23,10 +23,16 @@ namespace llarp
uint64_t started;
uint64_t timeout;
llarp_timer_handler_func func;
bool done;
timer(uint64_t ms = 0, void* _user = nullptr,
llarp_timer_handler_func _func = nullptr)
: user(_user), called_at(0), started(now()), timeout(ms), func(_func)
: user(_user)
, called_at(0)
, started(now())
, timeout(ms)
, func(_func)
, done(false)
{
}
@ -210,11 +216,13 @@ llarp_timer_run(struct llarp_timer_context* t, struct llarp_threadpool* pool)
itr->second.called_at = now;
llarp_threadpool_queue_job(pool, itr->second);
}
else
else if(itr->second.done)
{
// timer was already called, remove timer
itr = t->timers.erase(itr);
}
else
++itr;
}
else // timer not hit yet
++itr;
@ -240,6 +248,7 @@ namespace llarp
call(user, timeout, 0);
else
call(user, timeout, diff);
done = true;
}
}
}