mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2025-11-14 07:21:01 +01:00
Code Issues Projects Releases Wiki Activity

MEDIUM: sessions: 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:54:34 +01:00 committed by Olivier Houchard
parent b4df492d01
commit d5b3d30b60
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/session.c
View File

@ -55,8 +55,8 @@ struct session *session_new(struct proxy *fe, struct listener *li, enum obj_type
vars_init(&sess->vars, SCOPE_SESS); vars_init(&sess->vars, SCOPE_SESS);
sess->task = NULL; sess->task = NULL;
sess->t_handshake = -1; /* handshake not done yet */ sess->t_handshake = -1; /* handshake not done yet */
HA_ATOMIC_ADD(&totalconn, 1); _HA_ATOMIC_ADD(&totalconn, 1);
HA_ATOMIC_ADD(&jobs, 1); _HA_ATOMIC_ADD(&jobs, 1);
LIST_INIT(&sess->srv_list); LIST_INIT(&sess->srv_list);
sess->idle_conns = 0; sess->idle_conns = 0;
} }
@ -97,7 +97,7 @@ void session_free(struct session *sess)
pool_free(pool_head_sess_srv_list, srv_list); pool_free(pool_head_sess_srv_list, srv_list);
} }
pool_free(pool_head_session, sess); pool_free(pool_head_session, sess);
HA_ATOMIC_SUB(&jobs, 1); _HA_ATOMIC_SUB(&jobs, 1);
} }
/* callback used from the connection/mux layer to notify that a connection is /* callback used from the connection/mux layer to notify that a connection is