diff --git a/src/fd.c b/src/fd.c index b4b3d7b48..634a6a33b 100644 --- a/src/fd.c +++ b/src/fd.c @@ -486,7 +486,7 @@ void updt_fd_polling(const int fd) fd_add_to_fd_list(&update_list[tgrp - 1], fd); - thr = one_among_mask(fdtab[fd].thread_mask & tg->threads_enabled, statistical_prng_range(MAX_THREADS)); + thr = one_among_mask(fdtab[fd].thread_mask & tg->threads_enabled, statistical_prng_range(tg->count)); thr += ha_tgroup_info[tgrp - 1].base; wake_thread(thr);