mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2025-09-22 06:11:32 +02:00
Code Issues Projects Releases Wiki Activity

[MINOR] add buffer_check_timeouts() to check what timeouts have fired.

Browse Source 
This new function sets the BF_*_TIMEOUT flags when a buffer timeout
has expired.
This commit is contained in:
Willy Tarreau 2008-09-04 09:14:08 +02:00
parent 534c5a2224
commit 2eb52f012d
1 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
include/proto/buffers.h
View File

@ -64,6 +64,24 @@ static inline int buffer_isfull(const struct buffer *buf) {
return buf->l == BUFSIZE; return buf->l == BUFSIZE;
} }
/* Check buffer timeouts, and set the corresponding flags. The
* likely/unlikely have been optimized for fastest normal path.
*/
static inline void buffer_check_timeouts(struct buffer *b)
{
if (likely(!(b->flags & (BF_SHUTR|BF_READ_TIMEOUT))) &&
unlikely(tick_is_expired(b->rex, now_ms)))
b->flags |= BF_READ_TIMEOUT;
if (likely(!(b->flags & (BF_SHUTW|BF_WRITE_TIMEOUT))) &&
unlikely(tick_is_expired(b->wex, now_ms)))
b->flags |= BF_WRITE_TIMEOUT;
if (likely(!(b->flags & BF_ANA_TIMEOUT)) &&
unlikely(tick_is_expired(b->analyse_exp, now_ms)))
b->flags |= BF_ANA_TIMEOUT;
}
/* flushes any content from buffer <buf> and adjusts flags /* flushes any content from buffer <buf> and adjusts flags
* accordingly. * accordingly.
*/ */