/* * timer.c -- Subroutines for (system-) timed events */ /* * $Id: timer.c,v 1.5 2005/08/08 09:43:07 murrayma Exp $ */ #include "copyright.h" #include "config.h" #include <signal.h> #include "mudconf.h" #include "config.h" #include "db.h" #include "interface.h" #include "match.h" #include "externs.h" #include "command.h" extern void pool_reset(void); extern void do_second(void); extern void fork_and_dump(int key); extern unsigned int alarm(unsigned int seconds); extern void pcache_trim(void); extern void check_events(void); void timer_callback(int fd, short event, void *arg); static struct timeval tv = { 0, 100000 }; static struct event timer_event; void init_timer() { mudstate.now = time(NULL); mudstate.dump_counter = ((mudconf.dump_offset == 0) ? mudconf.dump_interval : mudconf.dump_offset) + mudstate.now; mudstate.check_counter = ((mudconf.check_offset == 0) ? mudconf.check_interval : mudconf.check_offset) + mudstate.now; mudstate.idle_counter = mudconf.idle_interval + mudstate.now; mudstate.mstats_counter = 15 + mudstate.now; mudstate.events_counter = 900 + mudstate.now; // alarm(1); evtimer_set(&timer_event, timer_callback, NULL); evtimer_add(&timer_event, &tv); } #undef DISPATCH_DEBUG #ifdef DISPATCH_DEBUG #define DPSET(n) mudstate.debug_cmd = (char *) n #else #define DPSET(n) #endif void dispatch() { char *cmdsave; #ifdef USE_PYTHON mudstate.debug_cmd = "< Python >"; updatePython(); #endif cmdsave = mudstate.debug_cmd; DPSET("< dispatch >"); /* * this routine can be used to poll from interface.c */ if (!mudstate.alarm_triggered) return; mudstate.alarm_triggered = 0; mudstate.now = time(NULL); do_second(); /* * Free list reconstruction */ if ((mudconf.control_flags & CF_DBCHECK) && (mudstate.check_counter <= mudstate.now)) { mudstate.check_counter = mudconf.check_interval + mudstate.now; DPSET("< dbck >"); do_dbck(NOTHING, NOTHING, 0); pcache_trim(); } /* * Database dump routines */ if ((mudconf.control_flags & CF_CHECKPOINT) && (mudstate.dump_counter <= mudstate.now)) { mudstate.dump_counter = mudconf.dump_interval + mudstate.now; DPSET("< dump >"); fork_and_dump(0); } /* Mech stuff ; hopefully it means once ~per sec, although you can never be sure - therefore, the code does 'timejumps' as needed (see UpdateSpecialObjects for details) */ if (mudconf.have_specials) UpdateSpecialObjects(); /* * Idle user check */ if ((mudconf.control_flags & CF_IDLECHECK) && (mudstate.idle_counter <= mudstate.now)) { mudstate.idle_counter = mudconf.idle_interval + mudstate.now; DPSET("< idlecheck >"); check_idle(); } /* * Check for execution of attribute events */ if ((mudconf.control_flags & CF_EVENTCHECK) && (mudstate.events_counter <= mudstate.now)) { mudstate.events_counter = 900 + mudstate.now; DPSET("< eventcheck >"); check_events(); } #ifdef HAVE_GETRUSAGE /* * Memory use stats */ if (mudstate.mstats_counter <= mudstate.now) { int curr; mudstate.mstats_counter = 15 + mudstate.now; curr = mudstate.mstat_curr; if (mudstate.now > mudstate.mstat_secs[curr]) { struct rusage usage; curr = 1 - curr; getrusage(RUSAGE_SELF, &usage); mudstate.mstat_ixrss[curr] = usage.ru_ixrss; mudstate.mstat_idrss[curr] = usage.ru_idrss; mudstate.mstat_isrss[curr] = usage.ru_isrss; mudstate.mstat_secs[curr] = mudstate.now; mudstate.mstat_curr = curr; } } #endif mudstate.debug_cmd = cmdsave; } void timer_callback(int fd, short event, void *arg) { mudstate.alarm_triggered = 1; evtimer_add(&timer_event, &tv); dispatch(); } /* * --------------------------------------------------------------------------- * * do_timewarp: Adjust various internal timers. */ void do_timewarp(dbref player, dbref cause, int key, char *arg) { int secs; secs = atoi(arg); if ((key == 0) || (key & TWARP_QUEUE)) /* * Sem/Wait queues */ do_queue(player, cause, QUEUE_WARP, arg); if (key & TWARP_DUMP) mudstate.dump_counter -= secs; if (key & TWARP_CLEAN) mudstate.check_counter -= secs; if (key & TWARP_IDLE) mudstate.idle_counter -= secs; if (key & TWARP_EVENTS) mudstate.events_counter -= secs; }