mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2026-05-04 12:41:00 +02:00
Code Issues Projects Releases Wiki Activity

MEDIUM: vars: Use the new _HA_ATOMIC_* macros.

Browse Source 
Use the new _HA_ATOMIC_* macros and add barriers where needed.
This commit is contained in:
Olivier Houchard 2019-03-08 18:55:38 +01:00 committed by Olivier Houchard
parent cab0f0b418
commit 25ad13f9a0
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/vars.c
View File

@ -44,17 +44,17 @@ static void var_accounting_diff(struct vars *vars, struct session *sess, struct
switch (vars->scope) {
case SCOPE_REQ:
case SCOPE_RES:
HA_ATOMIC_ADD(&strm->vars_reqres.size, size);
_HA_ATOMIC_ADD(&strm->vars_reqres.size, size);
/* fall through */
case SCOPE_TXN:
HA_ATOMIC_ADD(&strm->vars_txn.size, size);
_HA_ATOMIC_ADD(&strm->vars_txn.size, size);
/* fall through */
case SCOPE_SESS:
HA_ATOMIC_ADD(&sess->vars.size, size);
_HA_ATOMIC_ADD(&sess->vars.size, size);
/* fall through */
case SCOPE_PROC:
HA_ATOMIC_ADD(&global.vars.size, size);
HA_ATOMIC_ADD(&var_global_size, size);
_HA_ATOMIC_ADD(&global.vars.size, size);
_HA_ATOMIC_ADD(&var_global_size, size);
}
}
@ -140,9 +140,9 @@ void vars_prune_per_sess(struct vars *vars)
}
HA_RWLOCK_WRUNLOCK(VARS_LOCK, &vars->rwlock);
HA_ATOMIC_SUB(&vars->size, size);
HA_ATOMIC_SUB(&global.vars.size, size);
HA_ATOMIC_SUB(&var_global_size, size);
_HA_ATOMIC_SUB(&vars->size, size);
_HA_ATOMIC_SUB(&global.vars.size, size);
_HA_ATOMIC_SUB(&var_global_size, size);
}
/* This function init a list of variabes. */