mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2025-12-08 11:11:01 +01:00
Code Issues Projects Releases Wiki Activity

MINOR: lua/htx: Adapt the functions get_in_length and is_full to be HTX aware

Browse Source
This commit is contained in:
Christopher Faulet 2018-12-14 13:39:09 +01:00 committed by Willy Tarreau
parent 724a12cc65
commit a3ceac17e4
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/hlua.c
View File

@ -3180,7 +3180,12 @@ __LJMP static int hlua_channel_get_in_len(lua_State *L)
MAY_LJMP(check_args(L, 1, "get_in_len")); MAY_LJMP(check_args(L, 1, "get_in_len"));
chn = MAY_LJMP(hlua_checkchannel(L, 1)); chn = MAY_LJMP(hlua_checkchannel(L, 1));
lua_pushinteger(L, ci_data(chn)); if (IS_HTX_STRM(chn_strm(chn))) {
struct htx *htx = htxbuf(&chn->buf);
lua_pushinteger(L, htx->data - co_data(chn));
}
else
lua_pushinteger(L, ci_data(chn));
return 1; return 1;
} }
@ -3193,7 +3198,14 @@ __LJMP static int hlua_channel_is_full(lua_State *L)
MAY_LJMP(check_args(L, 1, "is_full")); MAY_LJMP(check_args(L, 1, "is_full"));
chn = MAY_LJMP(hlua_checkchannel(L, 1)); chn = MAY_LJMP(hlua_checkchannel(L, 1));
rem = b_room(&chn->buf); if (IS_HTX_STRM(chn_strm(chn))) {
struct htx *htx = htxbuf(&chn->buf);
rem = htx_free_data_space(htx);
}
else
rem = b_room(&chn->buf);
rem -= global.tune.maxrewrite; /* Rewrite reserved size */ rem -= global.tune.maxrewrite; /* Rewrite reserved size */
lua_pushboolean(L, rem <= 0); lua_pushboolean(L, rem <= 0);