|
@@ -195,12 +195,12 @@ bool pop_timer_heap(int tid)
|
|
|
|
|
|
if( timer_heap[pos] == tid )
|
|
if( timer_heap[pos] == tid )
|
|
break;// found the timer
|
|
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
|
|
{// try left child
|
|
pos = left;
|
|
pos = left;
|
|
continue;
|
|
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
|
|
{// try right child
|
|
pos = right;
|
|
pos = right;
|
|
continue;
|
|
continue;
|
|
@@ -214,7 +214,7 @@ bool pop_timer_heap(int tid)
|
|
return false;// not found
|
|
return false;// not found
|
|
parent = BHEAP_PARENT(pos);
|
|
parent = BHEAP_PARENT(pos);
|
|
right = BHEAP_RIGHT(parent);
|
|
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
|
|
break;// try this right
|
|
pos = parent;
|
|
pos = parent;
|
|
}
|
|
}
|
|
@@ -294,6 +294,26 @@ bool adjust_tick(unsigned int* tick)
|
|
return true;
|
|
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.
|
|
/// Returns a free timer id.
|
|
static int acquire_timer(void)
|
|
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
|
|
/// Retrieves internal timer data
|
|
const struct TimerData* get_timer(int tid)
|
|
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 &timer_data[tid];
|
|
return NULL;
|
|
return NULL;
|
|
}
|
|
}
|
|
@@ -393,7 +413,7 @@ const struct TimerData* get_timer(int tid)
|
|
/// Returns 0 on success, < 0 on failure.
|
|
/// Returns 0 on success, < 0 on failure.
|
|
int delete_timer(int tid, TimerFunc func)
|
|
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));
|
|
ShowError("delete_timer error : no such timer %d (%08x(%s))\n", tid, (int)func, search_timer_func_list(func));
|
|
return -1;
|
|
return -1;
|
|
@@ -404,9 +424,11 @@ int delete_timer(int tid, TimerFunc func)
|
|
return -2;
|
|
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;
|
|
return 0;
|
|
}
|
|
}
|
|
|
|
|
|
@@ -421,6 +443,11 @@ int addtick_timer(int tid, unsigned int tick)
|
|
/// Returns the new tick value, or -1 if it fails.
|
|
/// Returns the new tick value, or -1 if it fails.
|
|
int settick_timer(int tid, unsigned int tick)
|
|
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 )
|
|
if( timer_data[tid].tick == tick )
|
|
return tick;
|
|
return tick;
|
|
|
|
|
|
@@ -431,7 +458,8 @@ int settick_timer(int tid, unsigned int tick)
|
|
}
|
|
}
|
|
pop_timer_heap(tid);
|
|
pop_timer_heap(tid);
|
|
if( tick == -1 )
|
|
if( tick == -1 )
|
|
- tick = 0;
|
|
|
|
|
|
+ tick = 0;// -1 is reserved for error
|
|
|
|
+ timer_data[tid].type &= ~TIMER_REMOVE_HEAP;
|
|
timer_data[tid].tick = tick;
|
|
timer_data[tid].tick = tick;
|
|
push_timer_heap(tid);
|
|
push_timer_heap(tid);
|
|
return tick;
|
|
return tick;
|
|
@@ -470,24 +498,15 @@ int do_timer(unsigned int tick)
|
|
}
|
|
}
|
|
|
|
|
|
// in the case the function didn't change anything...
|
|
// 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;
|
|
timer_data[tid].type &= ~TIMER_REMOVE_HEAP;
|
|
|
|
|
|
switch( timer_data[tid].type )
|
|
switch( timer_data[tid].type )
|
|
{
|
|
{
|
|
|
|
+ case TIMER_FORCE_REMOVE:
|
|
case TIMER_ONCE_AUTODEL:
|
|
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;
|
|
break;
|
|
case TIMER_INTERVAL:
|
|
case TIMER_INTERVAL:
|
|
if( DIFF_TICK(timer_data[tid].tick, tick) < -1000 )
|
|
if( DIFF_TICK(timer_data[tid].tick, tick) < -1000 )
|