From 9280d2cf0d7d514cc2a3aaf76608d8e053d287bc Mon Sep 17 00:00:00 2001 From: Dmitry Kozlov Date: Sat, 21 Feb 2015 14:31:34 +0300 Subject: session: implemented idle and timeout timers --- accel-pppd/include/ap_session.h | 4 ++++ accel-pppd/session.c | 37 +++++++++++++++++++++++++++++++++++++ 2 files changed, 41 insertions(+) diff --git a/accel-pppd/include/ap_session.h b/accel-pppd/include/ap_session.h index 12f2937..41155f1 100644 --- a/accel-pppd/include/ap_session.h +++ b/accel-pppd/include/ap_session.h @@ -96,6 +96,10 @@ struct ap_session struct list_head pd_list; + int idle_timeout; + int session_timeout; + struct triton_timer_t timer; + uint32_t acct_rx_bytes; uint32_t acct_tx_bytes; uint32_t acct_input_gigawords; diff --git a/accel-pppd/session.c b/accel-pppd/session.c index dd7ffd4..da18e43 100644 --- a/accel-pppd/session.c +++ b/accel-pppd/session.c @@ -118,6 +118,27 @@ int __export ap_session_starting(struct ap_session *ses) return 0; } +static void ap_session_timer(struct triton_timer_t *t) +{ + struct timespec ts; + struct ap_session *ses = container_of(t, typeof(*ses), timer); + + if (ap_session_read_stats(ses, NULL)) + ap_session_terminate(ses, TERM_NAS_ERROR, 0); + + clock_gettime(CLOCK_MONOTONIC, &ts); + + if (ses->idle_timeout && ts.tv_sec - ses->idle_time >= ses->idle_timeout) { + log_ppp_msg("idle timeout\n"); + ap_session_terminate(ses, TERM_SESSION_TIMEOUT, 0); + } else if (ses->session_timeout) { + if (ts.tv_sec - ses->start_time >= ses->session_timeout) { + log_ppp_msg("session timeout\n"); + ap_session_terminate(ses, TERM_SESSION_TIMEOUT, 0); + } + } +} + void __export ap_session_activate(struct ap_session *ses) { if (ap_shutdown) @@ -132,6 +153,16 @@ void __export ap_session_activate(struct ap_session *ses) __sync_sub_and_fetch(&ap_session_stat.starting, 1); __sync_add_and_fetch(&ap_session_stat.active, 1); + if (ses->idle_timeout) { + ses->timer.expire = ap_session_timer; + ses->timer.period = 60000; + triton_timer_add(ses->ctrl->ctx, &ses->timer, 0); + } else if (ses->session_timeout) { + ses->timer.expire = ap_session_timer; + ses->timer.expire_tv.tv_sec = ses->session_timeout; + triton_timer_add(ses->ctrl->ctx, &ses->timer, 0); + } + #ifdef USE_BACKUP if (!ses->backup) backup_save_session(ses); @@ -197,6 +228,9 @@ void __export ap_session_finished(struct ap_session *ses) ses->ifname_rename = NULL; } + if (ses->timer.tpd) + triton_timer_del(&ses->timer); + #ifdef USE_BACKUP if (ses->backup) ses->backup->storage->free(ses->backup); @@ -221,6 +255,9 @@ void __export ap_session_terminate(struct ap_session *ses, int cause, int hard) if (!ses->terminate_cause) ses->terminate_cause = cause; + if (ses->timer.tpd) + triton_timer_del(&ses->timer); + if (ses->terminating) { if (hard) ses->ctrl->terminate(ses, hard); -- cgit v1.2.3