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
155
156
157
|
#include <time.h>
#include <assert.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/time.h>
#include <signal.h>
#ifdef __WIN32__
#include <time.h>
#endif /* __WIN32__ */
#include "main.h"
#include "list.h"
#include "myTimer.h"
#ifndef PUBLIC_SERVER
#include "interface.h"
#endif /* PUBLIC_SERVER */
static struct timeval my_start = {.tv_sec = 0, .tv_usec = 0};
list_t *timer_new()
{
return list_new();
}
void timer_restart()
{
gettimeofday(&my_start, NULL);
}
my_time_t timer_get_current_time()
{
struct timeval now;
my_time_t ticks;
if (my_start.tv_sec == 0 && my_start.tv_usec == 0) {
timer_restart();
}
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 timer_get_current_timeMicro()
{
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 *timer_newItem(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 = timer_get_current_time();
new->time = my_time;
return new;
}
static void timer_destroyItem(my_timer_t *p)
{
assert(p != NULL);
free(p);
}
int timer_add_task(list_t *listTimer, int type, void (*fce) (void *p), void *arg, my_time_t my_time)
{
my_timer_t *new;
new = timer_newItem(type, fce, arg, my_time);
list_add(listTimer, new);
return new->id;
}
void timer_event(list_t *listTimer)
{
int i;
my_timer_t *thisTimer;
my_time_t currentTime;
currentTime = timer_get_current_time();
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);
list_del_item(listTimer, i, free);
i--;
}
break;
case TIMER_PERIODIC:
if (currentTime >= thisTimer->createTime + thisTimer->time) {
thisTimer->fce(thisTimer->arg);
thisTimer->createTime = timer_get_current_time();
}
break;
default:
assert(!_("[Error] Bad setting of the timer"));
break;
}
}
}
void timer_del(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) {
list_del_item(listTimer, i, free);
return;
}
}
fprintf(stderr, _("[Error] Unable to delete event from the timer as it is not present in it [%d]\n"), id);
assert(0);
}
void timer_destroy(list_t *listTimer)
{
list_destroy_item(listTimer, timer_destroyItem);
}
|