mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2026-03-09 09:01:51 +01:00
Code Issues Projects Releases Wiki Activity

MINOR: listener: use a common thr_idx from the reference listener

Browse Source 
Instead of seeing each listener use its own thr_idx, let's use the same
for all those from a shard. It should provide more accurate and smoother
thread allocation.
This commit is contained in:
Willy Tarreau 2023-03-29 17:02:17 +02:00
parent 9d360604bd
commit b657492680
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/listener.c
View File

@ -1190,6 +1190,7 @@ void listener_accept(struct listener *l)
uint n0, n1, n2, r1, r2, t, t1, t2;
const struct tgroup_info *g1, *g2;
ulong m1, m2;
uint *thr_idx_ptr;
/* The principle is that we have two running indexes,
* each visiting in turn all threads bound to this
@ -1215,7 +1216,8 @@ void listener_accept(struct listener *l)
/* keep a copy for the final update. thr_idx is composite
* and made of (n2<<16) + n1.
*/
n0 = l->thr_idx;
thr_idx_ptr = l->rx.shard_info ? &((struct listener *)(l->rx.shard_info->ref->owner))->thr_idx : &l->thr_idx;
n0 = _HA_ATOMIC_LOAD(thr_idx_ptr);
while (1) {
int q1, q2;
@ -1392,7 +1394,7 @@ void listener_accept(struct listener *l)
n1 += (n2 << 16);
/* try to update the index */
if (likely(_HA_ATOMIC_CAS(&l->thr_idx, &n0, n1)))
if (likely(_HA_ATOMIC_CAS(thr_idx_ptr, &n0, n1)))
break;
} /* end of main while() loop */