diff --git a/src/proto_sockpair.c b/src/proto_sockpair.c index a6005ee5b..bdc7ebee0 100644 --- a/src/proto_sockpair.c +++ b/src/proto_sockpair.c @@ -158,7 +158,7 @@ static int sockpair_bind_listener(struct listener *listener, char *errmsg, int e listener->state = LI_LISTEN; fd_insert(fd, listener, listener->proto->accept, - thread_mask(listener->bind_conf->bind_thread)); + thread_mask(listener->bind_conf->bind_thread) & all_threads_mask); return err; diff --git a/src/proto_tcp.c b/src/proto_tcp.c index df4e5a4d2..197cb432b 100644 --- a/src/proto_tcp.c +++ b/src/proto_tcp.c @@ -999,7 +999,7 @@ int tcp_bind_listener(struct listener *listener, char *errmsg, int errlen) listener->state = LI_LISTEN; fd_insert(fd, listener, listener->proto->accept, - thread_mask(listener->bind_conf->bind_thread)); + thread_mask(listener->bind_conf->bind_thread) & all_threads_mask); tcp_return: if (msg && errlen) { diff --git a/src/proto_uxst.c b/src/proto_uxst.c index 2a5e4319d..61c89d545 100644 --- a/src/proto_uxst.c +++ b/src/proto_uxst.c @@ -343,7 +343,7 @@ static int uxst_bind_listener(struct listener *listener, char *errmsg, int errle listener->state = LI_LISTEN; fd_insert(fd, listener, listener->proto->accept, - thread_mask(listener->bind_conf->bind_thread)); + thread_mask(listener->bind_conf->bind_thread) & all_threads_mask); return err;