From c19cc669d01b7720add8c80a47947a5c43ed12fc Mon Sep 17 00:00:00 2001 From: Guus Sliepen Date: Fri, 14 Jan 2011 20:35:40 +0100 Subject: [PATCH] Add a copy of tinc 1.0's event infrastructure. --- src/event.c | 109 ++++++++++++++++++++++++++++++++++++++++++++++++++++ src/event.h | 46 ++++++++++++++++++++++ 2 files changed, 155 insertions(+) create mode 100644 src/event.c create mode 100644 src/event.h diff --git a/src/event.c b/src/event.c new file mode 100644 index 0000000..36dab9f --- /dev/null +++ b/src/event.c @@ -0,0 +1,109 @@ +/* + event.c -- event queue + Copyright (C) 2002-2009 Guus Sliepen , + 2002-2005 Ivo Timmermans + + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + 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; if not, write to the Free Software Foundation, Inc., + 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. +*/ + +#include "system.h" + +#include "splay_tree.h" +#include "event.h" +#include "utils.h" +#include "xalloc.h" + +splay_tree_t *event_tree; + +int id; + +static int event_compare(const event_t *a, const event_t *b) { + if(a->time > b->time) + return 1; + + if(a->time < b->time) + return -1; + + return a->id - b->id; +} + +void init_events(void) { + event_tree = splay_alloc_tree((splay_compare_t) event_compare, (splay_action_t) free_event); +} + +void exit_events(void) { + splay_delete_tree(event_tree); +} + +void expire_events(void) { + splay_node_t *node; + event_t *event; + time_t diff; + + /* + * Make all events appear expired by substracting the difference between + * the expiration time of the last event and the current time. + */ + + if(!event_tree->tail) + return; + + event = event_tree->tail->data; + time_t now = time(NULL); + + if(event->time < now) + return; + + diff = 1 + event->time - now; + + for(node = event_tree->head; node; node = node->next) { + event = node->data; + event->time -= diff; + } +} + +event_t *new_event(void) { + return xmalloc_and_zero(sizeof(event_t)); +} + +void free_event(event_t *event) { + free(event); +} + +void event_add(event_t *event) { + event->id = ++id; + splay_insert(event_tree, event); +} + +void event_del(event_t *event) { + splay_delete(event_tree, event); +} + +event_t *get_expired_event(void) { + event_t *event; + + if(event_tree->head) { + event = event_tree->head->data; + + if(event->time < time(NULL)) { + splay_node_t *node = event_tree->head; + splay_unlink_node(event_tree, node); + free(node); + return event; + } + } + + return NULL; +} diff --git a/src/event.h b/src/event.h new file mode 100644 index 0000000..b823c72 --- /dev/null +++ b/src/event.h @@ -0,0 +1,46 @@ +/* + event.h -- header for event.c + Copyright (C) 2002-2009 Guus Sliepen , + 2002-2005 Ivo Timmermans + + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + 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; if not, write to the Free Software Foundation, Inc., + 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. +*/ + +#ifndef __TINC_EVENT_H__ +#define __TINC_EVENT_H__ + +#include "splay_tree.h" + +extern splay_tree_t *event_tree; + +typedef void (*event_handler_t)(void *); + +typedef struct event { + time_t time; + int id; + event_handler_t handler; + void *data; +} event_t; + +extern void init_events(void); +extern void exit_events(void); +extern void expire_events(void); +extern event_t *new_event(void) __attribute__ ((__malloc__)); +extern void free_event(event_t *); +extern void event_add(event_t *); +extern void event_del(event_t *); +extern event_t *get_expired_event(void); + +#endif /* __TINC_EVENT_H__ */ -- 2.25.1