RepoMirrors/haproxy
1
0
Fork 0
mirror of http://git.haproxy.org/git/haproxy.git/ synced 2025-01-06 12:20:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

MEDIUM: stream: Use generic version to perform sync receives and sends

Browse Source 
Instead of using connection versions, we now use generic versions. It means
we will also perfom sync receives and sync sends on applets too, but only
for applets using their own buffers. Old applets are not concerned.
This commit is contained in:
Christopher Faulet 2024-02-01 16:36:25 +01:00
parent 5056cbdb86
commit 2e6733eb45
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/stream.c
View File

@ -1736,8 +1736,8 @@ struct task *process_stream(struct task *t, void *context, unsigned int state)
scb = s->scb;
/* First, attempt to receive pending data from I/O layers */
sc_conn_sync_recv(scf);
sc_conn_sync_recv(scb);
sc_sync_recv(scf);
sc_sync_recv(scb);
/* Let's check if we're looping without making any progress, e.g. due
* to a bogus analyser or the fact that we're ignoring a read0. The
@ -2349,7 +2349,7 @@ struct task *process_stream(struct task *t, void *context, unsigned int state)
}
/* Let's see if we can send the pending request now */
sc_conn_sync_send(scb);
sc_sync_send(scb);
/*
* Now forward all shutdown requests between both sides of the request buffer
@ -2459,7 +2459,7 @@ struct task *process_stream(struct task *t, void *context, unsigned int state)
scf_flags = (scf_flags & ~(SC_FL_SHUT_DONE|SC_FL_SHUT_WANTED)) | (scf->flags & (SC_FL_SHUT_DONE|SC_FL_SHUT_WANTED));
/* Let's see if we can send the pending response now */
sc_conn_sync_send(scf);
sc_sync_send(scf);
/*
* Now forward all shutdown requests between both sides of the buffer