RepoMirrors/haproxy
1
0
Fork 0
mirror of http://git.haproxy.org/git/haproxy.git/ synced 2024-12-27 15:12:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

MEDIUM: stream: don't abusively loop back on changes on CF_SHUT*_NOW

Browse Source 
These flags are not used by analysers, only by the shut* functions, and
they were covered by CF_MASK_STATIC only because in the past the shut
functions were in the middle of the analysers. But here they are causing
excess loop backs which provide no value and increase processing cost.
Ideally the CF_MASK_STATIC bitfield should be revisited, but doing this
alone is enough to reduce by 30% the number of calls to si_sync_send().
This commit is contained in:
Willy Tarreau 2019-06-06 14:45:26 +02:00
parent 3c5c066d66
commit 1ec9bb5b62
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/stream.c
View File

@ -2144,7 +2144,7 @@ struct task *process_stream(struct task *t, void *context, unsigned short state)
req->flags &= ~CF_WAKE_ONCE;
rqf_last = req->flags;
if ((req->flags ^ flags) & CF_MASK_STATIC)
if ((req->flags ^ flags) & (CF_SHUTR|CF_SHUTW))
goto resync_request;
}
@ -2213,7 +2213,7 @@ struct task *process_stream(struct task *t, void *context, unsigned short state)
res->flags &= ~CF_WAKE_ONCE;
rpf_last = res->flags;
if ((res->flags ^ flags) & CF_MASK_STATIC)
if ((res->flags ^ flags) & (CF_SHUTR|CF_SHUTW))
goto resync_response;
}
@ -2500,7 +2500,7 @@ struct task *process_stream(struct task *t, void *context, unsigned short state)
goto resync_stream_interface;
/* otherwise we want to check if we need to resync the req buffer or not */
if ((req->flags ^ rqf_last) & CF_MASK_STATIC)
if ((req->flags ^ rqf_last) & (CF_SHUTR|CF_SHUTW))
goto resync_request;
/* perform output updates to the response buffer */