summaryrefslogtreecommitdiff
path: root/src/common/timer.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/common/timer.c')
-rw-r--r--src/common/timer.c61
1 files changed, 40 insertions, 21 deletions
diff --git a/src/common/timer.c b/src/common/timer.c
index cf594ef6d..df227cb57 100644
--- a/src/common/timer.c
+++ b/src/common/timer.c
@@ -195,12 +195,12 @@ bool pop_timer_heap(int tid)
if( timer_heap[pos] == tid )
break;// found the timer
- if( left < timer_heap_num && DIFF_TICK(timer_data[tid].tick, timer_data[timer_heap[left]].tick) <= 0 )
+ if( left < timer_heap_num && DIFF_TICK(timer_data[tid].tick, timer_data[timer_heap[left]].tick) >= 0 )
{// try left child
pos = left;
continue;
}
- if( right < timer_heap_num && DIFF_TICK(timer_data[tid].tick, timer_data[timer_heap[right]].tick) <= 0 )
+ if( right < timer_heap_num && DIFF_TICK(timer_data[tid].tick, timer_data[timer_heap[right]].tick) >= 0 )
{// try right child
pos = right;
continue;
@@ -214,7 +214,7 @@ bool pop_timer_heap(int tid)
return false;// not found
parent = BHEAP_PARENT(pos);
right = BHEAP_RIGHT(parent);
- if( pos != right && right < timer_heap_num && DIFF_TICK(timer_data[tid].tick, timer_data[timer_heap[right]].tick) <= 0 )
+ if( pos != right && right < timer_heap_num && DIFF_TICK(timer_data[tid].tick, timer_data[timer_heap[right]].tick) >= 0 )
break;// try this right
pos = parent;
}
@@ -294,6 +294,26 @@ bool adjust_tick(unsigned int* tick)
return true;
}
+/// Releases a timer.
+static
+void release_timer(int tid)
+{
+ if( timer_data[tid].type == 0 )
+ return;// already released
+
+ memset(&timer_data[tid], 0, sizeof(struct TimerData));
+ if( free_timer_list_num >= free_timer_list_max )
+ {
+ free_timer_list_max += 256;
+ if( free_timer_list )
+ RECREATE(free_timer_list, int, free_timer_list_max);
+ else
+ CREATE(free_timer_list, int, free_timer_list_max);
+ memset(free_timer_list + (free_timer_list_max - 256), 0, sizeof(int)*256);
+ }
+ free_timer_list[free_timer_list_num++] = tid;
+}
+
/// Returns a free timer id.
static int acquire_timer(void)
{
@@ -383,7 +403,7 @@ int add_timer_interval(unsigned int tick, TimerFunc func, int id, intptr data, i
/// Retrieves internal timer data
const struct TimerData* get_timer(int tid)
{
- if( tid >= 0 && tid < timer_data_num )
+ if( tid >= 0 && tid < timer_data_num && timer_data[tid].type != 0 )
return &timer_data[tid];
return NULL;
}
@@ -393,7 +413,7 @@ const struct TimerData* get_timer(int tid)
/// Returns 0 on success, < 0 on failure.
int delete_timer(int tid, TimerFunc func)
{
- if( tid < 0 || tid >= timer_data_num )
+ if( tid < 0 || tid >= timer_data_num || timer_data[tid].type == 0 )
{
ShowError("delete_timer error : no such timer %d (%08x(%s))\n", tid, (int)func, search_timer_func_list(func));
return -1;
@@ -404,9 +424,11 @@ int delete_timer(int tid, TimerFunc func)
return -2;
}
- timer_data[tid].func = NULL;
- timer_data[tid].type = TIMER_ONCE_AUTODEL;
-
+ if( timer_data[tid].type&TIMER_REMOVE_HEAP )
+ // timer func being executed, make sure it's marked for removal when it ends
+ timer_data[tid].type = TIMER_FORCE_REMOVE|TIMER_REMOVE_HEAP;
+ else if( pop_timer_heap(tid) )
+ release_timer(tid);
return 0;
}
@@ -421,6 +443,11 @@ int addtick_timer(int tid, unsigned int tick)
/// Returns the new tick value, or -1 if it fails.
int settick_timer(int tid, unsigned int tick)
{
+ if( tid < 0 || tid >= timer_data_num || timer_data[tid].type == 0 )
+ {
+ ShowError("settick_timer error : no such timer %d\n", tid);
+ return -1;
+ }
if( timer_data[tid].tick == tick )
return tick;
@@ -431,7 +458,8 @@ int settick_timer(int tid, unsigned int tick)
}
pop_timer_heap(tid);
if( tick == -1 )
- tick = 0;
+ tick = 0;// -1 is reserved for error
+ timer_data[tid].type &= ~TIMER_REMOVE_HEAP;
timer_data[tid].tick = tick;
push_timer_heap(tid);
return tick;
@@ -470,24 +498,15 @@ int do_timer(unsigned int tick)
}
// in the case the function didn't change anything...
- if( timer_data[tid].type & TIMER_REMOVE_HEAP )
+ if( timer_data[tid].type & TIMER_REMOVE_HEAP || timer_data[tid].type == TIMER_FORCE_REMOVE )
{
timer_data[tid].type &= ~TIMER_REMOVE_HEAP;
switch( timer_data[tid].type )
{
+ case TIMER_FORCE_REMOVE:
case TIMER_ONCE_AUTODEL:
- timer_data[tid].type = 0;
- if( free_timer_list_num >= free_timer_list_max )
- {
- free_timer_list_max += 256;
- if( free_timer_list )
- RECREATE(free_timer_list, int, free_timer_list_max);
- else
- CREATE(free_timer_list, int, free_timer_list_max);
- memset(free_timer_list + (free_timer_list_max - 256), 0, sizeof(int)*256);
- }
- free_timer_list[free_timer_list_num++] = tid;
+ release_timer(tid);
break;
case TIMER_INTERVAL:
if( DIFF_TICK(timer_data[tid].tick, tick) < -1000 )