summaryrefslogtreecommitdiff
path: root/accel-pppd/ctrl/l2tp/l2tp.c
diff options
context:
space:
mode:
authorGuillaume Nault <g.nault@alphalink.fr>2014-02-06 17:23:53 +0100
committerDmitry Kozlov <xeb@mail.ru>2014-02-08 09:31:00 +0400
commit4654e90f1903756523808afd6a00112060c67dc2 (patch)
treee8ea009616612b1bfedd3a90fe6941c463b7f9eb /accel-pppd/ctrl/l2tp/l2tp.c
parentea57a3932621e89d7ca206dc8354fbb9f6596f3e (diff)
downloadaccel-ppp-4654e90f1903756523808afd6a00112060c67dc2.tar.gz
accel-ppp-4654e90f1903756523808afd6a00112060c67dc2.zip
l2tp: add session statistics for control channels
Compute control channel statistics for L2TP sessions and report them in the "show stat" command. Signed-off-by: Guillaume Nault <g.nault@alphalink.fr>
Diffstat (limited to 'accel-pppd/ctrl/l2tp/l2tp.c')
-rw-r--r--accel-pppd/ctrl/l2tp/l2tp.c20
1 files changed, 20 insertions, 0 deletions
diff --git a/accel-pppd/ctrl/l2tp/l2tp.c b/accel-pppd/ctrl/l2tp/l2tp.c
index dd132a7b..3cb2acbe 100644
--- a/accel-pppd/ctrl/l2tp/l2tp.c
+++ b/accel-pppd/ctrl/l2tp/l2tp.c
@@ -78,6 +78,10 @@ static unsigned int stat_conn_starting;
static unsigned int stat_conn_active;
static unsigned int stat_conn_finishing;
+static unsigned int stat_sess_starting;
+static unsigned int stat_sess_active;
+static unsigned int stat_sess_finishing;
+
static unsigned int stat_active;
static unsigned int stat_starting;
static unsigned int stat_finishing;
@@ -642,6 +646,8 @@ static void __session_destroy(struct l2tp_sess_t *sess)
mempool_free(sess);
+ __sync_sub_and_fetch(&stat_sess_finishing, 1);
+
/* Now that the session is fully destroyed,
* drop the reference to the tunnel.
*/
@@ -671,11 +677,16 @@ static void l2tp_session_free(struct l2tp_sess_t *sess)
case STATE_WAIT_OCRP:
case STATE_WAIT_OCCN:
log_session(log_info2, sess, "deleting session\n");
+
+ __sync_sub_and_fetch(&stat_sess_starting, 1);
+ __sync_add_and_fetch(&stat_sess_finishing, 1);
break;
case STATE_ESTB:
log_session(log_info2, sess, "deleting session\n");
triton_event_fire(EV_CTRL_FINISHED, &sess->ppp.ses);
+ __sync_sub_and_fetch(&stat_sess_active, 1);
+ __sync_add_and_fetch(&stat_sess_finishing, 1);
pthread_mutex_lock(&sess->apses_lock);
if (sess->apses_ctx.tpd)
@@ -1116,6 +1127,8 @@ static struct l2tp_sess_t *l2tp_tunnel_alloc_session(struct l2tp_conn_t *conn)
tunnel_hold(conn);
session_hold(sess);
+ __sync_add_and_fetch(&stat_sess_starting, 1);
+
return sess;
}
@@ -1520,6 +1533,8 @@ static int l2tp_session_connect(struct l2tp_sess_t *sess)
}
triton_event_fire(EV_CTRL_STARTED, &sess->ppp.ses);
+ __sync_sub_and_fetch(&stat_sess_starting, 1);
+ __sync_add_and_fetch(&stat_sess_active, 1);
sess->state1 = STATE_ESTB;
if (l2tp_session_start_data_channel(sess) < 0) {
@@ -3935,6 +3950,11 @@ static int show_stat_exec(const char *cmd, char * const *fields, int fields_cnt,
cli_sendv(client, " active: %u\r\n", stat_conn_active);
cli_sendv(client, " finishing: %u\r\n", stat_conn_finishing);
+ cli_send(client, " sessions (control channels):\r\n");
+ cli_sendv(client, " starting: %u\r\n", stat_sess_starting);
+ cli_sendv(client, " active: %u\r\n", stat_sess_active);
+ cli_sendv(client, " finishing: %u\r\n", stat_sess_finishing);
+
cli_send(client, " sessions (data channels):\r\n");
cli_sendv(client, " starting: %u\r\n", stat_starting);
cli_sendv(client, " active: %u\r\n", stat_active);