From 349cfa7acb95abe865209a28e417ec74b56f9bba Mon Sep 17 00:00:00 2001 From: Alberto Gonzalez Iniesta Date: Tue, 21 Feb 2012 15:53:40 +0100 Subject: Imported Upstream version 2.2.1 --- interval.c | 77 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 77 insertions(+) create mode 100644 interval.c (limited to 'interval.c') diff --git a/interval.c b/interval.c new file mode 100644 index 0000000..44d59d0 --- /dev/null +++ b/interval.c @@ -0,0 +1,77 @@ +/* + * OpenVPN -- An application to securely tunnel IP networks + * over a single TCP/UDP port, with support for SSL/TLS-based + * session authentication and key exchange, + * packet encryption, packet authentication, and + * packet compression. + * + * Copyright (C) 2002-2010 OpenVPN Technologies, Inc. + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License version 2 + * as published by the Free Software Foundation. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program (see the file COPYING included with this + * distribution); if not, write to the Free Software Foundation, Inc., + * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + */ + +#include "syshead.h" + +#include "interval.h" + +#include "memdbg.h" + +void +interval_init (struct interval *top, int horizon, int refresh) +{ + CLEAR (*top); + top->refresh = refresh; + top->horizon = horizon; +} + +bool +event_timeout_trigger (struct event_timeout *et, + struct timeval *tv, + const int et_const_retry) +{ + bool ret = false; + const time_t local_now = now; + + if (et->defined) + { + int wakeup = (int) et->last + et->n - local_now; + if (wakeup <= 0) + { +#if INTERVAL_DEBUG + dmsg (D_INTERVAL, "EVENT event_timeout_trigger (%d) etcr=%d", et->n, et_const_retry); +#endif + if (et_const_retry < 0) + { + et->last = local_now; + wakeup = et->n; + ret = true; + } + else + { + wakeup = et_const_retry; + } + } + + if (tv && wakeup < tv->tv_sec) + { +#if INTERVAL_DEBUG + dmsg (D_INTERVAL, "EVENT event_timeout_wakeup (%d/%d) etcr=%d", wakeup, et->n, et_const_retry); +#endif + tv->tv_sec = wakeup; + tv->tv_usec = 0; + } + } + return ret; +} -- cgit v1.2.3