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
150
151
152
153
154
|
#include <time.h>
#include <assert.h>
#include <stdlib.h>
#include <string.h>
#include <sys/time.h>
#include <signal.h>
#ifdef __WIN32__
# include <time.h>
#endif
#include "main.h"
#include "list.h"
#include "myTimer.h"
#ifndef PUBLIC_SERVER
# include "interface.h"
#endif
static struct timeval my_start = {.tv_sec = 0,.tv_usec = 0 };
list_t *newTimer()
{
return newList();
}
void restartTimer()
{
gettimeofday(&my_start, NULL);
}
my_time_t getMyTime()
{
struct timeval now;
my_time_t ticks;
if (my_start.tv_sec == 0 && my_start.tv_usec == 0)
restartTimer();
gettimeofday(&now, NULL);
ticks = (now.tv_sec - my_start.tv_sec) * 1000 + (now.tv_usec - my_start.tv_usec) / 1000;
//printf("-> %d\n", ticks);
return ticks;
}
my_time_t getMyTimeMicro()
{
static struct timeval my_micro_start = {.tv_sec = 0,.tv_usec = 0 };
struct timeval now;
my_time_t ticks;
if (my_micro_start.tv_sec == 0 && my_micro_start.tv_usec == 0)
gettimeofday(&my_micro_start, NULL);
gettimeofday(&now, NULL);
ticks = (now.tv_sec - my_micro_start.tv_sec) * 1000 * 1000 + (now.tv_usec - my_micro_start.tv_usec);
//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(!_("Timer is really weirdly set!"));
break;
}
}
}
void delTimer(list_t * listTimer, int id)
{
my_timer_t *thisTimer;
int i;
for (i = 0; i < listTimer->count; i++) {
thisTimer = (my_timer_t *) listTimer->list[i];
assert(thisTimer != NULL);
if (thisTimer->id == (unsigned)id) {
delListItem(listTimer, i, free);
return;
}
}
assert(!_("There is no such ID!"));
}
void destroyTimer(list_t * listTimer)
{
destroyListItem(listTimer, destroyTimerItem);
}
|