mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2025-08-05 22:56:57 +02:00
Code Issues Projects Releases Wiki Activity

BUG/MEDIUM: hlua: Report to SC when data were consumed on a lua socket

Browse Source 
The lua cosocket are quite strange. There is an applet used to handle the
connection and writer and readers subscribed on it to write or read
data. Writers and readers are tasks woken up by the cosocket applet when
data can be consumed or produced, depending on the channels buffers
state. Then the cosocket applet is woken up by writers and readers when read
or write events were performed.

It means the cosocket applet has only few information on what was produced
or consumed. It is the writers and readers responsibility to notify any
blocking. Among other things, the readers must take care to notify the
stream on top of the cosocket applet that some data was consumed. Otherwise,
it may remain blocked, waiting for a write event (a write event from the
stream point of view is a read event from the cosocket point of view).

Thie patch must be backported as far as 2.8, and maybe to 2.6 too.
This commit is contained in:
Christopher Faulet 2025-07-18 16:07:16 +02:00
parent 48df877dab
commit 21e45a61d1
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/hlua.c
View File

@ -2969,7 +2969,16 @@ __LJMP static int hlua_socket_receive_yield(struct lua_State *L, int status, lua
}
/* Consume data. */
co_skip(oc, len + skip_at_end);
if (len + skip_at_end) {
co_skip(oc, len + skip_at_end);
oc->flags |= CF_WRITE_EVENT | CF_WROTE_DATA;
if (s->scb->room_needed < 0 || channel_recv_max(oc) >= s->scb->room_needed)
sc_have_room(s->scb);
sc_ep_report_send_activity(s->scf);
}
else if (!s->scb->room_needed)
sc_have_room(s->scb);
/* Don't wait anything. */
applet_will_consume(appctx);