Kill the recursion in olsr_get_timer() with a trivial core reorganization.
[olsrd.git] / src / scheduler.h
1
2 /*
3  * The olsr.org Optimized Link-State Routing daemon(olsrd)
4  * Copyright (c) 2004, Andreas T√łnnesen(andreto@olsr.org)
5  * Timer rewrite (c) 2008, Hannes Gredler (hannes@gredler.at)
6  * All rights reserved.
7  *
8  * Redistribution and use in source and binary forms, with or without 
9  * modification, are permitted provided that the following conditions 
10  * are met:
11  *
12  * * Redistributions of source code must retain the above copyright 
13  *   notice, this list of conditions and the following disclaimer.
14  * * Redistributions in binary form must reproduce the above copyright 
15  *   notice, this list of conditions and the following disclaimer in 
16  *   the documentation and/or other materials provided with the 
17  *   distribution.
18  * * Neither the name of olsr.org, olsrd nor the names of its 
19  *   contributors may be used to endorse or promote products derived 
20  *   from this software without specific prior written permission.
21  *
22  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 
23  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 
24  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS 
25  * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE 
26  * COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, 
27  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, 
28  * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; 
29  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER 
30  * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 
31  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN 
32  * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE 
33  * POSSIBILITY OF SUCH DAMAGE.
34  *
35  * Visit http://www.olsr.org for more information.
36  *
37  * If you find this software useful feel free to make a donation
38  * to the project. For more information see the website or contact
39  * the copyright holders.
40  *
41  */
42
43
44 #ifndef _OLSR_SCHEDULER
45 #define _OLSR_SCHEDULER
46
47 #include "common/list.h"
48
49 #include "olsr_types.h"
50
51 #include <time.h>
52
53 #define TIMER_WHEEL_SLOTS 256
54 #define TIMER_WHEEL_MASK (TIMER_WHEEL_SLOTS - 1)
55
56 /* Some defs for juggling with timers */
57 #define MSEC_PER_SEC 1000
58 #define USEC_PER_SEC 1000000
59 #define NSEC_PER_USEC 1000
60 #define USEC_PER_MSEC 1000
61
62 typedef void (*timer_cb_func)(void *);         /* callback function */
63
64 /*
65  * Our timer implementation is a based on individual timers arranged in
66  * a double linked list hanging of hash containers called a timer wheel slot.
67  * For every timer a timer_entry is created and attached to the timer wheel slot.
68  * When the timer fires, the timer_cb function is called with the
69  * context pointer.
70  * The implementation supports periodic and oneshot timers.
71  * For a periodic timer the timer_period field is set to non zero,
72  * which causes the timer to run forever until manually stopped.
73  */
74 struct timer_entry {
75   struct list_node timer_list;         /* memory pooling, or wheel membership */
76   clock_t timer_clock;                 /* when timer shall fire (absolute time) */
77   unsigned int timer_period;           /* set for periodical timers (relative time) */
78   olsr_cookie_t timer_cookie;          /* used for diag stuff */
79   olsr_u8_t timer_jitter_pct;          /* the jitter expressed in percent */
80   olsr_u8_t timer_flags;               /* misc flags */
81   unsigned int timer_random;           /* cache random() result for performance reasons */
82   timer_cb_func timer_cb;              /* callback function */
83   void *timer_cb_context;              /* context pointer */
84 };
85
86 /* inline to recast from timer_list back to timer_entry */
87 LISTNODE2STRUCT(list2timer, struct timer_entry, timer_list);
88
89 #define OLSR_TIMER_ONESHOT    0 /* One shot timer */
90 #define OLSR_TIMER_PERIODIC   1 /* Periodic timer */
91
92 /* Timer flags */
93 #define OLSR_TIMER_RUNNING  ( 1 << 0)   /* this timer is running */
94
95 /* Memory pooling */
96 #define OLSR_TIMER_MEMORY_CHUNK 100     /* timers per chunk */
97
98 /* Timers */
99 void olsr_init_timers(void);
100 void olsr_set_timer(struct timer_entry **, unsigned int, olsr_u8_t, olsr_bool,
101                     timer_cb_func, void *, olsr_cookie_t);
102 struct timer_entry *olsr_start_timer(unsigned int, olsr_u8_t, olsr_bool,
103                                      timer_cb_func, void *, olsr_cookie_t);
104 void olsr_change_timer(struct timer_entry *, unsigned int, olsr_u8_t, olsr_bool);
105 void olsr_stop_timer(struct timer_entry *);
106
107 /* Printing timestamps */
108 const char *olsr_clock_string(clock_t);
109 const char *olsr_wallclock_string(void);
110
111 /* Main scheduler loop */
112 void olsr_scheduler(void);
113
114 /*
115  * Provides a timestamp s1 milliseconds in the future according
116  * to system ticks returned by times(2)
117  * We cast the result of the division to clock_t. That serves two purposes:
118  * - it workarounds numeric underflows if the pollrate is <= 0.5
119  * - since we add "now_times" which is an integer, users (hopefully) expect
120  *   to get integeres as result (which is without the cast not guaranteed)
121  */
122 #define GET_TIMESTAMP(s1)       (now_times + (clock_t)((s1) / olsr_cnf->system_tick_divider))
123
124 /* Compute the time in milliseconds when a timestamp will expire. */
125 #define TIME_DUE(s1)    ((long)((s1) * olsr_cnf->system_tick_divider) - now_times)
126
127 /* Returns TRUE if a timestamp is expired */
128 #define TIMED_OUT(s1)   ((long)((s1) - now_times) < 0)
129
130 /* Timer data */
131 extern clock_t now_times; /* current idea of times(2) reported uptime */
132
133
134 #define SP_PR_READ              0x01
135 #define SP_PR_WRITE             0x02
136
137 #define SP_IMM_READ             0x04
138 #define SP_IMM_WRITE            0x08
139
140
141 typedef void (*socket_handler_func)(int fd, void *data, unsigned int flags);
142
143
144 struct olsr_socket_entry {
145   int fd;
146   socket_handler_func process_immediate;
147   socket_handler_func process_pollrate;
148   void *data;
149   unsigned int flags;
150   struct olsr_socket_entry *next;
151 };
152
153 void add_olsr_socket(int fd, socket_handler_func pf_pr, socket_handler_func pf_imm, void *data, unsigned int flags);
154 int remove_olsr_socket(int fd, socket_handler_func pf_pr, socket_handler_func pf_imm);
155 void enable_olsr_socket(int fd, socket_handler_func pf_pr, socket_handler_func pf_imm, unsigned int flags);
156 void disable_olsr_socket(int fd, socket_handler_func pf_pr, socket_handler_func pf_imm, unsigned int flags);
157
158 /*
159  * a wrapper around times(2). times(2) has the problem, that it may return -1
160  * in case of an err (e.g. EFAULT on the parameter) or immediately before an
161  * overrun (though it is not en error) just because the jiffies (or whatever
162  * the underlying kernel calls the smallest accountable time unit) are
163  * inherently "unsigned" (and always incremented).
164  */
165 unsigned long olsr_times(void);
166
167
168 #endif
169
170 /*
171  * Local Variables:
172  * c-basic-offset: 2
173  * End:
174  */