mirror of
http://git.haproxy.org/git/haproxy.git/
synced 2024-12-18 09:24:31 +00:00
MINOR: peers: Use the applet API to send message
The peers applet now use the applet API to send message instead of the channel API. This way, it does not need to take care to request more room if it fails to put data into the channel's buffer.
This commit is contained in:
parent
f4258bdf3b
commit
7a48b72d39
11
src/peers.c
11
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;
|
||||
|
Loading…
Reference in New Issue
Block a user