kore

a fork of the worlds most advanced web framework
Log | Files | Refs | README | LICENSE

commit 8040103458f6d90167b95969d84d6b42f4df8003
parent 39467847fb2bdbcb8dccb1f9b68282b802281b6d
Author: Joris Vink <joris@coders.se>
Date:   Tue, 22 Jan 2019 11:23:59 +0100

fix for multiple consumers for the async queues.

Diffstat:
Msrc/python.c | 3++-
1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/python.c b/src/python.c @@ -2233,8 +2233,9 @@ pyqueue_op_iternext(struct pyqueue_op *op) kore_pool_put(&queue_object_pool, object); TAILQ_FOREACH(waiting, &op->queue->waiting, list) { - if (waiting->coro == coro_running) { + if (waiting->coro->id == coro_running->id) { TAILQ_REMOVE(&op->queue->waiting, waiting, list); + waiting->op->waiting = NULL; kore_pool_put(&queue_wait_pool, waiting); break; }