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

MINOR: htx: Add a function to truncate all blocks after a specific offset

Browse Source 
This function will be used to truncate all incoming data in a channel, keeping
outgoing ones.

This may be backported to 1.9.
This commit is contained in:
Christopher Faulet 2019-01-07 14:53:27 +01:00
parent f9a48ef791
commit 00cf697215
2 changed files with 21 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
include/common/htx.h
View File

@ -170,6 +170,7 @@ extern struct htx htx_empty;
struct htx_blk *htx_defrag(struct htx *htx, struct htx_blk *blk);
struct htx_blk *htx_add_blk(struct htx *htx, enum htx_blk_type type, uint32_t blksz);
struct htx_blk *htx_remove_blk(struct htx *htx, struct htx_blk *blk);
void htx_truncate(struct htx *htx, uint32_t offset);
struct htx_blk *htx_replace_blk_value(struct htx *htx, struct htx_blk *blk,
const struct ist old, const struct ist new);

20
src/htx.c
View File

@ -287,6 +287,26 @@ struct htx_blk *htx_remove_blk(struct htx *htx, struct htx_blk *blk)
return blk;
}
/* Truncate all blocks after the one containing the offset <offset>. This last
* one is truncated too.
*/
void htx_truncate(struct htx *htx, uint32_t offset)
{
struct htx_blk *blk;
struct htx_ret htxret;
htxret = htx_find_blk(htx, offset);
blk = htxret.blk;
if (blk && htxret.ret) {
uint32_t sz = htx_get_blksz(blk);
htx_set_blk_value_len(blk, sz - htxret.ret);
blk = htx_get_next_blk(htx, blk);
}
while (blk)
blk = htx_remove_blk(htx, blk);
}
/* Tries to append data to the last inserted block, if the type matches and if
* there is enough non-wrapping space. Only DATA and TRAILERS content can be
* appended. If the append fails, a new block is inserted. If an error occurred,