diff --git a/src/peers.c b/src/peers.c index 96f6de9a0..145d66940 100644 --- a/src/peers.c +++ b/src/peers.c @@ -3080,8 +3080,11 @@ static void peer_io_handler(struct appctx *appctx) } } - if (curpeer->flags & PEER_F_WAIT_SYNCTASK_ACK) + if (curpeer->flags & PEER_F_WAIT_SYNCTASK_ACK) { + applet_wont_consume(appctx); goto out; + } + applet_will_consume(appctx); /* local peer is assigned of a lesson, start it */ if (curpeer->learnstate == PEER_LR_ST_ASSIGNED && curpeer->local)