]> git.netwichtig.de Git - user/henk/code/inspircd.git/blob - src/timer.cpp
Add timeouts to the http module. Two seperate timeouts, 60 seconds to receive headers...
[user/henk/code/inspircd.git] / src / timer.cpp
1 /*       +------------------------------------+
2  *       | Inspire Internet Relay Chat Daemon |
3  *       +------------------------------------+
4  *
5  *  InspIRCd is copyright (C) 2002-2006 ChatSpike-Dev.
6  *                       E-mail:
7  *                <brain@chatspike.net>
8  *                <Craig@chatspike.net>
9  *     
10  * Written by Craig Edwards, Craig McLure, and others.
11  * This program is free but copyrighted software; see
12  *            the file COPYING for details.
13  *
14  * ---------------------------------------------------
15  */
16
17 #include "inspircd.h"
18 #include "timer.h"
19
20 void TimerManager::TickTimers(time_t TIME)
21 {
22         timerlist::iterator found = Timers.find(TIME);
23
24         if (found != Timers.end())
25         {
26                 timergroup* x = found->second;
27                 /*
28                  * There are pending timers to trigger
29                  */
30                 for (timergroup::iterator y = x->begin(); y != x->end(); y++)
31                 {
32                         InspTimer* n = *y;
33                         n->Tick(TIME);
34                         DELETE(n);
35                 }
36
37                 Timers.erase(found);
38                 DELETE(x);
39         }
40 }
41
42 void TimerManager::DelTimer(InspTimer* T)
43 {
44         timerlist::iterator found = Timers.find(T->GetTimer());
45
46         if (found != Timers.end())
47         {
48                 timergroup* x = found->second;
49                 for (timergroup::iterator y = x->begin(); y != x->end(); y++)
50                 {
51                         InspTimer* n = *y;
52                         if (n == T)
53                         {
54                                 DELETE(n);
55                                 x->erase(y);
56                                 if (!x->size())
57                                         Timers.erase(found);
58                                 return;
59                         }
60                 }
61         }
62 }
63
64 /*
65  * Because some muppets may do odd things, and their ircd may lock up due
66  * to crappy 3rd party modules, or they may change their system time a bit,
67  * this accounts for shifts of up to 120 secs by looking behind for missed
68  * timers and executing them. This is only executed once every 5 secs.
69  * If you move your clock BACK, and your timers move further ahead as a result,
70  * then tough titty you'll just have to wait.
71  */
72 void TimerManager::TickMissedTimers(time_t TIME)
73 {
74         for (time_t n = TIME-1; n > TIME-120; n--)
75         {
76                 timerlist::iterator found = Timers.find(n);
77                 if (found != Timers.end())
78                 {
79                         timergroup* x = found->second;
80                         for (timergroup::iterator y = x->begin(); y != x->end(); y++)
81                         {
82                                 InspTimer* z = *y;
83                                 z->Tick(TIME);
84                                 DELETE(z);
85                         }
86
87                         Timers.erase(found);
88                         DELETE(x);
89                 }
90         }
91 }
92
93 void TimerManager::AddTimer(InspTimer* T)
94 {
95         timergroup* x = NULL;
96
97         timerlist::iterator found = Timers.find(T->GetTimer());
98         
99         if (found != Timers.end())
100         {
101                 x = found->second;
102         }
103         else
104         {
105                 x = new timergroup;
106                 Timers[T->GetTimer()] = x;
107         }
108
109         x->push_back(T);
110 }
111