1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
|
#include <time.h>
#include <assert.h>
#include <stdlib.h>
#include <string.h>
#include <sys/time.h>
#include <signal.h>
#include "main.h"
#include "list.h"
#include "myTimer.h"
#ifndef PUBLIC_SERVER
#include "interface.h"
#endif
static struct timeval start = { .tv_sec = 0, .tv_usec = 0 };
list_t* newTimer()
{
return newList();
}
void restartTimer()
{
gettimeofday(&start, NULL);
}
my_time_t getMyTime()
{
struct timeval now;
my_time_t ticks;
if( start.tv_sec == 0 && start.tv_usec == 0 )
{
restartTimer();
}
gettimeofday(&now, NULL);
ticks = (now.tv_sec-start.tv_sec)*1000+(now.tv_usec-start.tv_usec)/1000;
//printf("-> %d\n", ticks);
return ticks;
}
my_timer_t* newTimerItem(int type, void (*fce)(void *p), void *arg, my_time_t my_time)
{
static int new_id = 0;
my_timer_t *new;
assert( fce != NULL );
new = malloc( sizeof(my_timer_t) );
memset(new, 0, sizeof(my_timer_t));
new->id = new_id++;
new->type = type;
new->fce = fce;
new->arg = arg;
new->createTime = getMyTime();
new->time = my_time;
return new;
}
static void destroyTimerItem(my_timer_t *p)
{
assert( p != NULL );
free(p);
}
int addTaskToTimer(list_t *listTimer, int type, void (*fce)(void *p), void *arg, my_time_t my_time)
{
my_timer_t *new;
new = newTimerItem(type, fce, arg, my_time);
addList(listTimer, new);
return new->id;
}
void eventTimer(list_t *listTimer)
{
int i;
my_timer_t *thisTimer;
my_time_t currentTime;
currentTime = getMyTime();
for( i = 0 ; i < listTimer->count ; i++ )
{
thisTimer = (my_timer_t *)listTimer->list[i];
assert( thisTimer != NULL );
switch( thisTimer->type )
{
case TIMER_ONE:
if( currentTime >= thisTimer->createTime + thisTimer->time )
{
thisTimer->fce(thisTimer->arg);
delListItem(listTimer, i, free);
i--;
}
break;
case TIMER_PERIODIC:
if( currentTime >= thisTimer->createTime + thisTimer->time )
{
thisTimer->fce(thisTimer->arg);
thisTimer->createTime = getMyTime();
}
break;
default :
assert( ! "bad timer type !" );
break;
}
}
}
void delTimer(list_t *listTimer, int id)
{
int i;
my_timer_t *thisTimer;
for( i = 0 ; i < listTimer->count ; i++ )
{
thisTimer = (my_timer_t *)listTimer->list[i];
assert( thisTimer != NULL );
if( thisTimer->id == id )
{
delListItem(listTimer, i, free);
return;
}
}
assert( ! "Uloha s id nenajdena !" );
}
void destroyTimer(list_t *listTimer)
{
destroyListItem(listTimer, destroyTimerItem);
}
|