commit 6f5e4b98dfecb8852bda07420680c2028d95d0d2
author Willy Tarreau <w@1wt.eu> Fri Sep 15 09:07:56 2017 +0200
committer Willy Tarreau <w@1wt.eu> Fri Sep 15 11:49:52 2017 +0200
tree 8c9d893351df008d021f91d13dbbb53de3d92b12
parent 2cc5bae0b897a377d9f6e2740a091008fbbe42e3

MEDIUM: session: take care of incrementing/decrementing jobs

Each user of a session increments/decrements the jobs variable at its
own place, resulting in a real mess and inconsistencies between them.
Let's have session_new() increment jobs and session_free() decrement
it.

src/flt_spoe.c

diff --git a/src/flt_spoe.c b/src/flt_spoe.c
index 47aef57..f278809 100644
--- a/src/flt_spoe.c
+++ b/src/flt_spoe.c
@@ -1949,7 +1949,6 @@
 	strm->res.flags |= CF_READ_DONTWAIT;
 
 	conf->agent_fe.feconn++;
-	jobs++;
 	totalconn++;
 
 	task_wakeup(SPOE_APPCTX(appctx)->task, TASK_WOKEN_INIT);

src/hlua.c

diff --git a/src/hlua.c b/src/hlua.c
index acf5896..e1b7264 100644
--- a/src/hlua.c
+++ b/src/hlua.c
@@ -2415,7 +2415,6 @@
 
 	/* Update statistics counters. */
 	socket_proxy.feconn++; /* beconn will be increased later */
-	jobs++;
 	totalconn++;
 
 	task_wakeup(strm->task, TASK_WOKEN_INIT);

src/listener.c

diff --git a/src/listener.c b/src/listener.c
index d193b51..0af49b0 100644
--- a/src/listener.c
+++ b/src/listener.c
@@ -527,7 +527,6 @@
 			actconn++;
 		}
 
-		jobs++;
 		totalconn++;
 		l->nbconn++;
 
@@ -545,7 +544,6 @@
 			 */
 			if (!(l->options & LI_O_UNLIMITED))
 				actconn--;
-			jobs--;
 			l->nbconn--;
 			if (ret == 0) /* successful termination */
 				continue;

src/peers.c

diff --git a/src/peers.c b/src/peers.c
index 8fb3b78..17f1867 100644
--- a/src/peers.c
+++ b/src/peers.c
@@ -1836,7 +1836,6 @@
 	s->res.flags |= CF_READ_DONTWAIT;
 
 	p->feconn++;/* beconn will be increased later */
-	jobs++;
 	totalconn++;
 
 	peer->appctx = appctx;

src/session.c

diff --git a/src/session.c b/src/session.c
index c86baff..68a4303 100644
--- a/src/session.c
+++ b/src/session.c
@@ -53,6 +53,7 @@
 		memset(sess->stkctr, 0, sizeof(sess->stkctr));
 		vars_init(&sess->vars, SCOPE_SESS);
 		sess->task = NULL;
+		jobs++;
 	}
 	return sess;
 }
@@ -64,6 +65,7 @@
 	session_store_counters(sess);
 	vars_prune_per_sess(&sess->vars);
 	pool_free2(pool2_session, sess);
+	jobs--;
 }
 
 /* perform minimal intializations, report 0 in case of error, 1 if OK. */
@@ -377,7 +379,6 @@
 
 	if (!(sess->listener->options & LI_O_UNLIMITED))
 		actconn--;
-	jobs--;
 	sess->listener->nbconn--;
 	if (sess->listener->state == LI_FULL)
 		resume_listener(sess->listener);

src/stream.c

diff --git a/src/stream.c b/src/stream.c
index e9d6400..d8c1a7e 100644
--- a/src/stream.c
+++ b/src/stream.c
@@ -2420,7 +2420,7 @@
 	sess->fe->feconn--;
 	if (s->flags & SF_BE_ASSIGNED)
 		s->be->beconn--;
-	jobs--;
+
 	if (sess->listener) {
 		if (!(sess->listener->options & LI_O_UNLIMITED))
 			actconn--;