void timeq_tick() {
SYNCHRONIZE(synchronized);
struct timeq_entry *entry, *next;
- time_t now = time(0);
+ struct timeval now;
+ gettimeofday(&now, NULL);
for(entry = timeq_events; entry; entry = next) {
- if(entry->execute <= now) {
+ if(!timeval_is_bigger(entry->execute, now)) {
next = entry->next;
if(timeq_events == entry)
timeq_events = next;
}
struct timeq_entry* timeq_add(int seconds, timeq_callback_t *callback, void *data) {
- time_t now = time(0);
+ return timeq_uadd(seconds * 1000, callback, data);
+}
+
+struct timeq_entry* timeq_uadd(int useconds, timeq_callback_t *callback, void *data) {
+ struct timeval now;
+ gettimeofday(&now, NULL);
struct timeq_entry *entry = malloc(sizeof(*entry));
if (!entry)
{
return NULL;
}
SYNCHRONIZE(synchronized);
- entry->execute = now + seconds;
+ now.tv_usec += (useconds % 1000);
+ now.tv_sec += (useconds / 1000);
+ entry->execute = now;
entry->callback = callback;
entry->data = data;
entry->name = NULL;
struct timeq_entry *next, *prev = NULL;
for(next = timeq_events; next; next = next->next) {
- if(next->execute >= entry->execute)
+ if(timeval_is_bigger(next->execute, now))
break;
else
prev = next;
}
struct timeq_entry* timeq_add_name(char *name, int seconds, timeq_callback_t *callback, void *data) {
+ return timeq_uadd_name(name, seconds * 1000, callback, data);
+}
+
+struct timeq_entry* timeq_uadd_name(char *name, int useconds, timeq_callback_t *callback, void *data) {
SYNCHRONIZE(synchronized);
- struct timeq_entry *entry = timeq_add(seconds, callback, data);
+ struct timeq_entry *entry = timeq_uadd(useconds, callback, data);
entry->name = strdup(name);
DESYNCHRONIZE(synchronized);
return entry;