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

Return an invalid wait ID for processes.wait() if the process has already exited.

Browse source 
Avoids overlap with valid wait IDs, so that a paired cancelWait() doesn't cancel a different wait.
This commit is contained in:
Sönke Ludwig 2019-08-21 23:05:52 +02:00 committed by Sönke Ludwig
parent de199d3410
commit 72234fc0a7
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
source/eventcore/drivers/posix/processes.d
View file

@ -231,7 +231,7 @@ final class SignalEventDriverProcesses(Loop : PosixEventLoop) : EventDriverProce
if (info.exited) {
exited = true;
exitCode = info.exitCode;
return 0;
return size_t.max;
} else {
info.callbacks ~= on_process_exit;
return info.callbacks.length - 1;
@ -245,14 +245,16 @@ final class SignalEventDriverProcesses(Loop : PosixEventLoop) : EventDriverProce
return id;
}
final override void cancelWait(ProcessID pid, size_t waitId)
final override void cancelWait(ProcessID pid, size_t wait_id)
{
if (wait_id == size_t.max) return;
lockedProcessInfo!((info) {
assert(info !is null, "Unknown process ID");
assert(!info.exited, "Cannot cancel wait when none are pending");
assert(info.callbacks.length > waitId, "Invalid process wait ID");
assert(info.callbacks.length > wait_id, "Invalid process wait ID");
info.callbacks[waitId] = null;
info.callbacks[wait_id] = null;
})(pid);
}