#ifndef WIN32
fcntl(fileno(cache->pipe), F_SETFL, O_NONBLOCK);
#endif
- timeq_add(1, neonserv_cmd_extscript_callback, cache);
+ timeq_uadd(200, neonserv_cmd_extscript_callback, cache);
}
static TIMEQ_CALLBACK(neonserv_cmd_extscript_callback) {
else
reply(cache->textclient, cache->user, "%s", command);
}
- timeq_add(1, neonserv_cmd_extscript_callback, cache);
+ timeq_uadd(200, neonserv_cmd_extscript_callback, cache);
}
do {
socket_loop(SOCKET_SELECT_TIME);
} while(time(0) < socket_wait);
- timeq_tick();
- loop_bots();
clearTempUsers();
destroyEvents();
- queue_loop();
}
running_threads--;
return NULL;
running_threads++;
pthread_create(&tid[tid_id], NULL, thread_main, NULL);
}
+ int usleep_delay = 1000000 / TICKS_PER_SECOND;
+ while(running) {
+ timeq_tick();
+ loop_bots();
+ queue_loop();
+ usleep(usleep_delay);
+ }
for(tid_id = 0; tid_id < worker_threads; tid_id++) {
pthread_join(tid[tid_id], NULL);
}
#define BOTWAR_DETECTION_TIME 7
#define BOTWAR_DETECTION_EVENTS 6
#define REWHO_TIMEOUT 10 /* wait 10 seconds before WHO an unauthed user again */
+#define TICKS_PER_SECOND 10
//valid nick chars
#define VALID_NICK_CHARS "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ1234567890{|}~[\\]^-_`"
#define TEMPUSER_LIST_INDEX VALID_NICK_CHARS_FIRST_LEN
+#define timeval_is_bigger(x,y) ((x.tv_sec > y.tv_sec) || (x.tv_sec == y.tv_sec && x.tv_usec > y.tv_usec))
+
extern time_t start_time;
extern int statistics_enabled;
#ifdef HAVE_THREADS
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;
struct timeq_entry {
char *name;
- time_t execute;
+ struct timeval execute;
timeq_callback_t *callback;
void *data;
void init_timeq();
void timeq_tick();
struct timeq_entry* timeq_add(int seconds, timeq_callback_t *callback, void *data);
+struct timeq_entry* timeq_uadd(int useconds, timeq_callback_t *callback, void *data);
struct timeq_entry* timeq_add_name(char *name, int seconds, timeq_callback_t *callback, void *data);
+struct timeq_entry* timeq_uadd_name(char *name, int useconds, timeq_callback_t *callback, void *data);
int timeq_del(struct timeq_entry* entry);
int timeq_del_name(char *name);
int timeq_name_exists(char *name);