3 * - By John Hodge (thePowersGang)
7 #define SANITY 1 // Enable ASSERTs
11 #include <timers_int.h>
13 #include <hal_proc.h> // Proc_GetCurThread
14 #include <workqueue.h>
15 #include <threads_int.h> // Used to get thread timer
18 void Timer_CallbackThread(void *Unused);
19 void Timer_CallTimers(void);
21 tTimer *Time_CreateTimer(int Delta, tTimerCallback *Callback, void *Argument);
22 void Time_ScheduleTimer(tTimer *Timer, int Delta);
23 void Time_RemoveTimer(tTimer *Timer);
24 tTimer *Time_AllocateTimer(tTimerCallback *Callback, void *Argument);
26 void Time_InitTimer(tTimer *Timer, tTimerCallback *Callback, void *Argument);
28 void Time_FreeTimer(tTimer *Timer);
29 void Time_Delay(int Time);
33 volatile Uint64 giTicks = 0;
34 volatile Sint64 giTimestamp = 0;
35 volatile Uint64 giPartMiliseconds = 0;
37 tWorkqueue gTimers_CallbackQueue;
38 tShortSpinlock gTimers_ListLock;
41 void Timer_CallbackThread(void *Unused)
43 Threads_SetName("Timer Callback Thread");
44 Workqueue_Init(&gTimers_CallbackQueue, "Timer Callbacks", offsetof(tTimer, Next));
48 tTimer *timer = Workqueue_GetWork(&gTimers_CallbackQueue);
50 if( !timer->Callback ) {
51 LOG("Timer %p doesn't have a callback", timer);
52 ASSERT( timer->Callback );
55 // Save callback and argument (because once the mutex is released
56 // the timer may no longer be valid)
57 tTimerCallback *cb = timer->Callback;
58 void *arg = timer->Argument;
60 LOG("Callback fire %p", timer);
62 // Allow Time_RemoveTimer to be called safely
68 // Mark timer as no longer needed
73 * \fn void Timer_CallTimers()
75 void Timer_CallTimers()
77 SHORTLOCK(&gTimers_ListLock);
78 while( gTimers && gTimers->FiresAfter < now() )
80 ASSERT( gTimers != gTimers->Next );
81 // Get timer from list
82 tTimer *timer = gTimers;
83 gTimers = gTimers->Next;
86 if( timer->Callback ) {
87 LOG("Callback schedule %p", timer);
88 Workqueue_AddWork(&gTimers_CallbackQueue, timer);
91 LOG("Event fire %p", timer);
92 ASSERT( timer->Argument );
93 Threads_PostEvent(timer->Argument, THREAD_EVENT_TIMER);
97 SHORTREL(&gTimers_ListLock);
101 * \brief Schedule an action (Legacy)
103 tTimer *Time_CreateTimer(int Delta, tTimerCallback *Callback, void *Argument)
105 tTimer *ret = malloc(sizeof(tTimer));
106 if( !ret ) return NULL;
107 Time_InitTimer(ret, Callback, Argument);
108 Time_ScheduleTimer(ret, Delta);
113 * \brief Schedule a timer to fire
115 void Time_ScheduleTimer(tTimer *Timer, int Delta)
121 if( !Timer ) return ;
123 if( Timer->bActive ) return;
126 Timer->FiresAfter = now() + Delta;
129 LOG("%p added timer %p - %i ms (ts=%lli)",
130 __builtin_return_address(0), Timer, Delta, Timer->FiresAfter);
132 // Add into list (sorted)
133 SHORTLOCK(&gTimers_ListLock);
134 // Mutex_Release( &Timer->Lock ); // Prevent deadlocks
135 for( prev_next = &gTimers, t = gTimers; t; prev_next = &t->Next, t = t->Next )
137 ASSERT( prev_next != &t->Next );
138 ASSERT( CheckMem(t, sizeof(tTimer)) );
141 LOG("Double schedule - increasing delta");
142 SHORTREL(&gTimers_ListLock);
145 LOG(" t = %p ts:%lli", t, t->FiresAfter);
146 if( t->FiresAfter > Timer->FiresAfter ) break;
151 LOG(" prev_next=%p Timer=%p next=%p", prev_next, Timer, t);
152 SHORTREL(&gTimers_ListLock);
156 * \brief Delete a timer from the running list
158 void Time_RemoveTimer(tTimer *Timer)
163 if( !Timer ) return ;
165 SHORTLOCK(&gTimers_ListLock);
166 for( prev_next = &gTimers, t = gTimers; t; prev_next = &t->Next, t = t->Next )
168 ASSERT( prev_next != &t->Next );
169 ASSERT( CheckMem(t, sizeof(tTimer)) );
172 *prev_next = t->Next;
176 SHORTREL(&gTimers_ListLock);
180 LOG("%p removed %p", __builtin_return_address(0), Timer);
183 LOG("%p tried to remove %p (already complete)", __builtin_return_address(0), Timer);
187 * \brief Allocate a timer object, but don't schedule it
189 tTimer *Time_AllocateTimer(tTimerCallback *Callback, void *Argument)
191 tTimer *ret = malloc(sizeof(tTimer));
192 if( !ret ) return NULL;
193 Time_InitTimer(ret, Callback, Argument);
198 * \brief Initialise a timer
199 * \note Mostly an internal function
201 void Time_InitTimer(tTimer *Timer, tTimerCallback *Callback, void *Argument)
204 Argument = Proc_GetCurThread();
205 Timer->FiresAfter = 0;
206 Timer->Callback = Callback;
207 Timer->Argument = Argument;
208 // memset( &Timer->Lock, 0, sizeof(Timer->Lock) );
210 LOG("Initialised timer %p (cb=%p,arg=%p)", Timer, Callback, Argument);
214 * \brief Free an allocated timer
216 void Time_FreeTimer(tTimer *Timer)
218 if( !Timer ) return ;
219 Time_RemoveTimer( Timer ); // Just in case
221 // Ensures that we don't free until the timer callback has started
222 while( Timer->bActive ) Threads_Yield();
223 // Release won't be needed, as nothing should be waiting on it
224 // Mutex_Acquire( &Timer->Lock );
228 LOG("%p deallocated %p", __builtin_return_address(0), Timer);
232 * \fn void Time_Delay(int Delay)
233 * \brief Delay for a small ammount of time
235 void Time_Delay(int Delay)
238 tTimer *t = &Proc_GetCurThread()->ThreadTimer;
239 Time_InitTimer(t, NULL, NULL);
240 Time_ScheduleTimer(t, Delay);
241 Threads_WaitEvents(THREAD_EVENT_TIMER);
245 //EXPORT(Time_CreateTimer);
246 EXPORT(Time_ScheduleTimer);
247 EXPORT(Time_RemoveTimer);
248 EXPORT(Time_AllocateTimer);
249 //EXPORT(Time_InitTimer);
250 EXPORT(Time_FreeTimer);