diff --git a/server/queuenode.ml b/server/queuenode.ml index 00b57dc..ad346fe 100644 --- a/server/queuenode.ml +++ b/server/queuenode.ml @@ -54,6 +54,7 @@ let shoveller info = info.waiters_out (Some sub); message_loop () | false -> + info.waiters <- info.waiters - 1; waiter_loop () in waiter_loop () in message_loop ()