RepoMirrors/haproxy
1
0
Fork 0
mirror of http://git.haproxy.org/git/haproxy.git/ synced 2024-12-18 01:14:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

CLEANUP: stream: rename a few remaining occurrences of "stream *sess"

Browse Source 
These are some leftovers from the ancient code where they were still
called sessions, but these areas in the code remain confusing due to
this naming. They were now called "strm" which will not even affect
indenting nor alignment.
This commit is contained in:
Willy Tarreau 2021-03-09 15:43:32 +01:00
parent 57647cac62
commit e89fae3a4e
2 changed files with 15 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
include/haproxy/stream.h
View File

@ -69,7 +69,7 @@ void stream_dump_and_crash(enum obj_type *obj, int rate);
struct ist stream_generate_unique_id(struct stream *strm, struct list *format);
void stream_process_counters(struct stream *s);
void sess_change_server(struct stream *sess, struct server *newsrv);
void sess_change_server(struct stream *strm, struct server *newsrv);
struct task *process_stream(struct task *t, void *context, unsigned int state);
void default_srv_error(struct stream *s, struct stream_interface *si);
@ -280,7 +280,7 @@ static inline void stream_inc_http_fail_ctr(struct stream *s)
}
}
static inline void stream_add_srv_conn(struct stream *sess, struct server *srv)
static inline void stream_add_srv_conn(struct stream *strm, struct server *srv)
{
/* note: this inserts in reverse order but we do not care, it's only
* used for massive kills (i.e. almost never). MT_LIST_ADD() is a bit
@ -288,25 +288,25 @@ static inline void stream_add_srv_conn(struct stream *sess, struct server *srv)
* from a conflict with an adjacent MT_LIST_DEL, and using it improves
* the performance by about 3% on 32-cores.
*/
MT_LIST_ADD(&srv->per_thr[tid].streams, &sess->by_srv);
HA_ATOMIC_STORE(&sess->srv_conn, srv);
MT_LIST_ADD(&srv->per_thr[tid].streams, &strm->by_srv);
HA_ATOMIC_STORE(&strm->srv_conn, srv);
}
static inline void stream_del_srv_conn(struct stream *sess)
static inline void stream_del_srv_conn(struct stream *strm)
{
struct server *srv = sess->srv_conn;
struct server *srv = strm->srv_conn;
if (!srv)
return;
MT_LIST_DEL(&sess->by_srv);
HA_ATOMIC_STORE(&sess->srv_conn, NULL);
MT_LIST_DEL(&strm->by_srv);
HA_ATOMIC_STORE(&strm->srv_conn, NULL);
}
static inline void stream_init_srv_conn(struct stream *sess)
static inline void stream_init_srv_conn(struct stream *strm)
{
sess->srv_conn = NULL;
MT_LIST_INIT(&sess->by_srv);
strm->srv_conn = NULL;
MT_LIST_INIT(&strm->by_srv);
}
static inline void stream_choose_redispatch(struct stream *s)

8
src/stream.c
View File

@ -2532,9 +2532,9 @@ void stream_update_time_stats(struct stream *s)
* expect to be informed about any change in the number of active streams on a
* server.
*/
void sess_change_server(struct stream *sess, struct server *newsrv)
void sess_change_server(struct stream *strm, struct server *newsrv)
{
struct server *oldsrv = sess->srv_conn;
struct server *oldsrv = strm->srv_conn;
if (oldsrv == newsrv)
return;
@ -2545,7 +2545,7 @@ void sess_change_server(struct stream *sess, struct server *newsrv)
__ha_barrier_atomic_store();
if (oldsrv->proxy->lbprm.server_drop_conn)
oldsrv->proxy->lbprm.server_drop_conn(oldsrv, 0);
stream_del_srv_conn(sess);
stream_del_srv_conn(strm);
}
if (newsrv) {
@ -2554,7 +2554,7 @@ void sess_change_server(struct stream *sess, struct server *newsrv)
__ha_barrier_atomic_store();
if (newsrv->proxy->lbprm.server_take_conn)
newsrv->proxy->lbprm.server_take_conn(newsrv, 0);
stream_add_srv_conn(sess, newsrv);
stream_add_srv_conn(strm, newsrv);
}
}