this repo has no description
Fix queue cleanup for dead processes
+6
-1
+6
-1
lib/trinity/scheduler.ex
+6
-1
lib/trinity/scheduler.ex
···
354
354
# Note that we do not currently bother to destroy aliases here
355
355
356
356
case :ets.lookup(proc_queue_keys, pid) do
357
-
[{_event, ^pid, qk}] ->
357
+
[{:timeout_infinity, _ref}] ->
358
+
:ets.delete(proc_queue_keys, pid)
359
+
[{:timeout, _ref, qk}] ->
360
+
:ets.delete(queue, qk)
361
+
:ets.delete(proc_queue_keys, pid)
362
+
[{:resume, qk}] ->
358
363
:ets.delete(queue, qk)
359
364
:ets.delete(proc_queue_keys, pid)
360
365
_ -> :noop