mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2025-09-26 16:21:22 +02:00
Code Issues Projects Releases Wiki Activity

CLEANUP: channel: No longer notify the producer in co_skip()/co_htx_skip()

Browse Source 
Thanks to the commit "BUG/MINOR: applet: Notify the other side if data were
consumed by an applet", it is no longer necessary to notify the producer when an
applet skips output data. Now, it is the default applet handler responsibility
to take care of that.
This commit is contained in:
Christopher Faulet 2021-04-27 23:06:20 +02:00
parent 925abdfdac
commit 8b604d1656
1 changed files with 3 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
include/haproxy/channel.h
View File

@ -925,36 +925,26 @@ static inline int32_t channel_htx_fwd_headers(struct channel *chn, struct htx *h
* when data have been read directly from the buffer. It is illegal to call
* this function with <len> causing a wrapping at the end of the buffer. It's
* the caller's responsibility to ensure that <len> is never larger than
* chn->o. Channel flags WRITE_PARTIAL and WROTE_DATA are set.
* chn->o.
*/
static inline void co_skip(struct channel *chn, int len)
{
b_del(&chn->buf, len);
chn->output -= len;
c_realign_if_empty(chn);
/* notify that some data was written to the SI from the buffer */
chn->flags |= CF_WRITE_PARTIAL | CF_WROTE_DATA;
chn_prod(chn)->flags &= ~SI_FL_RXBLK_ROOM; // si_rx_room_rdy()
}
/* HTX version of co_skip(). This function skips at most <len> bytes from the
* output of the channel <chn>. Depending on how data are stored in <htx> less
* than <len> bytes can be skipped. Channel flags WRITE_PARTIAL and WROTE_DATA
* are set.
* than <len> bytes can be skipped..
*/
static inline void co_htx_skip(struct channel *chn, struct htx *htx, int len)
{
struct htx_ret htxret;
htxret = htx_drain(htx, len);
if (htxret.ret) {
if (htxret.ret)
chn->output -= htxret.ret;
/* notify that some data was written to the SI from the buffer */
chn->flags |= CF_WRITE_PARTIAL | CF_WROTE_DATA;
chn_prod(chn)->flags &= ~SI_FL_RXBLK_ROOM; // si_rx_room_rdy()
}
}
/* Tries to copy chunk <chunk> into the channel's buffer after length controls.