FreeCalypso > hg > freecalypso-sw
changeset 464:14d2a7f473c3
OSL: os_tim_ir.c reconstruction by Das Signal
author | Michael Spacefalcon <msokolov@ivan.Harhan.ORG> |
---|---|
date | Thu, 26 Jun 2014 03:23:29 +0000 |
parents | aad742029813 |
children | d5cf423dad3a |
files | gsm-fw/gpf/osl/os_tim_ir.c |
diffstat | 1 files changed, 284 insertions(+), 0 deletions(-) [+] |
line wrap: on
line diff
--- a/gsm-fw/gpf/osl/os_tim_ir.c Tue Jun 24 00:16:04 2014 +0000 +++ b/gsm-fw/gpf/osl/os_tim_ir.c Thu Jun 26 03:23:29 2014 +0000 @@ -32,3 +32,287 @@ timer_error(int err) { } + +/* + * The following function reconstructions have been contributed by Das Signal. + * The code passes gcc, but some polish is still likely needed. + */ + +/* FIXME: t_handle is unused?! */ +void os_Timeout(UNSIGNED t_handle) +{ + UNSIGNED s_ticks; + OS_HANDLE task_handle; + OS_HANDLE e_handle; + int t_index, i, done; + T_OS_TIMER_TABLE_ENTRY **t_r4; + T_OS_TIMER_TABLE_ENTRY *timer; + void (*timeout_func) (OS_HANDLE, OS_HANDLE, USHORT); + OS_TIME InitialTime; + + if (t_list_access) { + t_start_ticks++; + NU_Reset_Timer(&os_timer_cb, os_Timeout, 1, 0, + NU_ENABLE_TIMER); + return; + } + + t_list_access = 1; + timer = t_running; + if (t_running) { + s_ticks = 0; + done = 0; + i = 0; + do { + timeout_func = timer->TimeoutProc; + if (timer->p_ticks) + p_list[i++] = timer; + task_handle = timer->task_handle; + e_handle = timer->entity_handle; + t_index = timer->t_index; + timer->status = 1; + if (timer->next == timer) { + t_running = NULL; + done = 1; + } else { + timer->prev->next = timer->next; + timer->next->prev = timer->prev; + if (timer->next->r_ticks) { + t_running = timer->next; + s_ticks = timer->r_ticks; + done = 1; + } else + timer = timer->next; + } + /* FIXME: IND$CALL() ? */ + } + while (!done); + + if (s_ticks) { + t_start_ticks = NU_Retrieve_Clock(); + NU_Reset_Timer(&os_timer_cb, os_Timeout, s_ticks, 0, + NU_ENABLE_TIMER); + } + } + for (t_r4 = p_list; *t_r4; t_r4++) { + timer = *t_r4; + InitialTime = SYSTEM_TICKS_TO_TIME(timer->p_ticks); + os_StartTimer(timer->entity_handle, timer->t_handle, + timer->t_index, InitialTime, InitialTime); + *t_r4 = NULL; + } + + t_list_access = 0; + return; +} + +static int os_remove_timer_from_list(T_OS_TIMER_TABLE_ENTRY *timer) +{ + OS_TICK c_ticks; + + if (timer != t_running) { + if (timer->next != t_running) + timer->next->r_ticks += timer->r_ticks; + } + else { + c_ticks = NU_Retrieve_Clock(); + if (timer->next == timer) { + t_running = 0; + } else { + timer->next->r_ticks = + t_start_ticks + timer->r_ticks + + timer->next->r_ticks - c_ticks; + t_running = timer->next; + } + NU_Control_Timer(&os_timer_cb, NU_DISABLE_TIMER); + if (t_running != NULL) { + t_start_ticks = c_ticks; + if (t_running->r_ticks != 0) + NU_Reset_Timer(&os_timer_cb, os_Timeout, + t_running->r_ticks, 0, + NU_ENABLE_TIMER); + } + } + if (timer->next != timer) { + timer->prev->next = timer->next; + timer->next->prev = timer->prev; + } + timer->next = NULL; + timer->prev = NULL; + timer->status = 1; + return 1; +} + +static unsigned os_add_timer_to_list(T_OS_TIMER_TABLE_ENTRY *timer, OS_TICK ticks) +{ + T_OS_TIMER_TABLE_ENTRY *t_list; + OS_TICK c_ticks, r1_ticks, return_ticks; + + if (ticks == 0) + ticks = 1; + + c_ticks = NU_Retrieve_Clock(); + t_list = t_running; + if (t_list != NULL) { + if (t_running->r_ticks >= c_ticks - t_start_ticks) { + r1_ticks = + t_running->r_ticks - c_ticks + t_start_ticks; + t_running->r_ticks = r1_ticks; + } else { + r1_ticks = 0; + t_running->r_ticks = 0; + } + t_start_ticks = c_ticks; + return_ticks = 0; + while (ticks >= r1_ticks) { + ticks -= r1_ticks; + t_list = t_list->next; + if (t_list == t_running) + goto out; + r1_ticks = t_list->r_ticks; + } + t_list->r_ticks -= ticks; + if (t_list == t_running) { + t_running = timer; + t_start_ticks = c_ticks; + NU_Control_Timer(&os_timer_cb, NU_DISABLE_TIMER); + return_ticks = ticks; + } +out: + timer->next = t_list; + timer->prev = t_list->prev; + t_list->prev->next = timer; + t_list->prev = timer; + timer->r_ticks = ticks; + } else { + timer->next = timer; + timer->prev = timer; + timer->r_ticks = ticks; + t_start_ticks = c_ticks; + t_running = timer; + return_ticks = ticks; + } + timer->status = 2; + return return_ticks; +} + +GLOBAL LONG os_StartTimer(OS_HANDLE TaskHandle, OS_HANDLE TimerHandle, + USHORT Index, OS_TIME InitialTime, + OS_TIME RescheduleTime) +{ + T_OS_TIMER_TABLE_ENTRY *timer; + OS_TICK ticks; + USHORT status; + STATUS sts; + + t_list_access = 1; + timer = &TimerTable[TimerHandle].entry; + if (TimerHandle > MaxSimultaneousTimer || timer->status == 0) { + t_list_access = 0; + return OS_ERROR; + } + + sts = NU_Obtain_Semaphore(&TimSemCB, NU_SUSPEND); + /* FIXME: not sure about this + if (sts != NU_SUCCESS) + os_MyHandle(sts); + */ + status = timer->status; + if (status == 2) + status = os_remove_timer_from_list(timer); + timer->t_handle = TimerHandle; + timer->task_handle = os_MyHandle(); + timer->entity_handle = TaskHandle; + timer->t_index = Index; + timer->p_ticks = TIME_TO_SYSTEM_TICKS(RescheduleTime); + ticks = os_add_timer_to_list(timer, TIME_TO_SYSTEM_TICKS(InitialTime)); + if (ticks) + NU_Reset_Timer(&os_timer_cb, os_Timeout, ticks, 0, NU_ENABLE_TIMER); + if (sts == NU_SUCCESS) + NU_Release_Semaphore(&TimSemCB); + t_list_access = 0; + return OS_OK; +} + +/* FIXME: TaskHandle is unused?! */ +GLOBAL LONG os_StopTimer(OS_HANDLE TaskHandle, OS_HANDLE TimerHandle) +{ + T_OS_TIMER_ENTRY *timer_e; + STATUS sts; + + t_list_access = 1; + timer_e = &TimerTable[TimerHandle]; + if (TimerHandle > MaxSimultaneousTimer || timer_e->entry.status == 0) { + t_list_access = 0; + return OS_ERROR; + } + sts = NU_Obtain_Semaphore(&TimSemCB, NU_SUSPEND); + if (timer_e->entry.status == 2) + os_remove_timer_from_list(&timer_e->entry); + if (sts == NU_SUCCESS) + NU_Release_Semaphore(&TimSemCB); + t_list_access = 0; + return OS_OK; +} + +GLOBAL LONG os_IncrementTick(OS_TICK ticks) +{ + return OS_OK; +} + +/* FIXME: TaskHandle is unused?! */ +GLOBAL LONG os_DestroyTimer(OS_HANDLE TaskHandle, OS_HANDLE TimerHandle) +{ + STATUS sts; + T_OS_TIMER_ENTRY *timer_e; + + t_list_access = 1; + sts = NU_Obtain_Semaphore(&TimSemCB, NU_SUSPEND); + timer_e = &TimerTable[TimerHandle]; + if (TimerHandle > MaxSimultaneousTimer || timer_e->entry.status == 0) { + if (sts == NU_SUCCESS) + NU_Release_Semaphore(&TimSemCB); + t_list_access = 0; + return OS_ERROR; + } + timer_e->next_t_handle = next_t_handle; + timer_e->entry.status = 0; + used_timers--; + t_list_access = 0; + if (sts == NU_SUCCESS) + NU_Release_Semaphore(&TimSemCB); + return OS_OK; +} + +/* FIXME: TaskHandle and MemPoolHandle are unused?! */ +GLOBAL LONG os_CreateTimer(OS_HANDLE TaskHandle, + void (*TimeoutProc) (OS_HANDLE, OS_HANDLE, USHORT), + OS_HANDLE *TimerHandle, OS_HANDLE MemPoolHandle) +{ + STATUS sts; + OS_HANDLE orig_next_t_handle; + T_OS_TIMER_ENTRY *timer_e; + + t_list_access = 1; + sts = NU_Obtain_Semaphore(&TimSemCB, NU_SUSPEND); + orig_next_t_handle = next_t_handle; + if (next_t_handle == 0) { /* INVALID_HANDLE */ + if (sts == NU_SUCCESS) + NU_Release_Semaphore(&TimSemCB); + t_list_access = 0; + return OS_ERROR; + } + + timer_e = &TimerTable[next_t_handle]; + timer_e->entry.status = 1; + timer_e->entry.TimeoutProc = TimeoutProc; + *TimerHandle = orig_next_t_handle; + next_t_handle = timer_e->next_t_handle; + used_timers++; + if (max_used_timers < used_timers) + max_used_timers = used_timers; + if (sts == NU_SUCCESS) + NU_Release_Semaphore(&TimSemCB); + t_list_access = 0; + return OS_OK; +}