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

MEDIUM: applet: Check room needed to unblock opposite SC when data was consumed

Browse Source 
If the opposite SC is waiting for a minimum free space to receive more data,
it is only unblock is the condition is respected. 0 is a special cases where
the opposite SC is always unblocked.
This commit is contained in:
Christopher Faulet 2023-05-05 11:39:03 +02:00
parent fab82bfd55
commit c184b11b1a
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/applet.c
View File

@ -400,7 +400,7 @@ int appctx_buf_available(void *arg)
struct task *task_run_applet(struct task *t, void *context, unsigned int state) struct task *task_run_applet(struct task *t, void *context, unsigned int state)
{ {
struct appctx *app = context; struct appctx *app = context;
struct stconn *sc; struct stconn *sc, *sco;
unsigned int rate; unsigned int rate;
size_t count; size_t count;
@ -428,6 +428,7 @@ struct task *task_run_applet(struct task *t, void *context, unsigned int state)
} }
sc = appctx_sc(app); sc = appctx_sc(app);
sco = sc_opposite(sc);
/* We always pretend the applet can't get and doesn't want to /* We always pretend the applet can't get and doesn't want to
* put, it's up to it to change this if needed. This ensures * put, it's up to it to change this if needed. This ensures
@ -455,8 +456,11 @@ struct task *task_run_applet(struct task *t, void *context, unsigned int state)
*/ */
if (count != co_data(sc_oc(sc))) { if (count != co_data(sc_oc(sc))) {
sc_oc(sc)->flags |= CF_WRITE_EVENT | CF_WROTE_DATA; sc_oc(sc)->flags |= CF_WRITE_EVENT | CF_WROTE_DATA;
sc_have_room(sc_opposite(sc)); if (sco->room_needed < 0 || channel_recv_max(sc_oc(sc)) >= sco->room_needed)
sc_have_room(sco);
} }
else if (!sco->room_needed)
sc_have_room(sco);
if (sc_ic(sc)->flags & CF_READ_EVENT) if (sc_ic(sc)->flags & CF_READ_EVENT)
sc_ep_report_read_activity(sc); sc_ep_report_read_activity(sc);