diff --git a/src/peers.c b/src/peers.c index c1052c2a7..503a71fcc 100644 --- a/src/peers.c +++ b/src/peers.c @@ -1205,7 +1205,6 @@ static inline int peer_send_msg(struct appctx *appctx, struct peer_prep_params *params) { int ret, msglen; - struct stconn *sc = appctx_sc(appctx); msglen = peer_prepare_msg(trash.area, trash.size, params); if (!msglen) { @@ -1215,14 +1214,10 @@ static inline int peer_send_msg(struct appctx *appctx, } /* message to buffer */ - ret = ci_putblk(sc_ic(sc), trash.area, msglen); + ret = applet_putblk(appctx, trash.area, msglen); if (ret <= 0) { - if (ret == -1) { - /* No more write possible */ - sc_need_room(sc); - return -1; - } - appctx->st0 = PEER_SESS_ST_END; + if (ret != -1) + appctx->st0 = PEER_SESS_ST_END; } return ret;