upstream/haproxy
1
0
Fork 0
mirror of https://github.com/haproxy/haproxy.git synced 2026-04-21 06:06:59 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 6

MEDIUM: fd: Wait if locked in fd_grab_tgid() and fd_take_tgid().

Browse source 
Wait while the tgid is locked in fd_grab_tgid() and fd_take_tgid().
As that lock is barely used, it should have no impact.
This commit is contained in:
Olivier Houchard 2025-01-29 16:51:40 +01:00 committed by Olivier Houchard
parent 814b5dfe30
commit 52b97ff8dd
1 changed files with 9 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
include/haproxy/fd.h
View file

@ -373,6 +373,10 @@ static inline uint fd_take_tgid(int fd)
uint old;
old = _HA_ATOMIC_FETCH_ADD(&fdtab[fd].refc_tgid, 0x10000) & 0xffff;
while (old & 0x8000) {
old = _HA_ATOMIC_LOAD(&fdtab[fd].refc_tgid) & 0xffff;
__ha_cpu_relax();
}
if (likely(old))
return old;
HA_ATOMIC_SUB(&fdtab[fd].refc_tgid, 0x10000);
@ -398,6 +402,11 @@ static inline uint fd_grab_tgid(int fd, uint desired_tgid)
uint old;
old = _HA_ATOMIC_FETCH_ADD(&fdtab[fd].refc_tgid, 0x10000) & 0xffff;
/* If the tgid is locked, wait until it no longer is */
while (old & 0x8000) {
old = _HA_ATOMIC_LOAD(&fdtab[fd].refc_tgid) & 0xffff;
__ha_cpu_relax();
}
if (likely(old == desired_tgid))
return 1;
HA_ATOMIC_SUB(&fdtab[fd].refc_tgid, 0x10000);