fix integer overflow protection absence for LocalManualEvent
This commit is contained in:
parent
ff93b0de81
commit
a840c51c5d
|
@ -778,7 +778,7 @@ struct LocalManualEvent {
|
||||||
target_timeout = now + timeout;
|
target_timeout = now + timeout;
|
||||||
}
|
}
|
||||||
|
|
||||||
while (m_waiter.m_emitCount <= emit_count) {
|
while (m_waiter.m_emitCount - emit_count > 0) {
|
||||||
m_waiter.wait!interruptible(timeout != Duration.max ? target_timeout - now : Duration.max);
|
m_waiter.wait!interruptible(timeout != Duration.max ? target_timeout - now : Duration.max);
|
||||||
try now = Clock.currTime(UTC());
|
try now = Clock.currTime(UTC());
|
||||||
catch (Exception e) { assert(false, e.msg); }
|
catch (Exception e) { assert(false, e.msg); }
|
||||||
|
@ -805,6 +805,22 @@ unittest {
|
||||||
runEventLoop();
|
runEventLoop();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
unittest {
|
||||||
|
import vibe.core.core : exitEventLoop, runEventLoop, runTask, sleep;
|
||||||
|
auto e = createManualEvent();
|
||||||
|
// integer overflow test
|
||||||
|
e.m_waiter.m_emitCount = int.max;
|
||||||
|
auto w1 = runTask({ e.wait(50.msecs, e.emitCount); });
|
||||||
|
runTask({
|
||||||
|
sleep(5.msecs);
|
||||||
|
e.emit();
|
||||||
|
sleep(50.msecs);
|
||||||
|
assert(!w1.running);
|
||||||
|
exitEventLoop();
|
||||||
|
});
|
||||||
|
runEventLoop();
|
||||||
|
}
|
||||||
|
|
||||||
unittest { // ensure that cancelled waiters are properly handled and that a FIFO order is implemented
|
unittest { // ensure that cancelled waiters are properly handled and that a FIFO order is implemented
|
||||||
import vibe.core.core : exitEventLoop, runEventLoop, runTask, sleep;
|
import vibe.core.core : exitEventLoop, runEventLoop, runTask, sleep;
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue