debian-packages/eventcore
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Add EventDriverTimers.isUnique.

Browse source
This commit is contained in:
Sönke Ludwig 2017-01-30 19:54:38 +01:00
parent 956978cc79
commit 6851776358
No known key found for this signature in database
GPG key ID: D95E8DB493EE314C
2 changed files with 11 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
source/eventcore/driver.d
View file

@ -422,6 +422,9 @@ interface EventDriverTimers {
Returns `false` $(I iff) the last reference was removed by this call. Returns `false` $(I iff) the last reference was removed by this call.
*/ */
bool releaseRef(TimerID descriptor); bool releaseRef(TimerID descriptor);
/// Determines if the given timer's reference count equals one.
bool isUnique(TimerID descriptor) const;
} }
interface EventDriverWatchers { interface EventDriverWatchers {

8
source/eventcore/drivers/timer.d
View file

@ -88,6 +88,7 @@ final class LoopTimeoutTimerDriver : EventDriverTimers {
assert(tm !is null); assert(tm !is null);
tm.id = id; tm.id = id;
tm.refCount = 1; tm.refCount = 1;
tm.timeout = long.max;
m_timers[id] = tm; m_timers[id] = tm;
return id; return id;
} }
@ -138,6 +139,7 @@ final class LoopTimeoutTimerDriver : EventDriverTimers {
final override void wait(TimerID timer, TimerCallback callback) final override void wait(TimerID timer, TimerCallback callback)
{ {
import eventcore.internal.utils; print("emit timer");
assert(!m_timers[timer].callback, "Calling wait() no a timer that is already waiting."); assert(!m_timers[timer].callback, "Calling wait() no a timer that is already waiting.");
m_timers[timer].callback = callback; m_timers[timer].callback = callback;
} }
@ -179,6 +181,12 @@ final class LoopTimeoutTimerDriver : EventDriverTimers {
return true; return true;
} }
final bool isUnique(TimerID descriptor)
const {
if (descriptor == TimerID.init) return false;
return m_timers[descriptor].refCount == 1;
}
} }
struct TimerSlot { struct TimerSlot {